java - 收到输入后如何通知所有线程

我目前正在开发一种让服务器等待连接的东西，一旦建立连接，就会创建一个线程来处理服务器与客户端之间的通信。所有这些通信都是基于String的，利用了InputStreamReaders和OutputStreamReaders，目前我需要做的是能够通过它们自己的ServerThread向每个连接的Client发送消息。关于事物编写方式的简单视图是：

public final static int SERVER_PORT = 12345;
private static int numThreads=0;

public void Server() {
    ServerSocket serverSocket = null;

    try{
        serverSocket = new ServerSocket(Server.SERVER_PORT);
    } catch (IOException e) {
        e.printStackTrace();
        System.exit(-1);
    }

    while (true) {
        try {
            Socket socket = serverSocket.accept();
            numThreads++;
            new ServerThread(socket, numThreads).start();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

变量numThreads主要用于将特定信息打印到客户端。在ServerThread上，我将拥有：

@Override
public void run() {
    while (true) {
        String command=null;
        try{
            command = readString(); //method that reads input from Client
            //Do actions based on command
        }catch(Exception ex){
            ex.getMessage();
        }
    }
    //Close streams and socket
}

所显示的方法的内容可能会有一些错别字，因为目前它们有很多错字，但应有助于可视化问题。

为了简化客户端，我们假设有一个客户端，它连接到服务器并将命令/消息发送到我们的ServerThread。

每次客户端连接到服务器时，都会创建一个新的ServerThread，它将持续等待客户端发送command。如果此command对应于例如“发送”，我需要向连接到服务器的每个客户端发送一条消息。我该怎么做？请让我知道我是否可以提供更多信息。

最佳答案

在这里，我提供了一个想法，可以通过事件监视（观察者模式）解决。
可以将发布者分成一个单独的类。

public class ServerThread implements Runnable {

  // Used for event subscription (CopyOnWriteArrayList is not the best implementation, please adjust
  // according to project needs)
  private static final List<ServerThread> LISTENERS = new CopyOnWriteArrayList<>();

  public ServerThread(Socket socket, int num) {
    // do something ...
    LISTENERS.add(this);
  }

  @Override
  public void run() {
    while (true) {
      String command = null;
      try {
        command = readString(); // method that reads input from Client
        // Do actions based on command
        if ("send".equals(command)) {
          ServerThread.publish(new SendEvent(command));
        }
      } catch (Exception ex) {
        ex.printStackTrace();
      }
    }
    // Close streams and socket
  }

  private String readString() {
    return null;
  }

  /**
   * event publishing method
   *
   * @param event
   */
  public static void publish(SendEvent event) {
    LISTENERS.forEach(listener -> listener.listen(event));
  }

  /**
   * Event processing method
   *
   * @param event
   */
  public void listen(SendEvent event) {
    // to something ...
  }
}