首页 > 其他分享 >rabbitmq的consumer_timeout修改

rabbitmq的consumer_timeout修改

时间:2022-11-29 20:46:56浏览次数:48  
标签:720000 rabbitmq 修改 timeout 超时 consumer

问题:

项目中使用了rabbitmq来做异步任务,最近突然发现一个耗时比较长的任务一直在重复执行。

排查:

排查日志后发现了超时,channel关闭。如果超过了consumer_timeout时间默认为180000ms后会断开连接,如果是手动ack,会报错PublisherCallbackChannel is closed

分析:

官网有说在目前支持的所有RabbitMQ版本中,在消费者交付确认时强制执行超时。这有助于检测从不确认交付的有bug(卡住)的消费者。这样的消费者会影响节点在磁盘上的数据压缩,并可能导致节点耗尽磁盘空间。

 

 解决:

  既然是因为超时原因导致的,那么给超时时间加大就可以了。

 1.在etc目录下建一个文件,/etc/rabbitmq.conf,rabbitmq默认不会建这个文件,然后文件里面设置consumer_timeout = 720000(根据需要来决定)。然后重新启动rabbitmq。这种方式会使得rabbitmq短暂不可用不是太友好。

 2.直接动态修改,通过 rabbitmqctl eval 'applicaton:set_env(rabbit,consumer_timeout,720000).'  修改。

3. 修改后通过rabbitmqctl eval 'application:get_env(rabbit,consumer_timeout).' 验证。

标签:720000,rabbitmq,修改,timeout,超时,consumer
From: https://www.cnblogs.com/long757747969/p/16936604.html

相关文章

  • rabbitmq
    title:rabbitmqdate:2022-11-2919:02:37tags:使用pom<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp......
  • Rabbitmq #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no queue ‘
    #method<channel.close>(reply-code=404,reply-text=NOT_FOUND-noqueue‘myQueueDirect‘invhost‘/‘是因为消息发布者queueDeclare方法中传递的exclusive参数传......
  • RabbitMQ帮助类
    一、RabbitMQHelper///<summary>///RabbitMQHelper的摘要说明///</summary>publicclassRabbitMQHelper{//主机privatere......
  • RabbitMQ基础
    1.初识MQ1.1.同步和异步通讯微服务间通讯有同步和异步两种方式:同步通讯:就像打电话,需要实时响应。异步通讯:就像发邮件,不需要马上回复。是你却不能跟多个人同时通话。......
  • Linux 安装RabbitMq
    1、下载Erlang和Rabbithttps://d28dx6y1hfq314.cloudfront.net/828/1039/el/8/package_files/2279064.rpm?t=1669605802_12ad3355a4114c22e9b151acfe4484891078938eh......
  • RabbitMQ 消息队列
    消息队列经过前面的学习,我们已经了解了我们之前的技术在分布式环境下的应用,接着我们来看最后一章的内容。那么,什么是消息队列呢?我们之前如果需要进行远程调用,那么一般......
  • python使用rabbitMQ
    python使用rabbitMQ 生产者消费者模型-------生产者-------------importpikaimportrandom#创建凭证credentials=pika.PlainCredentials('guest','guest')#新......
  • rabbitMQ--基本概念
    MQ的概念优点:1.应用解耦,提升系统容错性和可维护性 图中,假如不加入MQ,如果库存系统宕机,则会导致订单系统宕机,从而导致整个分布式宕机。 2.异步提速,提高系统的吞吐......
  • 《ASP.NET Core技术内幕与项目实战》精简集-DDD准备5.5:集成事件RabbitMQ
     本节内容,部分为补充内容,部分涉及到9.3.10-9.3.12(P335-342)。主要NuGet包:RabbitMQ.Client 微服务间,跨进程的事件发布和订阅,需要借助第三方服务器作为事件总线,目前常......
  • 微服务之RabbitMQ
    同步通讯和异步通讯  微服务基于Feign的调用就属于同步方式,存在一些问题        异步调用方案异步调用常见实现就是事件驱动模式优势一:服务解......