spring.application.name=spring-boot-rabbitmq
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=nut
spring.rabbitmq.password=nut

/*** 延迟队列配置exchange*/
@Configuration
public class DelayQueueConfig {public static final String DELAY_EXCHANGE = "DELAY_EXCHANGE";public static final String DELAY_QUEUE = "DELAY_QUEUE";public static final String DELAY_ROUTING_KEY = "DELAY_ROUTING_KEY";@Bean("delayExchange")public Exchange delayExchange() {Map<String, Object> args = new HashMap<>(1);
//       x-delayed-type    声明 延迟队列Exchange的类型args.put("x-delayed-type", "direct");return new CustomExchange(DELAY_EXCHANGE, "x-delayed-message",true, false,args);}@Bean("delayQueue")public Queue delayQueue() {return QueueBuilder.durable(DELAY_QUEUE).build();}/*** 将延迟队列通过routingKey绑定到延迟交换器** @return*/@Beanpublic Binding delayQueueBindExchange() {return new Binding(DELAY_QUEUE, Binding.DestinationType.QUEUE, DELAY_EXCHANGE, DELAY_ROUTING_KEY, null);}}

/*** 延迟队列发送者*/
@Component
@Slf4j
public class DelayQueueSender {@Autowiredprivate RabbitTemplate rabbitTemplate;public void sendDelayQueue(int number) {log.warn("延迟队列发送 : {} milliseconds", number);// 这里的Exchange可以是业务的Exchange，为了方便测试这里直接往死信Exchange里投递消息
        rabbitTemplate.convertAndSend(DelayQueueConfig.DELAY_EXCHANGE,DelayQueueConfig.DELAY_ROUTING_KEY,number, (message) -> {// 设置延迟的毫秒数message.getMessageProperties().setDelay(number);log.info("Now : {}", ZonedDateTime.now());return message;});}
}

/*** 延迟队列消费者*/
@Component
@Slf4j
@RabbitListener(queues = DelayQueueConfig.DELAY_QUEUE)
public class DelayQueueConsumer {@RabbitHandlerpublic void receiveDelayMessage(Integer milliseconds){log.warn("DelayQueueConsumer Time : {}， and the millis : {}", ZonedDateTime.now(), milliseconds);}}

@RunWith(SpringRunner.class)
@SpringBootTest
public class RabbitmqApplicationTests {@Autowiredprivate DelayQueueSender delayQueueSender;@Testpublic void testDelayQueueSender(){delayQueueSender.sendDelayQueue(5000);}
}