- 应用骨架: Solon + MyBatis-Plus + PostgreSQL + Redis + Sa-Token - 核心链路: 回调网关 → 消息落库(幂等) → 分发队列(FOR UPDATE SKIP LOCKED) → worker消费/重试/死信 - 多租户隔离: 前缀法账号映射, 所有业务表带 tenant_id - 管理后台: FreeMarker 渲染, 租户/授权/队列/用量管理页面 - 历史消息补拉: 水位线驱动, getRoamMsg/getGroupMsg 增量拉取, 兜底回调丢失 - msg_key 统一算法(回调/补拉共享, 跨路径去重) Co-Authored-By: Claude <noreply@anthropic.com>
7 lines
867 B
Plaintext
7 lines
867 B
Plaintext
1.消息服务 Chat 回调URL配置,目前这个已配置,用来将每条消息保存到本地(每个系统肯定都不一样)
|
|
2.需要将现有几个不同应用的数据合并到一个应用,比如im用户,im群组等
|
|
3.如果遇到未正确回调url的,导致本地消息数据丢失的,需要同步腾讯api拉取同步消息
|
|
4.需要有功能来统计不同系统的使用情况,包括im使用情况,音视频使用情况
|
|
5.需要统一将消息服务回调放到统一工具中,即本系统中,本系统负责保存所有回调存过来的消息,并负责拉取历史消息,并根据系统来打上标记,系统之间不能串
|
|
6.还需要考虑腾讯回调过来的消息,需要第一时间发送到每个系统的回调地址中,需要消息队列,需要回执及重发机制,避免因目标系统宕机造成消息丢失
|