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

系统架构概述
数据库设计
核心依赖配置
核心实体类设计
RabbitMQ 配置与消息队列设计
Redis 缓存设计
私信发送服务
消息状态同步服务
RabbitMQ 消费者
WebSocket 实时通信
历史消息查询服务
控制器层
系统特点
高并发与集群优化
安全与隐私设计
运维与监控
总结

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>