基于 SpringBoot RabbitMQ Redis MySQL 的社交平台私信系统设计与实现

目录

1. 系统架构概述
2. 数据库设计
3. 核心依赖配置
4. 核心实体类设计
5. RabbitMQ 配置与消息队列设计
6. Redis 缓存设计
7. 私信发送服务
8. 消息状态同步服务
9. RabbitMQ 消费者
10. WebSocket 实时通信
11. 历史消息查询服务
12. 控制器层
13. 系统特点
14. 高并发与集群优化
15. 安全与隐私设计
16. 运维与监控
17. 总结

1. 系统架构概述

系统主要由以下模块组成：

• 数据库 (MySQL)：存储用户信息、会话、私信消息
• 缓存 (Redis)：缓存会话列表、未读消息数、热点消息
• 消息队列 (RabbitMQ)：异步处理消息发送、状态同步、推送通知
• WebSocket 服务：实现实时消息推送
• 微服务拆分：消息发送服务、状态同步服务、历史消息查询服务

系统整体架构如下图所示（可在实施时绘制架构图）：

2. 数据库设计

-- 用户表 CREATE TABLE users ( id BIGINT PRIMARY KEY AUTO_INCREMENT, username VARCHAR(50) UNIQUE NOT NULL, nickname VARCHAR(100), avatar_url VARCHAR(255), created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ); -- 私信会话表 CREATE TABLE message_conversations ( id BIGINT PRIMARY KEY AUTO_INCREMENT, user1_id BIGINT NOT NULL, user2_id BIGINT NOT NULL, last_message_id BIGINT, last_message_time TIMESTAMP, unread_count1 INT DEFAULT 0, unread_count2 INT DEFAULT 0, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, INDEX idx_user1 (user1_id, last_message_time), INDEX idx_user2 (user2_id, last_message_time), UNIQUE KEY uk_users (user1_id, user2_id) ); -- 私信消息表 CREATE TABLE private_messages ( id BIGINT PRIMARY KEY AUTO_INCREMENT, conversation_id BIGINT NOT NULL, sender_id BIGINT NOT NULL, receiver_id BIGINT NOT NULL, content TEXT NOT NULL, message_type TINYINT DEFAULT 1, status TINYINT DEFAULT 1, send_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP, read_time TIMESTAMP NULL, INDEX idx_conversation (conversation_id, send_time), INDEX idx_sender (sender_id, send_time), INDEX idx_receiver (receiver_id, send_time) );

优化建议：

• 高并发可按月分表 private_messages_YYYYMM
• 会话表唯一性保持 user1Id < user2Id
• receiver_id + status 索引用于快速查询未读消息

3. 核心依赖配置

<dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-jpa</artifactId> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId>