
# AQChat：从服务启动到消息处理全流程
```
AQChat 是一个基于 Netty + WebSocket 的高性能即时通讯系统，采用 Protobuf 二进制协议实现消息编解码，支持文本、图片、文
件、音频、视频等多种消息类型，具备消息提醒、消息撤回重新编辑、艾特成员/AI助手等功能。集成阿里百炼、Gitee AI 等多个 AI
平台，支持多轮对话、文本转语音、文本转图片等功能。
```
## 1. 服务启动流程

### 启动入口
- `AQChatApplication.java` 是 SpringBoot 应用的主类，通过 `SpringApplication.run()` 方法启动应用

### Netty 服务器初始化
`AQChatNettyStarter.java` 负责初始化 Netty 服务器：
- 创建 `ServerBootstrap` 实例
- 配置 `bossGroup` 和 `workGroup` 线程池
- 设置 `childHandler` 处理连接
- 绑定 WebSocket 端口

### 消息处理器注册
- `AQChatCommandHandler.java` 注册为全局指令处理器，负责处理所有客户端请求
- `MessageRecognizer.java` 在启动时初始化，建立消息命令与消息体的映射关系

## 2. 消息发送流程

### 客户端发送消息
- 客户端通过 WebSocket 发送消息，消息格式为 Protobuf 序列化数据

### Netty 通道处理
- `MessageDecoder.java` 解码消息，将二进制数据转换为 `SendMsgCmd对象
- `AQChatCommandHandler.java` 接收到消息后，通过 commandHandler 获取对应的处理器

### 指令处理器调用
`SendMsgCmdHandler.java` 处理消息发送请求：
- 验证用户登录状态和房间状态
- 生成消息ID并保存到 Redis
- 通过 MQ 发送消息

### 消息存储
- `MqSendingAgent.java` 的 `storeMessage()` 方法将消息发送到 MQ 的 `STORE_MESSAGE_TOPIC`
- `StoreMessageReceiver.java` 接收存储消息，调用 `messageService.saveMessage()` 保存到数据库

## 3. 消息广播流程

### MQ 消费者接收
- `MessageBroadcastReceiver.java` 接收广播消息，使用 `DefaultMQPushConsumer` 订阅 `SEND_MESSAGE_TOPIC` 主题
- 处理消息并广播给所有在线用户

### 全局通道管理
- `GlobalChannelHolder.java` 管理所有用户的连接通道，维护 `CHANNELS` 映射表
- 提供 `sendBroadcastMessage()` 方法向房间内所有用户发送消息

### 消息广播实现
- `MessageBroadcaster.java` 实现消息广播，使用 `ChannelGroup` 管理房间内的所有通道
- 提供 `broadcast()` 方法向所有在线用户发送消息

## 4. AI 消息处理流程

### AI 服务调用
- `GiteeAiService.java` 调用 Gitee AI 服务，使用 `giteeAiClient` 发送请求
- 处理流式响应，通过 `globalChannelHolder.sendBroadcastAiMessage()` 广播 AI 回复

### AI 消息处理
- `AiHelperReceiver.java` 接收 AI 助手消息，使用 `aiService.streamCallWithMessage()` 处理流式输出
- 通过 `globalChannelHolder.sendBroadcastAiMessage()` 广播 AI 回复

## 5. 数据存储流程

### 消息持久化
- `StoreMessageReceiver.java` 接收存储消息，调用 `messageService.saveMessage()` 保存消息
- `IAQMessageMapper.java` 提供数据库接口，`messageMapper.insert()` 插入数据库

### 数据库操作
- `AqMessage.java` 是消息实体类，映射到 `aq_message` 表
- `IAQMessageService.java` 提供业务逻辑接口，`saveMessage()` 方法调用 Mapper 插入数据

## 6. 用户状态管理

### 用户登录
- `UserLoginCmdHandler.java` 处理用户登录，生成用户ID并保存到 Redis
- 将用户通道加入全局通道持有者

### 用户退出
- `UserLogoutCmdHandler.java` 处理用户退出，清除用户信息，移除用户通道

### 心跳检测
- `HeartBeatHandler.java` 实现心跳检测，使用 `IdleStateHandler` 监控连接状态，超时自动断开连接

AQChatApplication.java 是 SpringBoot 应用的主类，通过 SpringApplication.run() 方法启动应用

AQChat：从服务启动到消息处理全流程

网络与通信

后端

架构设计

AQChat是基于Netty+WebSocket的高性能即时通讯系统，支持文本、图片、文件等多媒体消息，集成AI助手功能。系统采用Protobuf协议实现高效消息编解码，提供完整的消息处理流程，包括服务启动、消息发送、广播、AI处理和存储功能。通过Redis和MQ实现消息队列管理，支持多平台AI服务调用，具备完善的用户状态管理和心跳检测机制。

数据存储

数据转换

数据库

服务器

Redis

AI驱动 智领未来

tencentdb-catalog

腾讯云数据库特惠，新用户首单0.5折起


4核4G3M云服务器 新用户低至38元/年！

对象存储COS新用户低至1元！


腾讯云 IM，全球通信，1折起


文章

问答

视频

教程

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云智能顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

聚焦“写作效率、视觉美观与运行性能”三方面进行全面升级，为您提供更高效、稳定的创作环境

社区富文本&Markdown编辑器全新改版上线，欢迎大家体验!

诚挚邀请您参与本次调研，分享您的真实使用感受与建议。您的反馈至关重要，感谢您的支持与参与！

社区新版编辑器体验调研

AQChat是基于Netty+WebSocket的高性能即时通讯系统，支持文本、图片、文件等多媒体消息，集成AI助手功能。系统采用Protobuf协议实现高效消息编解码，提供完整的消息处理流程，包括服务启动、消息发送、广播、AI处理和存储功能。通过Redis和MQ实现消息队列管理，支持多平台AI服务调用，具备完善的用户...

AQChat：从服务启动到消息处理全流程-腾讯云开发者社区-腾讯云

AQChat：从服务启动到消息处理全流程

AQChat：从服务启动到消息处理全流程

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐