从服务器消费连续消息的Websocket客户端

3
我有一个 WebSocket 服务器,URL 是 “wss://api.client.com/subscribe/”,它提供了一系列不间断的 JSON 消息流(每个消息约 1200 字节)。
我已经按照 "https://dev59.com/S18d5IYBdhLWcg3wxklq#26454417" 中提到的方法创建了一个 WebSocket 客户端。
客户端正在消费这些消息,但是过了一段时间后我会收到以下错误信息:
closing websocketCloseReason: code [1009], reason [The decoded text message was too big for the output buffer and the endpoint does not support partial messages]

如何在接收到消息后清除缓冲区? 或者,有没有一种方法可以在连接关闭后立即重新连接到服务器?
我会尽快消耗服务器返回的消息并将其打印在控制台上。我不希望消息存储在缓冲区中,因为无论我增加多少缓冲区大小,服务器都会填满它,因为它是一连串的连续消息。

https://alidg.me/blog/2016/9/10/java-9-http-websocket-client - firstpostcommenter
https://github.com/netty/netty/tree/4.1/example/src/main/java/io/netty/example/http/websocketx/client - firstpostcommenter
1个回答

0

有没有一个Spring Boot解决方案适用于这个问题的答案? - Jeredriq Demas

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接