Javaのソケットを使った通信で困ってます

Question

Javaで通信プログラムを書こうとしています
まだ初心者なのでわからないことだらけなのですが回答宜しくい願いします
問題はクライアントから受け取った文字列を接続しているクライアントすべてに送信するプログラムなのですがクライアントに送信できないことが問題です
エラーは出ていません
以下作成したコードです（インポート文は省略させていただきます

＝＝＝＝＝＝＝＝サーバー＝＝＝＝＝＝＝＝
public class ServerBace {
static ServerSocket SSocket = null;
static Socket socket = null;
static Vector<Player> PlayerList = new Vector<Player>(0);

public static void main (String[] args) {
	while (true) {
		try {
			SSocket = new ServerSocket(8080);
			System.out.println("サーバーを起動しました");
			while (true) {
				socket = SSocket.accept();
				System.out.println(socket.getLocalSocketAddress() + "と接続しています");
				new Thread(new Player(socket)).start();
				socket = null;
			}
		} catch (Exception e) {	}
	}
}

public static void sendMessage (String message) {
	try {
		System.out.println("送信メッセージ：" + message);
		for (int count = 0; count < PlayerList.size(); count ++) {
			PlayerList.get(count).OUT.write(message);
			PlayerList.get(count).OUT.newLine();
			PlayerList.get(count).OUT.flush();
		}
	} catch (Exception e) {
		System.out.println(e);
	}
}


public static class Player implements Runnable {
	Socket socket = null;
	BufferedWriter OUT = null;
	BufferedReader IN = null;

	public Player (Socket socketDummy) {
		try {
			socket = socketDummy;
			OUT = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
			IN = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			if (PlayerList.size() < 2) {
				PlayerList.add(this);
			} else {
				OUT.write("セッション数が上限を超えました");
				OUT.newLine();
				OUT.flush();
				System.out.println(socket.getInetAddress() + "がセッション上限に達したため切断されました");
				socket.close();
			}
		} catch (Exception e) {	}
	}

	public void run () {
		try {
			while (true) {
				String Message = IN.readLine();
				sendMessage(Message);
			}
		} catch (Exception e) {
			System.out.println(e);
		} finally {
			try {
				System.out.println(socket.getInetAddress() + "とセッションを切断します");
				socket.close();
				OUT.close();
				IN.close();
			} catch (Exception e) {	}
		}
	}
}

}

＝＝＝＝＝＝＝＝＝クライアント＝＝＝＝＝＝＝＝＝
public class Client {
static Socket socket = null;
static PrintWriter OUT = null;
static BufferedReader IN = null;

public static void main (String[] args) {
	Scanner scan = new Scanner(System.in);
	try {
		socket = new Socket();
		socket.connect(new InetSocketAddress(args[0], 8080));

		OUT = new PrintWriter(socket.getOutputStream(), true);
		IN = new BufferedReader(new InputStreamReader(socket.getInputStream()));

		while (true) {
			String Message = scan.nextLine();
			if (Message.equals("exit")) {
				break;
			}
			OUT.println(Message);
			OUT.flush();
		}
		scan.close();
	} catch (Exception e) {
		System.out.println(e);
	} finally {
		try {
			socket.close();
			OUT.close();
			IN.close();
			System.out.println("セッションを終了しました");
		} catch (Exception e) {	}
	}
}

}

何か間違いがあればご指摘お願いします

Comments

[argius]

いくつか教えてください。サーバー側の「～と接続しています」メッセージは出力されていますか？ サーバーとクライアントは同じマシンで実行していますか？（将来的には別のマシンで実行するのだと思いますが。）

[退会済みユーザー]

Client実行時に引数でlocalhostを入力した場合サーバー側に「～と接続しています」という表示は表示されます
また別のマシンとの接続でも表示されます

Answer 1

※申し訳ありませんが、この回答は誤っています。

詳しくは、コメント欄をご覧ください。

---

クライアント側は、接続が確立された後でString Message = scan.nextLine();を実行しているので、相手からのメッセージ送信を待っている状態です。

なので、サーバー側から何かメッセージを送信してあげる必要があります。

それ以降も、メッセージのキャッチボールをしてあげる必要があります。
片方がwriteしたら受け側では同じタイミングでreadするようにします。

Comments

[退会済みユーザー]

ベストアンサーとなっていますが違いませんか？
サーバーはメッセージを送信しています。
クライアント側でそのメッセージを出力していないだけです。
まあようするにClient側でwrite(OUT.flush())したらその後に受信したメッセージをread(IN.read()とかIN.readLine()とか)してどこかしらに出力する必要があります。
ただしこのやりとりの場合、明確なメッセージの終わりがないのでどこまでストリームを読めばいいのかは難しいでしょう。

[argius]

zoasさん

私には両方ともread状態に入っているように見えましたが、よろしければどこでサーバーがメッセージを送信しているのかご指摘いただけますか？

[退会済みユーザー]

ServerBace はsocket = SSocket.accept(); で接続を受け入れ、
その後別スレッドにてPlayerで
String Message = IN.readLine();
sendMessage(Message);
としているでしょう？

[argius]

そのIN.readLine();で、クライアント側からの送信が無いのでブロックされますよね？

[退会済みユーザー]

ClientでOUT.println(Message); してるでしょう？
とここまで書いて考えましたが、まさかクライアント側が標準入力からの入力待ちしてる前提でおっしゃってますかね？
私はもちろん質問者様はコマンドラインなりから文字を入力している前提で考えましたし、コピペで動作もさせてみました。

[argius]

失礼しました。
scan.nextLine();をサーバーからの入力だと勘違いしました。
この回答は誤っていますね。

ご指摘ありがとうございました。