Java多人聊天室

import javax.swing.*;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.io.*;
import java.net.Socket;
import java.time.DateTimeException;

class CilThr extends Thread{
    Socket socket;
    JTextArea ta;
    public CilThr(Socket socket,JTextArea ta){//获取客户端的socket和文本区域
        this.socket=socket;
        this.ta=ta;

    }
    @Override
    public void run() {
        while (true){//一直在接收中
            try {
                InputStream inputStream=socket.getInputStream();//字节输入流
                DataInputStream din=new DataInputStream(inputStream);//数据输入流
                String text=din.readUTF();//获取输入的数据
                ta.append(text);//添加到文本区域

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

public class kefuduang {
    JFrame jf;
    JLabel jLabel;
    JTextField tf1,tf2;
    JButton start,send;
    JTextArea ta;

    Socket socket=new Socket("localhost",9000);//连接服务器需要的端口号9000

    public kefuduang() throws IOException {
        jf=new JFrame("客户端");
        jLabel=new JLabel("用户名");
        tf1=new JTextField(15);
        tf2=new JTextField(35);
        start=new JButton("连接");
        send=new JButton("发送");
        ta=new JTextArea(40,40);
        init();//调用方法实现界面
    }

    public void init(){
        JPanel jp1=new JPanel();
        JPanel jp2=new JPanel();
        JPanel jp3=new JPanel();

        ta.setEditable(false);//让文本框不能输入，只是显示出来
        send.setEnabled(false);//设置发送按钮，不能按，因为还没有连接上服务器

        jp1.add(jLabel);
        jp1.add(tf1);
        jp1.add(start);

        jp2.add(ta);
        jp2.add(new JScrollPane(ta,JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,JScrollPane.HORIZONTAL_SCROLLBAR_ALWAYS));//设置文本区域的滚动条

        jp3.add(tf2);
        jp3.add(send);

        jf.add(jp1, BorderLayout.NORTH);//设置布局
        jf.add(jp2,BorderLayout.CENTER);
        jf.add(jp3,BorderLayout.SOUTH);

        jf.setVisible(true);
        jf.setLocationRelativeTo(null);
        jf.setSize(500,500);
        jf.setDefaultCloseOperation(JFrame.DISPOSE_ON_CLOSE);
        
        handler();//添加按钮监听
        new CilThr(socket,ta).start();//接收其他客户端发来的信息

    }

    private void handler() {
        start.addActionListener(new AbstractAction() {//连接
            @Override
            public void actionPerformed(ActionEvent e) {
                //发起连接
                String user= tf1.getText();//获取用户名
                System.out.println(user+"发起连接请求");

                try {
                    OutputStream outputStream=socket.getOutputStream();//字节输出流
                    DataOutputStream dout=new DataOutputStream(outputStream);//数据输出流
                    dout.writeUTF(user+" 加入聊天");//.writeUTF里的内容输出到文本里
                    ta.append(user+" 加入聊天"+"\n");//添加到显示的文本区域
                    send.setEnabled(true);//再设置“发送”按钮可以被点击

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


                //接收
            }
        });

        send.addActionListener(new AbstractAction() {//“发送”按钮
            @Override
            public void actionPerformed(ActionEvent e) {
                try {
                    OutputStream outputStream=socket.getOutputStream();//字节输出流
                    DataOutputStream dout=new DataOutputStream(outputStream);//数据输出流

                    String text=tf2.getText();//获取待发送文本框的内容

                    dout.writeUTF(text);//输出到文件

                    ta.append("我说： "+text+"\n");//添加到显示的文本区域
                    tf2.setText("");//设置下一次需要输入文本框的内容为空
                } catch (IOException ex) {
                    ex.printStackTrace();
                }

            }
        });
    }


    public static void main(String[] args) throws IOException {
        new kefuduang(); //调用构造方法 出界面

    }
}

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.Date;

class ServerThread extends Thread{

    Socket socket;
    ArrayList<MySocket> sockets;

    public ServerThread(Socket socket, ArrayList<MySocket> sockets) {//获取主函数传过来的值
        this.socket=socket;
        this.sockets=sockets;
    }

    @Override
    public void run() {
        while(true){//接收一个用户的多次发送信息
            try {
                InputStream inputStream=socket.getInputStream();//字节输入流
                DataInputStream din=new DataInputStream(inputStream);//数据输入流
                String text=din.readUTF();//获取输入的信息

                String user="";//设置当前用户名为空，以防下一次赋值
                for(int i=0;i<sockets.size();i++){//遍历sockets集合
                    if(socket==sockets.get(i).getSocket()){//判断当前发放信息的用户
                        user=sockets.get(i).getUser();//获取当前发放信息的用户名
                    }
                }

                for(int i=0;i<sockets.size();i++){
                    Socket sc=sockets.get(i).getSocket();//获取每个用户的socket
                    if(sc!=socket){//判断 不需要自己发信息给自己
                        OutputStream outputStream=sc.getOutputStream();//字节输出流
                        DataOutputStream dout=new DataOutputStream(outputStream);//数据输出流
                        dout.writeUTF(user+":"+text+"\n");//把当前客户端的名字和信息发送给除自己以外的其他客户端
                    }
                }
            } catch (IOException e) {
                e.printStackTrace();
            }

        }
    }
}

class MySocket{//把每一台客户端的socket 和用户名联系起来
   private Socket socket;//客户端的socket
   private String user;//客户名

    public MySocket(Socket socket, String user) {
        this.socket=socket;
        this.user=user;
    }

    public Socket getSocket() {
        return socket;
    }

    public void setSocket(Socket socket) {
        this.socket = socket;
    }

    public String getUser() {
        return user;
    }

    public void setUser(String user) {
        this.user = user;
    }
}

public class guanbo {
    static ArrayList<MySocket> sockets=new ArrayList<MySocket>();//定义一个静态的集合里面的类型是class类 MySocket

    public static void main(String[] args) throws IOException {
        ServerSocket ss=new ServerSocket(9000);//服务器的端口号为9000
        System.out.println("服务器准备就绪");

        while(true){//收集每一次客户端的连接
            Socket socket=ss.accept();
            System.out.println("响应请求");

            //每响应一个客户端就产生一个myscokcet
            InputStream inputStream=socket.getInputStream();//字节输入流
            DataInputStream din=new DataInputStream(inputStream);//数据输入流
            String user=din.readUTF();//获取客户端的名称 
            user=user.substring(0,user.length()-4);//把客户端的名字获取，删除“加入聊天”
            MySocket ms=new MySocket(socket,user);//把用户的名字和socket放到MyScket里

            sockets.add(ms);//再添加到集合里，这样就可以保存每一个客户端的名字和socket

            new ServerThread(socket,sockets).start();//启动线程 把当前客户端的socket和加入到服务器的所有socket传到线程通过构造器，并开启线程run方法
        }
    }
}