Jetty Websockets - 在处理不可靠的连接时正确发送异步消息

Question

我正在使用 Jetty 9.3.5，我想知道在发送 websocket 消息时处理不可靠连接的正确方法是什么，特别是：我注意到 websocket 连接没有正常关闭的情况，即使客户端侧向下，在服务器上触发 onClose() 需要很长时间（例如，用户关闭笔记本电脑盖并将其置于待机状态 - 可能需要 1-2 小时才能在服务器上收到关闭事件服务器端）。

因此，由于客户端仍处于注册状态，服务器会不断发送开始构建的消息。这在发送大量消息时会成为一个问题。

我已经测试过发送字节消息：

Session.getRemote().sendBytes(ByteBuffer, WriteCallback)
Session.getRemote().sendBytesByFuture(ByteBuffer);

为了在一侧模拟连接中断（即用户将笔记本电脑置于待机状态），在 Linux 上，我为 eth0 接口分配了一个 IP 地址，开始发送消息，然后将其关闭：

ifconfig eth0 192.168.1.1
ifconfig eth0 up
--- start sending messages (simple incremented numbers) and connect using Chrome browser and print them ---
ifconfig eth0 down

这样：Jetty 还在发送消息，Chrome 客户端没有收到，onClose 或 onError 没有在服务器端触发

我关于 Jetty 的问题是：

1. 有没有办法清除队列中未传递的消息？ 我试过了，但没有运气：

   Session.getRemote().flush();

2. 可以设置最大排队消息数吗？ 我试过了：

   WebSocketServletFactory.getPolicy().setMaxBinaryMessageBufferSize(1)

3. 我可以检测客户端是否没有收到消息吗？ （或者如果连接处于异常状态，比如说） 我试过了：

   session.getRemote().sendBytes(bb, new WriteCallback() {
   
                   @Override
                   public void writeSuccess() {
                       //print success                     }
   
                   @Override
                   public void writeFailed(Throwable arg0) {
                       //print fail
                   }
               });
   

但是即使没有收到消息，这也会打印成功。

我也试过用，但没找到解决办法：

factory.getPolicy().setIdleTimeout(...);
factory.getPolicy().setAsyncWriteTimeout(3000);
sendPing()

提前致谢！

Answer 1

不幸的是，作为消息传递协议的 WebSocket 协议并不是真正为消息之间的这种细微差别而设计的。

必须先完成第一条消息，然后才能考虑发送下一条消息。因此，如果您正在处理一条消息，则无法安全地取消该消息。

充其量，可以存在一个 API 来截断带有 CONTINUATION / 空负载 / fin=true 的消息。

但即使那样，远程端点也不知道您取消了消息，它只会看到部分消息。

最好使用操作系统级别的事件（如 Android 的连接意图）或通过定期 websocket PING（将自身插入到传出 websocket 帧的行前）来处理检测连接问题。

但是，即使使用 PING，如果您的传出 websocket 帧正在进行中，则在该 websocket 帧完成发送之前，即使 PING 也无法发送。

RemoteEndpoint.flush() 将尝试刷新所有待处理的消息（和帧），而不是清除待处理的消息（或帧）。

至于检测客户端是否收到消息，您需要在自己的层中实现某种消息 ACK 来验证，协议没有这样的概念。 （一些建立在 websocket 之上的 libs/apis 已经在该层实现了消息 ACK。cometd message ack extension 是一个真实世界的例子）

您试图解决什么样的情况？

也许使用RemoteEndpoint.sendPartialString(String, boolean) 或RemoteEndpoint.sendPartialBytes(ByteBuffer, boolean) 发送整个消息的较小帧可能对您有用。但是，对方可能没有可以读取这些部分帧的 API（例如：浏览器中的 Javascript）。