我有一个 WebSocket 服务器,URL 是 “wss://api.client.com/subscribe/”,它提供了一系列不间断的 JSON 消息流(每个消息约 1200 字节)。
我已经按照 "https://dev59.com/S18d5IYBdhLWcg3wxklq#26454417" 中提到的方法创建了一个 WebSocket 客户端。
客户端正在消费这些消息,但是过了一段时间后我会收到以下错误信息:
如何在接收到消息后清除缓冲区? 或者,有没有一种方法可以在连接关闭后立即重新连接到服务器?
我会尽快消耗服务器返回的消息并将其打印在控制台上。我不希望消息存储在缓冲区中,因为无论我增加多少缓冲区大小,服务器都会填满它,因为它是一连串的连续消息。
我已经按照 "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]
如何在接收到消息后清除缓冲区? 或者,有没有一种方法可以在连接关闭后立即重新连接到服务器?
我会尽快消耗服务器返回的消息并将其打印在控制台上。我不希望消息存储在缓冲区中,因为无论我增加多少缓冲区大小,服务器都会填满它,因为它是一连串的连续消息。