쓰레드는 소켓/프린트 라이더 상호 작용에 매달린다.

Question

내 프로그램이 멈추기 전까지는 더 적은 메시지를 보내고 약 20 초 후에 실행된다. 나는 스레드 덤프를 만들었어요 그리고 스레드가 중지 코드의 다음 줄에 나 포인트 :

if(s.isClosed() || !s.isConnected() || s.isInputShutdown() || s.isOutputShutdown() || out == null || out.checkError()) { 

이

"class xxx.xxx.xxx" prio=10 tid=0x000000000200d800 nid=0x6e7f waiting for monitor entry [0x00007f63172b6000] 
    java.lang.Thread.State: BLOCKED (on object monitor) 
     at java.io.PrintWriter.flush(PrintWriter.java:291) 
     - waiting to lock <0x00000000ec810218> (a java.io.BufferedWriter) 
     at java.io.PrintWriter.checkError(PrintWriter.java:330) 

이 스레드 덤프 정보는 지적 내 스레드 덤프의 일부입니다 문제는 Printwriter.checkError()에 있습니다. 그러나 나는 그것이 왜 여기서 멈출 것인지 이해할 수 없다.

아래 코드는 상황에 맞는 코드입니다.

public void parseMessage(final byte[] bytes) { 
    synchronized (receivers) { 
     for (final Socket s : receivers.keySet()) { 
      final PrintWriter out = receivers.get(s); 
      if(s.isClosed() || !s.isConnected() || s.isInputShutdown() || s.isOutputShutdown() || out == null || out.checkError()) { 
       receivers.remove(s); 
       failedToConnect(s.getInetAddress().getHostAddress(), s.getPort()); 
       continue; 
      } 
      queue.add(out, bytes); 
     } 
    } 
} 

업데이트 14 januari (수신기가 Map<Socket, PrintWriter>이다) (그리니치 표준시 10시 + 1) :

대신하는 차 BufferedWriter

업데이트 14 januari와 PrintWriter (그리니치 표준시 16시 +1) :

나는 더 많은 테스트를 해봤지만 일부 네트워크/독자들이 문제를 일으키고 있습니다. 응용 프로그램은 일부 외부 네트워크 (인터넷을 통해)의 일부 독자에게 내부 네트워크 및 일부 독자에게 데이터를 보냅니다. 이것이 정확히 무엇을 일으키는지는 아직까지는 알 수 없지만 몇 가지 단서가 있습니다. 몇 가지 다시 시작한 후 두 네트워크 간의 연결이 닫히지 않았으므로 연결이 열린 상태를 유지할 수있었습니다. 나는 아직도 정확히 무슨 일이 일어나고 있는지 모르지만 그것이 네트워크 문제라고 생각합니다. 서버 측에서는 연결은 "FIN_WAIT1"에 있고 판독기 쪽에서는 "ESTABLISHED"로 유지됩니다. 그것은 신호가 그것을 닫으려면 전송되었습니다조차도 독자가 연결을 닫으려고 신호하지 않을 것 같습니다. 스레드가 차단

Answer 1

의이 대부분 쓸데없는 일련의 당신이 how-to-analyze-java-thread-dumps

Answer 2

if(s.isClosed() || !s.isConnected() || s.isInputShutdown() || s.isOutputShutdown() || out == null || out.checkError()) 

가 발생하는 것과 매우 유사이 링크를 살펴 가 I/O 요청을 기다리고 가능성 테스트.

• 소켓이 닫혀 있으면 코드의이 부분에 전혀 들어가서는 안됩니다.
• 소켓이 연결되어 있지 않은 경우에도 마찬가지입니다.
• 입력을 위해 소켓을 종료 한 경우 쓸 수 없다는 의미는 아닙니다.
• 출력을 위해 소켓을 종료 한 경우이 코드 부분에 있어서는 안됩니다.
• out이 null 인 경우 코드의이 부분에 있어서는 안됩니다.
• 테스트는 checkError()이 좋지만 실제로 네트워크를 통해 PrintWriter을 사용하지 않아야합니다. 예외가 발생하기 때문입니다. BufferedWriter을 사용하는 것이 더 좋을 것이며 여기에서하는 것처럼 다음 글쓰기보다는 예외가 발생하면 잘못 될 것이라고 예외를 알려주십시오.

당신은 또한이 Socket. 마찬가지로, Socket.isConnected()는 당신이 Socket,를 연결하거나 이미 생성자, 또는 ServerSocket.accept()를 통해 연결 받았는지를 알 수 닫은 여부 Socket.isClosed() 만 알려줍니다 것을 이해할 필요가있다. isInputShutdown() 및 isOutputShutdown().에 대해서도 마찬가지입니다. Socket.에 한 일만 알려줍니다. 연결의 상태에 대해 알려주는 방법은 없습니다.

이 스레드 덤프 정보는 문제가 Printwriter.checkError()에 있음을 나타냅니다. 그러나 나는 그것이 왜 여기서 멈출 것인지 이해할 수 없다.

스택 추적도 알려줍니다으로, 당신이 독자를 오버런 것을 의미하는 경우 블록 것을 flush().를 호출하고, TCP는 그를 자신의 소켓에 무료 버퍼 공간에 일부 데이터를 읽기 위해 기다리고 있습니다, 때문에 수신 버퍼 따라서 소켓 보내기 버퍼. 그 때까지 기본 send()이 차단됩니다. 독자의 속도를 높이는 것 외에는 할 수있는 일이 없습니다.