重庆潼南网站建设哪家便宜,淄博做网站电话,蒙阴网站建设,semir是什么意思文章目录 前言整体设计时序图时序图解释 最后 前言
当多个系统之间通过Kafka来解耦时#xff0c;在系统设计初期#xff0c;基本的要求都是相似的#xff0c;只不过是消费消息时的业务逻辑可能不同。
本文以业务系统和邮件系统解耦作为示例。业务系统需要发送邮件时#… 文章目录 前言整体设计时序图时序图解释 最后 前言
当多个系统之间通过Kafka来解耦时在系统设计初期基本的要求都是相似的只不过是消费消息时的业务逻辑可能不同。
本文以业务系统和邮件系统解耦作为示例。业务系统需要发送邮件时不在自身服务器上发送邮件 不通过RPC的方式调用邮件系统而是通过将发送邮件需求以消息的形式发送到Kafka 邮件系统通过从Kafka中消费消息来发送邮件。
通过这样的解耦有以下几点好处
由于业务系统不直接调用邮件系统所以不会将压力给到邮件系统避免两个系统因大量的请求响应而出现的系统不稳定问题Kafka的性能是非常出色的所以对于业务系统的大量写入应该可以hold住。当然我司每天写入的数据量和头部互联网公司的每天的海量数据没法比邮件系统可以根据实际情况来从容的消费消息也有利于我们可以针对邮件系统服务器进行硬件、软件、JVM等精细化的调优
整体设计
业务系统向Kafka发送消息消息系统从Kafka获取消息执行消费逻辑业务系统的消息被邮件系统消费之后还需要通知业务系统确保消息不丢失确保消息不重复消费Kafka的高可用、稳定性不在本文讨论范围之内
时序图
下列时序图使用mermaid绘制 如果看不清楚使用点此查看高清图片
时序图解释
1 ~ 10步骤为核心流程11 ~ 20步骤为可选流程 如果存在回调消息则还要回调
最后
整体大的细节就如时序图所示后续将在具体编码中进行更详细的说明。 下一篇博文专注于业务系统生产者端逻辑的实现。
