Skip to content

通讯中台-消息推送中心(DDD领域驱动设计+CQRS架构实战项目)

License

Notifications You must be signed in to change notification settings

dpwgc/imc-message-center

Repository files navigation

IMC Message Center

通讯中台-消息推送中心

消息中台系统

本项目是对 https://github.com/dpwgc/fast-im 项目的重构 (由 MVC 架构转为 DDD + CQRS 架构)


项目架构

  • 基础架构:基于 Spring Boot 结合 DDD 领域驱动设计及 CQRS 架构实现(代码层面实现读写分离,底层数据存储不分离)
  • 数据库:MariaDB(可换成 MySQL,两者通用)
  • 消息队列:Redis Stream
  • 分布式消息广播推送:基于 Redis 订阅/发布功能 + Spring WebSocket 实现

实现功能

  • 群聊消息广播发送(HTTP、WS)
  • 群聊消息广播撤回(HTTP)
  • 群聊消息查询(HTTP)
  • 群聊通知发布、删除与查询(HTTP)

架构图与流程图

  • 部署架构图 avatar IMC通讯中台可连接多个不同即时通讯应用的服务网关,网关集群按即时通讯应用的appId进行分类(来自appId:1的消息不会广播给appId:2的网关),可以部署多个IMC通讯中台,所有中台连接到同一个Redis和MariaDB源,每个中台连接任意数量的网关(自行分配)。

  • 消息发送与撤回流程 avatar 用户在APP端或者Web端发出消息,消息传入网关(用户端与网关请自行实现,本项目主要关注网关与中台的连接)。 网关再通过WebSocket连接将消息传入IMC通讯中台(连接方式见文档WS.md)。 中台将消息写入Redis Stream消息队列,然后再通过Redis Pub/Sub广播消息给所有持有相同appId的IMC通讯中台节点。 各个IMC通讯中台节点收到广播发来的消息后,再把这个消息推送给与自己连接的网关。 各个网关收到IMC通讯中台推送的消息后,再将消息推送给用户(该步骤自行实现)。


项目结构

垂直分层

  • message-center-sdk 存放一些ui层要用到的实体类(例如DTO对象、Command对象)
  • message-center-ui 用户接口层(表示层,包括接口服务及配置服务)
  • message-center-app 应用层(对下层传来的对象进行业务处理,再传给上层)
  • message-center-domain 领域层(负责组装基础服务层传来的数据对象)
  • message-center-infrastructure 基础服务层(包括数据库交互、缓存交互以及一些工具类)

avatar

水平分区

读写分区
  • command 写入服务
  • query 查询服务
服务分区
  • chat 聊天模块
    • message 聊天消息服务
  • notice 通知模块
    • information 通知信息服务

Releases

No releases published

Packages

No packages published