Java套接字和删除连接

检测套接字是否已丢失最合适的方法是什么?或者包是否真的被发送了?

我有一个通过Apple Gatways向iPhone发送Apple推送通知的库( available on GitHub )客户机需要打开一个套接字并发送每个消息的二进制表示;但不幸的是,苹果没有返回任何确认信息。连接也可以重用以发送多条消息。我使用的是简单的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() 超时250毫秒的操作。这将强制执行一个读取操作,该操作在连接断开时失败,但在其他情况下挂起250毫秒。

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");
}

[顺便说一下,我还有一个并发测试库,它使设置变得更好、更清晰。也可以在gist上检查样本。

运行时,我得到以下输出:

Closed socket
writing new packets
Finished writing
Run without any errors