Java / Groovy Socket - Обнаружение закрытия сокета неблокирующим способом

Question

Я пытаюсь создать небольшой HTTP-прокси, который может переписать запрос / заголовки в соответствии с моими требованиями. Если он уже существует, пожалуйста, укажите мне на это. Иначе...

Я написал кое-что, что ПОЧТИ работает. Он может выполнять функцию прокси, но не переписывать (пока). Проблема в том, что я не могу определить, когда удаленный сокет был закрыт, не выполняя блокировку чтения. КРИТИЧЕСКИ для функциональности этой вещи, чтобы она была в состоянии обнаружить закрытие сокета без блокировки. Я НАУЧИЛ документацию по API Java и не могу найти ЛЮБОГО указания на то, что это возможно. Вот что у меня есть:

    while ( this.inbound.isConnected() && this.outbound.isConnected() ) { 

      try {
        while ( ( available = readFromClient.available() ) != 0 ) { 
          if ( available > 1024 ) available = 1024
          bytesRead = readFromClient.read( buffer, 0, available )
          writeToServer.write( buffer, 0, bytesRead )
        }   

        while ( ( available = readFromServer.available() ) != 0 ) { 
          if ( available > 1024 ) available = 1024
          bytesRead = readFromServer.read( buffer, 0, available )
          writeToClient.write( buffer, 0, bytesRead )
        }                                                                                       
      } catch (e) { 
        print e
      }   

      println "Connected:      " + this.inbound.isConnected() 
      println "Bound:          " + this.inbound.isBound() 
      println "InputShutdown:  " + this.inbound.isInputShutdown() 
      println "OutputShutdown: " + this.inbound.isOutputShutdown() 
      print "\n";

      Thread.sleep( 10 )

    }   

Тесты на закрытие сокета никогда не показывают, что сокет был закрыт. И, как я уже упоминал, я не могу найти ЛЮБЫХ примеров того, как обнаружить условие "КОНЕЦ ФАЙЛА" в потоке без блокирующего чтения.

Должен быть способ. Кто-нибудь здесь знает, что это?

Answer 1

Я предполагаю, что вы используете java.net.Socket для вашего ввода / вывода. Чтобы сделать неблокирующий ввод / вывод в Java, вы должны использовать пакет NIO.

В частности, вы захотите использовать java.nio.channels.SocketChannel для связи. Вызов configureBlocking(false) на канале read() вернет либо количество прочитанных данных, либо -1 для закрытых, либо ноль, если данные недоступны. Исключение также может быть вызвано некоторыми ошибочными условиями.

Вот пример, показывающий неблокирующий ввод / вывод с использованием SocketChannel.

Answer 2

Нет, это не помогает Как вы можете даже знать, что вы должны читать, если соединение отключено на другой стороне, а селектор java nio не переводит канал в готовый набор, когда это происходит?

Насколько я могу судить, это просто нарушает дизайн, и нет никакого способа сделать это. Пожалуйста, кто-нибудь поправит меня, если я ошибаюсь...