栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

RabbitMQ报错

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

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解释清楚了。问题解决
补充一下吧,删除队列在这个位置

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/659412.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号