springboot整合RabbitMQ中的TTL實(shí)例代碼

第springboot整合RabbitMQ中的TTL實(shí)例代碼importorg.springframework.amqp.core.*;

importorg.springframework.beans.factory.annotation.Qualifier;

importorg.springframework.context.annotation.Bean;

importorg.springframework.context.annotation.Configuration;

importjava.util.HashMap;

*ttl隊(duì)列配置文件類

@Configuration

publicclassTtlQueueConfig{

//普通交換機(jī)名稱

publicstaticfinalStringX_EXCHANGE="X";

//死信交換機(jī)名稱

publicstaticfinalStringY_DEAD_LETTER_EXCHANGE="Y";

//普通隊(duì)列名稱

publicstaticfinalStringQUEUE_A="QA";

publicstaticfinalStringQUEUE_B="QB";

//死信隊(duì)列名稱

publicstaticfinalStringDEAD_LETTER_QUEUE_D="QD";

*聲明x交換機(jī)

*@return

@Bean("xExchange")//別名和方法名取一樣

publicDirectExchangexExchange(){

returnnewDirectExchange(X_EXCHANGE);

*聲明y交換機(jī)

*@return

@Bean("yExchange")//別名和方法名取一樣

publicDirectExchangeyExchange(){

returnnewDirectExchange(Y_DEAD_LETTER_EXCHANGE);

//聲明隊(duì)列A

@Bean("queueA")

publicQueuequeueA(){

finalHashMapString,Objectarguments

=newHashMap();

//設(shè)置死信交換機(jī)

arguments.put("x-dead-letter-exchange",Y_DEAD_LETTER_EXCHANGE);

//設(shè)置死信RoutingKey

arguments.put("x-dead-letter-routing-key","YD");

//設(shè)置TTL設(shè)置10秒過期

arguments.put("x-message-ttl",10000);

returnQueueBuilder.durable(QUEUE_A)

.withArguments(arguments)

.build();

//聲明隊(duì)列B

@Bean("queueB")

publicQueuequeueB(){

HashMapString,Objectarguments

=newHashMap();

//設(shè)置死信交換機(jī)

arguments.put("x-dead-letter-exchange",Y_DEAD_LETTER_EXCHANGE);

//設(shè)置死信RoutingKey

arguments.put("x-dead-letter-routing-key","YD");

//設(shè)置TTL設(shè)置40秒過期

arguments.put("x-message-ttl",40000);

returnQueueBuilder.durable(QUEUE_B)

.withArguments(arguments)

.build();

@Bean("queueD")

publicQueuequeueD(){

returnQueueBuilder.durable(DEAD_LETTER_QUEUE_D)

.build();

*A隊(duì)列綁定X交換機(jī)

*@paramqueueA

*@return

@Bean

publicBindingqueueABindingX(@Qualifier("queueA")QueuequeueA,

@Qualifier("xExchange")DirectExchangexExchange){

returnBindingBuilder.bind(queueA).to(xExchange).with("XA");

*B隊(duì)列綁定X交換機(jī)

*@paramqueueB

*@paramxExchange

*@return

@Bean

publicBindingqueueBBindingX(@Qualifier("queueB")QueuequeueB,

@Qualifier("xExchange")DirectExchangexExchange){

returnBindingBuilder.bind(queueB).to(xExchange).with("XB");

*D隊(duì)列綁定死信y交換機(jī)

*@paramqueueD

*@paramyExchange

*@return

@Bean

publicBindingqueueDBindingX(@Qualifier("queueD")QueuequeueD,

@Qualifier("yExchange")DirectExchangeyExchange){

returnBindingBuilder.bind(queueD).to(yExchange).with("YD");

}

生產(chǎn)者代碼

我們用Controller寫，通過網(wǎng)頁提交的方式生產(chǎn)消息

url：http://localhost:8080/ttl/sendMsg/message

packagecom.xbfinal.springbootrabbitmq.controller;

importlombok.extern.slf4j.Slf4j;

importorg.springframework.amqp.rabbit.core.RabbitTemplate;

importorg.springframework.beans.factory.annotation.Autowired;

importorg.springframework.web.bind.annotation.GetMapping;

importorg.springframework.web.bind.annotation.PathVariable;

importorg.springframework.web.bind.annotation.RequestMapping;

importorg.springframework.web.bind.annotation.RestController;

importjava.util.Date;

*生產(chǎn)者

*發(fā)送延遲消息

@Slf4j

@RestController

@RequestMapping("/ttl")

publicclassSendMsgController{

@Autowired

privateRabbitTemplaterabbitTemplate;

@GetMapping("/sendMsg/{message}")

publicvoidsendMsg(@PathVariableStringmessage){

("當(dāng)前時(shí)