Клиентский сокет читает «freezes»

Question

Я хочу написать простой веб-прокси для упражнений. Вот код, который я до сих пор:

def g = new Proxy() 
g.serverPort = 9000 
println "starting" 
g.eachClient { Socket client -> 
    println "got a client" 
    try { 
     client.withStreams { input,output -> 
      String text = input.text 
      println "received $text from client" 
      client.close() 
     } 
    } catch(IOException io) { 
     println "IO error. Probably client disconnected" 
     //io.printStackTrace() 
    } 
} 

вещь, линия:

String text = input.text

поглощает все имеющиеся данные в InputStream сокета. Если клиент не закрывает соединение, этот метод будет просто ждать, пока он не сможет прочитать конец символа файла (если я правильно помню). Что я должен предотвратить, чтобы это произошло, и чтобы строка клиента была доступна как можно скорее?

Answer 1

Я думаю, что вы захотите проверить документацию на ObjectInputStream. Сделайте length = input.available, чтобы получить количество доступных байтов в настоящее время, затем используйте input.read(buffer, offset, length), чтобы читать точно столько же, сколько доступно. Вероятно, вы захотите запустить новый поток для каждого нового соединения, которое прозрачно управляет этим буфером в фоновом режиме, если только вы не создаете однопоточный прокси-сервер.