자바에서 끝까지 열린 스트림을 읽습니다.

Question

아파치의 텔넷 클라이언트로부터 입력 스트림을 받고 있습니다. 텔넷 클라이언트에 명령을 보낼 때마다 터미널 출력을 다시 InputStream에 기록하지만이 스트림은 텔넷 세션까지 열려 있습니다.

이제 끝까지이 스트림의 데이터를 읽는 방법을 원합니다. 스트림이 항상 열려 있기 때문에 문제가 끝날지 결정할 수 없습니다. 특정 문자가 발견 될 때까지 데이터를 읽지 않았습니다. 이는 대부분의 경우 프롬프트입니다.)하지만 프롬프트는 명령에 따라 계속 변경되며 명령 실행 후 무엇이 될지 알 길이 없습니다.

더 잘 설명 SO에 비슷한 질문이있다지만 아무 대답이 없다 :

Problems with InputStream

도와주세요 ...

Answer 1

마침내 나는 timeout을 사용했다. 기본적으로 1 초 동안 문자를 사용할 수 없으면 포기했다. 스트림이 열려있는 경우, 어떤 * 정확히 * 당신은 "말"에 의해 의미합니까

private char readChar(final InputStream in){ 
     ExecutorService executor = Executors.newFixedThreadPool(1); 
     //set the executor thread working 
     Callable<Integer> task = new Callable<Integer>() { 
      public Integer call() { 
       try { 
        return in.read(); 
       } catch (Exception e) { 
        //do nothing 
       } 
       return null; 
      } 
     }; 

     Future<Integer> future = executor.submit(task); 
     Integer result =null; 
     try { 
       result= future.get(1, TimeUnit.SECONDS); //timeout of 1 sec 
      } catch (TimeoutException ex) { 
       //do nothing 
      } catch (InterruptedException e) { 
      // handle the interrupts 
      } catch (ExecutionException e) { 
      // handle other exceptions 
      } finally { 
       future.cancel(false); 
       executor.shutdownNow(); 
      } 

     if(result==null) 
      return (char) -1; 
     return (char) result.intValue(); 
    } 

Answer 2

당신은 독서를위한 별도의 스레드를 생성해야합니다. 당신은 당신이 직면 한 정확한 이유를 위해 하나의 실에 "핑퐁"방식으로 갈 수는 없습니다.

덧붙여서 : 지금까지 링크 한 질문에는 대답이 있습니다. CPU를 100 %로드하지 말고 정말 좋은 충고입니다. :)

read 메서드는 블록이기 때문에 스레드에 루프에 넣을 수 있습니다 루프를 끝내고 IOException 또는 "-1"의 스레드를 종료하고 영원히 행복하게 살자.