Java：JavaSocket编程开发多人聊天室「建议收藏」

大家好，又见面了，我是你们的朋友全栈君。

实现内容

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编程开发多人聊天室（群聊、私聊等）