TCP Netty确保收到消息

我正在创建客户端 – 服务器系统,应该能够在不稳定的网络中工作。 它假设连接可以一次断开,然后系统必须重新连接并继续它的工作。 我正在使用Netty并遇到一个问题:我们怎么知道我们发送的消息是由另一台主机收到的?

我在想,为此可以使用ChannelFuture,如果附加的未来监听器失败,我可以简单地尝试再次发送消息:

ChannelFuture fut = channel.write(message); fut.addListener(new ChannelFutureListener() { @Override public void operationComplete(ChannelFuture future) throws Exception { if (!future.isSuccess()) { LOGGER.error("Message send failed. Message: " + message, future.getCause()); //Queue message to be send after reconnect } } }); 

但是当我完成时,我注意到,听众从不打印错误。 (当我的系统几乎无法正常工作时,我通过从网络上拔下来测试了这一点)我还注意到,我发送的消息的所有未来都进入“完成”状态,并且无法确保收到消息(不使用确认消息)

据我所知,TCP协议保证会收到消息,使用它时我们可以知道哪些发送包到达目的地,哪些不到。 我无法相信Netty不允许知道它。

有没有一种好方法可以知道消息已经发送?

你误解了TCP。 TCP不保证您的邮件已收到。 它提供可靠的有序字节流。 它对您的消息一无所知,也无法告诉您远程主机何时收到该消息。 因此Netty也不会。 Netty只能告诉您,您的消息在传输之前已写入操作系统缓冲区。 这是您的代码检测到的内容。

为确保收到您的消息,接收方必须发回明确的确认。 实现此目标的最佳方法取决于协议的预期行为,但通常涉及维护已发送但尚未确认的所有消息的表。

您的所有未来都是将信息写入网络。

要保证接收,您必须实现确认或使用消息号并重新发送请求。