IM-Server 是一个基于 Spring Boot 3 + Spring Cloud Alibaba 构建的高性能、高可用的即时通讯服务端系统。本系统采用微服务架构设计，支持大规模用户并发连接，提供完整的即时通讯解决方案，包括消息推送、音视频通话、文件传输等核心功能。

• Java 21: 利用最新的Java特性，提供卓越的性能和安全性
• Spring Boot 3.2.0: 原生支持JDK 21，优化容器化部署
• Spring Cloud Alibaba: 完整的微服务治理解决方案
• 微服务架构: 模块化设计，支持独立部署和扩展
• 高并发支持: 基于WebSocket的长连接管理，支持亿万级并发

• 即时消息: 支持文本、图片、语音、视频、文件等多种消息类型
• 群组聊天: 完整的群组管理，支持群聊头像自动生成
• 音视频通话: WebRTC + SRS 技术，支持一对一和群组通话
• 消息推送: 实时消息推送，支持离线消息存储
• 文件传输: 基于MinIO的文件存储和管理

• 身份认证: JWT Token 认证机制
• 密码加密: RSA 非对称加密，确保传输安全
• 权限控制: 细粒度的功能权限管理
• 数据安全: 敏感数据加密存储

• 高可用性: 服务注册发现、负载均衡、熔断降级
• 可扩展性: 水平扩展，支持动态扩容
• 监控告警: 集成Sentinel，实时监控系统状态
• 配置管理: 动态配置，支持热更新

功能: 系统入口，负责请求路由、负载均衡、限流熔断

• 集成Sentinel实现网关限流和负载均衡
• 通过Nacos实现服务注册与发现
• 根据Redis中的用户信息，定向转发长连接请求

功能: 用户身份验证和权限管理

• 用户登录、注册、令牌生成和验证
• 提供RSA公钥，用于登录时密码加密
• 手机短信验证码服务

功能: WebSocket长连接管理和消息推送

• 管理客户端长连接，支持心跳机制
• 通过RabbitMQ接收消息并推送给用户
• 支持多实例部署，自动负载均衡

功能: 核心业务逻辑处理

• 消息发送、接收、存储和查询
• 群组管理、文件上传、群聊头像生成
• 消息分发到对应的im-connect服务

用户发送消息流程:
1. 客户端 → im-gateway → im-server
2. im-server 处理业务逻辑
3. im-server → RabbitMQ → im-connect
4. im-connect → 用户长连接 → 客户端

长连接管理流程:
1. 客户端通过im-gateway建立WebSocket连接
2. im-connect 注册用户信息和机器码到Redis
3. 定期心跳维持连接状态
4. 连接断开时清理Redis中的相关信息

客户端 → im-gateway → im-server → RabbitMQ → im-connect → 客户端

1. 构造消息 DTO（含 messageId — 全局唯一，建议 Snowflake 或 UUID；messageTempId 仅客户端使用）。
2. 持久化消息 + 写 outbox（同一事务）：
   • 将消息写入消息表（im_private_message/im_group_message），并在 outbox 表插入一条记录（outbox 保存 messageId/payload/targetBroker/状态）。
3. 提交事务（数据库事务提交成功即代表消息被可靠保存）。
4. 尝试发送到 RabbitMQ（read from outbox 或者立即 publish）：
   • 使用 Publisher Confirms（channel.confirmSelect()）和 mandatory 标志，确保 broker 接收（且消息标记为持久化）。
   • 若 publish 返回 confirm（ack），将 outbox 状态标为 SENT_TO_BROKER。
   • 若 publish 失败或无确认，保持 outbox 状态为 PENDING，后台任务会重试（见下）。
5. 后台补偿任务：周期性扫描 outbox 状态为 PENDING/FAILED 的记录，重试 publish，或人工介入。

• 交换机/队列都设置为 durable
• 发布消息时设置 persistent=true
• 使用 publisher confirms（比事务更轻量且推荐）
• 考虑使用 quorum queues 或 高可用镜像/cluster 来避免单节点丢失
• 设置 dead-letter-exchange（DLX）用于无法投递/多次重试的消息

1. 消费到消息后，先 ack RabbitMQ（或按你设计先处理再 ack，注意需要保证不丢失）。常见做法：
   • 先把消息持久化（如果需要），然后 ack；或
   • 使用 manual ack：处理成功后 ack，处理失败 nack/reject（可重入或进 DLX）
2. 幂等处理：在投递前查询是否已处理（查 messageId 的 delivery 表或 status 字段）；若已投递则忽略
3. 路由到客户端：找到用户对应的 WebSocket 连接（从 Redis 注册表），将消息发送到客户端
4. 等待客户端 ACK（可选但强烈建议）：
   • 客户端收到后返回 DELIVERY_ACK(messageId) 给 im-connect
   • im-connect 更新 DB（或通过 RPC/HTTP 回调 im-server）把消息状态标为 DELIVERED
   • 若客户端未 ACK，im-connect 可重试若干次后将状态设为 UNDELIVERED 并进入重试策略/告警

• 客户端在接收消息后应回送 ACK（并持久保存消息、更新 UI），并对重复消息做去重（通过 messageId）

• Java 21: 运行时环境
• Spring Boot 3.2.0: 应用框架
• Spring Cloud Alibaba 2023.0.0.0-RC1: 微服务框架
• Spring WebFlux: 响应式Web框架
• MyBatis Plus: 数据持久层框架
• Netty: 服务端长连接网络框架

• Nacos: 服务注册发现、配置管理
• Redis: 缓存、会话管理
• RabbitMQ: 消息队列、异步通信
• MinIO: 对象存储、文件管理
• SRS: 流媒体服务、WebRTC支持

• Docker: 容器化部署
• Nginx: 反向代理、负载均衡
• JDK 21: Java运行环境

• JDK: 21.0.0+
• Docker: 20.10.0+
• Docker Compose: 2.0.0+
• 操作系统: Linux/Windows/macOS

注意: 建议使用Linux环境部署，以获得最佳性能表现

# 启动 Redis
docker run --name redis -p 6379:6379 -v /root/redis/conf/redis.conf:/usr/local/etc/redis/redis.conf -d redis --appendonly yes

# 启动 Nacos
docker run -itd --name nacos --env PREFER_HOST_MODE=hostname --env MODE=standalone --env NACOS_AUTH_IDENTITY_KEY=serverIdentity --env NACOS_AUTH_IDENTITY_VALUE=security --env NACOS_AUTH_TOKEN=SecretKey012345678901234567890123456789012345678901234567890123456789 -p 8848:8848 -p 9848:9848 -p 9849:9849 nacos/nacos-server:v2.2.1

# 启动 RabbitMQ
docker run -d --hostname my-rabbit --name rabbit -p 15672:15672 -p 5671-5672:5671-5672 rabbitmq
docker exec -it rabbit /bin/bash
rabbitmq-plugins enable rabbitmq_management

# 启动 MinIO
docker run -p 9000:9000 -p 9090:9090 --name minio -d --restart=always -e "MINIO_ACCESS_KEY=minioadmin" -e "MINIO_SECRET_KEY=minioadmin" -v /root/minio/data:/data -v /root/minio/config:/root/.minio minio/minio server /data --console-address ":9090" --address ":9000"

# 启动 SRS (注意: CANDIDATE必须设置为物理机IP)
docker run -it -p 1935:1935 -p 1985:1985 -p 8080:8080 -p 1990:1990 -p 8088:8088 --env CANDIDATE=192.168.1.9 -p 8000:8000/udp registry.cn-hangzhou.aliyuncs.com/ossrs/srs:6.0-d2

# 启动 PostgreSQL
docker run -d --name postgres -p 35432:5432 -e POSTGRES_USER=postgres -e POSTGRES_PASSWORD=postgres -e POSTGRES_DB=postgres -v D:/Docker-vm/postgresql/vectordata:/var/lib/postgresql/data ankane/pgvector

# application.yml 示例配置
spring:
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848
      config:
        server-addr: localhost:8848
        file-extension: yml

  redis:
    host: localhost
    port: 6379

  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

# 文件存储配置
minio:
  endpoint: localhost:9000
  accessKey: minioadmin
  secretKey: minioadmin
  bucket: im-files

# SRS配置
srs:
  webrtc: http://localhost:8080
  rtmp: rtmp://localhost:1935

推荐使用两种方式启动服务：

方式一：手动依次启动

1. im-database (端口：8086)
2. im-auth (端口: 8084)
3. im-server (端口: 8085)
4. im-connect (端口: 19000-19002)
5. im-gateway (端口: 9191)

方式二：使用构建脚本一键启动

# Windows 系统
deploy-all.bat

# Linux/macOS 系统
./deploy-all.sh

• 网关服务: http://localhost:9191
• 认证服务: http://localhost:8084
• 业务服务: http://localhost:8085
• Nacos控制台: http://localhost:8848/nacos (账号: nacos/nacos)
• RabbitMQ管理: http://localhost:15672 (账号: guest/guest)
• MinIO控制台: http://localhost:9090 (账号: minioadmin/minioadmin)
• SRS服务: http://localhost:8080
• PostgreSQL: localhost:35432

im-server/
├── im-gateway/          # 网关服务
├── im-auth/             # 认证服务
├── im-connect/          # 连接服务
├── im-server/           # 业务服务
├── im-common/           # 公共模块
│   ├── im-core/         # 核心工具
│   ├── im-domain/       # 领域模型
│   ├── im-general/      # 通用组件
│   ├── im-grpc/         # gRPC相关
│   ├── im-security/     # 安全模块
│   ├── im-spring/       # Spring扩展
│   └── im-utils/        # 工具类库
└── docs/                # 项目文档

• 遵循阿里巴巴Java开发手册
• 使用统一的代码格式化工具
• 完善的注释和文档
• 单元测试覆盖率 > 80%

启动服务后，访问以下地址查看API文档：

• Swagger UI: http://localhost:8085/doc.html
• OpenAPI: http://localhost:8085/v3/api-docs

# 运行单元测试
mvn test

# 运行集成测试
mvn verify

# 生成测试报告
mvn jacoco:report

# 构建镜像
mvn clean package -DskipTests

# 使用Docker Compose一键部署所有服务
docker-compose up -d

• 使用Nginx进行反向代理和负载均衡
• 配置SSL证书，支持HTTPS
• 设置合适的JVM参数
• 配置日志收集和监控告警

• 并发连接: 支持10,000+ WebSocket连接
• 消息延迟: 平均延迟 < 100ms
• 系统吞吐: 10,000+ TPS
• 响应时间: 99%请求 < 200ms

测试环境: 8核16G云服务器，JDK 21，Docker部署

• Spring Boot - Java应用框架

• Spring Cloud Alibaba - 微服务解决方案

• Nacos - 服务注册发现

• Redis - 内存数据库

• RabbitMQ - 消息队列

• MinIO - 对象存储

• SRS - 流媒体服务器

我们欢迎所有形式的贡献！请查看 CONTRIBUTING.md 了解详情。

1. Fork 项目
2. 创建功能分支 (git checkout -b feature/AmazingFeature)
3. 提交更改 (git commit -m 'Add some AmazingFeature')
4. 推送到分支 (git push origin feature/AmazingFeature)
5. 创建 Pull Request

• 提交 Issue 报告问题或建议新功能
• 加入技术交流群讨论技术细节

• 项目主页: https://github.com/Luckly-XYZ

• 问题反馈: Issues

• 邮箱: [email protected]

本项目仅供学习和参考使用，不得用于任何商业用途。作者不对使用本项目可能引起的任何直接或间接损失承担责任。

1. 本项目是一个开源学习项目，旨在提供即时通讯技术的学习和研究参考。
2. 项目中涉及的技术方案、代码实现仅供参考，不保证其在生产环境中的稳定性、安全性和可靠性。
3. 用户在使用本项目时应自行承担所有风险，包括但不限于数据丢失、系统损坏、通信安全等问题。
4. 作者不提供任何形式的技术支持和保障，也不对项目的使用效果做任何承诺和保证。
5. 如将本项目用于商业用途，需自行承担可能的法律风险和责任。

本项目目前处于积极维护状态，持续更新和完善功能。

⭐ 如果这个项目对您有帮助，请给我们一个星标！