【RabbitMq(一)】 初相识
1、为什么引入MQ(消息队列)
解决服务之间数据同步的问题,每个服务的基本数据都有自己存储的地方,当一个服务的数据 变化的时候,其他的服务数据应该也会跟着变化,如果用代码来做约束了,违背了服务的独立的原则,此时引入技术MQ
2、MQ简介
MQ是典型的生产者、消费者模型,生产者负责向消息队列中生产消息,消费者从队列中获取消息,然后笑死的生产和消费都是异步的,这样消费者和生产者就实现了解耦合,现在实现MQ有两种主流的方式:AMQP、JMS。
AMQP(高级消息队列协议)不受开发语言的限制。它是跨语言的
JMS(java 消息服务) 实际上是JMS API,专门用于java语言的
3、常见的MQ产品
- ActiveMQ:基于JMS
- RabbitMQ:基于AMQP协议,erlang语言开发,稳定性好
- RocketMQ:基于JMS,阿里巴巴产品,目前交由Apache基金会
- Kafka:分布式消息系统,高吞吐量 (常见于大数据领域)
4、RabbitMQ 导图
5、如何避免信息丢失
(1)消费者的手动ACK机制,可以防止消费者丢失信息
(2)如果消费者消费之前,MQ宕机,消息就没了,引入持久化,对队列、Exchange、消息进行持久化,但是性能会降低,此时需要对数据安全和性能进行分析评估,取舍
6、推荐博文
https://blog.****.net/chizizhixin/article/details/78488735