视频封面 · 热门壁纸推荐 / Bilibili
650 字
3 分钟
SpringCloud09-MQ
简单的介绍了SpringCloud中的MQ。
初识MQ
同步调用
原理示意：同步调用的调用方需要等待本次请求的处理结果，才能继续依赖该结果的流程。若多个调用串行发生，端到端延迟会累积；一处变慢或失败还可能沿依赖链传播，因此需要明确超时、错误处理与隔离边界，不能仅凭同步方式就推断系统一定发生级联故障。
优点
- 时效性较强，可以立即得到结果
缺点
- 耦合度高
- 每次加入新的需求，都要修改原来的代码
- 性能下降
- 调用者需要等待服务提供者响应，如果调用链过长则晌应时间等于每次调用的时间之和
- 资源浪费
- 调用链中的每个服务在等待响应过程中，不能释故请求占用的资源，高并发场录下会极度浪费系统资源
- 级联失败
- 如果服务提供者出现问题,所有调用方都会跟着出问题,如同多米诺骨牌一样，迅速导致整个微服务群故障
异步调用
原理示意：异步调用把消息提交与后续业务处理分开，消费者按自己的处理能力消费队列中的消息。生产者收到发布确认，并不等于消费者已经完成业务；故障隔离和流量削峰也依赖 Broker 容量、消息持久化、失败重试及消费者幂等。需要最终结果时，可另行设计结果事件或状态查询。
优点
- 耦合度低
- 吞吐量提升
- 故障隔离
- 流量削峰
缺点
- 依赖于Broker的可靠性、安全性、吞吐能力
- 架构复杂了，业务没有明显的流程线，不好追踪管理
MQ
MQ（MessageQueue），中文是消息队列，字面来看就是存放消息的队列。也就是事件驱动架构中的Broker。
| RabbitMQ | ActiveMQ | RocketMQ | Kafka | |
|---|---|---|---|---|
| 公司/社区 | Rabbit | Apache | 阿里 | Apache |
| 开发语言 | Erlang | Java | Java | Scala&Java |
| 协议支持 | AMQP,XMPP,SMTP,STOMP | Openwire,STOMP,REST,XMPP,AMQP | 自定义协议 | 自定义协议 |
| 可用性 | 高 | 一般 | 高 | 高 |
| 单机吞吐量 | 一般 | 差 | 高 | 非常高 |
| 消息延迟 | 微秒级 | 毫秒级 | 毫秒级 | 毫秒以内 |
| 消息可靠性 | 高 | 一般 | 高 | 一般 |