客户端套接字读取“冻结”

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

消耗 Socket 的 InputStream 中的所有可用数据。如果客户端没有关闭连接，该方法将等到它可以读取文件结尾字符（如果我没记错的话）。我需要做些什么来防止这种情况发生，并尽快让客户的字符串可用？

Answer 1

我认为您需要查看ObjectInputStream 上的文档。执行length = input.available 获取当前可用字节数，然后使用input.read(buffer, offset, length) 读取可用字节数。您可能希望为每个新连接启动一个新线程，该线程在后台透明地管理此缓冲区，除非您一开始就制作单线程代理。