springboot+rabbitmq延迟一段时间后再发送到队列

叁歲伎倆 2023-03-01 09:41 3阅读 0赞

**springboot+rabbitmq延迟一段时间后再发送到队列**

**解决方法：**

1.声明队列、交换机

import org.springframework.amqp.core.Binding;

import org.springframework.amqp.core.BindingBuilder;

import org.springframework.amqp.core.DirectExchange;

import org.springframework.amqp.core.Queue;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import java.util.HashMap;

import java.util.Map;

@Configuration

public class DirectRabbitConfig \{

@Bean

public Queue smsWithTimeCacheQueue() \{  //创建缓存队列SmsWithTimeCacheQueue

Map<String, Object> arguments = new HashMap<>();

arguments.put("x-dead-letter-exchange","SmsExchange");//缓存队列过期后，发送消息到对应的交换机SmsExchange上

arguments.put("x-dead-letter-routing-key","SmsRoutingKey");//缓存队列通过SmsRoutingKey，传递到实际消费队列

return new Queue("SmsWithTimeCacheQueue",true,false,false,arguments);

\}

@Bean

public DirectExchange smsWithTimeCacheExchange() \{//创建缓存交换机SmsWithTimeCacheExchange

return new DirectExchange("SmsWithTimeCacheExchange");

\}

@Bean

Binding bingSmsWithTimeCacheQueue() \{//声明SmsWithTimeCacheQueue作为 routingkey 并将其绑定交换机和队列

return BindingBuilder.bind(smsWithTimeCacheQueue()).to(smsWithTimeCacheExchange()).with("SmsWithTimeCacheQueue");

\}

\}

2.发送消息到缓存队列，延迟1分钟发送消息到SmsExchange交换机绑定的队列上请参考：[http://www.yayihouse.com/yayishuwu/chapter/2717][http_www.yayihouse.com_yayishuwu_chapter_2717]

[http_www.yayihouse.com_yayishuwu_chapter_2717]: http://www.yayihouse.com/yayishuwu/chapter/2717

发表评论取消回复

表情：

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

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

相关阅读

相关试用ChatGPT一段时间后

最近半年，互联网一款现象级的应用诞生：「ChatGPT」；其火爆的程度，不输前面的羊了个羊；最初了解到ChatGPT还是春节的时候，但那时网上的测评还没引起足够的好奇心

浅浅的花香味﹌/ 2024年03月22日 13:46/ 0 赞/ 152 阅读

相关 springboot+rabbitmq延迟一段时间后再发送到队列

springboot+rabbitmq延迟一段时间后再发送到队列解决方法： 1.声明队列、交换机 import org.springframework.amqp.

叁歲伎倆/ 2023年03月01日 09:41/ 0 赞/ 4 阅读

相关 arduino向串口发送数据时掉包_经过很长一段时间后，Arduino停止向串口发送数据...

时钟可能会折叠。 previousclock = millis()可能会在折叠前陷入高值。您可以扩展测试以包括(currentmilis＆lt; previousmillis

雨点打透心脏的1/2处/ 2023年01月09日 01:25/ 0 赞/ 31 阅读

相关 SpringBoot 项目中集成RabbitMQ消息队列，发送消息，监听消息,延迟队列

1.添加依赖包 > <dependency> > <groupId>org.springframework.boot</groupId> >

分手后的思念是犯贱/ 2022年11月06日 01:00/ 0 赞/ 288 阅读

相关程序延迟一段时间解决方案

第一种方法： Try\{ Thread.sleep(longmillions); \}catch(InterruptedException e)\{\} 第二种方

我就是我/ 2022年09月25日 14:17/ 0 赞/ 390 阅读

相关 TCP协议过一段时间接不到数据

hello，I‘m Shendi 最近在整TCP代理服务器，在编写完程序进行测试时发现了一个问题当 TCP 连接，客户端和服务端都不发送数据，且都不断开连接的情况下，时

小灰灰/ 2022年09月12日 02:53/ 0 赞/ 181 阅读

相关 SpringCloud-----SpringCloud配置中心运行一段时间后读取不到配置

![70][] [70]: /images/20220511/7591734c6e5f40c597342dbc46fab10b.png

偏执的太偏执、/ 2022年05月11日 00:04/ 0 赞/ 187 阅读

相关消息延迟队列处理拼团时间到期

1.RabbitMqConfig / 延时队列交换机注意这里的交换机类型：CustomExchange

深碍√TFBOYSˉ_/ 2021年09月24日 19:36/ 0 赞/ 333 阅读

相关 RabbitMQ--过期时间TTL、死信队列、延迟队列和优先队列

过期时间TTL TTL，Time to Live的简称，即过期时间。RabbitMQ 可以对消息和队列设置TTL。设置消息的TTL：目前有两种方法可以设置消息的T

淡淡的烟草味﹌/ 2021年08月29日 14:33/ 0 赞/ 743 阅读

相关 ActiveMQ--发送消息到队列、从队列接收消息

JMS编码总体架构 ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9i

清疚/ 2021年08月13日 11:59/ 0 赞/ 957 阅读