javaでチャットサーバの作成でリアルタイムな送受信が行えない

Question

javaを用いて複数人のチャットサーバの作成を行っています。

・echoサーバーとクライアントのサンプルを元に作成しています。
・echoサーバーに接続を行ったクライアントの順番に、0から番号を割り振っています。
・送信の際は、「'クライアントに割り振った番号' '送信内容'」の形式で送信を行います
・クライアントがechoサーバーに接続した場合、スレッドを起動するマルチスレッドで作成しています。

手順
①二つのクライアント(A,B)からチャットサーバーに接続を行います
②クライアントAからクライアントBに対して送信(A->B)
③クライアントBからクライアントAに対して送信(B->A)

問題点
・②終了時、チャットサーバーに送信内容のログは表示されるのですが、
クライアントB側で受信されません。
・③終了時、先ほど送信した(A->B)の送信内容をクライアントBで受信します。

どのように行えば、リアルタイムに送受信を行うことが出来るのでしょうか。
どなたかご教示の程、どうぞよろしくお願いいたします。

ChatServer

import java.net.Socket;
 import java.net.ServerSocket;
 import java.io.BufferedReader;
 import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
 import java.io.IOException;
  
 public class ChatServer {
  
  public static final int ECHO_PORT = 10007;
  private static ChatServer CS = new ChatServer();
  
  public static ChatServer getInstance(){
	  return CS;
  }
  
  public static void start() {
    ServerSocket serverSocket = null;
    Manager manager = null;
    manager = Manager.getInstance();
    
    try {
      serverSocket = new ServerSocket(ECHO_PORT);
      System.out.println("EchoServerが起動しました(port="
                         + serverSocket.getLocalPort() + ")");
      while (true) {
        Socket socket = serverSocket.accept();
        new EchoThread(socket).start();
        manager.setVal("member",socket);
      }
    } catch (IOException e) {
      e.printStackTrace();
    } finally {
      try {
        if (serverSocket != null) {
          serverSocket.close();
        }
      } catch (IOException e) {}
    }
  }
}
 
class EchoThread extends Thread {
 
  private Socket socket;
 
  public EchoThread(Socket socket) {
    this.socket = socket;
    System.out.println("接続されました "
                       + socket.getRemoteSocketAddress());
  }
 
  public void run() {
    try {
      BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
      PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
      String line;
      while ( (line = in.readLine()) != null ) {
        System.out.println(socket.getRemoteSocketAddress()
                           + " 受信: " + line);
        //out.println(line);
        send(line);
      }
    } catch (IOException e) {
      e.printStackTrace();
    } finally {
      try {
        if (socket != null) {
          socket.close();
        }
      } catch (IOException e) {}
      System.out.println("切断されました "
                         + socket.getRemoteSocketAddress());
    }
  }
 
  public void send(String line){
	  Manager manager = null;
	  manager = Manager.getInstance();
	  String sendTo = line.split(" ",0)[0];
	  OutputStream ret = null;
	  Socket socket = null;
	  try {
		  socket = (Socket)manager.getVal(sendTo);
		  BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
		  ret = socket.getOutputStream();
	      PrintWriter out = new PrintWriter(ret, true);
	      out.println(line);
	  }catch (IOException e) {
	      e.printStackTrace();
	  } 
  }
}

Client

import java.net.Socket;
 import java.net.ServerSocket;
 import java.io.BufferedReader;
 import java.io.InputStreamReader;
 import java.io.PrintWriter;
 import java.io.IOException;
  
 public class Client {
  
  public static final int ECHO_PORT = 10007;
 
  public static void main(String args[]) {
    Socket socket = null;
    try {
      socket = new Socket("localhost", ECHO_PORT);
      System.out.println("接続しました"
                         + socket.getRemoteSocketAddress());
      BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
      PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
      BufferedReader keyIn = new BufferedReader(new InputStreamReader(System.in));
      String input;
      while ( (input = keyIn.readLine()).length() > 0 ) {
    	System.out.println("input now");
        out.println(input);
        String line = in.readLine();
        if (line != null) {
          System.out.println(line);
        } else {
        	System.out.println("break");
          break;
        }
      }
    } catch (IOException e) {
      e.printStackTrace();
    } finally {
      try {
        if (socket != null) {
          socket.close();
        }
      } catch (IOException e) {}
      System.out.println("切断されました "
                         + socket.getRemoteSocketAddress());
    }
  }
}

Answer 1

クライアントの作りに問題があると思います。

クライアントでの受け取るべきデータには次の２つがあります。

1. そのクライアントを利用しているユーザーからの標準入力
2. 他のクライアントから送信されたメッセージ

クライアントの作りでは1., 2.を順番に同期的にreadしてますので、例えば1の実行中は2が到達していても何も表示されないのは当然です。複数のクライアントから同時に複数のメッセージが到着しても1を1行入力する度に2で受信できるメッセージは1行だけですから、チャットプログラムの基本構造として成立してないように感じます。

普通は、1と2を別々のスレッドで並行して行う(A)ようにするか1,2を同時に待つ(B)ようにして対処します。(B)はjava.nio.channels.Selectorのような仕組みで達成可能な気がしますが自分は詳細を調べたことがないので本当かどうか自信ないです。一方(A)なら簡単です。

またCUIでやるには少々無理があると思います。キーボードから入力中に標準出力へ他者からのメッセージが表示されてしまうといったいどうなってしまうのでしょうか？それはコンソールとして何を使うかによって振る舞いがかわりそうです。自分ならこのクライアントはGUIアプリにします。

Comments

[alice-R]

早々にご回答ありがとうございます。
全然分からなかったのでこれで進められそうです。
本当にありがとうございました。