RabbitMQ报错

RabbitMQ报错 RabbitMQ报错本

前言
这里主要收集一些我在学习和使用RabbitMQ时遇到的一些报错。
持续更新中

1.队列类型不匹配

报错信息：inequivalent arg ‘durable’ for queue ‘simple.queue’ in vhost ‘/’: received ‘false’ but current is ‘true’

报错场景：使用Springboot注解创建队列后，再次使用原生API创建队列并发送消息。
解决方案：UI界面上删除给队列

//AMQP创建队列，名称为simple.queue
@RabbitListener(queuesToDeclare = @Queue("simple.queue"))
     public void listenSimpleQueue(String msg) {
         System.out.println("消费者接收到simple.queue的消息：【" + msg + "】");
     }

//使用原生API再次创建队列
String queueName = "simple.queue";
channel.queueDeclare(queueName, false, false, false, null);
//queueDeclare的第二个参数表示的是durable，即需不需要进行持久化，这里是false

根据报错信息，你也知道怎么回事了，就是我们已经创建了这个队列并进行了持久化，而你现在发送消息进来发送的是给为持久化的，你觉得这合理吗？它能不报错吗？

那为什么他会创建持久类型的呢，我们看源码

你看不懂？没关系。翻译给你看：

指定此队列是否应该是持久的。默认情况下，如果提供了队列名称，则它是持久的。 @return true 如果队列被声明为持久的。 @see org.springframework.amqp.core.QueueisDurable()

ok解释清楚了。问题解决
补充一下吧，删除队列在这个位置