RabbitMq queue异常导致consumer停止

偶发性rabbitmq出问题或者认为操作错误，访问不了queue，导致消费端停止消费

org.springframework.amqp.rabbit.listener.QueuesNotAvailableException: Cannot prepare queue for listener. Either the queue doesn't exist or the broker will not allow us to use it.at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start(BlockingQueueConsumer.java:599)at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1424)at java.lang.Thread.run(Thread.java:745)
Caused by: org.springframework.amqp.rabbit.listener.BlockingQueueConsumer$DeclarationException: Failed to declare queue(s):[s.message.like.add]at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.attemptPassiveDeclarations(BlockingQueueConsumer.java:672)at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start(BlockingQueueConsumer.java:571)... 2 common frames omitted
Caused by: java.io.IOException: nullat com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:105)at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:101)at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:123)at com.rabbitmq.client.impl.ChannelN.queueDeclarePassive(ChannelN.java:992)at com.rabbitmq.client.impl.ChannelN.queueDeclarePassive(ChannelN.java:50)at sun.reflect.GeneratedMethodAccessor711.invoke(Unknown Source)at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)at java.lang.reflect.Method.invoke(Method.java:498)at org.springframework.amqp.rabbit.connection.CachingConnectionFactory$CachedChannelInvocationHandler.invoke(CachingConnectionFactory.java:980)at com.sun.proxy.$Proxy231.queueDeclarePassive(Unknown Source)at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.attemptPassiveDeclarations(BlockingQueueConsumer.java:651)... 3 common frames omitted
Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - failed to perform operation on queue 'q.hell' in vhost '/' due to timeout, class-id=50, method-id=10)at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:66)at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:32)at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:366)at com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:229)at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:117)... 11 common frames omitted
Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - failed to perform operation on queue 's.message.like.add' in vhost '/' due to timeout, class-id=50, method-id=10)at com.rabbitmq.client.impl.ChannelN.asyncShutdown(ChannelN.java:505)at com.rabbitmq.client.impl.ChannelN.processAsync(ChannelN.java:336)at com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:143)at com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:90)at com.rabbitmq.client.impl.AMQConnection.readFrame(AMQConnection.java:634)at com.rabbitmq.client.impl.AMQConnection.access$300(AMQConnection.java:47)at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:572)... 1 common frames omittedStopping container from aborted consumer

跟踪

SimpleMessageListenerContainer

catch (QueuesNotAvailableException ex) {logger.error("Consumer received fatal=" + SimpleMessageListenerContainer.this.mismatchedQueuesFatal+ " exception on startup", ex);if (SimpleMessageListenerContainer.this.missingQueuesFatal) {logger.error("Consumer received fatal exception on startup", ex);this.startupException = ex;// Fatal, but no point re-throwing, so just abort.aborted = true;}publishConsumerFailedEvent("Consumer queue(s) not available", aborted, ex);}

SimpleMessageListenerContainer.this.missingQueuesFatal = true 将aborted

查代码跟踪，如下配置设置

import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.boot.autoconfigure.amqp.SimpleRabbitListenerContainerFactoryConfigurer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class RabbitConfiguration {@Beanpublic SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(SimpleRabbitListenerContainerFactoryConfigurer configurer,ConnectionFactory connectionFactory) {SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();//Whether to fail if the queues declared by the container are not available on the broker and/or whether to stop the container if one or more queues are deleted at runtime.factory.setMissingQueuesFatal(false);configurer.configure(factory, connectionFactory);return factory;}}

至此涉及queue访问失败场景会一直重试直到可用，默认5次

RabbitMq queue异常导致consumer停止相关推荐

RabbitMQ 连接异常导致容器中的SpringBoot 项目退出问题分析
1.首先描述一下问题: 今日在开发环境提测时,发现了部署在容器中的后台服务一直在重新启动,导致无法提供服务. 2.项目背景采用了 Springboot+nacos,消息中心使用mq,使用依赖 // ...
从源码角度分析RabbitMQ重启后，消费者停止消费怎么解决
前段时间的RabbitMQ broker服务端由于某个队列一直积压消息,运维在凌晨对mq服务端机器pod进行了扩容,重启了RabbitMQ,然后早上发现自己的服务在mq重启之后一直报异常,停止消费了, ...
Celery多个定时任务使用RabbitMQ,Queue冲突解决
Celery多个定时任务使用RabbitMQ,Queue冲突解决一. 场景描述使用celery实现定时任务后,任务会被定时添加到后端指定的队列里,队列可以是RabbitMQ,也可以是redis. ...
一、RabbitMQ初使用（Consumer）
RabbieMQ使用过程中的小问题在rabbitmq的使用过程中,记录一些自己的使用问题因为在我当前的项目中,我只是一个独立的分析jar,各位看官按自己需求修改首先是pom引用: <dep ...
关于线程池运行过程中，业务逻辑出现未知异常导致线程中断问题反思
最近在项目研发中的关于线程池应用过程中由于业务逻辑异常导致的线程中断,但程序未中断导致的脏数据问题话不多说,在最近最新的一个版本发布过程中,业务需要,我们要定期去给客户预留出可用的资源数据,提供客 ...
解决android 异常导致应用程序停止运行的错误
(一) 前言各位亲爱的午饭童鞋,是不是经常因为自己的程序中出现未层捕获的异常导致程序异常终止而痛苦不已?嗯,是的.. 但是,大家不要怕,今天给大家分享一个东东可以解决大家这种困扰,吼吼! (二) U ...
java启动RabbitMQ消息报异常解决办法
java启动RabbitMQ消息报异常解决办法参考文章: (1)java启动RabbitMQ消息报异常解决办法 (2)https://www.cnblogs.com/meilibao/p/11357 ...
Chrome浏览器对统一资源发出多个请求时，导致最多停止20s问题
Chrome浏览器对统一资源发出多个请求时,导致最多停止20s问题 Chrome浏览器对统一资源发出多个请求时,导致最多停止20s问题使用环境: 问题描述: 解决方案: 永久: 临时: 参考文档主要 ...
为什么开软件计算机停止工作原理,出现一个问题,导致程序停止正常工作请关闭该程序...
出现一个问题,导致程序停止正常工作请关闭该程序internet explorer已停止工作,出现了一个问题,导致程序停止正常工作.请关闭该程序遇到这个问题,不知道有没有软件的错误日志. 出现一个问题 ...

RabbitMq queue异常导致consumer停止

跟踪

RabbitMq queue异常导致consumer停止相关推荐

最新文章

热门文章