java - 客户端套接字读取 "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

消耗Socket的InputStream中的所有可用数据。如果客户端没有关闭连接，该方法将一直等待，直到它可以读取文件结束字符(如果我没记错的话)。我必须采取什么措施来防止这种情况发生，并尽快提供客户端的字符串？

Answer 1

我认为您需要查看 ObjectInputStream 上的文档。使用 length = input.available 获取当前可用字节数，然后使用 input.read(buffer, offset, length) 读取完全相同的数量字节可用。您可能希望为每个新连接启动一个新线程，以透明地在后台管理此缓冲区，除非您首先要创建单线程代理。