Springboot ActiveMQ 消息重发延迟时间坑记

你的名字 2022-11-29 11:57 140阅读 0赞

正确配置：

@Bean
        public RedeliveryPolicy redeliveryPolicy(){
            RedeliveryPolicy  redeliveryPolicy=   new RedeliveryPolicy();
            //是否在每次尝试重新发送失败后,增长这个等待时间
            redeliveryPolicy.setUseExponentialBackOff(true);
            //重发次数,默认为6次   
            redeliveryPolicy.setMaximumRedeliveries(3);
            //重发时间间隔,默认为1秒 ！！！！ 
            redeliveryPolicy.setInitialRedeliveryDelay(2000);
            //第一次失败后重新发送之前等待2000毫秒,第二次失败再等待2000 * 2毫秒,这里的2就是value
            redeliveryPolicy.setBackOffMultiplier(2);
            //是否避免消息碰撞
            redeliveryPolicy.setUseCollisionAvoidance(false);
            //设置重发最大拖延时间-1 表示没有拖延只有UseExponentialBackOff(true)为true时生效
            redeliveryPolicy.setMaximumRedeliveryDelay(-1);
            return redeliveryPolicy;
        }

# **坑点,这个延迟时间属性设置时****毫秒****级别，****别再** **人传人 设置一个 个位数 了：**   ![20200820143524877.png][] #

消费失败时，自动延迟重发，可以看到延迟秒数生效：

![20200820143447702.png][]

[20200820143524877.png]: /images/20221124/6b7405674eee4b689f42579a00a48e85.png
[20200820143447702.png]: /images/20221124/df9420ecd7ef445ca6b3783b5aef5db7.png

发表评论取消回复

表情：

评论列表（有 0 条评论，140人围观）

还没有评论，来说两句吧...

相关阅读

相关 SpringBoot集成MQTT实现消息收发，断线重连

开始研究JAVA及MQTT，写下该文章方便使用参考 1、添加依赖 pom.xml <dependency> <groupId>org.springf

秒速五厘米/ 2023年10月15日 15:46/ 0 赞/ 59 阅读

相关 springboot整合activemq接收消息

1、在pom.xml中添加依赖包  <dependency> <grou

痛定思痛。/ 2023年06月24日 08:16/ 0 赞/ 17 阅读

相关 springboot整合activemq发送消息

1、启动activemq，并进入MQ的消息队列 ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text

左手的ㄟ右手/ 2023年06月24日 08:15/ 0 赞/ 16 阅读

相关 SpringBoot踩坑记

启动 `WARNING : Your ApplicationContext is unlikely to start due to a @ComponentScan

我会带着你远行/ 2023年06月09日 15:21/ 0 赞/ 34 阅读

相关 ActiveMQ之消息服务器平台【发邮件】

消息服务平台处理公司内部各种消息业务比如发送邮件发送短信微信推送接口有两种类型异步同步 ![cefa35a5a8d77179c80c002d

桃扇骨/ 2022年12月08日 04:27/ 0 赞/ 187 阅读

相关 Springboot ActiveMQ 消息重发延迟时间坑记

正确配置： @Bean public RedeliveryPolicy redeliveryPolicy(){ Red

你的名字/ 2022年11月29日 11:57/ 0 赞/ 140 阅读

相关 activemq延迟发送消费者会实时得到消息

目前的情况是生产端告诉TCP端想要延迟发送 TextMessage message = session.createTextMessage(newsJson); lon

野性酷女/ 2022年06月13日 02:44/ 0 赞/ 168 阅读

相关 Rabbit MQ 发消息例子以及发失败后定时重发

第一步，创建自己交换器名称，交换器模式等信息 import org.slf4j.Logger; import org.springframework.amqp.core.

超、凢脫俗/ 2022年04月01日 06:14/ 0 赞/ 236 阅读

相关 ActiveMQ的消息重发与死信处理

概述在发生以下情形时，消息会给重发给客户端： 1. 使用了一个事务性的会话且调用了rollback()方法。 2. 在调用commit()方法前一个事务性的会话被

亦凉/ 2022年02月22日 16:50/ 0 赞/ 350 阅读

相关 rabbitmq connection lost之后重发消息

在debug一个使用了rabbit的应用程序时，遇到这样一个问题。应用程序收到了rabbitmq的消息，正在处理，由于是debug，应用程序在编辑器里长时间的停留在某个节点，导

拼搏现实的明天。/ 2021年09月21日 08:10/ 0 赞/ 465 阅读