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

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

1 голос
/ 10 июня 2010

Я пытаюсь создать небольшой 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 )

    }

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

Ответы [ 2 ]

2 голосов
/ 10 июня 2010

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

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

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

0 голосов
/ 13 января 2011

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

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

...