RabbitMQ常见问题解决方案

RabbitMQ常见问题解决方案

消息丢失问题

1. 生产者丢失消息
2. RabbitMQ弄丢消息
3. 消费者弄丢消息

生产者丢失消息

• 生产者消息没到交换机，相当于生产者弄丢消息
• 交换机没有把消息路由到队列，相当于生产者弄丢消息

对于上面两种情况，我们可以使用异步的监听操作机制来预防

①成功/未成功发送到交换机可以触发一个

confirm-type

监听

②交换机发送到队列会有一个

publisher-returns

监听

在pom文件中引入依赖项后进行配置文件的编写

rabbitmq:
    publisher-returns:true
    publisher-confirm-type: correlated 
#新版本 publisher-confirms:true 已过时

编写配置类

@Configuration@Slf4jpublicclassRabbitMQConfig{
   @AutowiredprivateRabbitTemplate rabbitTemplate;@PostConstructpublicvoidenableConfirmCallback(){
   //confirm 监听，当消息成功发到交换机 ack = true，没有发送到交换机 ack = false//correlationData 可在发送时指定消息唯一 id
        rabbitTemplate.setConfirmCallback((correlationData, ack, cause)->{
   if(!ack){
   //记录日志、发送邮件通知、落库定时任务扫描重发}});//当消息成功发送到交换机没有路由到队列触发此监听
        rabbitTemplate.setReturnsCallback(returned ->{
   //记录日志、发送邮件通知、落库定时任务扫描重发});}}

tips:

对于实际开发中，一般不这样使用，因为丢失的概率很低，成本又很高，一般都采用日志/邮件记录，手动维护

真的极其罕见的是生产者弄丢消息，那么开发往数据库补数据就行了。

RabbitMQ弄丢消息

• RabbitMQ 宕机导致队列、队列中的消息丢失，相当于 RabbitMQ 弄丢消息

解决方法就是设置持久化消息写出磁盘，这样子可以确保RabbitMQ宕机重启后队列和消息不会丢失

持久化操作:

• 交换机持久化
• 队列持久化
• 消息持久化

交换机持久化

@RabbitListener(
        bindings =@QueueBinding(
                value =@Queue(
                    value =