88

Socket#close()リモート側のソケットで呼び出されたかどうかをどのように検出しますか?

4

4 に答える 4

65

このisConnectedメソッドは役に立たずtrue、リモート側がソケットを閉じていても返されます。これを試して:

public class MyServer {
    public static final int PORT = 12345;
    public static void main(String[] args) throws IOException, InterruptedException {
        ServerSocket ss = ServerSocketFactory.getDefault().createServerSocket(PORT);
        Socket s = ss.accept();
        Thread.sleep(5000);
        ss.close();
        s.close();
    }
}

public class MyClient {
    public static void main(String[] args) throws IOException, InterruptedException {
        Socket s = SocketFactory.getDefault().createSocket("localhost", MyServer.PORT);
        System.out.println(" connected: " + s.isConnected());
        Thread.sleep(10000);
        System.out.println(" connected: " + s.isConnected());
    }
}

サーバーを起動し、クライアントを起動します。ソケットが 2 回目に閉じられたにもかかわらず、"connected: true" が 2 回表示されることがわかります。

実際に確認する唯一の方法は、関連付けられた Input/OutputStreams を読み取る (戻り値として -1 を取得する) または書き込む ( IOException(破損したパイプ) がスローされる) ことです。

于 2008-09-30T07:41:15.173 に答える
29

答えがずれているので、これをテストして結果を投稿することにしました - テスト例を含めて。

ここでのサーバーは、クライアントにデータを書き込むだけで、入力は期待していません。

サーバー:

ServerSocket serverSocket = new ServerSocket(4444);
Socket clientSocket = serverSocket.accept();
PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);
while (true) {
  out.println("output");
  if (out.checkError()) System.out.println("ERROR writing data to socket !!!");
  System.out.println(clientSocket.isConnected());
  System.out.println(clientSocket.getInputStream().read());
        // thread sleep ...
  // break condition , close sockets and the like ...
}
  • clientSocket.isConnected() は、クライアントが接続すると (切断後も) 常に true を返します。
  • getInputStream().read()
    • クライアントが接続されている限り、スレッドは入力を待機するため、プログラムは何も実行しません-入力を取得する場合を除く
    • クライアントが切断された場合は -1 を返します
  • out.checkError() クライアントが切断されるとすぐに true になるので、これをお勧めします
于 2011-11-25T11:33:01.773 に答える
13

クライアントソケットへの書き込み中にソケット出力ストリームエラーを確認することもできます。

out.println(output);
if(out.checkError())
{
    throw new Exception("Error transmitting data.");
}
于 2009-10-29T22:52:46.810 に答える