Javaで、サーバーとクライアントでデータを送り合う処理

Question

現在Javaでオセロを作成しております。
その中で『プレイヤー１(サーバー)VSプレイヤー２(クライアント)』
でプログラムを作成したいと思っております。

具体的には
基本的なルールはサーバーで実行。
クライアントが行うのは、配置する座標を決めてサーバーに返す処理です。

クライアントはサーバーを継承してコーディングを行なっています。
どのようなメソッドで値を返すことができるのかわからずご質問させていただきました。

また、教えていただきたいと感じている点をまとめるとこの通りです。
・座標となるpointをサーバーに返す処理
・どちらかのターンの時に反対のコードを座標が帰ってくるまで待機させる

かなり途中のコードですが、下記の中の
pointをサーバーに返したいと考えております。

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.ResourceBundle;

	/**
	 * ソケット通信(クライアント側)
	 */
	class Clients extends Servers{
		void runClient() {
			ResourceBundle rb = ResourceBundle.getBundle("Pro");
			Socket cSocket = null;
			BufferedReader in = null;
			try {
				p2 = new Player('b', 2);//プレイヤー1 白
				cSocket = new Socket(rb.getString("server_id"), Integer.parseInt(rb.getString("server_port")));
				in = new BufferedReader(new InputStreamReader(cSocket.getInputStream()));
				PrintWriter out = new PrintWriter(cSocket.getOutputStream(), true);
				System.out.println("サーバーと接続中");
				while (true) {
					for (int i = 0; i < board.length; i++) {
						for (int j = 0; j < board[i].length; j++) {
							if (board[i][j] == 0) {//コマが置かれていない場所をチェック
								if (Board.check_change(board, i, j, p2.color, "check")) {//置ける時
									board[i][j] = 3;
								}
							}
						}
					}
					Board.print(kazu, board, com2);
					for (int i = 1; i < status.length; i++) {//盤面の状態を表示
						System.out.println(color[i] + ":" + status[i] + " ");
					}
					System.out.println("------------------------");
					System.out.println(color[p2.color] + "のターン" + " ");
					int[] point = p2.getPoint();//一番有利な座標を見つける。
					col = point[0];
					row = point[1];
				} //mainループ
			} catch (Exception e) {
				e.printStackTrace();
			} finally {
				try {
					if (in != null) {
						in.close();
					}
					if (cSocket != null) {
						cSocket.close();
					}
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		}
	}

	public class Client {
		public static void main(String[] args) {
			Clients s2 = new Clients();
			s2.runClient();
		}
	}

Comments

[dodox86]

JavaのTCPサーバークライアントプログラムが分からないということでしょうか。
(1) サーバーからクライアントへの受信データは
in = new BufferedReader(new InputStreamReader(cSocket.getInputStream()));
でのinで読み出し、
(2) クライアントからサーバーへの送信データは
PrintWriter out = new PrintWriter(cSocket.getOutputStream(), true);
のout で書き出す、と言うことが基本になりそうですが。

[jimbe]

機能的に考えますと, クライアントがサーバを継承する意味は無いように思えますが, なぜ継承しているのでしょうか.

[gentaro]

概念的にもクライアントがサーバーを継承するのは理解し難い気が。
P2P的な何かを実装しようとしてる場合ならギリギリわかる気はするけど。

Answer 1

このようなコードで試せます.
(無限ループなので, テキトウに止めてください.)

package teratail.q246663;

import java.io.*;
import java.net.*;

public class ReversiCommunicationTest {
  public static final int PORT = 12345;
  public static void main(String[] args) {
    new Thread(new Server(PORT)).start();
    new Client("127.0.0.1", PORT).run();
  }
}
class Point {
  final int col, row;
  Point(int col, int row) { this.col = col; this.row = row; }
  @Override
  public String toString() {
    return super.toString()+"[col="+col+",row="+row+"]";
  }
}
class Communicator implements AutoCloseable {
  private BufferedReader reader;
  private PrintWriter out;
  Communicator(Socket s) throws IOException {
    try {
      reader = new BufferedReader(new InputStreamReader(s.getInputStream()));
      out = new PrintWriter(s.getOutputStream(), true);
    } catch(IOException e) {
      close();
    }
  }
  void send(Point point) throws IOException {
    out.println(point.col+","+point.row);
  }
  Point receive() throws IOException {
    String line = reader.readLine();
    if(line == null) return null;
    String[] tokens = line.split(",");
    return new Point(Integer.parseInt(tokens[0]), Integer.parseInt(tokens[1]));
  }
  @Override
  public void close() throws IOException {
    if(out == null) { out.close(); out = null; }
    if(reader == null) { reader.close(); reader = null; }
  }
}
class Server implements Runnable {
  private int port;
  Server(int port) {
    this.port = port;
  }
  @Override
  public void run() {
    try (ServerSocket ss = new ServerSocket(port);
        Communicator comm = new Communicator(ss.accept());) {

      Point point = null;
      while(true) {
        System.out.println("Server: 考え中");
        point = thinking();
        System.out.println("Server: 送信="+point);
        comm.send(point);

        System.out.println("Server: 受信待ち");
        point = comm.receive();
        System.out.println("Server: 受信="+point);
      }
    } catch(IOException e) {
      e.printStackTrace();
    }
  }
  private Point thinking() {
    try {
      Thread.sleep((long)(Math.random()*3000)+2000); //[ms]
    } catch(InterruptedException e) {
      e.printStackTrace();
    }
    return new Point((int)(Math.random()*8), (int)(Math.random()*8));
  }
}
class Client implements Runnable {
  private String host;
  private int port;
  Client(String host, int port) {
    this.host = host;
    this.port = port;
  }
  @Override
  public void run() {
    try (Communicator comm = new Communicator(new Socket(host, port));) {

      Point point = null;
      while(true) {
        System.out.println("Client: 受信待ち");
        point = comm.receive();
        System.out.println("Client: 受信="+point);

        System.out.println("Client: 考え中");
        point = thinking();
        System.out.println("Client: 送信="+point);
        comm.send(point);
      }
    } catch(IOException e) {
      e.printStackTrace();
    }
  }
  private Point thinking() {
    try {
      Thread.sleep((long)(Math.random()*3000)+2000); //[ms]
    } catch(InterruptedException e) {
      e.printStackTrace();
    }
    return new Point((int)(Math.random()*8), (int)(Math.random()*8));
  }
}

Client: 受信待ち
Server: 考え中
Server: 送信=teratail.q246663.ReversiCommunicationTest$Point@334495b1[col=3,row=2]
Server: 受信待ち
Client: 受信=teratail.q246663.ReversiCommunicationTest$Point@7852e922[col=3,row=2]
Client: 考え中
Client: 送信=teratail.q246663.ReversiCommunicationTest$Point@4e25154f[col=5,row=8]
Client: 受信待ち
Server: 受信=teratail.q246663.ReversiCommunicationTest$Point@76460dbd[col=5,row=8]
Server: 考え中
Server: 送信=teratail.q246663.ReversiCommunicationTest$Point@28d2af42[col=1,row=7]
Server: 受信待ち
Client: 受信=teratail.q246663.ReversiCommunicationTest$Point@70dea4e[col=1,row=7]
Client: 考え中
Client: 送信=teratail.q246663.ReversiCommunicationTest$Point@5c647e05[col=4,row=3]
Client: 受信待ち
Server: 受信=teratail.q246663.ReversiCommunicationTest$Point@47fadae9[col=4,row=3]
Server: 考え中
Server: 送信=teratail.q246663.ReversiCommunicationTest$Point@508426ba[col=3,row=8]
Server: 受信待ち
 :
 :

Comments

[anpan___]

ご返信遅くなり大変申し訳ありません！
いただいたコードを参考に無事に座標を送る処理が完成しました…！

感謝申し上げます。