java socket多个客户端不接收消息

Question

我正在制作一个 java 套接字聊天程序，并且我使它与多个连接兼容，当用户加入时，它不会向所有客户端发送消息“[user] Joined”，只是发送给连接的客户端，但我有一个如果有人能告诉我为什么它只向最近加入的用户发送消息，则为每个客户提供线程，我将不胜感激。这是服务器代码

import java.io.*;
import java.net.*;
import java.util.ArrayList;

public class server {
public ObjectInputStream input;
public ServerSocket server;
public Socket s;
public ObjectOutputStream output;
public ArrayList<Socket> users = new ArrayList<Socket>();
public class Accept implements Runnable {
    public void run() {
        try {
            server = new ServerSocket(55555, 100);
        } catch (IOException e) {
            e.printStackTrace();
        }
        while(true) {
            try {
                s = server.accept();
                users.add(s);
                new EchoThread(s).start();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}
public class EchoThread extends Thread {
    private Socket sock;
    public EchoThread(Socket s) throws IOException {
        this.sock = s;
        output = new ObjectOutputStream(sock.getOutputStream());
    }
    public void run() {
        System.out.println(sock.getInetAddress() + " Connected");
        try {
            for(Socket s: users) {
                output.writeObject(s.getInetAddress() + " Connected");
            }
        } catch (IOException e1) {
            e1.printStackTrace();
        }
    }
}
server() throws IOException {
    Thread t = new Thread(new Accept());
    t.start();
}
public static void main(String[] args) throws IOException {
    new server();
}
}

Answer 1

所以， 每次有人连接到服务器时，你都会创建一个新的 EchoThread。 每个用户都有自己的 EchoThread。

您的服务器角色是管理所有 EchoThreads 和 Sockets。

 output.writeObject(s.getInetAddress() + " Connected");

这只会向一个用户发送消息。 您的服务器应该有一个 Sockets 列表并向每个 Sockets 发送消息

public ArrayList<Socket> users = new ArrayList<Socket>();
public ArrayList<ObjectOutputStream> outputs = new ArrayList<ObjectOutputStream>();


public class Accept implements Runnable {

    public void run() {

        try {
            server = new ServerSocket(55555, 100);
        } catch (IOException e) {
            e.printStackTrace();
        }

        while(true) {
            try {
                s = server.accept();
                users.add(s);
                outputs.add(new ObjectOutputStream(s.getOutputStream()));

                for (ObjectOutputStream o: outputs) {
                    o.writeObject(s.getInetAddress() + " has connected");
                }

            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}