java - 在 Ubuntu 或 Windows 中运行的 Java 程序中套接字的不同行为

Question

我正在研究两个程序之间的通信，一个使用 C++，另一个使用 Java，使用标准套接字连接。这两个程序在同一台机器内的 UNIX (Ubuntu) 下运行，并定期共享信息一段时间。在执行的某个时刻，总是在同一时刻，它会卡住，因为 C++ 中的程序发送信息，而 Java 中的程序没有获取所有信息，因此它们阻塞，因为第一个期望接收到该信息，而第二个不发送任何事情都是因为没有在第一时间收到信息。

奇怪的是你在 Windows 下用 Java 执行程序。然后它运行正常，程序正确结束，没有任何阻塞。

我认为是 Java 应用程序的问题，但为什么在 Ubuntu 或 Windows 下运行有区别？套接字的行为是否不同？ Ubuntu 和 Windows 中的 JVM 是否有一些参数不同？

非常感谢您!

朱伦。

编辑:

这是读取缓冲区的 Java 端代码:

   if (task.equals("receiving")){
        try {
            BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            out = socket.getOutputStream();

            // receive messages
            char[] length = new char[5];
            while (!socket.isClosed()&&(!socket.isInputShutdown())){
                in.read(length,0,5);
                // this way of reading the length implies that only one command
                // at a time can be received and interpreted, so far the iCS does not
                // concatenate more commands in one transmission
                int commandLength = length[4];
                System.err.println("Speed Advice --> command received with length "+ commandLength);
                char[] command = new char[commandLength - 1];
                in.read(command,0,commandLength - 1);
                /*if (cow){
                    System.err.println("Speed Advice --> Last byte received for X-pos is "+(int)command[commandLength-1]);
                }*/
                readCommand(command);
            }
            System.err.println("Speed Advice --> Socket was externally closed.");
            in.close();
            closeConnection();
        }catch (Exception e) {
            e.printStackTrace();
        }
    }

而这个 C++ 发送信息:

void 
    Socket::
    send( std::vector<unsigned char> b) 
    throw( SocketException )
{
    if( socket_ < 0 ) return;

    size_t numbytes = b.size();
    unsigned char *const buf = new unsigned char[numbytes];

    for(size_t i = 0; i < numbytes; ++i)
    {
        buf[i] = b[i];
    }

    if (verbose_) 
    {
        cerr << "Send " << numbytes << " bytes via tcpip::Socket: [";
        for(size_t i = 0; i < numbytes; ++i)
        {
            buf[i] = b[i];
            cerr << " " << (int)b[i] << " ";
        }
        cerr << "]" << endl;
    }

    unsigned char const *buf_ptr = buf;
    while( numbytes > 0 )
    {
#ifdef WIN32
        int n = ::send( socket_, (const char*)buf_ptr, static_cast<int>(numbytes), 0 );
#else
        int n = ::send( socket_, buf_ptr, numbytes, 0 );
#endif
        if( n<0 )
        {
            // BailOnSocketError definitely throws an exception so clear up heap
            delete[] buf;
            BailOnSocketError( "send failed" );
        }

        numbytes -= n;
        buf_ptr += n;
    }

    delete[] buf;
}

Answer 1

BufferedReader 不是具体的问题，也不是“TCP 堆栈已满”。并且不需要 select() 来解决它。

你在这里犯了几个常见的错误。

1. 您正在忽略 read() 的返回值。 它可能是 -1，表示对等方已关闭连接，您必须先对其进行测试并采取行动。或者它可以是 1 和您请求的大小之间的任何值。您只是盲目地假设您在调用 in.read(buffer,0,5) 时将获得 5 个字节。 无法保证这一点。您需要使用 DataInputStream.readFully()。

2. 您正在从 C++ 发送 8 位字符，并使用 Java 中的 Reader。这没有任何意义。使用 InputStream。 具体来说，使用 DataInputStream，这样您就可以按照上面的建议调用 readFully()。

3. Socket.isClosed() 告诉您您是否已关闭套接字。它不会告诉您对等方是否已关闭连接。这就是上面的 -1 的用途。

4. 同样，Socket.isInputShutdown() 告诉您您是否在此套接字上有关闭输入。它不会告诉您对等端是否有关闭输出。同样，这就是上面 -1 的用途。

所以这两个测试都是没有意义的，当其中任何一个为真时，您打印的消息是不正确的。