当前位置：首页 > news >正文

Java基于局域网的聊天室系统设计与实现，附源码+论文

news 来源：原创 2025/6/13 11:46:53

一、系统架构与技术原理

基于局域网的Java聊天室采用客户端-服务器(C/S)架构，通过TCP/IP协议实现消息传输。系统包含以下核心组件：

服务器端：
- 维护在线用户列表
- 处理消息转发
- 管理用户连接生命周期
客户端：
- 建立与服务器的连接
- 发送/接收消息
- 提供用户界面交互
通信协议：
- 自定义消息格式：[消息类型]:[发送者]:[内容]
- 心跳机制保持连接活跃
- 异常处理与重连策略

二、核心代码实现

1. 服务器端实现

import java.io.*;
import java.net.*;
import java.util.*;
import java.util.concurrent.*;public class ChatServer {private static final int PORT = 9999;private static final Map<String, PrintWriter> clients = new ConcurrentHashMap<>();private static final ExecutorService threadPool = Executors.newCachedThreadPool();public static void main(String[] args) {try (ServerSocket serverSocket = new ServerSocket(PORT)) {System.out.println("服务器启动在端口: " + PORT);while (true) {Socket clientSocket = serverSocket.accept();threadPool.submit(new ClientHandler(clientSocket));}} catch (IOException e) {e.printStackTrace();} finally {threadPool.shutdown();}}// 客户端处理器private static class ClientHandler implements Runnable {private final Socket clientSocket;private String clientName;public ClientHandler(Socket socket) {this.clientSocket = socket;}@Overridepublic void run() {try (BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true)) {// 处理用户登录String loginMsg = in.readLine();if (loginMsg.startsWith("LOGIN:")) {clientName = loginMsg.substring(6);clients.put(clientName, out);broadcast("SYSTEM:" + clientName + " 加入了聊天室");broadcastUserList();}// 处理消息循环String inputLine;while ((inputLine = in.readLine()) != null) {if (inputLine.startsWith("CHAT:")) {String message = inputLine.substring(5);broadcast(clientName + ":" + message);} else if (inputLine.startsWith("PRIVATE:")) {String[] parts = inputLine.substring(8).split(":", 2);if (parts.length == 2) {String recipient = parts[0];String message = parts[1];sendPrivateMessage(clientName, recipient, message);}}}} catch (IOException e) {// 连接异常处理} finally {// 用户退出处理if (clientName != null) {clients.remove(clientName);broadcast("SYSTEM:" + clientName + " 离开了聊天室");broadcastUserList();}try {clientSocket.close();} catch (IOException e) {e.printStackTrace();}}}// 广播消息给所有客户端private void broadcast(String message) {clients.forEach((name, writer) -> {writer.println(message);});}// 发送用户列表更新private void broadcastUserList() {StringBuilder userList = new StringBuilder("USERLIST:");clients.keySet().forEach(name -> userList.append(name).append(","));broadcast(userList.toString());}// 发送私聊消息private void sendPrivateMessage(String sender, String recipient, String message) {PrintWriter recipientWriter = clients.get(recipient);if (recipientWriter != null) {recipientWriter.println("PRIVATE:" + sender + ":" + message);}}}
}

2. 客户端实现

import java.io.*;
import java.net.*;
import java.util.*;
import javax.swing.*;
import java.awt.*;
import java.awt.event.*;public class ChatClient extends JFrame {private static final String SERVER_IP = "127.0.0.1";private static final int PORT = 9999;private Socket socket;private PrintWriter out;private BufferedReader in;private String userName;private JTextArea chatArea;private JTextField messageField;private JList<String> userList;private DefaultListModel<String> listModel;public ChatClient(String userName) {this.userName = userName;initComponents();connectToServer();}private void initComponents() {setTitle("聊天室 - " + userName);setSize(800, 600);setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);// 创建聊天区域chatArea = new JTextArea();chatArea.setEditable(false);JScrollPane chatScrollPane = new JScrollPane(chatArea);// 创建用户列表listModel = new DefaultListModel<>();userList = new JList<>(listModel);JScrollPane userScrollPane = new JScrollPane(userList);userScrollPane.setPreferredSize(new Dimension(150, 0));// 创建消息输入框messageField = new JTextField();messageField.addActionListener(e -> sendMessage());// 创建发送按钮JButton sendButton = new JButton("发送");sendButton.addActionListener(e -> sendMessage());// 布局JPanel bottomPanel = new JPanel(new BorderLayout());bottomPanel.add(messageField, BorderLayout.CENTER);bottomPanel.add(sendButton, BorderLayout.EAST);JPanel mainPanel = new JPanel(new BorderLayout());mainPanel.add(chatScrollPane, BorderLayout.CENTER);mainPanel.add(userScrollPane, BorderLayout.EAST);mainPanel.add(bottomPanel, BorderLayout.SOUTH);add(mainPanel);// 双击用户发送私聊userList.addMouseListener(new MouseAdapter() {@Overridepublic void mouseClicked(MouseEvent e) {if (e.getClickCount() == 2) {String selectedUser = userList.getSelectedValue();if (selectedUser != null && !selectedUser.equals(userName)) {messageField.setText("/private " + selectedUser + " ");messageField.requestFocus();messageField.setCaretPosition(messageField.getText().length());}}}});// 窗口关闭时处理addWindowListener(new WindowAdapter() {@Overridepublic void windowClosing(WindowEvent e) {disconnect();}});}private void connectToServer() {try {socket = new Socket(SERVER_IP, PORT);out = new PrintWriter(socket.getOutputStream(), true);in = new BufferedReader(new InputStreamReader(socket.getInputStream()));// 发送登录信息out.println("LOGIN:" + userName);// 启动消息接收线程new Thread(this::receiveMessages).start();appendMessage("系统: 已连接到服务器");} catch (IOException e) {JOptionPane.showMessageDialog(this, "无法连接到服务器: " + e.getMessage(), "连接错误", JOptionPane.ERROR_MESSAGE);System.exit(1);}}private void receiveMessages() {try {String message;while ((message = in.readLine()) != null) {if (message.startsWith("SYSTEM:")) {appendMessage(message.substring(7));} else if (message.startsWith("PRIVATE:")) {String[] parts = message.substring(8).split(":", 2);if (parts.length == 2) {appendMessage("[私聊] " + parts[0] + ": " + parts[1]);}} else if (message.startsWith("USERLIST:")) {updateUserList(message.substring(9));} else {appendMessage(message);}}} catch (IOException e) {appendMessage("系统: 与服务器的连接已断开");} finally {disconnect();}}private void sendMessage() {String message = messageField.getText().trim();if (!message.isEmpty()) {if (message.startsWith("/private ")) {String[] parts = message.substring(8).split(" ", 2);if (parts.length == 2) {String recipient = parts[0];String privateMessage = parts[1];out.println("PRIVATE:" + recipient + ":" + privateMessage);appendMessage("[私聊给" + recipient + "] " + privateMessage);}} else {out.println("CHAT:" + message);}messageField.setText("");}}private void updateUserList(String userListStr) {listModel.clear();String[] users = userListStr.split(",");for (String user : users) {if (!user.isEmpty()) {listModel.addElement(user);}}}private void appendMessage(String message) {SwingUtilities.invokeLater(() -> {chatArea.append(message + "\n");chatArea.setCaretPosition(chatArea.getDocument().getLength());});}private void disconnect() {try {if (socket != null && !socket.isClosed()) {socket.close();}} catch (IOException e) {e.printStackTrace();}System.exit(0);}public static void main(String[] args) {SwingUtilities.invokeLater(() -> {String userName = JOptionPane.showInputDialog("请输入您的用户名:");if (userName != null && !userName.trim().isEmpty()) {new ChatClient(userName.trim()).setVisible(true);} else {JOptionPane.showMessageDialog(null, "用户名不能为空", "错误", JOptionPane.ERROR_MESSAGE);}});}
}

三、系统功能解析

用户管理：
- 服务器维护在线用户映射表（用户名→输出流）
- 客户端启动时需提供唯一用户名
- 实时广播用户上下线状态
消息处理：
- 公共消息：广播给所有在线用户
- 私聊消息：点对点加密传输（可扩展）
- 命令解析：支持/private等系统命令
界面交互：
- 聊天历史区域：显示所有消息
- 用户列表：支持双击发送私聊
- 消息输入框：支持回车发送

四、技术优化与扩展

多线程处理：

// 使用线程池优化服务器性能
private static final ExecutorService threadPool = new ThreadPoolExecutor(10,                     // 核心线程数100,                    // 最大线程数60L, TimeUnit.SECONDS,  // 空闲线程存活时间new LinkedBlockingQueue<>(1000), // 任务队列new ThreadPoolExecutor.CallerRunsPolicy() // 拒绝策略);

心跳机制实现：

// 客户端心跳发送线程
private void startHeartbeat() {new Thread(() -> {try {while (socket.isConnected()) {out.println("HEARTBEAT");Thread.sleep(30000); // 每30秒发送一次心跳}} catch (Exception e) {reconnect(); // 心跳失败时重连}}).start();
}

消息加密：

// 消息加密示例（使用AES）
private String encryptMessage(String message) {try {Cipher cipher = Cipher.getInstance("AES");SecretKeySpec keySpec = new SecretKeySpec("MySecretKey12345".getBytes(), "AES");cipher.init(Cipher.ENCRYPT_MODE, keySpec);byte[] encryptedBytes = cipher.doFinal(message.getBytes());return Base64.getEncoder().encodeToString(encryptedBytes);} catch (Exception e) {return message; // 加密失败返回原文}
}