java小课设：利用MySQL做一个聊天室

bro是个懒狗，耗时一个晚上，只写了一些基础功能，其他的可以根据必要自己添加

实现思绪：在MySQL数据库中设置一个message表，用来存储聊天信息，聊天界面输入的内容写入message表，用户程序每秒从MySQL中获取一次聊天记录，并加载进入自己的页面，实现聊天室。

食用方法：
ChatServer类中的数据库信息修改为自己的数据库
从ChatApplication类启动
复制粘贴主类中的user语句，可以添加多个用户窗口进行测试。

1. new User(server);

复制代码

用户名用来作为聊天室中的昵称

下方的输入框里输入信息，回车键发送，实现相互聊天。

下面是源代码（附表明）

pom依赖

1.         <dependency>
2.             <groupId>commons-logging</groupId>
3.             <artifactId>commons-logging</artifactId>
4.             <version>1.1.1</version>
5.         </dependency>
6.         
7.         <dependency>
8.             <groupId>mysql</groupId>
9.             <artifactId>mysql-connector-java</artifactId>
10.             <version>8.0.32</version>
11.         </dependency>
12.         
13.         
14.         <dependency>
15.             <groupId>net.sf.json-lib</groupId>
16.             <artifactId>json-lib</artifactId>
17.             <version>2.4</version>
18.             <classifier>jdk15</classifier>
19.         </dependency>

复制代码

ChatApplication

1. import javax.swing.*;
3. // 定义一个名为ChatApplication的公共类，作为聊天应用程序的入口
4. public class ChatApplication {
5.     // main方法是Java程序的入口点
6.     public static void main(String[] args) {
7.         // 使用SwingUtilities.invokeLater确保GUI创建和更新在事件调度线程上进行
8.         SwingUtilities.invokeLater(() -> {
9.             // 创建ChatServer实例，用于管理聊天服务器和数据库交互
10.             ChatServer server = new ChatServer();
11.             // 创建三个User实例，模拟三个用户连接到聊天服务器
12.             new User(server);
13.             new User(server);
14.             new User(server);
15.         });
16.     }
17. }

复制代码

ChatServer

1. import java.sql.*;
3. // ChatServer类，用于管理聊天服务器的功能，包括数据库连接、消息存储和检索
4. public class ChatServer {
5.     // 数据库连接对象
6.     private Connection connection;
8.     // ChatServer的构造函数，初始化数据库连接并准备聊天环境
9.     public ChatServer() {
10.         try {
11.             // 初始化数据库连接
12.             // 设置数据库URL、用户名和密码
13.             String url = "jdbc:mysql://localhost:3306/atguigudb"; // 数据库URL
14.             String user = "root"; // 数据库用户名
15.             String password = "123456"; // 数据库密码
16.             // 获取数据库连接
17.             connection = DriverManager.getConnection(url, user, password);
19.             // 创建消息表，如果表不存在则创建
20.             createMessagesTable();
21.             // 可选操作：清空聊天记录（根据需求决定是否执行）
22.             clearChatHistory();
23.         } catch (Exception e) {
24.             // 打印异常堆栈信息
25.             e.printStackTrace();
26.         }
27.     }
29.     // 创建消息表的方法
30.     private void createMessagesTable() {
31.         // SQL语句：如果消息表不存在，则创建它
32.         String createTableSQL = "CREATE TABLE IF NOT EXISTS messages ("
33.                 + "id INT AUTO_INCREMENT PRIMARY KEY, " // 自增主键
34.                 + "sender VARCHAR(255) NOT NULL, " // 发送者
35.                 + "content TEXT NOT NULL, " // 消息内容
36.                 + "timestamp TIMESTAMP DEFAULT CURRENT_TIMESTAMP" // 时间戳，默认为当前时间
37.                 + ")";
38.         try (Statement stmt = connection.createStatement()) {
39.             // 执行SQL语句
40.             stmt.execute(createTableSQL);
41.         } catch (Exception e) {
42.             // 打印异常堆栈信息
43.             e.printStackTrace();
44.         }
45.     }
47.     // 清空聊天记录的方法（可选）
48.     private void clearChatHistory() {
49.         try (PreparedStatement ps = connection.prepareStatement("DELETE FROM messages")) {
50.             // 执行删除操作，清空messages表
51.             ps.executeUpdate();
52.         } catch (Exception e) {
53.             // 打印异常堆栈信息
54.             e.printStackTrace();
55.         }
56.     }
58.     // 保存聊天消息的方法
59.     public void saveMessage(String sender, String message) {
60.         try (PreparedStatement ps = connection.prepareStatement("INSERT INTO messages (sender,content) VALUES (?, ?)")) {
61.             // 设置SQL语句中的参数值
62.             ps.setString(1, sender);
63.             ps.setString(2, message);
64.             // 执行插入操作
65.             ps.executeUpdate();
66.         } catch (Exception e) {
67.             // 打印异常堆栈信息
68.             e.printStackTrace();
69.         }
70.     }
72.     // 获取所有聊天消息的方法
73.     public String getAllMessages() {
74.         StringBuilder chatHistory = new StringBuilder();
75.         try (PreparedStatement ps = connection.prepareStatement(
76.                 "SELECT sender, content FROM messages ORDER BY timestamp ASC")) {
77.             // 执行查询操作
78.             ResultSet rs = ps.executeQuery();
79.             // 遍历结果集，构建聊天历史字符串
80.             while (rs.next()) {
81.                 String sender = rs.getString("sender");
82.                 String content = rs.getString("content");
83.                 chatHistory.append(sender).append(": ").append(content).append("\n");
84.             }
85.         } catch (Exception e) {
86.             // 打印异常堆栈信息
87.             e.printStackTrace();
88.         }
89.         return chatHistory.toString(); // 返回聊天历史字符串
90.     }
91. }

复制代码

User

1. import javax.swing.*;
2. import java.awt.*;
4. // User类，用于管理用户登录界面和启动聊天客户端
5. public class User {
6.     private ChatServer server;
8.     // User的构造函数，接收ChatServer实例并启动用户登录界面
9.     public User(ChatServer server) {
10.         this.server = server;
11.         loginUser(); // 只启动一个用户的登录窗口，用于演示
12.     }
14.     // 启动用户登录界面的方法
15.     public void loginUser() {
16.         JFrame loginFrame = new JFrame("请输入用户名");
17.         JTextField usernameField = new JTextField(15);
18.         JButton loginButton = new JButton("登录");
20.         loginFrame.setLayout(new FlowLayout());
21.         loginFrame.add(new JLabel("用户名:"));
22.         loginFrame.add(usernameField);
23.         loginFrame.add(loginButton);
25.         loginFrame.setSize(400, 200);
26.         loginFrame.setLocationRelativeTo(null);
27.         loginFrame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
28.         loginFrame.setVisible(true);
30.         // 为登录按钮添加事件监听器
31.         loginButton.addActionListener(e -> {
32.             String username = usernameField.getText().trim();
33.             if (!username.isEmpty()) {
34.                 loginFrame.dispose();
35.                 new ChatClient(username, server); // 启动聊天客户端
36.             } else {
37.                 JOptionPane.showMessageDialog(loginFrame, "请输入用户名", "错误", JOptionPane.ERROR_MESSAGE);
38.             }
39.         });
40.     }
41. }

复制代码

ChatClient

1. import javax.swing.*;
2. import java.awt.*;
4. // ChatClient类，用于管理聊天客户端的界面和功能
5. public class ChatClient {
6.     private JFrame frame;
7.     private JTextArea chatArea;
8.     private JTextField inputField;
10.     private ChatServer server;
11.     private String username;
13.     // ChatClient的构造函数，接收用户名和ChatServer实例并初始化聊天客户端
14.     public ChatClient(String username, ChatServer server) {
15.         this.server = server;
16.         this.username = username;
18.         frame = new JFrame(username + " - 聊天室");
19.         frame.setSize(600, 400);
20.         frame.setLocationRelativeTo(null);
22.         chatArea = new JTextArea();
23.         chatArea.setFont(new Font("Noto Sans CJK", Font.PLAIN, 16));
24.         chatArea.setEditable(false); // 禁止编辑聊天区域
25.         inputField = new JTextField();
26.         inputField.setFont(new Font("Noto Sans CJK", Font.PLAIN, 16));
28.         frame.setLayout(new BorderLayout());
29.         frame.add(new JScrollPane(chatArea), BorderLayout.CENTER);
30.         frame.add(inputField, BorderLayout.SOUTH);
32.         loadChatHistory(); // 加载聊天历史
34.         // 为输入框添加事件监听器，用于发送消息
35.         inputField.addActionListener(e -> sendMessage());
37.         // 启动一个线程，定期加载聊天历史以更新聊天区域
38.         new Thread(() -> {
39.             while (true) {
40.                 try {
41.                     Thread.sleep(1000); // 每秒更新一次
42.                     loadChatHistory();
43.                 } catch (InterruptedException ex) {
44.                     ex.printStackTrace();
45.                 }
46.             }
47.         }).start();
49.         frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
50.         frame.setVisible(true);
51.     }
53.     // 发送消息的方法
54.     private void sendMessage() {
55.         String message = inputField.getText();
56.         if (!message.trim().isEmpty()) {
57.             server.saveMessage(username, message); // 保存消息到服务器
58.             inputField.setText(""); // 清空输入框
59.         }
60.     }
62.     // 加载聊天历史的方法
63.     private void loadChatHistory() {
64.         String chatHistory = server.getAllMessages(); // 从服务器获取聊天历史
65.         chatArea.setText(chatHistory); // 设置聊天区域的内容
66.         chatArea.setCaretPosition(chatArea.getDocument().getLength()); // 将光标移动到文本末尾
67.     }
68. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。