java - 如何使用 websocket 检查消息是否真的在 Netty 中传递？

Question

我正在使用 Netty 开发一个 websocket 应用程序。我想知道消息是否真的从源发送到目的地。特别是，我们假设客户端和服务器有一个开放的 channel 并暂时交换一些消息。在某个时刻，客户端出现故障，但 Netty 中的 channel 仍然处于 Activity 状态。我尝试在发送消息之前使用 isReachable() ，但是这个方法在某些场景下似乎有 bug(例如，Win7 的机器已启动，但 isReachable() 返回 false)。现在，我的想法是实现一种使用 ACK 的机制，即服务器发送消息，客户端发回 ack。为此，我需要一个超时来查看在一定时间间隔后，相应的确认是否没有到达。 Netty中有类似的东西吗？

Answer 1

关于 isReachable() - 它只是一个尽力而为的 API。文档指出，它尝试发送 ICMP 回显请求或创建到目标主机上端口 7 的 TCP 连接，这两种操作都很有可能被防火墙阻止。您的情况是否发生这种情况？

至于承认，Netty 中没有任何内容将此作为标准，但实现起来应该不会太困难。首先，每条消息都需要通过某种标识符来唯一识别，可能是序列号，但全局唯一标识符意味着您可以在断开连接时恢复。然后您想要创建一个实现 ChannelInboundHandler 和 ChannelOutboundHandler 的组合处理程序(假设 Netty 4)。发送消息时

• 将消息添加到按其 ID 索引的 map
• 创建与消息 ID 关联的计时器。将其添加到按消息 ID 索引的另一个 map
• 转发消息

当收到 ACK 时，取消计时器并从各自的映射中删除计时器和消息。如果计时器触发，请使用关联的 ID 来决定如何处理计时器和消息(可能重新传输并重置计时器)。

Netty 提供了一个 HashedWheelTimer，用于有效管理大量计时器，其分辨率适合此类 Activity 。

您可能还需要考虑限制重试次数，以便您可以停止并提出错误，而不是无限期地持续下去。