简介:
MQ 全称 Message Queue (消息队列),是在消息的传输过程中保存消息的容器。多用于分布式系统之间的通信。

图中A为消息生产者(Producer),B为消息消费者(Consumer),则MQ为中间件。
MQ 优劣
–在A系统与B系统中间加一层MQ。
优势:
· 应用解耦:
降低系统间的耦合度,提高容错,便于维护。
(如果系统异常,MQ会停止发送消息)
· 异步提速:
接收到请求后,添加到消息队列中,不立即访问对应的服务
提升用户体验 & 系统吞吐量
· 削峰填谷:
高并发场景下,MQ不用访问具体的服务,仅接收消息
并将请求限流发送给服务端可靠性高
劣势:
· 系统可用性降低
系统引入的外部依赖越多,系统稳定性越差。
(MQ的高可用?)
· 系统复杂度提高
MQ 增加了系统的复杂度。
之前系统间是同步的远程调用,加入 MQ 后通过 MQ 进行异步调用。
(消息重复消费?消息丢失?消息传递的顺序?)
· 一致性问题
A 系统处理完业务,通过 MQ 给B、C、D三个系统发消息数据。
如果B系统、C系统处理成功,D系统处理失败。
(消息处理的一致性?)
MQ应用场景
1、生产者不需要从消费者处获得反馈。引入消息队列之前的直接调用,其接口的返回值应该为空,实现异步。 2、容许短暂的数据不一致性 3、解耦、提速、削峰的收益 > 加入MQ、管理MQ的成本
常见的 MQ产品:

也有使用 Redis 实现 MQ 的案例。