Java 服务器使用套接字连接到其他服务器答案

【问题标题】：Java server connect to other server using socketsJava 服务器使用套接字连接到其他服务器
【发布时间】：2020-10-10 08:23:05
【问题描述】：

我有一个项目，我必须构建一个系统，其中多个服务器相互通信以响应客户端。

我可以让客户端与服务器通信，但在让服务器启动它们之间的连接时遇到问题。

在下面的代码中，您可以看到我有一个包含所有服务器 ip 的列表。对于每个 ip，当前服务器尝试与其他服务器连接。您还可以看到服务器正在等待连接，在这种情况下，是来自其他服务器的连接。

@Override
public void run() {
    // Trying to connect with server
    for (String serverIp : servers) {
        System.out.println("Trying to connect with " + serverIp);
        try {
            Socket clientSocket = new Socket(serverIp, this.port);
            this.clientPool.submit(new ClientThread(clientSocket, this.streamHandler));
        } catch (Exception e) {
            System.out.println("Error");
        }
        System.out.println("Connected with " + serverIp);
    }
    // Receiving connections from other servers
    // In these case we call client to the other server
    try (ServerSocket serverSocket = new ServerSocket(port)) {
        System.out.println("Waiting for clients to connect...");
        while (true) {
            Socket clientSocket = serverSocket.accept();
            this.clientPool.submit(new ClientThread(clientSocket, this.streamHandler));
        }
        // serverSocket.close();
    } catch (IOException e) {
        Configuration.printError("Error starting server", e);
    }
}

问题是服务器需要尝试与其他服务器连接并等待来自其他服务器的连接。并且在接收到新连接后，它需要停止尝试连接到对应服务器，或者如果服务器尝试连接到另一台服务器成功，它需要停止从该服务器接收新连接。

关于如何使用套接字实现此功能的任何建议？

【问题讨论】：

为什么不用zookeeper？实例之间的协调？

标签： java multithreading sockets distributed-system raft

【解决方案1】：

您似乎尝试分步执行此操作，首先所有服务器都尝试连接到其他服务器，但还没有服务器开始接受连接。在 clientSocket 连接到服务器后，您便开始接受连接。听起来这可能会导致死锁。

您知道每个服务器都必须接受来自其他服务器的连接。您还知道每台服务器都需要启动与其他服务器的连接。

您必须在两个不同的线程中接受连接和启动的连接，或者您应该使用异步/事件驱动模型并管理事件循环。

并且在接收到新连接后，它需要停止尝试连接到对应服务器，或者如果服务器尝试连接到另一台服务器成功，它需要停止接收来自该服务器的新连接。

在这里你想避免一场比赛。如果每个服务器在尝试连接到其他服务器之前等待 X 时间，这是最容易做到的。这个 X 应该是从启动开始的随机延迟。例如。服务器 A 在连接前等待 5 秒，服务器 B 在连接前等待 1 秒，服务器 C 在连接前等待 13 秒。但是服务器 B 和 C 不会发起任何连接，因为服务器 A 已经与这些服务器建立了连接。

【讨论】：