java - 更快地检测 Java/Android 中的损坏套接字

Question

背景

我的应用程序从手机收集数据并将其发送到远程服务器。
数据首先存储在内存中(或在文件足够大时存储在文件中)，应用程序每隔 X 秒左右刷新一次该数据并将其发送到服务器。

成功发送每条数据是关键任务，我宁愿发送两次数据也不愿不发送。

问题

作为测试，我将应用程序设置为每 5 秒发送一次带有时间戳的数据，这意味着服务器上每 5 秒就会出现一个新行。
如果我终止服务器，我希望这些行停止，它们现在应该被写入内存。

当我再次启用服务器时，我应该能够确认没有丢失任何事件。

然而，问题是当我终止服务器时，IO 操作需要大约 20 秒才能开始失败，这意味着在这 20 秒内，应用程序愉快地发送事件并将它们从内存中删除，但它们永远不会到达服务器并丢失永远。

我需要一种方法来确保数据确实到达了服务器。

这可能是更基本的 TCP 问题之一，但同样如此，我还没有找到任何解决方案。

我试过的东西

• 设置Socket.setTcpNoDelay(true)
• 删除所有缓冲写入器并仅使用 OutputStream直接
• 每次发送后刷新流

附加信息

我无法更改服务器的响应方式，这意味着我无法告诉服务器确认数据(不仅仅是 TCP 机制)，服务器将静静地接受数据而不发回任何内容。

代码 fragment

类的初始化:

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;

---

更新1

我再说一遍，我无法改变服务器的行为方式。
它通过 TCP 和 UPD 接收数据，并且不发回任何数据以确认接收。这是事实，在完美的世界中，服务器肯定会确认数据，但这根本不会发生。

---

更新2

Fraggle 发布的解决方案非常完美(关闭套接字并等待输入流关闭)。

然而，这带来了一系列新问题。
因为我在打电话，所以我必须假设用户不能发送无限量的字节，并且我希望尽可能将所有数据流量保持在最低水平。

我不担心打开一个新套接字的开销，那几个字节不会有什么不同。然而，我担心的是，每次我连接到服务器时，我都必须发送一个短字符串来标识我是谁。

字符串本身并没有那么长(大约 30 个字符)，但如果我过于频繁地关闭和打开套接字，它就会加起来。

一个解决方案是每隔 X 字节“刷新”一次数据，问题是我必须明智地选择 X；如果太大，则在套接字出现故障时会发送太多重复数据；如果太小，则开销太大。

---

最后更新

我的最终解决方案是通过每 X 字节关闭套接字来“刷新”套接字，如果一切都不好，将再次发送这些 X 字节。

这可能会在服务器上创建一些重复的事件，但可以在那里进行过滤。

Answer 1

Dan 的解决方案是我在阅读您的问题后立即提出的建议，他得到了我的赞成票。

现在我可以建议解决这个问题吗？我不知道你的设置是否可行，但处理设计糟糕的软件(这是你的服务器，抱歉)的一种方法是包装它，或者在 fancy-design-pattern-talk 中提供一个外观，或者在plain-talk 在你的 pain-in-the-behind 服务器前面放置了一个代理。设计有意义的基于 ack 的协议(protocol)，让代理在内存中保留足够的数据样本，以便能够检测和容忍断开的连接等。简而言之，让手机应用程序连接到驻留在“服务器级”某处的代理使用“好”协议(protocol)的机器，然后让代理使用“坏”协议(protocol)连接到服务器进程。客户端负责生成数据。代理负责与服务器打交道。

只是另一个想法。

编辑0:

您可能会发现这个很有趣:The ultimate SO_LINGER page, or: why is my tcp not reliable .