java之Socket实现简易的聊天室程序

客户端程序：

package 聊天室;

import java.awt.BorderLayout;
import java.awt.TextArea;
import java.awt.TextField;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.net.SocketException;
import java.net.UnknownHostException;

import javax.swing.JFrame;

public class ChatClient extends JFrame{
    TextField tfText=new TextField();//发送文本框
    TextArea taContent=new TextArea();//聊天记录框
    Socket s=null;
    DataOutputStream dos=null;
    DataInputStream dis=null;
    private boolean bConnected=false;
    
    public static void main(String[] args) {
        new ChatClient().init();

    }
    
    //窗体显示
    public void init() {

        setBounds(400,300,300,300);
        add(tfText,BorderLayout.SOUTH);
        add(taContent,BorderLayout.NORTH);
        pack();//调整此窗口的大小，以适合其子组件的首选大小和布局
        addWindowListener(new WindowAdapter() {

            @Override
            public void windowClosing(WindowEvent e) {
                disconnect();
                System.exit(0);
            }
            
        });
        tfText.addActionListener(new TFListener());
        connect();
        new Thread(new RecvThread()).start();
        setVisible(true);
    }
    
    //连接服务器
    private void connect() {
        try {
            s=new Socket("192.168.56.1",10086);
            dos=new DataOutputStream(s.getOutputStream());
            dis=new DataInputStream(s.getInputStream());
System.out.println("connected！");
            bConnected=true;
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    //资源释放
    private void disconnect() {
        try {
            dos.close();
            s.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    //TextField的事件处理
    private class TFListener implements ActionListener{

        @Override
        public void actionPerformed(ActionEvent e) {
            String str=tfText.getText().trim();
            tfText.setText("");
            try {
                dos.writeUTF(str);
                dos.flush();
                
            } catch (IOException e1) {
                e1.printStackTrace();
            }
            
        }
        
    }
    
        //客户端接收其他客户端发送的信息
    private class RecvThread implements Runnable{

        @Override
        public void run() {
            try {
                while(bConnected) {
                    String str=dis.readUTF();
                    //System.out.println(str);
                    taContent.setText(taContent.getText()+str+'
');
                }
                
            }catch(SocketException e) {
                System.out.println("客户端被关闭了！");
            }catch(IOException e){
                e.printStackTrace();
            }
            
        }
        
    }
}
    

服务器程序：

package 聊天室;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.EOFException;
import java.io.IOException;
import java.net.BindException;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.util.ArrayList;
import java.util.List;


public class ChatServer {
    ServerSocket ss=null;
    private boolean started=false;//判断是否绑定服务器
    private boolean bConnected=false;//判断是否连接客户端
    List<Client> clientList=new ArrayList<>();
    
    public static void main(String[] args) {
        new ChatServer().start();

    }
    
    private void start() {
        try {
            //创建服务器端接收数据对象
            ss=new ServerSocket(10086);
            started=true;
        }catch(BindException e) {
            System.out.println("端口使用中....请关掉相关程序并重新运行服务器");
            System.exit(0);
        }catch(IOException e) {
            e.printStackTrace();
        }
            
        try {
            while(started) {//已经绑定到服务器，不断接受客户端的连接            
                Socket s=ss.accept();
                System.out.println("a client connected!");
                Client c=new Client(s);
                new Thread(c).start();        
                clientList.add(c);
            }    
        }catch(IOException e) {
            e.printStackTrace();            
        }finally {
            try {
                ss.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }                
    }
    
    //每一个线程负责一个客户端
    class Client implements Runnable{
        private Socket s=null;
        private DataInputStream dis=null;
        private DataOutputStream dos=null;

        public Client(Socket s) {
            this.s=s;
            try {
                dis=new DataInputStream(s.getInputStream());
                dos=new DataOutputStream(s.getOutputStream());
                bConnected=true;
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        @Override
        public void run() {
            try {
                while(bConnected) {//已经连上了客户端，开始读取客户端的数据到控制台
                    String str=dis.readUTF();
                    System.out.println(str);
                    //将其中一个客户端发送的数据发送至其他客户端
                    for(int i=0;i<clientList.size();i++) {
                        Client c=clientList.get(i);
                        c.send(str);
                    }
                }
            }catch(EOFException e) {
                System.out.println("Client close");        
            }catch(SocketException e) {
                System.out.println("a client quit!");
            }catch(IOException e) {
                e.printStackTrace();                    
            }finally {
                try {
                    if(s!=null) s.close();
                    if(dis!=null) dis.close();
                    if(dos!=null) dos.close();
                } catch (IOException e1) {
                    e1.printStackTrace();
                }
            }
            
        }
        
        //发送消息给其他客户端
        public void send(String str) {
            try {
                dos.writeUTF(str);//将其中一个客户端发送的数据写到服务器里
            } catch (IOException e) {
                clientList.remove(this);
                System.out.println("对方退出了。我从list里面去除了！");
                //e.printStackTrace();
            }
        }
        
    }
    
    

}

注意事项：要先启动服务器，再启动客户端

结果：