组件注解类#xff1a;

org.springfra…rabbitMQ安装插件rabbitmq-delayed-message-exchange

交换机由此type

org.springframework.amqp.core.*;

import

org.springframework.beans.factory.annotation.Qualifier;

import

org.springframework.context.annotation.Bean;

import

org.springframework.context.annotation.Configuration;import

java.util.HashMap;

delayed.queue;//routingKeypublic

static

HashMap();arguments.put(x-delayed-type,direct);return

new

CustomExchange(DELAYED_EXCHANGE_NAME,x-delayed-message,true,

Queue

QueueBuilder.durable(DELAYED_QUEUE_NAME).build();}Beanpublic

Binding

delayedQueueBindingDelayedExchange(Qualifier(delayedQueue)

Queue

delayedQueue,Qualifier(delayedExchange)

CustomExchange

BindingBuilder.bind(delayedQueue).to(delayedExchange).with(DELAYED_ROUTING_KEY).noargs();}

生产者代码实现

com.esint.controller;//发送延迟消息import

com.esint.configs.DelayedQueueConfig;

import

org.springframework.amqp.rabbit.core.RabbitTemplate;

import

org.springframework.beans.factory.annotation.Autowired;

import

org.springframework.web.bind.annotation.GetMapping;

import

org.springframework.web.bind.annotation.PathVariable;

import

org.springframework.web.bind.annotation.RequestMapping;

import

org.springframework.web.bind.annotation.RestController;import

java.util.Date;Slf4j

rabbitTemplate;GetMapping(/sendDelayMsg/{message}/{delayTime})public

void

delayTime){log.info(当前时间{},发送一条ttl为{}ms的消息给延迟交换机转队列{},new

Date().toString(),delayTime,message);rabbitTemplate.convertAndSend(DelayedQueueConfig.DELAYED_EXCHANGE_NAME,DelayedQueueConfig.DELAYED_ROUTING_KEY,message,

mes-{mes.getMessageProperties().setDelay(delayTime);return

mes;});}}

com.esint.configs.DelayedQueueConfig;

import

org.springframework.amqp.core.Message;

import

org.springframework.amqp.rabbit.annotation.RabbitListener;

import

org.springframework.stereotype.Component;import

java.util.Date;/***

DelayedQueueConfig.DELAYED_QUEUE_NAME)public

void

String(message.getBody());log.info(当前时间{}

收到延迟消息{},new

http://127.0.0.1:19092/ttl/sendDelayMsg/helloDelay1/30000

http://127.0.0.1:19092/ttl/sendDelayMsg/helloDelay2/3000

发送第一条消息helloDelay1