java socket 自动重连_socket 如何判断远端服务器的连接状态？连接断开，需重连...

要实现Socket自动重连，可以在Socket连接失败后，使用一个循环不断尝试重新连接，直到连接成功为止。连接失败可以通过捕获SocketException异常来判断。

判断远端服务器的连接状态可以通过发送心跳包来实现。比如可以定时发送一个固定格式的数据包（心跳包）到服务器，如果一段时间内没有收到服务器的回应，则认为连接断开，需要进行重连。在Java中，可以使用ScheduledExecutorService来定时发送心跳包。

下面是一个简单的示例代码：

public class SocketClient {
    private static final int HEARTBEAT_INTERVAL = 5000; // 心跳间隔时间，单位毫秒
    private String host = "localhost";
    private int port = 8080;
    private Socket socket;
    private ScheduledExecutorService executorService;

    public void connect() {
        try {
            socket = new Socket(host, port);
            executorService = Executors.newSingleThreadScheduledExecutor();
            executorService.scheduleAtFixedRate(() -> {
                try {
                    // 发送心跳包
                    OutputStream outputStream = socket.getOutputStream();
                    outputStream.write("ping".getBytes());
                    outputStream.flush();

                    // 设置读取超时时间
                    socket.setSoTimeout(HEARTBEAT_INTERVAL);

                    // 接收服务器的响应
                    InputStream inputStream = socket.getInputStream();
                    byte[] buffer = new byte[1024];
                    int len = inputStream.read(buffer);
                    if (len > 0) {
                        String response = new String(buffer, 0, len);
                        if (!"pong".equals(response)) {
                            // 服务器返回的响应不是预期的值，说明连接已断开，需要重连
                            throw new SocketException("Unexpected response from server");
                        }
                    } else {
                        // 服务器没有响应，说明连接已断开，需要重连
                        throw new SocketException("No response from server");
                    }
                } catch (IOException e) {
                    try {
                        socket.close();
                    } catch (IOException ex) {
                        ex.printStackTrace();
                    }
                    socket = null;
                    System.out.println("Connection lost, trying to reconnect...");
                }
            }, 0, HEARTBEAT_INTERVAL, TimeUnit.MILLISECONDS);
        } catch (IOException e) {
            System.out.println("Connection failed");
        }
    }

    public void disconnect() {
        try {
            executorService.shutdown();
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        SocketClient client = new SocketClient();
        client.connect();
    }
}

在上面的代码中，我们使用了一个ScheduledExecutorService来定时发送心跳包，并在心跳包发送失败后捕获SocketException异常来判断连接是否已断开。如果连接已断开，则关闭Socket并设置为null，并输出提示信息。在心跳包发送成功后，我们设置了读取超时时间，如果一段时间内没有收到服务器的回应，则也认为连接已断开。