2

我正在使用 Websocket 进行数据事务,客户端通过 Tyrus 客户端端点 api 进行侦听。从服务器传输大小为 5kb 或更少的消息时,它会顺利到达客户端,但任何大于 5kb 的消息都不会到达客户端,并且该特定会话上的通信已经消失。因此,我尝试在会话中将消息缓冲区大小设置如下,但它始终保持为零,也尝试在设置后立即在配置下方打印,但这也返回零。

甚至尝试在客户端端点消息侦听器中配置消息大小

@OnMessage(maxMessageSize =1024*64)

那么如何增加 websocket 中的消息缓冲区大小呢?

session.setMaxTextMessageBufferSize(64 * 1024);
session.setMaxBinaryMessageBufferSize(64 * 1024);
System.out.println("Session Binary size >> " + session.getMaxBinaryMessageBufferSize());
System.out.println("Session Text size >> " + session.getMaxTextMessageBufferSize());
4

2 回答 2

3

您应该在您的对等方的两侧设置此设置,即在您接收消息的服务器(对等)端以及从服务器接收消息的对等方。

@OnMessage(maxMessageSize = 1024 * 1024) public void onBinaryMessage(Session session, ByteBuffer msg) { //todo }

于 2016-02-02T13:49:12.003 回答
1

我遇到了同样的问题(在我的 Android 应用程序中收到的所有消息都从服务器端限制为 64KB),我发现的解决方案是增加二进制限制大小:

1) 客户端:在 WebSocket 实现的类定义中添加下一行

@WebSocket(maxTextMessageSize = 640 * 1024,
           maxBinaryMessageSize = 640 * 1024)  

2)服务器:虽然不在我的控制范围内(它是第 3 方提供商),但似乎他们设法使用以下命令对其进行了配置:

WebSocketSession ---> setBinaryMessageSizeLimit
WebSocketPolicy.newServerPolicy().setMaxBinaryMessageSize(100000);

我已经读过一个更好的解决方案是让客户端直接管理的 64KB 消息块,但在我的情况下,我无法让它在我的应用程序客户端的 OnWebSocketMessage 实现中工作,即使通常使用二进制定义Jetty 协议使用:

@OnWebSocketMessage
public void onMessage(Session session, 
                      byte[] message, int offset, int length)

无论如何,我希望一些 WebSocket 专家可以给我们一些比我提出的更好的解决方案。干杯!

于 2016-08-04T07:47:30.067 回答