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

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

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

    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 )

    }

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

ДОЛЖЕН быть способ. Кто-нибудь здесь знает, что это такое?


java input sockets groovy nonblocking
person John Arrowwood    schedule 10.06.2010    source источник

Ответы (2)


arrow_upward
2
arrow_downward

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

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

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

person ataylor    schedule 10.06.2010

arrow_upward
0
arrow_downward

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

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

person BadZen    schedule 12.01.2011
comment
Согласованный! В данный момент я сталкиваюсь с этой проблемой - если другая сторона убита, я не получаю событие чтения, и даже запись в сокет не вызывает ошибки. Вот это боль... - person trojanfoe; 08.02.2011