【RabbitMQ】

课程背景

一.初始MQ

1.同步调用

2.异步调用

1.解耦合：如果需要扩展业务，那就扩呗，让扩展的服务去监听消息队列就可以了

2.无需等待：只管发消息，发完就不管了，干别的事去了

3.故障隔离：接收消息的服务故障了，和发消息的无关，你失败了就接着重试就行了，总会成功的

4.流量削峰：当高并发进来时，先缓存在里面，等空闲的时候再去处理

二.快速入门

1.基本介绍

2.快速入门

3.workQueue

4.Fanout交换机（广播）

发一个消息，多个微服务都来监听，只有队列没有交换机的话，被一个消费者消费一次就没了，所以是不行的。

三.生产者

1.可靠性

连接时，失败重连，连接多长时间算超时，属于阻塞式等待

2.确认机制

侧重于消息发送时，mq返回一个结果给生产者，成功还是失败。

1.案例（异步回调）

每一个消息都要有一个自己的id，不能重复

四.MQ的可靠性

MQ自己把消息搞丢了

解决方案

1.数据持久化

消息持久化解决了存储在内存的安全问题，同时解决了page out引起的阻塞。但性能不高。

2.Lazy queue

五.消费者的可靠性

1.确认机制

reject：消息本身就有问题。不断重试还是会有问题。

2.失败重试机制