Java套接字和断开的连接

Question

检测插座是否已掉落的最合适方法是什么？还是实际上是否发送过数据包？

我有一个库，用于通过Apple网关（在GitHub上提供）将Apple
Push Notifications发送到iPhone
。客户端需要打开一个套接字并发送每个消息的二进制表示形式。但不幸的是，Apple不会返回任何确认。该连接也可以重用于发送多个消息。我正在使用简单的Java套接字连接。相关代码为：

Socket socket = socket();   // returns an reused open socket, or a new one
socket.getOutputStream().write(m.marshall());
socket.getOutputStream().flush();
logger.debug("Message \"{}\" sent", m);

在某些情况下，如果在发送消息时或之前发送消息时断开了连接；Socket.getOutputStream().write()虽然成功完成。我希望这是由于TCP窗口尚未耗尽。

有什么方法可以确定一个数据包是否确实进入了网络？我尝试了以下两种解决方案：

1. 插入socket.getInputStream().read()一个250ms超时的附加操作。这将导致读取操作在断开连接后失败，但会挂起250ms。

2. 将TCP发送缓冲区大小（例如Socket.setSendBufferSize()）设置为消息二进制大小。

两种方法都可以使用，但是会大大降低服务质量。吞吐率从100条消息/秒增加到最多10条消息/秒。

有什么建议？

更新：

质疑多个答案质疑所描述的可能性。我针对所描述的行为构建了“单元”测试。在Gist
273786处检查单元箱。

这两个单元测试都有两个线程，一个服务器和一个客户端。客户端发送数据时服务器关闭，而没有抛出IOException异常。这是主要方法：

public static void main(String[] args) throws Throwable {
    final int PORT = 8005;
    final int FIRST_BUF_SIZE = 5;

    final Throwable[] errors = new Throwable[1];
    final Semaphore serverClosing = new Semaphore(0);
    final Semaphore messageFlushed = new Semaphore(0);

    class ServerThread extends Thread {
        public void run() {
            try {
                ServerSocket ssocket = new ServerSocket(PORT);
                Socket socket = ssocket.accept();
                InputStream s = socket.getInputStream();
                s.read(new byte[FIRST_BUF_SIZE]);

                messageFlushed.acquire();

                socket.close();
                ssocket.close();
                System.out.println("Closed socket");

                serverClosing.release();
            } catch (Throwable e) {
                errors[0] = e;
            }
        }
    }

    class ClientThread extends Thread {
        public void run() {
            try {
                Socket socket = new Socket("localhost", PORT);
                OutputStream st = socket.getOutputStream();
                st.write(new byte[FIRST_BUF_SIZE]);
                st.flush();

                messageFlushed.release();
                serverClosing.acquire(1);

                System.out.println("writing new packets");

                // sending more packets while server already
                // closed connection
                st.write(32);
                st.flush();
                st.close();

                System.out.println("Sent");
            } catch (Throwable e) {
                errors[0] = e;
            }
        }
    }

    Thread thread1 = new ServerThread();
    Thread thread2 = new ClientThread();

    thread1.start();
    thread2.start();

    thread1.join();
    thread2.join();

    if (errors[0] != null)
        throw errors[0];
    System.out.println("Run without any errors");
}

[顺便说一句，我也有一个并发测试库，它使设置更好，更清晰。同样在要点检查样本]。

运行时，我得到以下输出：

Closed socket
writing new packets
Finished writing
Run without any errors

Answer 1

这对您没有太大帮助，但是从技术上讲，您提出的两个解决方案都不正确。OutputStream.flush（）以及您可以想到的任何其他API调用都不会做您需要的事情。

确定对等方是否已接收到数据包的唯一可移植且可靠的方法是等待对等方的确认。该确认可以是实际响应，也可以是正常的套接字关闭。故事的结尾-
确实没有其他方法，而且这不是Java特定的-这是基本的网络编程。

如果这不是持久连接-也就是说，如果您只是发送一些东西然后关闭连接-
这样做的方式是捕获所有IOExceptions（它们中的任何一个都指示错误），然后执行正常的套接字关闭：

1. socket.shutdownOutput();
2. wait for inputStream.read() to return -1, indicating the peer has also shutdown its socket