/**
     * 普通交換機(jī)綁定普通交換機(jī)
     *
     * @return
     */
    @Bean
    public Queue queueA() {
        //信息配置
        Map<String, Object> map = new HashMap<>();
        //message在該隊(duì)列queue的存活時(shí)間最大為15秒
        map.put("x-message-ttl", 15000);
        //x-dead-letter-exchange參數(shù)是設(shè)置該隊(duì)列的死信交換器（DLX）
        map.put("x-dead-letter-exchange", "exchangeB");
        //x-dead-letter-routing-key參數(shù)是給這個(gè)DLX指定路由鍵
        map.put("x-dead-letter-routing-key", "queueB");
        return new Queue("queueA", true, false, false, map);
    }
    @Bean
    public DirectExchange exchangeA() {
        return new DirectExchange("exchangeA");
    }
    @Bean
    public Binding bindingA() {
        return BindingBuilder
                .bind(queueA())
                .to(exchangeA()).with("queueA");
    }
    /**
     * 死信交換機(jī)綁定死信交換機(jī)
     *
     * @return
     */
    @Bean
    public Queue queueB() {
        return new Queue("queueB");
    }
    @Bean
    public DirectExchange exchangeB() {
        return new DirectExchange("exchangeB");
    }
    @Bean
    public Binding bindingB() {
        return BindingBuilder
                .bind(queueB())
                .to(exchangeB()).with("queueB");
    }

    @RequestMapping("/send6")
    public String sendSix() throws JsonProcessingException {
        rabbitTemplate.convertAndSend("exchangeA", "queueA", "檢查訂單是否過期");
        return "??";
    }

package com.ycxw.consumer.demos;
import com.rabbitmq.client.Channel;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.support.AmqpHeaders;
import org.springframework.messaging.handler.annotation.Header;
import org.springframework.stereotype.Component;
import java.io.IOException;
@Component
public class DLXReceiver {
    @RabbitListener(queues = {"queueA"})
    @RabbitHandler
    public void handlerA(String msg, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) throws IOException {
        System.out.println("已接受到隊(duì)列queueA傳遞過來的消息：" + msg);
        channel.basicReject(tag, false);// 拒接消息，如果為true則拒絕后又從新回到隊(duì)列被接受（循環(huán)），除非消息過期。
        //channel.basicAck(tag, true); 確認(rèn)消息（）一次性全接受，如果為false則接受一次
    }
    /**
     * 接受死信消息
     *
     * @param msg
     */
    @RabbitListener(queues = {"queueB"})
    @RabbitHandler
    public void handlerB(String msg) {
        /**
         * ...接受到信息，去數(shù)據(jù)庫處理
         */
        System.out.println("已接受到隊(duì)列queueB傳遞過來的消息：" + msg);
    }
}