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

Posted 2023-02-26

【中文标题】多客户端聊天程序，向所有客户端广播聊天？

【英文标题】：Multi-client chat program, broadcasting chat to all clients?

【发布时间】：2015-07-03 20:23:38

【问题描述】：

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

服务器：

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("");

            
        

    

    

【问题讨论】：

您需要将ServerThread 实例存储在某种数组/映射/列表中。然后，当服务器接收到来自客户端的消息时，循环遍历这些值（或选择一个特定的人）并使用这些 ServerThread 实例的输出流发送它。我有一个示例here（转到底部显示 EDIT）

谢谢你的回答，我会更详细地看看这个。

如果您在理解上有任何问题，请告诉我

@VinceEmigh，你为什么不把它（和代码的副本）放到一个答案中？

@VinceEmigh 我试图实现这一点，但我的客户端是否必须是多线程的（总是监听？）

【参考方案1】：

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

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

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