ソケットストリームでBufferedReaderのタイムアウトを設定する方法

Question

ここでは、2秒ごとにサーバーの応答を確認するスレッドを作成していますが、client.monitorResponse()はreadLine()メソッドであり、応答が受信されるまで続行されません。 。私は、サーバーに接続されたクライアントソケットを経由して応答を拾っています

public SocketObject(Socket client, int numberOfClients) throws Exception { 
    socket = client; // the .accept() socket is passed through 
    // this is because I assign them ID's for later use (I hold an ArrayList of sockets) 
    this.clientId = numberOfClients; 

    // both these are static to the class 

    outputStream = new PrintWriter(client.getOutputStream()); 
    inputStream = new BufferedReader(new InputStreamReader(client.getInputStream())); 
} 

public void sendResponse(String response) { 
    outputStream.println(response); 
} 

：

client = new ClientObject("localhost"); 
timer.scheduleAtFixedRate(new TimerTask() { 
    @Override 
    public void run() { 
     try { 
      String response = null; 
      if(!(response = client.monitorResponse()).isEmpty()) { 
       System.out.println("Response: " + response); 
      } catch (Exception e) { 
       e.printStackTrace(); 
      } 
    } 
}, 2000, 2000); 

私は（clientが確立ソケットがある）ので、などのサーバーを経由して応答を送信しています：

public ClientObject(String hostname) throws IOException { 

    // socket is static to this class 

    socket = new Socket(hostname, 4444); 
    System.out.println("Connected to " + hostname + " on port 4444..."); 

    // both static to this class 

    outputStream = new PrintWriter(socket.getOutputStream(), true); 
    inputStream = new BufferedReader(new InputStreamReader(socket.getInputStream())); 

    System.out.println("Successfully started a stream on " + hostname); 
    this.hostname = hostname; 
} 

public String monitorResponse() throws Exception { 
    System.out.println("Listening for a response..."); 
    return inputStream.readLine(); 
} 

デバッグコンソールにのみメートルを語っされたらが応答を聞く...出力を表示しますそれはスレッド内でinputStream.readLine()メソッドを通過しないということです。とにかくBufferedReaderにタイムアウトを追加できますか？私はBufferedReaderを作成する前にソケットに.setSoTimeout()を追加するような複数のソリューションを試しましたが、指定された時間後に接続/ソケットを閉じることができました。

ご協力いただければ幸いです。

Answer 1

ノンブロッキング（NIO）リクエストを使用し、その間に改行を探すチャンクを読み込む必要があります。通常Javaでは、使用しているStreamクラスのNIOバージョンを探し、それを使ってN秒ごとに新しいコンテンツをチェックするだけです。

String partialLine=""; 
public static String monitorResponse() throws Exception { 
    System.out.println("Listening for a response..."); 
    int nextByte; 
    String nextChar; 
    while (inputStream.ready()) { 
     nextByte = inputStream.read(); 
     nextChar = Character.toString ((char) nextByte); 
     partialLine += nextChar; 
     if ("\n".equals(nextChar)) { 
      String line = partialLine; 
      partialLine = ""; 
      return line.replace("\r\n", ""); 
     } 
    } 
    return ""; 
} 

の詳細はhttp://tutorials.jenkov.com/java-nio/nio-vs-io.htmlをチェックアウト：最小限の変更であなたのケースでは、ブロッキングを防止するためにBufferedReader.ready()で通話を遮断するあまり派手で効率的な方法を使用することができます。

Answer 2

私はBufferedReaderにタイムアウトを追加できますか？

いいえ、ただし、Socketには、Socket.setSoTimeout()でタイムアウトを設定できます。

私はBufferedReaderを作成する前にソケットに.setSoTimeout（）を追加するなど、複数の解決策を試しましたが、指定した時間後に接続/ソケットを閉じることができました。

いいえソケットを閉じません。それはSocketTimeoutExceptionを投げ、あなたはそれを捕らえて適切に扱うべきです。ソケットが閉じている場合は、閉じています。解決策：しないでください。