基于 SpringBoot + WebSocket 的即时通讯系统源码解析宠友IM

互联网产品形态中，“内容 + 社交”已经成为社区类APP的主流发展方向。无论是偏种草分享，还是兴趣圈层沉淀，用户之间的即时沟通能力都在不断被放大。

从技术实现角度来看，一套成熟的IM即时通讯系统，往往不仅仅是“聊天窗口”的实现，而是涵盖消息、关系链、实时通信、数据同步等多个核心模块。本文将结合实际工程经验，以“宠友IM”为例，对一套支持多端互通的即时通讯系统进行完整拆解，适合研发人员与技术选型决策参考。

UI效果图和功能演示

一、系统整体架构设计

在技术选型上，宠友IM采用的是典型的分层架构：

客户端：

UniApp（覆盖 Android / iOS / 小程序 / H5 / PC）
Vue2 + SCSS 进行界面构建

服务端：

SpringBoot 提供业务接口
MyBatis-Plus 简化数据访问
Redis 处理缓存与高频数据
MySQL 进行持久化存储

通信层：

WebSocket 长连接实现实时消息推送

这种架构的核心优势在于：

一套代码支持五端运行
数据完全互通
降低维护成本与开发周期

二、消息模块设计（核心能力）

IM系统中最重要的模块就是“消息”。

1. 消息结构统一设计

为了支持多种消息类型（文本、图片、语音等），通常会进行结构抽象：

public class MessageEntity { private String msgId; private Long fromId; private Long toId; private String msgType; private String content; private Long sendTime; }

通过 msgType 区分不同类型，使系统具备良好的扩展能力。

2. 多消息类型支持

宠友IM支持的消息类型包括：

文本消息
图片与短视频
语音消息
文件传输
表情与自定义表情
名片分享

这种多样化设计可以满足社区产品中的复杂表达需求。

基于 SpringBoot + WebSocket 的即时通讯系统源码解析宠友IM

3. 消息状态控制

常见状态包括：

已发送
已送达
已读

实现方式通常为：

客户端上报已读状态
服务端同步状态给发送方

同时还支持：

消息撤回
消息删除
文本复制

三、会话与未读消息优化

在IM系统中，会话列表是访问频率最高的模块之一。

1. 会话能力

主要包括：

最近消息展示
未读数量提示
会话置顶
删除会话

2. Redis未读数设计

为了避免频繁访问数据库，未读数通常放在Redis中：

String key = "im:unread:" + userId + ":" + sessionId; redisTemplate.opsForValue().increment(key);

这种方式在高并发情况下依然能够保持较好的性能。

四、WebSocket 实时通信实现

IM系统的实时性依赖于长连接技术。

1. WebSocket优势

服务端主动推送
减少HTTP请求开销
延迟更低

2. 简单实现示例

@ServerEndpoint("/ws/{userId}") public class WsServer { private static ConcurrentHashMap sessionMap = new ConcurrentHashMap<>(); @OnOpen public void onOpen(Session session, @PathParam("userId") Long userId) { sessionMap.put(userId, session); } }

通过维护连接映射关系，可以实现点对点消息推送。