Java：JavaSocket编程开发多人聊天室[通俗易懂]

大家好，欢迎来到IT知识分享网。

实现内容

1. 用Java图形用户界面编写聊天室服务器端和客户端， 支持多个客户端连接到一个服务器。每个客户端能够输入账号。
2. 可以实现群聊（聊天记录显示在所有客户端界面）。
3. 完成好友列表在各个客户端上显示。
4. 可以实现私人聊天，用户可以选择某个其他用户，单独发送信息。
5. 服务器能够群发系统消息，能够强行让某些用户下线。
6. 客户端的上线下线要求能够在其他客户端上面实时刷新。

运行结果

部分代码

import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;
import java.util.*;
import java.text.*;
import javax.swing.*;

public class ClientChat extends JFrame { 
   
	private static final long serialVersionUID = 1L;
	
	
	private Socket socket ;                  //负责和服务器通信
	
	private JTextArea contentArea;           //群聊消息显示框
    private JTextArea sendArea;              //消息编辑区域
    private JTextArea friendsList;           //好友列表
    private String name;                     //用户名
    private JComboBox cmb;                   //发送对象下拉框
    
    public ClientChat(Socket socket,String name)  { 
   
    	
        this.socket = socket ;
        this.name  = name ;
        
        this.init();        //初始化聊天客户端
        this.setDefaultCloseOperation(WindowConstants.EXIT_ON_CLOSE);
        this.setVisible(true);
       
        //接下来启动单独线程，从服务器中读取数据
        ClientThread thread  = new ClientThread(socket,contentArea,cmb) ;
        thread.start();
        
    }
   
    public void init( )  { 
   
        this.setTitle("我的聊天室");
        this.setSize(500,500);
        int x = (int)Toolkit.getDefaultToolkit().getScreenSize().getWidth() ;
        int y = (int)Toolkit.getDefaultToolkit().getScreenSize().getHeight() ;
       
        this.setLocation( (x-this.getWidth() )/2, ( y-this.getHeight() )/2 );
        this.setResizable(false);
       
        
        contentArea = new JTextArea();
        contentArea.setLineWrap(true);  //换行方法
        JScrollPane logPanel = new JScrollPane(contentArea, JScrollPane.VERTICAL_SCROLLBAR_AS_NEEDED, JScrollPane.HORIZONTAL_SCROLLBAR_NEVER);
        contentArea.append("----------------------------消息记录--------------------------------------\n");
        
        sendArea = new JTextArea();
        sendArea.setLineWrap(true);    //控制每行显示长度最大不超过界面长度
        JScrollPane sendPanel = new JScrollPane(sendArea, JScrollPane.VERTICAL_SCROLLBAR_AS_NEEDED, JScrollPane.HORIZONTAL_SCROLLBAR_NEVER);
        
        friendsList = new JTextArea();
        friendsList.setLineWrap(true);
        JScrollPane friendPanel2 = new JScrollPane(friendsList, JScrollPane.VERTICAL_SCROLLBAR_AS_NEEDED, JScrollPane.HORIZONTAL_SCROLLBAR_NEVER);
        friendsList.append("------------好友列表-------------\n");
        
        JSplitPane splitpane1 = new JSplitPane(JSplitPane.VERTICAL_SPLIT,logPanel,sendPanel) ;
        splitpane1.setDividerLocation(290);
        JSplitPane splitpane2 = new JSplitPane(JSplitPane.HORIZONTAL_SPLIT,splitpane1,friendPanel2) ;
        splitpane2.setDividerLocation(320);
        this.add(splitpane2,BorderLayout.CENTER);
       
        //按钮面板
        JPanel bPanel  = new JPanel() ;
        bPanel.setLayout(new FlowLayout(FlowLayout.RIGHT)) ;
        this.add(bPanel,BorderLayout.SOUTH) ;
        
        JLabel toNamelabel=new JLabel("发送对象：");
        cmb=new JComboBox(); 
        cmb.addItem("所有人");
        bPanel.add(toNamelabel);
        bPanel.add(cmb);
       
        JLabel namelabel = new JLabel("用户名： "+this.name+" ") ;
        bPanel.add(namelabel) ;
       
        JButton closeButton = new JButton("退 出") ;
        closeButton.addActionListener( new ActionListener() { 
     //退出按钮监听
            public void actionPerformed(ActionEvent e)  { 
   
            	
            	String sendStr = name + "!!!!" ;
                PrintWriter out = null ;
                try  { 
   
                    out = new PrintWriter(new OutputStreamWriter(socket.getOutputStream() ) ) ;
                    out.println(sendStr) ;
                    out.flush();
                }catch(Exception ex)  { 
   
                    ex.printStackTrace();
                }
                
            	exit();
            }
        });
        bPanel.add(closeButton) ;
       
        JButton sendButton = new JButton("发 送") ;
        sendButton.addActionListener(new ActionListener() { 
     //发送按钮监听
            public void actionPerformed(ActionEvent e) { 
   
                String str = sendArea.getText();  //获取发送的消息
                SimpleDateFormat formater = new SimpleDateFormat("HH:mm:ss") ;  //获取当前时间
                String time  = formater.format(new Date() ) ;
                String toName = (String) cmb.getSelectedItem();  //获取发送对象
                
                //发送给服务器的消息格式为 时间 本客户端用户名 对 发送对象 说： 消息 <本客户端用户名>(发送对象)
                String sendStr = time + " " + name + " 对 " + toName +" 说: "+ str + "<" + name +">" + "(" + toName + ")";
                PrintWriter out = null ;
                try  { 
   
                    out = new PrintWriter(new OutputStreamWriter(socket.getOutputStream() ) ) ;  //发送给服务器
                    out.println(sendStr) ;
                    out.flush();
                }catch(Exception ex)  { 
   
                    ex.printStackTrace();
                }
                sendArea.setText("");
            }
        });
        bPanel.add(sendButton) ;   
            
    }
    
	public void exit() { 
      //退出
		this.dispose();
		System.exit(0);
	}
	

//客户端与服务器端通信的线程类
class ClientThread extends Thread  { 
   
    private Socket socket ;
    private JTextArea contentArea ;
    private JComboBox cmb;
   
    public ClientThread(Socket socket, JTextArea  conteArea , JComboBox cmb) { 
   
        this.socket = socket ;
        this.contentArea = conteArea ;
        this.cmb = cmb;
    }
   
    public void run() { 
   
        BufferedReader br = null ;
        try  { 
   
            br = new BufferedReader(new InputStreamReader(socket.getInputStream())) ;
            String str = null ;
            while( (str = br.readLine()) != null) { 
   
            	if(str.endsWith("上线了 ]")) { 
     //新用户上线，加入列表中
            		if(!str.substring(3, str.length()-5).equals(name)) { 
   
            			friendsList.append(str.substring(3, str.length()-5));
            			friendsList.append("\n");
            			cmb.addItem(str.substring(3, str.length()-5));
            		}
            		contentArea.append(str);
                	contentArea.append("\n");
            	}
            	else if(str.endsWith("下线了 ]")) { 
     //用户下线
            		contentArea.append(str);
                    contentArea.append("\n");
                    	
                    cmb.removeItem(str.substring(3, str.length()-5));
            	} 
            	else if(str.endsWith("被强制下线 ]")) { 
     //服务器强制下线消息
            		if(str.substring(3, str.length()-7).equals(name)) { 
   
            			exit();
            		}
            		else { 
   
            			contentArea.append(str);
                    	contentArea.append("\n");
                    	
                    	cmb.removeItem(str.substring(3, str.length()-7));
            		}
            	}
            	else if(str.endsWith("###")) { 
    //将在本客户端连接之前就已连接的客户端用户名添加到列表中
            		friendsList.append(str.substring(0, str.length()-3));
            		friendsList.append("\n");
            		cmb.addItem(str.substring(0, str.length()-3));
            	}
            	else if(str.substring(0,6).equals(" [ 通知：")) { 
     //服务器发送的系统通知
            		contentArea.append(str);
                    contentArea.append("\n");
            	}
            	else if(splitData(str,"<",">").equals(name)){ 
    //自己发送的消息
            		contentArea.append(str.substring(0, str.lastIndexOf("<")));
                	contentArea.append("\n");
            	}
            	else if(splitData(str,"(",")").equals(name)){ 
    //别人私聊给自己的消息
            		contentArea.append(str.substring(0, str.lastIndexOf("<")));
                	contentArea.append("\n");
            	}
            	else if(splitData(str,"(",")").equals("所有人")) { 
    //对所有人发送的消息
            		contentArea.append(str.substring(0, str.lastIndexOf("<")));
                	contentArea.append("\n");
            	}
            }
        }catch(Exception ex) { 
   
            ex.printStackTrace();
        }finally { 
   	
            if(br != null) { 
   
                try { 
   
                    br.close () ;
                }catch(IOException e) { 
   
                	e.printStackTrace();
                }
            }
        }
    }
    
    public String splitData(String str, String strStart, String strEnd) { 
     //获取字符串中某两个字符间的字符串
    	String tempStr;
    	tempStr = str.substring(str.indexOf(strStart) + 1, str.lastIndexOf(strEnd));
    	return tempStr;
    }
	}
}

完整代码

用JavaSocket编程开发多人聊天室（群聊、私聊等）