关于消息:聊聊消息中心的设计与实现逻辑

45次阅读

共计 1718 个字符,预计需要花费 5 分钟才能阅读完成。

腻烦被音讯打搅,又怕忽然间的宁静;

一、业务背景

微服务的架构体系中,会存在很多根底服务,提供一些大部分服务都可能须要的能力,比方文件治理、MQ 队列、缓存机制、音讯核心等等,这些服务须要提供各种能够复用的办法或者接口,以便其余业务服务能够疾速调用;上面来看看音讯告诉的原理:

这里的音讯不同于 MQ 队列,是指业务侧的告诉机制,例如短信、邮件、零碎音讯等,在业务层面的需要很多,通常会封装独自的音讯核心提供告诉机制;

从流程下面看,音讯告诉是典型的生产 - 生产模式,业务侧一直的生产音讯,音讯核心在接管之后进行生产,把告诉推送到相应的渠道中,很显然这种逻辑具备很高的复用性。

二、音讯告诉

1、流程治理

音讯告诉的流程设计,在各个业务线中通过音讯核心提供的接口办法,将不同场景下的音讯内容提交到音讯核心,音讯核心进行对立保护治理,并依据音讯的起源和去向,适配相应的推送逻辑:

  • 音讯生产:波及到的场景很多,比方流动、营销机制、零碎告诉、业务流转、过期揭示等;
  • 音讯治理:对预发送音讯的构造和参数进行校验,并创立音讯推送的工作,保护工作级别的推送治理,跟踪音讯的状态周期;
  • 音讯生产:基于音讯工作的构造,构建音讯推送的主体内容,并对接多个发送渠道,实现告诉的高效触达;
  • 定时工作:音讯能够间接即时推送,但如果是夜间定时工作触发,则要思考推送提早问题,将音讯放在指定时段投递;
  • 渠道对接:通常不同的渠道意味着不同的场景,例如监控推送钉钉,流动个别推送微信,账户变动发邮件,营销走短信,业务则利用内告诉;

在整个流程中波及到的模块比拟多,状态的流转也很简单,然而通过音讯核心进行统一标准治理和流入流出的跟踪,也能够提供清晰的生命周期监控和保护;

2、流程时序

在整个音讯告诉链路中,在不同的流转节点中,无不波及状态的变动(即 from.to 状态),这样能够形成整个生命周期的视图:

  • 初始化:业务方构建简略的音讯构造,申请发送到音讯核心后,初始化一个音讯工作;
  • 工作化:对音讯发送申请进行校验,并将音讯转换成一个规范的推送工作构造;
  • 推送中:依据工作推送的工夫周期类型,将工作构建成不同渠道的告诉主体,从而进行渠道音讯推送;
  • 已实现:依据音讯在渠道推送的状态回调,更新音讯核心的工作实现状态,或者失败重试;

大部分的音讯告诉机制都能够容忍肯定的提早性,所以音讯核心齐全能够解耦各个流程,引入 MQ 队列或者异步机制,业务方只须要将申请发送到音讯核心,之后由音讯核心对立调度和治理即可;

3、结构设计

这里依据零碎的实现过程和教训,给出一个数据结构的设计参考,用来对业务场景做简略的维度形容:

  • 音讯模板:定义告诉的主体构造,基于音讯的参数模型,构建推送的音讯内容;
  • 音讯工作:音讯核心治理和保护的主体构造,以工作的模式保护音讯从生产到推送实现的整个状态周期;
  • 场景记录:音讯最终推送进来的内容和场景分类,也能够简略的了解为不同渠道的投递记录;
  • 交互音讯:强调音讯在接管方是否触达并且对音讯产生了交互行为,例如会话,邮件回复,状态关联等;

三、实际总结

最初还是站在技术实现的角度,总结一下音讯告诉机制中的一些关键问题:

  • 生产生产:音讯生产之后写入音讯核心的存储容器,之后进行生产流程的治理,是业务解耦的罕用伎俩;
  • 工作治理:以工作的模式进行音讯推送的调度,通过工作状态的变动和管制,实现生命周期的治理;
  • 状态机:形容音讯的流转节点和状态,在不同的事件中触发不同的状态切换和转移,并在状态变动后连接各种业务动作;
  • 渠道对接:通常音讯推送的渠道多是第三方平台,所以在音讯核心会接入诸多的渠道,例如微信、钉钉、短信等;
  • 根底封装:作为分布式系统中的根底性能,在封装音讯治理性能时,要思考肯定的复用性和流程的可视化出现;

音讯的实质是信息的触达和传递,然而过多的音讯告诉也容易让用户产生厌倦心态,所以音讯内容的简洁明确,推送的距离时段以及浏览揭示,在产品具体的实现上须要极为用心,从而让音讯在业务体系中施展更大的价值。

四、参考源码

 编程文档:https://gitee.com/cicadasmile/butte-java-note

利用仓库:https://gitee.com/cicadasmile/butte-flyer-parent

正文完
 0