MQ基础信息mq的简介

MQ

同步和异步通讯

微服务间通讯有同步和异步两种方式&＃xff1a;

同步通讯&＃xff1a;就像打电话&＃xff0c;需要实时响应。

异步通讯&＃xff1a;就像发邮件&＃xff0c;不需要马上回复。

两种方式各有优劣&＃xff0c;打电话可以立即得到响应&＃xff0c;但是你却不能跟多个人同时通话。发送邮件可以同时与多个人收发邮件&＃xff0c;但是往往响应会有延迟。

同步通讯

Feign调用就属于同步方式&＃xff0c;虽然调用可以实时得到结果&＃xff0c;但存在下面的问题&＃xff1a;

同步调用的优点&＃xff1a;

·时效性较强&＃xff0c;可以立即得到结果

同步调用的问题&＃xff1a;

·耦合度高

·性能和吞吐能力下降

·有额外的资源消耗

·有级联失败问题

异步通讯

异步调用则可以避免上述问题&＃xff1a;

我们以购买商品为例&＃xff0c;用户支付后需要调用订单服务完成订单状态修改&＃xff0c;调用物流服务&＃xff0c;从仓库分配响应的库存并准备发货。

在事件模式中&＃xff0c;支付服务是事件发布者&＃xff08;publisher&＃xff09;&＃xff0c;在支付完成后只需要发布一个支付成功的事件&＃xff08;event&＃xff09;&＃xff0c;事件中带上订单id。

订单服务和物流服务是事件订阅者&＃xff08;Consumer&＃xff09;&＃xff0c;订阅支付成功的事件&＃xff0c;监听到事件后完成自己业务即可。

为了解除事件发布者与订阅者之间的耦合&＃xff0c;两者并不是直接通信&＃xff0c;而是有一个中间人&＃xff08;Broker&＃xff09;。发布者发布事件到Broker&＃xff0c;不关心谁来订阅事件。订阅者从Broker订阅事件&＃xff0c;不关心谁发来的消息。

Broker 是一个像数据总线一样的东西&＃xff0c;所有的服务要接收数据和发送数据都发到这个总线上&＃xff0c;这个总线就像协议一样&＃xff0c;让服务间的通讯变得标准和可控。

好处&＃xff1a;

·吞吐量提升&＃xff1a;无需等待订阅者处理完成&＃xff0c;响应更快速

·故障隔离&＃xff1a;服务没有直接调用&＃xff0c;不存在级联失败问题

·调用间没有阻塞&＃xff0c;不会造成无效的资源占用

·耦合度极低&＃xff0c;每个服务都可以灵活插拔&＃xff0c;可替换

·流量削峰&＃xff1a;不管发布事件的流量波动多大&＃xff0c;都由Broker接收&＃xff0c;订阅者可以按照自己的速度去处理事件

缺点&＃xff1a;

·架构复杂了&＃xff0c;业务没有明显的流程线&＃xff0c;不好管理

·需要依赖于Broker的可靠、安全、性能

技术对比

MQ&＃xff0c;中文是消息队列&＃xff08;MessageQueue&＃xff09;&＃xff0c;字面来看就是存放消息的队列。也就是事件驱动架构中的Broker。

几种常见MQ的对比&＃xff1a;

追求可用性&＃xff1a;Kafka、 RocketMQ 、RabbitMQ

追求可靠性&＃xff1a;RabbitMQ、RocketMQ

追求吞吐能力&＃xff1a;RocketMQ、Kafka

追求消息低延迟&＃xff1a;RabbitMQ、Kafka