0

サーバーを開き、このサーバーに接続してメッセージを受信するクライアントを作成する小さなプログラムを作成しようとしています。

これがこれまでのコードです

public static void main(String[] args) {
final ServerSocket serverSocket;
try {
    serverSocket = new ServerSocket(12345);
    Thread t = new Thread(){
        public void run(){
                try {
                    Socket server = serverSocket.accept();
                    PrintWriter writer = new PrintWriter(server.getOutputStream(), true);
                    writer.write("Hello World");
                    writer.flush();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        };
        t.start();
        Socket client = new Socket("localhost", 12345);
        BufferedReader reader = new BufferedReader(new InputStreamReader(client.getInputStream()));
        String message = reader.readLine();

        System.out.println("Received " + message);
    } catch (IOException e1) {
        e1.printStackTrace();
    }

}

プログラムを実行すると、readLine() で待機し続けるため、明らかにクライアントはサーバーからメッセージを受信しません。なぜこれが機能していないのか、誰かが考えていますか?

4

2 に答える 2

3

読み取りスレッドは、データ ストリームで改行を待機しています。使用するサーバーを変更するだけです：

writer.write("Hello World\r\n");

期待していた結果が得られます。または、サーバー ソケットを閉じるだけreadLineで、データ ストリームの最後に到達したときに戻ります。

于 2011-10-17T22:10:32.960 に答える
0

次のように readline をループに入れる必要があります。

public static void main(String[] args) {
    final ServerSocket serverSocket;
    try {
        serverSocket = new ServerSocket(12345);
        Thread t = new Thread() {
            public void run() {
                try {
                    Socket server = serverSocket.accept();
                    PrintWriter writer = new PrintWriter(server.getOutputStream(), true);
                    writer.write("Hello World");
                    writer.flush();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        };
        t.start();
        Socket client = new Socket("localhost", 12345);
        BufferedReader reader = new BufferedReader(new InputStreamReader(client.getInputStream()));
            // Check this --------------------------------------------------->
            String message = null;
            while ((message = in.readLine()) != null) {   
                    System.out.println("Received " + message);
                    break; //This break will exit the loop when the first message is sent by the server
            }

    } catch (IOException e1) {
        e1.printStackTrace();
    }

}

詳細な説明については、このドキュメントを読むことができます: http://download.oracle.com/javase/tutorial/networking/sockets/

于 2011-10-17T22:18:03.340 に答える