ServerSocket 不会等到它关闭再重新打开

Question

我正在用 java 编写客户端/服务器应用程序，并且我正在尝试使服务器能够自行重新启动。目前，服务器接受一个连接，从客户端读取一个对象，然后将对象/套接字/流传递给一个新的线程，该线程从那里接管。下一部分是问题所在：要重新启动已经运行的服务器（让我们将此实例称为“实例 1”），我启动它的一个新实例（实例 2）。如果 ServerSocket 已经在使用，实例 2 应该向 ServerSocket 写入一个空值，这将导致实例 1 关闭它，然后实例 2 应该像以前一样运行相同的块。这样做会成功终止实例 1，但除非我进入调试模式并控制何时发生哪一行，否则实例 2 会在 ServerSocket 关闭之前尝试重新打开它，因此它也会终止。我无法让实例 2 等到 ServerSocket 关闭后再尝试打开它。有没有我找不到的方法或实现？

import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Tester {

    protected ExecutorService threadPool = Executors.newFixedThreadPool(10);

    public static void main(String[] args) {
        new Tester();
    }

    public Tester () {
        try {
            listen();
        } catch (Exception e) {
            try {
                Socket socket = new Socket("127.0.0.1", 4444);
                new ObjectOutputStream(socket.getOutputStream()).writeObject(null);
                socket.close();

                listen();
            } catch (Exception ex) { e.printStackTrace(); }
        }

        return;
    }

    public void listen () throws Exception {
        try (ServerSocket serverSocket = new ServerSocket(4444);) {
            while (true) {
                Socket clientSocket = serverSocket.accept();
                ObjectInputStream in = new ObjectInputStream(clientSocket.getInputStream());
                Object obj = in.readObject();
                if(obj == null)
                    break;
          //    this.threadPool.execute(new ServerThread( ... ));
            }
            threadPool.shutdown();
        } catch (Exception e) {
            e.printStackTrace();
            throw new Exception();
        }
    }
}

Answer 1

尝试在延时循环中打开 ServerSocket，比如

for (int i = 0; i < 3; i++) {
  Thread.sleep(2000); //select your sleep time
  try {
    reopenMyServerSocket();
    break;
  }
  catch (IOException iox) {}
}

Answer 2

使用线程将是处理此问题的合适方法。如果您想使用线程，那么您可以按照我的示例进行操作。

    public static void main(String[] args) {            
        renderServer(9000);//render socket and handle request
    }

    public static void renderServer(int port){    
        ServerSocket  serverSocket  = new ServerSocket (port);
        System.out.println("Server started on "+ new Date());     

        while(true){
            Socket socket = serverSocket.accept(); 

            HandleClient handleClient = new HandleClient(socket);
            Thread thread = new Thread(handleClient);
            thread.start();
        }
    }

然后您必须创建处理每个请求的 HandleClient 类。请注意，HandleClient 类必须实现 Runnable，如下例所示。

public class HandleClient implements Runnable{ 

        Socket socket;

        public HandleClient(Socket socket){
            this.socket = socket;
        }


        @Override
        public void run() {
            //Your code goes in here
            DataInputStream in = new DataInputStream(socket.getInputStream());
            DataOutputStream out = new DataOutputStream(socket.getOutputStream());
            //Then you can continue from here
        }

}