我正在创建客户端 - 服务器系统,应该能够在不稳定的网络中工作.它假设连接可以一次断开,然后系统必须重新连接并继续它的工作.我正在使用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
}
}
});
Run Code Online (Sandbox Code Playgroud)
但是当我完成时,我注意到,听众从不打印错误.(当我的系统几乎无法正常工作时,我通过从网络上拔下来测试了这一点)另外我注意到我发送的消息的所有未来都进入"完成"状态,并且无法确保收到消息(不使用确认消息)
据我所知,TCP协议保证会收到消息,在使用它时我们可以知道哪些发送包到达目的地,哪些不到.我无法相信Netty不允许知道它.
有没有一种好方法可以知道消息已经发送?
小智 6
你误解了TCP.TCP不保证您的邮件已收到.它提供可靠的有序字节流.它对您的消息一无所知,也无法告诉您远程主机何时收到该消息.因此Netty也不会.Netty只能告诉您,您的消息在传输之前已写入操作系统缓冲区.这是您的代码正在检测的内容.
为确保收到您的消息,接收方必须发回明确的确认.实现此目标的最佳方法取决于协议的预期行为,但通常涉及维护已发送但尚未确认的所有消息的表.
归档时间: |
|
查看次数: |
1543 次 |
最近记录: |