用java实现两台服务器间的心跳机制

在 Java 中实现两台服务器之间的心跳机制可以通过使用套接字（Socket）来实现。以下是一个简单的示例代码，展示了如何在两台服务器之间建立心跳连接：

服务器端代码：

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
    public static void main(String[] args) {
        try {
            ServerSocket serverSocket = new ServerSocket(9999);
            System.out.println("Server started, waiting for client...");

            while (true) {
                Socket clientSocket = serverSocket.accept();
                System.out.println("Client connected: " + clientSocket.getInetAddress().getHostAddress());

                // 处理心跳连接
                HeartbeatHandler heartbeatHandler = new HeartbeatHandler(clientSocket);
                heartbeatHandler.start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

class HeartbeatHandler extends Thread {
    private Socket clientSocket;

    public HeartbeatHandler(Socket clientSocket) {
        this.clientSocket = clientSocket;
    }

    @Override
    public void run() {
        try {
            while (true) {
                // 接收心跳消息
                String message = receiveMessage();

                // 处理心跳消息
                if (message.equals("heartbeat")) {
                    System.out.println("Received heartbeat from client: " + clientSocket.getInetAddress().getHostAddress());
                    // 回复心跳消息
                    sendMessage("heartbeat");
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    private String receiveMessage() throws IOException {
        // 从客户端接收消息
        // ...
    }

    private void sendMessage(String message) throws IOException {
        // 向客户端发送消息
        // ...
    }
}

客户端代码：

import java.io.IOException;
import java.net.Socket;

public class Client {
    public static void main(String[] args) {
        try {
            Socket serverSocket = new Socket("server-ip-address", 9999);
            System.out.println("Connected to server: " + serverSocket.getInetAddress().getHostAddress());

            // 发送心跳消息
            while (true) {
                sendMessage("heartbeat");
                // 等待一段时间
                Thread.sleep(1000);
            }
        } catch (IOException | InterruptedException e) {
            e.printStackTrace();
        }
    }

    private static void sendMessage(String message) throws IOException {
        // 向服务器发送消息
        // ...
    }
}

请注意，这只是一个简单的示例，并未处理连接的断开、超时等异常情况。在实际应用中，你可能需要更加完善的错误处理和容错机制来保证心跳连接的稳定性和可靠性。