6

在这篇文章之后，我遇到了同样的问题，我设法通过一个简单的测试演员来重现它。我希望你能帮助我。

让我解释一下，我正在使用套接字发送消息。只要我将 so_timeout 设置为不到两分钟，一切都很好。但是，如果我将其设置为超过两分钟，则套接字会在两分钟后超时。因此，如果我将 so_timeout 设置为 10 秒，则套接字将在 10 秒后超时，但如果我将其设置为 180 秒，则套接字将在 120 秒后超时。

这是一个测试用例：

import java.io.*;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketTimeoutException;

/**
 *
 */
public class TestSocket1 {

public static void main(String[] args) throws IOException {

    ServerSocket serverSocket = new ServerSocket();

    serverSocket.setReuseAddress(true);
    serverSocket.bind(new InetSocketAddress(1111), 0);
    serverSocket.setSoTimeout(1000);
    Socket socket = null;

    boolean send = true;

    while (send) {
        try {
            socket = serverSocket.accept();
            Thread.sleep(100);
            String messageReceived = readFromSocket(socket);

            System.out.println(messageReceived);

            if (send) {
                send = false;

                Thread.sleep(150000); // Causing 2.5 minutes delay
                // Sending message

                BufferedWriter wr = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(), "UTF8"));
                PrintWriter printWriter = new PrintWriter(wr, true);

                String output = "Hello Back";

                printWriter.println(output);
                printWriter.flush();
                socket.shutdownOutput();

            }

        }
        catch (SocketTimeoutException ie) {
        }
        catch (Exception e) {
        }
        finally {
            if (socket != null) {
                socket.close();
            }
        }
    }


}

protected static String readFromSocket(Socket socket) throws IOException {
    StringBuilder messageReceived = new StringBuilder();
    BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"));

    String line = br.readLine();

    messageReceived.append(line);

    socket.shutdownInput();

    return messageReceived.toString();
}


}

import java.io.*;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.SocketAddress;

/**
 *
 */
public class TestSocket2 {

public static void main(String[] args) throws IOException {

    Socket socket = new Socket();
    socket.setKeepAlive(true);
    socket.setReuseAddress(true);
    socket.setTcpNoDelay(true);
    socket.setSoTimeout(180000); // Should wait 3 minutes before throwing time out exception - Actually throwing after 2 minutes

    SocketAddress socketAddress = new InetSocketAddress(1111);

    socket.connect(socketAddress, 5000);

    // Sending message

    BufferedWriter wr = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(), "UTF8"));
    PrintWriter printWriter = new PrintWriter(wr, true);

    String output = "Hello There";

    printWriter.println(output);
    printWriter.flush();
    socket.shutdownOutput();

    String messageReceived = readFromSocket(socket);

    System.out.println(messageReceived);

}

protected static String readFromSocket(Socket socket) throws IOException {
    StringBuilder messageReceived = new StringBuilder();
    BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"));

    String line = br.readLine();

    messageReceived.append(line);

    socket.shutdownInput();

    return messageReceived.toString();
}


}

您应该先运行 TestSocket1 类，然后再运行 TestSocket2。

我在这个问题上苦苦挣扎了很长时间，任何帮助都将不胜感激。谢谢你。

  • 编辑

所以我删除了对 SO_TimeOut 的依赖，并在这篇文章中接受了@Nick 的建议，在阅读之前检查可用的输入流。但现在的问题是，两分钟后可用字节总是返回 0，尽管输入已写入流。所以我仍然有同样的问题。

4

2 回答 2

2

所以我想出了问题所在

socket.shutdownInput();

导致套接字更改为 FIN_WAIT 状态，因此在关闭前等待 2 分钟（2MSL）

于 2013-06-10T15:06:57.943 回答
2

您不能将连接超时时间增加到超过平台默认值（大约一分钟）。你只能减少它。试图增加它实际上没有任何意义。你想达到什么目的？

于 2013-06-09T10:10:42.340 回答