Chat21 实时消息引擎

镜像概述

Chat21实时消息引擎是一个运行在RabbitMQ消息代理上的"观察者"应用，用于实现安全、高效的实时消息传递。它通过MQTT协议接收客户端发送的消息，按照"收件箱"模式进行转发，确保消息传递的隐私性、安全性和可控性，同时支持消息持久化、用户屏蔽等策略应用。

核心功能与特性

消息转发机制

• 路径转发逻辑：监听客户端发送到/outgoing路径的消息，转发至接收者的/clientadded路径
  • 发送路径示例：/apps/tilechat/users/USER-ID/RECIPIENT-USER-ID/messages/outgoing
  • 接收路径示例：/apps/tilechat/users/RECIPIENT-USER-ID/SENDER-USER-ID/messages/clientadded
• 操作类型标识：路径末尾部分指示操作类型，如/clientadded表示新消息到达

收件箱模式实现

• 采用类似电子邮件SMTP/POP3的协议模式，消息通过"观察者"中转，而非客户端直接共享路径
• 支持消息隐私保护、安全增强、持久化存储及策略应用（如用户屏蔽）

安全与权限控制

• 基于RabbitMQ JWT令牌规范实现细粒度权限控制
• 用户仅能读写自己的特定路径，无法直接访问其他用户的收件箱
• 确保消息传递过程中的隐私性和安全性，防止未授权访问

使用场景

• 实时聊天应用：为客户端提供安全的消息传递通道
• 协作工具：实现用户间实时消息交互，支持消息策略管理
• 需要隐私保护的通信系统：通过中转机制增强消息安全性
• 企业内部通信平台：满足严格的权限控制和数据安全要求

使用方法

前置条件

• 已部署RabbitMQ消息代理，支持MQTT协议
• 已配置RabbitMQ JWT令牌认证机制
• 客户端应用支持MQTT协议连接RabbitMQ

部署示例

Docker Run 命令

bash
docker run -d \
  --name chat21-messaging-engine \
  -e RABBITMQ_HOST=rabbitmq.example.com \
  -e RABBITMQ_PORT=5672 \
  -e RABBITMQ_VHOST=/ \
  -e JWT_SECRET=your_jwt_secret_key \
  -e PATH_PREFIX=/apps/tilechat/users \
  chat21/messaging-engine:latest

环境变量配置说明

工作流程

1. 消息发送：客户端通过MQTT协议将消息发送至自身的/outgoing路径，路径格式为：

   ${PATH_PREFIX}/USER-ID/RECIPIENT-USER-ID/messages/outgoing
   

2. 消息转发：引擎监听/outgoing路径，收到消息后通过AMQP协议转发至接收者路径：

   ${PATH_PREFIX}/RECIPIENT-USER-ID/SENDER-USER-ID/messages/clientadded
   

3. 消息接收：接收者客户端监听自身路径，通过路径末尾的/clientadded标识识别新消息并进行处理

核心优势

• 隐私增强：通过中转机制避免用户直接共享消息路径
• 安全可控：支持消息策略应用（如用户屏蔽、内容过滤）
• 持久化支持：可集成消息持久化存储，确保消息不丢失
• 权限隔离：基于JWT令牌的细粒度权限控制，用户仅能访问自己的路径

注意事项

• 需确保RabbitMQ已启用MQTT插件和JWT认证插件
• JWT令牌需包含正确的路径访问权限声明
• 路径前缀配置需与客户端应用保持一致，避免消息路由错误