1.先了解什么是同步通信和异步通信
按我的理解来说是
同步通信:实时对话传输
异步通信:得等对方回复了才能收到,时效性差
优缺点:同步通信只能同时对于一个人对话不能多线回复,而异步通信可以同时与几个人聊天
这就是实时的,得等待服务回应
当服务多了会性能下降,吞吐量也下降了
同步调用存在的问题
- 耦合度高(每次加入新需求都需要修改原来的代码)
- 性能和吞吐能力下降(调用者需要等待服务提供者的响应,如果调用链过长则每次响应时间等于调用时间之和)
- 有额外的资源消耗(调用链中每个服务在等待相应过程中不能释放资源,高并发下极度浪费系统资源)
- 有级联失败问题(如果服务提供者出现问题,所有调用方都会出现问题,和多米诺骨牌一样迅速导致整个微服务群故障)
?引入了broker(事件代理者)
例如
在这个体系中一旦有人支付成功就是一个事件
异步调用好处：
- 吞吐量提升：无需等待订阅者处理完成，响应更快速
- 故障隔离：服务没有直接调用，不存在级联失败问题
- 调用间没有阻塞，不会造成无效的资源占用
- 耦合度极低，每个服务都可以灵活插拔，可替换
- 流量削峰：不管发布事件的流量波动多大，都由 Broker 接收，订阅者可以按照自己的速度去处理事件
异步调用缺点：
- 架构复杂了，业务没有明显的流程线，不好管理
- 需要依赖于 Broker 的可靠、安全、性能
MQ消息队列
MQ，中文是消息队列（MessageQueue），字面来看就是存放消息的队列，也就是事件驱动架构中的 Broker
比较常见的 MQ 实现：
- ActiveMQ
- RabbitMQ
- RocketMQ
- Kafka
几种常见MQ的对比：
| RabbitMQ | ActiveMQ | RocketMQ | Kafka | |
|---|---|---|---|---|
| 公司/社区 | Rabbit | Apache | 阿里 | Apache |
| 开发语言 | Erlang | Java | Java | Scala&Java |
| 协议支持 | AMQP、XMPP、SMTP、STOMP | OpenWire、STOMP、REST、XMPP、AMQP | 自定义协议 | 自定义协议 |
| 可用性 | 高 | 一般 | 高 | 高 |
| 单机吞吐量 | 一般 | 差 | 高 | 非常高 |
| 消息延迟 | 微秒级 | 毫秒级 | 毫秒级 | 毫秒以内 |
| 消息可靠性 | 高 | 一般 | 高 | 一般 |