消息中心架构设计
2023-09-19 10:02:20 17 举报
消息中心架构设计通常包括以下几个部分:消息生产者、消息队列、消息消费者和消息存储。消息生产者负责将消息发送到消息队列中,消息队列负责存储和转发消息,消息消费者负责从消息队列中获取消息并进行处理,消息存储负责持久化存储消息。这种架构设计可以有效地解耦消息生产者和消费者,提高系统的可扩展性和可靠性。在实际应用中,常用的消息队列产品有RabbitMQ、Kafka等。总之,消息中心架构设计是一种常用的解耦手段,可以帮助我们构建更加灵活、可靠的系统。
作者其他创作
大纲/内容
APP名称归属APP日限流月限流单用户月限流单用户日限流
增删改查
查询租户、账号
已超限
消息回传解析
用户免打扰限流规则校验
API地址API Account SIDAuth Token短信解析频度发送号码:租户名称:
账号登录&权限
判断模板上配置的用户月接收上限
9、查询发送记录
查询应用限流限流配置规则
飞书/企微/钉钉接口配置
未超限
消息中台业务服务架构
未配置
需要提示目标人群是否维护了手机号码
1、消息中台接入发送渠道
适配推送人群
未来可拓展至客户侧应用....
发送渠道管理
任务调度发送消息
1、业务应用调用生成任务2、手工创建任务
判断是否超过APP日发送上限
业务应用B
按模板定义告警频度模板ID告警频度
AppPush
业务应用平台
API地址API Account SIDAuth Token短信解析频度发送的APP ID:
APP
Push模板ID消息模板名称:类型:通知/告警/营销参数定义:多语言类型:内容模板:创建人:创建时间:审核人:审核时间:
IM配置
消息查询
账号
IM模板ID消息模板名称:类型:通知/告警/营销参数定义:多语言类型:标题模板:内容模板:创建人:创建时间:审核人:审核时间:
6、业务平台触发消息推送
登录
表示该应用APP配置了的APP维度发送的用户免打扰限流配置,含日和月两个期间维度,目的防止APP的消息对目标用户过度骚扰
角色
消息模板
模板ID、消息ID、任务ID目标用户ID消息类型、消息内容发送调度来源发送渠道发送状态重发次数:每一次都记录,并计数最近发送时间
判断是否超过APP月发送上限
消息模板查询与传参
设置内容过滤规则
租户名称:CMI目的IP:目的信令端口:媒体协商IP:媒体协商端口:呼出号码:
消息任务调度
站内消息
触发失败重发
发送渠道
发送日志
查询该APP在用户维度日累计接收量+在途任务的发送量
增删查查
扫描失败记录
消息内容
查询该模板在用户维度日累计接收量+在途任务的发送量
商务
链路追踪
模板ID归属APP日限流月限流单用户月限流单用户日限流
7、生成发送任务
消息任务生命周期时序
发送配置
业务应用C
上级应用是否配置了按月/日限流值
任务管理
短信消息模板
更新任务状态
告警类模板频次配置
应用限流配置
接入管理
发送范围
用户操作
是否配置了上级应用
查询该APP日累发送量+在途任务的发送量
返回消息回执
消息发送对象联系人来源
IM会话
已配置
类型:平台/租户租户类型:运营商/企业/分销角色:租户成员类型:是否负责人:指定账号:指定飞书账号/群ID
模板限流设置
返回账号
如果配置了否,则表示不受APP层级的限流控制
不校验应用限流
是否配置了按月/日免打扰限流值
查询该APP在用户维度月累计接收量+在途任务的发送量
需要提示目标人群是否维护了邮箱
发送消息计算更新任务状态
触发生成消息推送任务
短信服务
遵从APP限流规则=是
模板是否配置了APP限流规则校验
指定账号ID
配置管理
短信模板ID消息模板名称:类型:通知/告警/营销参数定义:多语言类型:内容模板:创建人:创建时间:审核人:审核时间:
增查
租户
向渠道推送消息
返回消息订阅配置
IM消息模板
APP限流规则校验
多因子校验
适配告警、应用频次规则
Realm域
发送渠道配置任务状态:非告警类的一次发送成功即结束告警类的根据告警设置持续告警,下游调度判断关闭发送任务
如果发现超限,需要采取的措施,先坚持发送渠道的是否仍有容量,如容量满足,可调整消息中台超限配置如容量不满足,需调整追加发送渠道容量,再调整消息中台超限配置,或者等下个周期存量容量释放再进行发送
运营
消息渠道
验证联调
restful
判断APP配置的用户月接收上限
2、功能接入消息中台
webhook
语音短信
群ID指定账号ID
查询该APP月累发送量+在途任务的发送量
触发生成消息
统一消息接入平台网关
按模板定义重发配置模板ID重发扫描频度
配置告警频次
查询调用消息模板限流规则
向目标用发送
任务敏感内容告警
调用消息发送接口发送消息
生成消息发送日志
更新告警任务状态
校验限流规则
查
如果配置了是,则表示仅遵从APP层级的用户免打扰限流配置
查询该父级APP在用户维度月累计接收量+在途任务的发送量
目标发送账号邮箱/手机/IMID
查询是否配置了APP维度限流规则
keyclark
适配模板判断模板归属应用
表示该应用在配置的APP维度发送的数量限制,含日和月两个期间维度,目的防止APP在下游渠道发送量的TPS超量
消息中台
查询该模板在用户维度月累计接收量+在途任务的发送量
应用鉴权
任务状态回执
敏感词服务(阿里云)
查询调用消息模板用户免打扰规则
生成任务
计算消息发送量
3、配置消息模板
破屏消息
限流规则
用户
判断APP配置的用户日接收上限
配置消息渠道
消息模板ID
模板ID类型:通知/告警/营销参数定义:多语言类型:消息内容:创建时间:任务创建来源
邮件服务配置
APP名称敏感词状态创建时间
管理员
消息发送范围
上级应用是否配置了按月/日免打扰限流值
语音消息模板
遵从APP限流规则=否
邮件消息模板
短信API配置
用户操作回执
消息ID、任务ID、模板类型发送渠道调用状态调用时间是否重复调用渠道消息发送状态渠道发送时间是否重发发送内容
业务应用D
通过模板ID查询模板主要入参:token、模板ID、APP、模板参数、发送范围
任务内容更新
消息发送业务用户流程
如果配置了否,则表示不受APP层级的用户免打扰限流控制,查询模板是否有设置相关配置
飞书/企微/钉钉
5、配置模板的参数
PUSH配置
域管理(realm)
内容校验敏感词
校验权限校验模板状态校验参数校验发送范围
敏感词库配置
适配敏感词
适配渠道
邮件服务
业务应用E
调度失败记录扫描监控
查询发送日志
8、发送消息
语音API配置
渠道接入
本次暂不实现
联系人
语音模板ID消息模板名称:类型:通知/告警/营销参数定义:多语言类型:内容模板:创建人:创建时间:审核人:审核时间:
成员
发送状态回执
返回用户操作结果
鉴权
发送失败告警
消息中心
PORTAL
用户订阅
消息发送范围管理
发送失败重发配置
返回任务ID和状态返回失败原因
发送配置管理
查询支持订阅的消息
是否配置了按月/日限流值
如果配置了是,则表示仅遵从APP层级的限流控制
商家
邮件模板ID消息模板名称:类型:通知/告警/营销参数定义:多语言类型:标题模板:内容模板:签名模板:创建人:创建时间:审核人:审核时间:
平台
业务应用A
监控告警
业务应用
查询该父级APP在用户维度日累计接收量+在途任务的发送量
渠道接入联调
遵从APP免打扰控制=是
查询是否配置了APP维度用户按月/日免打扰限流规则
判断模板上配置的用户日接收上限
应用接入
邮件服务:发送邮箱设置:端口:协议:账号:密码:邮件解析频率:
10、结束告警
SDK
遵从APP免打扰控制则=否
以上是消息准备配置
消息中台关键业务对象
4、配置模板消息发送范围
默认重发配置
返回日志和回执
Push消息模板
返回订阅用户
敏感词库
0 条评论
下一页