在 java 套接字客户端程序中超时的位置

Question

我有下面的套接字程序，我能够成功地将测试消息发布到服务器程序，但是有时进程等待太久以防收到响应，有人可以指导我实现超时并在 2 秒后重试相同的连接。

import java.io.BufferedInputStream;
import java.io.BufferedWriter;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
public class Put_msg {
    public static String Post(String strRequestMessage, String strIP,
            int intPort) throws Exception {
        String strResponseMessage = "";
        try{
        Socket socket = null;
        socket = new Socket(strIP, intPort);
        BufferedInputStream bin = new BufferedInputStream(
                socket.getInputStream());
        PrintWriter pw1 = new PrintWriter(new BufferedWriter(
                new OutputStreamWriter(socket.getOutputStream())), true);
        pw1.println(strRequestMessage);
        pw1.flush();
        strResponseMessage = readInputStream(bin);
        socket.close();
        socket = null;
        }catch(Exception e){
            strResponseMessage = "ERROR:Post_JAVA:"+e.toString();
            return strResponseMessage;
        }
        return strResponseMessage;
    }
    public static String readInputStream(BufferedInputStream in)
            throws Exception {
        String read_msg = "";
        int i = in.read();
        if (i == -1) {
            return "-1";
        }
        read_msg = read_msg + (char) i;
        int available = in.available();
        if (available > 0) {
            byte[] Data = new byte[available];
            in.read(Data);
            read_msg = read_msg + new String(Data);
        }
        return read_msg;
    }
}

Answer 1

您可以使用

以下setSoTimeout向套接字添加超时：

socket = new Socket(strIp, intPort) ;
socket.setSoTimeout(2000); //2000 milliseconds

这将超时read花费的时间超过指定时间的调用

Answer 2

套

接字超时又名 当您为socket.setSoTimeout()提供非零值（默认值为零，表示无超时）时，SO_TIMEOUT将在阻止read()调用上启用超时。

但是，代码的一个更大的问题是使用 available() .我不知道你想做什么，但你做错了。目前，您的代码并不关心它是否从另一端接收任何内容、垃圾或全部数据。为什么不读取，直到另一端关闭连接以发出所有数据已发送的信号？

Answer 3

在

服务器或客户端套接字中设置套接字超时，如下所示：

Socket socket = new Socket();
socket.setSoTimeout(2000);

若要重复尝试直到成功，请将用于启动连接的代码放在其自己的方法中，并让该方法从方法的 catch 语句中调用自身。每次超时时都会调用 catch 语句，因此您可以从那里递归调用该方法，直到它成功。