文章目录
- 1.RabbitMQ 核心组件及功能详解
- 2.RabbitMQ-如何保证消息不丢失?
- 3.RabbitMQ消息的重复消费问题如何解决的？
- 4.RabbitMQ中死信交换机 ? (RabbitMQ延迟队列有了解过嘛)
- 5.RabbitMQ如果有100万消息堆积在MQ , 如何解决(消息堆积怎么解决)
- 6.RabbitMQ的高可用机制有了解过嘛
- 7.RabbitMQ如何保证消息的有序性？
- 8.RabbitMQ有哪些消息处理模式（订阅模式或工作模式）?
1.RabbitMQ 核心组件及功能详解
RabbitMQ 核心组件及功能详解
2.RabbitMQ-如何保证消息不丢失?
消息中间件的好处
- 提供了系统之间的异步调用，让服务与服务之间解耦
- 削峰、填谷
场景：
- 异步发送（验证码、短信、邮件…）
- MySQL和Redis , ES之间的数据同步
- 分布式事务
- 削峰填谷
消息发送者（publisher ）把消息发送给交换机（exchange），由交换机路由到队列，最后由消费者（consumer）进行消费消息。
出现消息丢失的四种情况：
- 消息未到达交换机
- 消息未到达队列
- 队列中消息丢失
- 消费者未接收到消息
生产者确认机制（解决消息未到达交换机、消息未到达队列问题）
RabbitMQ提供了publisher confirm机制来避免消息发送到MQ过程中丢失。消息发送到MQ以后，会返回一个结果（ack）给发送者，表示消息是否处理成功
如果消息发送失败，有两种情况：
- 消息到达交换机失败（publisher-confirm nack）
- 交换机路由到队列失败（publisher-return ack）
消息失败之后如何处理呢？
- 回调方法即时重发（知道哪一个消息发送失败，可以再发）
- 记录日志（如果还是发送失败，可以记录日志，通过查看日志进行补偿）
- 保存到数据库然后定时重发，成功发送后即刻删除表中的数据
如果重发失败了怎么办？
- 一般消息发送失败了，很大几率是服务提供者宕机了或者是MQ宕机了，这两者不可能一直处于宕机状态。
- 如果还是不能解决，需要人工来解决这些问题
消息已经正常发送到队列，但是MQ 宕机了，也会导致消息丢失，该怎么解决？
消息持久化（解决队列中消息丢失问题）
MQ默认是内存存储消息，开启持久化功能可以确保缓存在MQ中的消息不丢失。（MQ宕机或重启后，在内存中的消息肯定会丢失，需要持久化）
1.交换机持久化：
@Bean
public DirectExchange simpleExchange(){
// 三个参数：交换机名称、是否持久化、当没有queue与其绑定时是否自动删除
return new DirectExchange("simple.direct", true, false);
}
2.队列持久化：
@Bean
public Queue simpleQueue(){
// 使用QueueBuilder构建队列，durable就是持久化的
return QueueBuilder.durable("simple.queue").build();
}
3.消息持久化，SpringAMQP中的的消息默认是持久的，可以通过MessageProperties中的DeliveryMode来指定的：
Message msg = MessageBuilder
.withBody(message.getBytes(StandardCharsets.UTF_8)) //消息体
.setDeliveryMode(MessageDeliveryMode.PERSISTENT) //持久化
.build()
