Java服务器与客户端的通信

Question

现在我的ServerSocket是这样的

public class Main {

    public static void main(String[] args) {
        Server server = new Server(9008);
    }
}

public class Server {

    private ServerSocket server;
    private Socket client;
    private ArrayList<ClientConnection> clientList;

    public Server(int port) {
        try {
            // Create out server with our desired port
            server = new ServerSocket(port);
            // Server started, let the user know
            System.out.println("Server started at port " + port + "...");
        } catch (IOException e) {
            // Unable to start server, print error
            System.out.println("Unable to start server on port " + port + "...");
        } 
        // Start our main server method
        runServer();
    }

    public void runServer() {
        clientList = new ArrayList<>();
        while (true) {
            try {
                // Wait for new clients and accept them
                client = server.accept();
                // Let the user know - print
                System.out.println("New user connected - " + client.getLocalAddress().getHostAddress());
                // Start thread for our client
                ClientConnection getClient = new ClientConnection(client);
                clientList.add(getClient);
                Thread clientThread = new Thread(getClient);
                clientThread.start();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

public class ClientConnection implements Runnable {

    private Socket socket;

    public ClientConnection(Socket client) {
        // Set client socket
        this.socket = client;
    }

    public void run() {
        try {
            // Read from our client input
            BufferedReader readClient = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            String line;
            while ((line = readClient.readLine()) != null) {
                // Print client message
                System.out.println("Client says - " + line);
            }
        } catch(IOException e) {

        }
    }
}

一切正常，客户端连接，发送一些数据，服务器读取它，但我的问题是如何从我的服务器发送消息到所有的客户端？我目前保存客户端上的ArrayList，所以我可以只是循环，ArrayList打开一个作家和刷新它，但我想发送的数据，我得到我的ClientConnection类

我应该如何处理这个代码？在服务器类上完成的所有操作？或

Answer 1

不要说得太具体，但您可能应该看看观察者模式。

当一个新的客户端连接到服务器并且您创建了ClientConnection实例时，它可以被处理消息的另一个类观察到。这样，当客户端发送消息并且ClientConnection处理它时，它会自动将消息传输到处理消息传递功能并了解所有连接的类，然后该类将消息传输到所有客户端。

1. 使ClientConnection实现可观察接口（或扩展可观察类以获得更方便的使用）
2. makeServer实现了观察者界面，这样它就可以观察到可观察的东西。
3. 当客户端连接时，创建一个新的ClientConnection并使Server监听它（add观察员（））
4. 当客户端发送新消息时，使ClientConnection执行setChanged（）和通知观察员
5. 这样服务器就会注意到（通过它应该实现的更新方法）新消息，以及是哪个ClientConnection发送了它。
6. 服务器现在遍历其所有客户端并将消息发送给每个客户端

见观察者和观察者，这应该足够了。如果没有，网上有一大堆关于观察者模式的文章。