如何解决在Java / Android中更快地检测到套接字损坏
| 背景 我的应用程序从电话中收集数据，并将其发送到远程服务器。 数据首先存储在内存中（如果足够大，则存储在文件中），每隔X秒钟左右，应用程序就会刷新该数据并将其发送到服务器。 至关重要的任务是成功发送每个数据，我宁愿将数据发送两次而不是根本不发送。 问题 作为测试，我将应用程序设置为每5秒发送带有时间戳的数据，这意味着每5秒在服务器上出现一条新行。 如果我杀死服务器，我希望这些行停止，那么现在应该将它们写入内存。 当我再次启用服务器时，我应该能够确认没有任何事件丢失。 但是问题是，当我杀死服务器时，IO操作开始需要大约20秒钟才能开始失败，这意味着在这20秒钟内，应用程序很乐意发送事件并将其从内存中删除，但它们从未到达服务器，并且永远丢失了。 我需要一种方法来确保数据实际到达服务器。 这可能是更基本的TCP问题之一，但同样如此，我还没有找到任何解决方案。 我尝试过的东西 设定Socket.setTcpNoDelay(true)
socket = new Socket(host,port);
socket.setTcpNoDelay(true);
while(!dataList.isEmpty()) {
String data = dataList.removeFirst();
inMemoryCount -= data.length();
try {
OutputStream os = socket.getOutputStream();
os.write(data.getBytes());
os.flush();
}
catch(IOException e) {
inMemoryCount += data.length();
dataList.addFirst(data);
socket = null;
return false;
}
}
return true;
解决方法
请在此处查看已接受的答案：Java套接字和断开的连接
socket.shutdownOutput（）;
等待inputStream.read（）返回-1，指示对等方也已关闭其套接字
, 坏消息：您无法检测到失败的连接，除非尝试在该连接上发送或接收数据。
好消息：正如您所说，如果您发送重复数据就可以了。因此，您的解决方案不必担心在不到20秒的时间内检测到故障。相反，只需保留一个循环缓冲区，其中包含最后30或60秒的数据。每次检测到故障然后重新连接时，都可以通过重新发送已保存的数据来启动会话。
（如果服务器在不到一分钟的时间内反复启动和关闭，这可能会成为问题；但是，如果这样做，您还有其他问题要解决。）
,Dan的解决方案是我在读完您的问题后建议的方案，他得到了我的支持。
现在，我可以建议解决此问题吗？我不知道您的设置是否可行，但是处理设计欠佳的软件（这是您的服务器，对不起）的一种方法是将其包装起来，或者在精美的设计模式中提供外观，或者简而言之，将代理放在您的后台服务器之前。设计有意义的基于ack的协议，使代理在内存中保留足够的数据样本，以便能够检测和容忍断开的连接等。总之，使电话应用程序连接到位于服务器级服务器上的代理。 \“机器使用\” good \“协议，然后使代理使用\” bad \“协议连接到服务器进程。客户负责生成数据。代理负责处理服务器。
只是另一个想法。
编辑0：
您可能会发现这很有趣：最终的SO_LINGER页面，或者：为什么我的tcp不可靠。
, 无法使用：无法修改服务器
您的服务器无法确认它收到的与另一个数据包一起的每条消息吗？客户端不会删除服务器尚未确认的消息。
这将影响性能。为避免速度变慢，您可以在收到确认之前继续发送消息，并在一条返回消息中确认几条消息。
如果您每5秒钟发送一条消息，并且30秒钟内网络堆栈都未检测到断开连接，则您只需存储6条消息。如果未确认发送的6条消息，则可以认为连接已断开。 （我想您的应用程序中已经实现了重新连接和积压发送的逻辑。）
, 如何在使远程主机响应每个UDP数据报的同时在单独的UDP套接字上发送UDP数据报，然后在远程主机不响应时杀死TCP连接呢？它足够快地检测到链接断开:)
, 使用http POST而不是套接字连接，然后可以向每个帖子发送响应。在客户端，仅当响应指示成功时，才从内存中删除数据。
确保更多的开销，但100％的时间给您您想要的东西。
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。