我很难弄清楚如何使用 msgpack 设置非阻塞 IO(网络套接字)。写入部分是微不足道的,因为 msgpack 可以ByteBuffer
相当容易地生成一个,但我不知道如何对 MessagePack 对象进行非阻塞读取。看看MessagePack.read()
有三个主要选项...... read(InputStream in)
,read(byte[] b)
和read(ByteBuffer b)
。所有这些都是阻塞操作。
我尝试使用非阻塞传输的原因是我的服务器可能需要数百个同时的长期连接。
有什么建议么?在我的谷歌搜索中,似乎大多数人只是使用带有阻塞 IO 的 msgpack。我能想到的唯一选择是