文档建议反馈控制台
首页
学习
活动
专区
圈层
工具
MCP广场
文章/答案/技术大牛
发布
首页
学习
活动
专区
圈层
工具
MCP广场
返回腾讯云官网
社区首页 >问答首页 >Spring AMQP RabbitListener调整自动重连配置

问Spring AMQP RabbitListener调整自动重连配置
EN

Stack Overflow用户
提问于 2020-05-27 21:50:54
回答 1查看 991关注 0票数 2

我正在尝试更好地理解当代理关闭&恢复时的RabbitListener行为。我在localhost:6672上的docker容器中设置了一只兔子，并创建了一个简单的spring boot应用程序来监听消息。还将application.yml配置为指向这只兔子。

代码语言：javascript
运行
复制
        @RabbitListener(containerFactory = "myListenerContainerFactory", 
                bindings = @QueueBinding(value = @Queue(value = "MY_QUEUE"), exchange = @Exchange(value = "MY_EXCHANGE"), key = "MY_KEY"))
        public void onMessage(final Mesg message) {
            //some handling
        }

还定义了下面的容器工厂

代码语言：javascript
运行
复制
    @Bean
    public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory cf) {
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(cf);
        factory.setMessageConverter(new Jackson2JsonMessageConverter());
        factory.setDefaultRequeueRejected(false);
        factory.setConsumerTagStrategy(q -> "My App");
        return factory;
    }

在rabbit容器运行时，我启动了spring boot应用程序&它能够自动创建交换/队列&能够使用我通过rabbit管理控制台发布的消息。当spring boot应用程序运行时，我强行删除了兔子容器(docker rm my_instance -f)，它开始打印以下消息。

代码语言：javascript
运行
复制
2020-05-26 17:03:15.097 ERROR 26816 --- [ 127.0.0.1:6672]  o.s.a.r.c.CachingConnectionFactory       : Channel shutdown: connection error
2020-05-26 17:03:15.614  INFO 26816 --- [cTaskExecutor-1]  o.s.a.r.l.SimpleMessageListenerContainer : Restarting Consumer@69176296: tags=[[My App]], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:6672/,1), conn: Proxy@522c56e8 Shared Rabbit Connection: SimpleConnection@7578dfd0 [delegate=amqp://guest@127.0.0.1:6672/, localPort= 65342], acknowledgeMode=AUTO local queue size=0
2020-05-26 17:03:15.618  INFO 26816 --- [cTaskExecutor-2]  o.s.a.r.c.CachingConnectionFactory       : Attempting to connect to: localhost:6672
2020-05-26 17:03:22.662  WARN 26816 --- [cTaskExecutor-2]  o.s.a.r.l.SimpleMessageListenerContainer : Consumer raised exception, processing can restart if the connection factory supports it. Exception summary: org.springframework.amqp.AmqpConnectException: java.net.ConnectException: Connection refused: connect
2020-05-26 17:03:22.663  INFO 26816 --- [cTaskExecutor-2]  o.s.a.r.l.SimpleMessageListenerContainer : Restarting Consumer@31978e0c: tags=[[]], channel=null, acknowledgeMode=AUTO local queue size=0
2020-05-26 17:03:22.663  INFO 26816 --- [cTaskExecutor-3]  o.s.a.r.c.CachingConnectionFactory       : Attempting to connect to: localhost:6672
2020-05-26 17:03:29.683  WARN 26816 --- [cTaskExecutor-3]  o.s.a.r.l.SimpleMessageListenerContainer : Consumer raised exception, processing can restart if the connection factory supports it. Exception summary: org.springframework.amqp.AmqpConnectException: java.net.ConnectException: Connection refused: connect

在再次启动rabbit容器之后，spring boot app似乎检测到了它，但是它打印了以下消息&我认为它没有建立成功的连接。查看日志，默认情况下似乎设置了3次重试，有没有可以用来增加限制的配置？

有没有关于处理这类情况的最佳实践？我的应用程序预计会连接到不同的rabbit集群，其中之一可能会继续维护&我需要一种方法来在rabbit集群备份后立即自动重新连接。

代码语言：javascript
运行
复制
2020-05-26 17:05:18.303  INFO 26816 --- [TaskExecutor-19]  o.s.a.r.l.SimpleMessageListenerContainer : Restarting Consumer@5053bc3c: tags=[[]], channel=null, acknowledgeMode=AUTO local queue size=0
2020-05-26 17:05:18.306  INFO 26816 --- [TaskExecutor-20]  o.s.a.r.c.CachingConnectionFactory       : Attempting to connect to: localhost:6672
2020-05-26 17:05:18.348  INFO 26816 --- [TaskExecutor-20]  o.s.a.r.c.CachingConnectionFactory       : Created new connection: myConnectionFactory#ebfe707:19/SimpleConnection@19d03268 [delegate=amqp://guest@127.0.0.1:6672/, localPort= 49260]
2020-05-26 17:05:18.396  WARN 26816 --- [TaskExecutor-20]  o.s.a.r.listener.BlockingQueueConsumer   : Failed to declare queue: MY_QUEUE
2020-05-26 17:05:18.402  WARN 26816 --- [TaskExecutor-20]  o.s.a.r.listener.BlockingQueueConsumer   : Queue declaration failed; retries left=3

org.springframework.amqp.rabbit.listener.BlockingQueueConsumer$DeclarationException: Failed to declare queue(s):[MY_QUEUE]
    at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.attemptPassiveDeclarations(BlockingQueueConsumer.java:710) ~[spring-rabbit-2.1.4.RELEASE.jar:2.1.4.RELEASE]
    at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.passiveDeclarations(BlockingQueueConsumer.java:594) ~[spring-rabbit-2.1.4.RELEASE.jar:2.1.4.RELEASE]
    at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start(BlockingQueueConsumer.java:581) ~[spring-rabbit-2.1.4.RELEASE.jar:2.1.4.RELEASE]
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.initialize(SimpleMessageListenerContainer.java:1196) ~[spring-rabbit-2.1.4.RELEASE.jar:2.1.4.RELEASE]
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1041) ~[spring-rabbit-2.1.4.RELEASE.jar:2.1.4.RELEASE]
    at java.base/java.lang.Thread.run(Thread.java:834) ~[na:na]
Caused by: java.io.IOException: null
    at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:126) ~[amqp-client-5.4.3.jar:5.4.3]
    at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:122) ~[amqp-client-5.4.3.jar:5.4.3]
    at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:144) ~[amqp-client-5.4.3.jar:5.4.3]
    at com.rabbitmq.client.impl.ChannelN.queueDeclarePassive(ChannelN.java:1006) ~[amqp-client-5.4.3.jar:5.4.3]
    at com.rabbitmq.client.impl.ChannelN.queueDeclarePassive(ChannelN.java:52) ~[amqp-client-5.4.3.jar:5.4.3]
    at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:na]
    at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:na]
    at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:na]
    at java.base/java.lang.reflect.Method.invoke(Method.java:566) ~[na:na]
    at org.springframework.amqp.rabbit.connection.CachingConnectionFactory$CachedChannelInvocationHandler.invoke(CachingConnectionFactory.java:1110) ~[spring-rabbit-2.1.4.RELEASE.jar:2.1.4.RELEASE]
    at com.sun.proxy.$Proxy283.queueDeclarePassive(Unknown Source) ~[na:na]
    at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.attemptPassiveDeclarations(BlockingQueueConsumer.java:689) ~[spring-rabbit-2.1.4.RELEASE.jar:2.1.4.RELEASE]
    ... 5 common frames omitted
Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no queue 'MY_QUEUE' in vhost '/', class-id=50, method-id=10)
    at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:66) ~[amqp-client-5.4.3.jar:5.4.3]
    at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:36) ~[amqp-client-5.4.3.jar:5.4.3]
    at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:494) ~[amqp-client-5.4.3.jar:5.4.3]
    at com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:288) ~[amqp-client-5.4.3.jar:5.4.3]
    at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:138) ~[amqp-client-5.4.3.jar:5.4.3]
    ... 14 common frames omitted
Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no queue 'MY_QUEUE' in vhost '/', class-id=50, method-id=10)
    at com.rabbitmq.client.impl.ChannelN.asyncShutdown(ChannelN.java:516) ~[amqp-client-5.4.3.jar:5.4.3]
    at com.rabbitmq.client.impl.ChannelN.processAsync(ChannelN.java:346) ~[amqp-client-5.4.3.jar:5.4.3]
    at com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:178) ~[amqp-client-5.4.3.jar:5.4.3]
    at com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:111) ~[amqp-client-5.4.3.jar:5.4.3]
    at com.rabbitmq.client.impl.AMQConnection.readFrame(AMQConnection.java:670) ~[amqp-client-5.4.3.jar:5.4.3]
    at com.rabbitmq.client.impl.AMQConnection.access$300(AMQConnection.java:48) ~[amqp-client-5.4.3.jar:5.4.3]
    at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:597) ~[amqp-client-5.4.3.jar:5.4.3]
    ... 1 common frames omitted

2020-05-26 17:05:23.420  WARN 26816 --- [TaskExecutor-20]  o.s.a.r.listener.BlockingQueueConsumer   : Failed to declare queue: MY_QUEUE
2020-05-26 17:05:23.425  WARN 26816 --- [TaskExecutor-20]  o.s.a.r.listener.BlockingQueueConsumer   : Queue declaration failed; retries left=2
rabbitmq
spring-amqp
spring-rabbit
EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2020-05-27 22:40:51

代码语言：javascript
运行
复制
 reply-text=NOT_FOUND - no queue 'MY_QUEUE' in vhost '/'

您有一个声明为auto-delete的MY_QUEUE，并且在建立连接期间看起来没有重新创建它。考虑将其作为bean，并让RabbitAdmin在重新连接时处理其创建。

欲了解更多信息，请访问：https://docs.spring.io/spring-amqp/docs/2.2.7.RELEASE/reference/html/#broker-configuration

票数 2
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：

https://stackoverflow.com/questions/62044758

复制
相关文章

相似问题

领券

腾讯云开发者

扫码关注腾讯云开发者

扫码关注腾讯云开发者

领取腾讯云代金券

热门产品

热门推荐

更多推荐

Copyright © 2013 - 2025 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有 

深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 深公网安备号 44030502008569

腾讯云计算（北京）有限责任公司 京ICP证150476号 |  京ICP备11018762号 | 京公网安备号11010802020287

问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档