一、问题领路
21.1音尘中间件的愚弄场景
音尘中间件的愚弄场景主要有两个：异步解耦与削峰填谷。
咱们最初通过电商平台用户注册送积分、送优惠券这个场景来聚首异步解耦合。要是不使用音尘中间件，电商平台送积分的结束也许是下图这个表情：
咱们简便看一下这个经由。
用户在网站前端注册页面填写有关信息，然后调用账号中心办事，注册账号。
账户中心最初试验用户注册逻辑处理（举例判断用户是否已注册、是否安妥注册条款等），然后写入到数据库。
注册告成后，需要调用积分中心（营救积分接口）给用户送积分。
送完积分后，再调用优惠券有关接口，为用户营救优惠券。
告成送完积分、优惠券后，向用户复返“注册告成”
从架构角度看，上头这个结束顺次有一个特地严重的问题，那等于可推广性低。
举例，要是要在春节时期转折动作计谋，在发送积分的同期，还需要迥殊发送新春大礼包，确立东谈主员为了结束这一功能，就不得不修改用户注册经由，并从头部署用户注册模块。
从功能维度来看，此次需求的变更集结在动作有关的内容。用户注书本人的逻辑并未发生变化，但由于用户注册逻辑与动作模块存在耦合，两个模块必须一谈转折和发布，这就对系统牢固性形成了影响。
另外，调用积分、优惠券两个良友 RPC 央求让用户注册主经由变长，在高并发场景下，用户注册这一环容易成为系统瓶颈。
要惩处上头这两个彰着的筹画弱势，常用的决议是引入音尘中间件，让用户注册主经由和商家动作异步解耦合。纠正后的时序图如下：
账户中心完成用户注册有关逻辑后，会向 MQ 发送一条音尘到 MQ 办事器，然后就径直给用户复返“注册告成”。营救优惠券、积分等与动作有关的需求咱们不错异步试验，这么，不管后续互动逻辑发生什么变化，账户中心皆不需要发布新版块。
引入送积分办事（MQ 浪费者愚弄）和送优惠券办事（MQ 浪费者愚弄）会订阅音尘，并凭证音尘调用积分中心、优惠券中心的办事。要是后续动作发生变化，举例取消送积分动作但启动营救新春大礼包，那咱们只需住手送积分办事愚弄，加多送新春大礼包的浪费者愚弄，就不错实在作念到对新增绽开，对修改关闭。
音尘中间件的另外一个常用场景是削峰填谷。咱们来看一个外卖骑手送餐的场景。它的筹画架构图如下：
咱们划分阐明一下“创建订单经由”和“查询订单信息”两个经由，研究一下这个决议的精髓。
先来看创建订单经由。
用户在 App 中下单，App 会调用网关有关接口创建订单，网关接受到央求后，并不是径直调用里面商户订单中心来创建订单接口，而是先发送一条音尘到 MQ。
商户接单模块（Consumer）订阅 MQ 中的音尘，处理音尘的时期调用里面商户订单中心创建订单接口，创建一条实在的订单数据到数据库。
创建订单后，商户订单中心将再发送一条音尘到 MQ 办事器。然后骑手分派模块（Consumer）订阅音尘，调用派单办事有关接口，诱骗骑手进行外卖配送。
同期，数据同步组件（Canal）将数据库中的数据准实时同步到 Es 办事器。
为什么网关不径直调用外部的创建订单接口，而是将数据先写入到 MQ 中呢？
两个人为什么叫这名字？其实这并不是他们的真名，而是各自的外号。他们两个出名的地方也正是因此2024香港六合彩開獎號碼查詢，因为两个人都是出了名的胆大，这胆大的人呢，咱说白了，就是一根筋，就是爱抬杠的那种人。虽说外号是村民给他们起的，但是两个人并不生气，相反还很受用。
咱们不妨设念念一下，商户订单中心救援的最大并发为 1w/tps。要是某一个业务岑岭期，从网关参加的流量眨眼间飙升到 1.5w/tps，况兼执续了 10 分钟，商户订单系统会径直崩溃，形成办事不行用等严重故障！
那该如何惩处呢？
有东谈主可能会说，咱们不错使用限流机制保护商户订单系统。举例，咱们只允许 9000TPS 的流量从网关参加到商户订单中心，径直闭幕豪阔的流量，让客户端重试。这照实不错惩处问题，但会带来经济损构怨厄运的用户体验。
这个时期咱们有一个愈加友好的惩处决议：引入音尘中间件。
引入音尘中间件的指标是让它来扛住海量流量，流量先参加到音尘队伍中，然后浪费端卑劣系统不错冉冉浪费音尘中间件中的数据，这么能有用保护卑劣系统不被瞬时的流量击破。这种决议可能带来的最坏成果等于，浪费这些音尘会存在延伸。但这些订单皆不错告成创建，实在的交往步履也曾产生了。接下来要作念的等于凭证骨子情况扩容简略缩容，尽快将积压的数据处理掉。
不外咱们这个时期引入音尘中间件，其实潜台词是它们的性能必须怡悦底下几个基本要求：高婉曲量、低延伸，还要具体音尘堆积才气。
咱们再看一下订单查询经由：
用户在 App 端发起订单查询，App 会调用网关的订单查询接口，网关再将央求转发到里面的订单查询办事；
订单查询办事不是在 MySQL 数据库，而是径直查询 Es 中的数据。
这里一个筹画的亮点是，引入了数据同步组件 Canal，将 MySQL 数据库中的数据实时同步到了 Es。这么查询订单时只查 Es 就不错了，结束了订单写入与订单查询在异构数据源的读写分离。
21.2 音尘中间件的时候选型
在这节课的终末，咱们来望望如何采取音尘中间件。
现在音尘中间件规模主要的中间件包括 RocketMQ、Kafka 和 RabbitMQ，咱们先来看一下这张功能对比图：
褪色上头这张图，咱们再对比分析一下。
最初，我以为功能级别不具备一票否决权。
举例，RabbitMQ 救援优先级队伍，而 RocketMQ、Kafka 不救援，那么要是咱们的花式中有优先级队伍的使用诉求，咱们就必须将 Kafka、RocketMQ 排猬缩，采取使用 RabbitMQ 吗？我是不提出这么作念的，任何波及到功能的短板，皆不错通过其他方式结束。
但我也并不是说功能特点就小数皆不紧迫。这小数我在背面筹划 RocketMQ 与 Kafka 的选型时会再次谈到。
其次，我以为在选型时要特地夺目中间件的性能和推广性。
因为跟着业务不停地发展，性能问题会越来越卓绝，况兼性能问题皆具有遮掩性，一朝发生，碎裂性大，影响进程深，让东谈主防不堪防。
举例，RabbitMQ 的音尘堆积才气不彊，一朝浪费端无法实时将音尘处理掉，会极大影响音尘办事器发送音尘的性能。这小数长短常致命的，因为引入音尘中间件的指标等于险阻住洪峰流量，要是音尘中间件因为积压问题影响了音尘的发送，那是万万不行取的。
因此，从性能的角度来看，RocketMQ 和 Kafka 比 RabbitMQ 的推崇更好。