多客户端聊天程序，向所有客户端广播聊天？

Question

我正在尝试制作一个可以容纳多个客户的非常简单的聊天程序。我有一个多线程服务器，可以将多个客户端连接到它，但服务器只与一个客户端通信（应该，每个客户端都在自己的线程上）我需要帮助让服务器从所有连接的人发送所有消息客户到每个客户。我想我需要在线程之间共享一个对象？代码如下：

服务器：

import java.net.ServerSocket;
import java.net.Socket;


public class ThreadedCommandServer {

    public static void main(String[] args) throws Exception {
        System.out.println("Starting server....");
        int port = 8989;


        ServerSocket ss = new ServerSocket(port);


        while(true) {
            System.out.println("Waiting for connection from client...");
            Socket socket = ss.accept();
            ServerThread st = new ServerThread(socket);
            st.start();

        }
    }

}

服务器线程：

import java.io.InputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.net.Socket;

public class ServerThread extends Thread {

    private Socket socket = null;
    private String s;

    public ServerThread(Socket s) {
        socket = s;

    }

    public void run() {
        try {
            InputStream is = socket.getInputStream();
            ObjectInputStream ois = new ObjectInputStream(is);
            s = (String) ois.readObject();
            System.out.println("received string: " + s);
            OutputStream os = socket.getOutputStream();
            ObjectOutputStream oos = new ObjectOutputStream(os);
            oos.writeObject(s);
            System.out.println("sent object back to client...");
        } catch (Exception e) {
            System.out.println(e.toString());
        }

    }

}

客户：

import java.io.InputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;


public class Controller {

private ClientFrame cf;
private String message;
private Socket socket;
private String response;

public Controller(ClientFrame cf) {
    this.cf = cf;
}


public void sendChat(String s) {
    message = s;
    System.out.println("FROM CONTROLLER: received: " + message);
    try {
    InetAddress i = InetAddress.getByName("localhost");
    socket= new Socket(i, 8989);
    OutputStream os = socket.getOutputStream();
    ObjectOutputStream oos = new ObjectOutputStream(os);
    System.out.println("FROM CONTROLLER: sending message to the server...");
    oos.writeObject(message);
    InputStream is = socket.getInputStream();
    ObjectInputStream ois = new ObjectInputStream(is);
    System.out.println("getting string back from server....");
    response = (String) ois.readObject();
    cf.updateGUI(response);
    }
    catch (Exception e) {
        e.printStackTrace();
    }
}

}

图形界面：

   import java.awt.BorderLayout;
    import java.awt.event.ActionEvent;
    import java.awt.event.ActionListener;
    import javax.swing.JButton;
    import javax.swing.JFrame;
    import javax.swing.JPanel;
    import javax.swing.JScrollPane;
    import javax.swing.JTextArea;
    import javax.swing.JTextField;

    public class ClientFrame extends JFrame {

    private JTextArea chatArea;
    private JTextField type;
    private JButton submit;
    private JPanel upper;
    private JPanel lower;
    private BorderLayout bl;
    JScrollPane jsp;
    Controller c;

    public ClientFrame() {
        bl = new BorderLayout();
        upper = new JPanel();
        lower = new JPanel();
        chatArea = new JTextArea("chat goes here", 20, 30);
        c = new Controller(this);
        chatArea.setEditable(false);
        chatArea.setLineWrap(true);
        type = new JTextField("type here", 20);
        jsp = new JScrollPane(chatArea);
        new SmartScroller(jsp);
        lower.add(type);
        submit = new JButton("send");
        submit.addActionListener(new Submit());
        type.addActionListener(new Submit());
        lower.add(submit);
        upper.add(jsp);
        this.setSize(400, 600);
        this.setLayout(bl);
        this.setTitle("MattChatt");
        this.add(upper, BorderLayout.NORTH);
        this.add(lower, BorderLayout.SOUTH);
        this.setVisible(true);
        this.setResizable(false);
        this.setDefaultCloseOperation(EXIT_ON_CLOSE);
    }

    public void updateGUI(String s) {
        chatArea.append("\n" + s);
    }

    private class Submit implements ActionListener {

        @Override
        public void actionPerformed(ActionEvent e) {

            if (type.getText().equals("")) {
                System.out.println("no text entered");
            } else {
                System.out.println("submitted");
                c.sendChat(type.getText());
                type.setText("");

            }
        }

    }

    }

Answer 1

您无法访问您创建的所有ServerThreads。 您需要做的是将它们全部组合到一个集合中，例如ArrayList。

或者更好的是HashMap，如果您想扩展您的应用程序以允许私人消息传递，您需要访问特定的ServerThread，而使用HashMap，您可以轻松做到这一点。

无论如何...当发送消息时，您应该循环您的集合并将消息发送到与每个ServerThread 关联的OutputStreams。