<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId> <!-- 用于接口測試 -->
</dependency>

spring:
  rabbitmq:
    addresses: amqp://study:study@110.41.51.65:5672/bite 
    listener:
      simple:
        acknowledge-mode: manual # 手動確認(rèn)模式，便于觀察消息狀態(tài)

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.FanoutExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.QueueBuilder;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class TtlQueueConfig {
    // 常量：交換機(jī)、隊(duì)列名稱（參考文檔命名）
    public static final String TTL_EXCHANGE_NAME = "ttl_exchange";
    public static final String TTL_QUEUE_WITH_TTL = "ttl_queue2"; // 帶TTL的隊(duì)列
    public static final String TTL_QUEUE_NO_TTL = "ttl_queue"; // 不帶TTL的隊(duì)列（用于對比）
    // 1. 聲明Fanout交換機(jī)（廣播模式，確保消息能被多個隊(duì)列接收）
    @Bean("ttlExchange")
    public FanoutExchange ttlExchange() {
        return FanoutExchangeBuilder.fanoutExchange(TTL_EXCHANGE_NAME)
                .durable(true) // 持久化：服務(wù)重啟后交換機(jī)不丟失
                .build();
    }
    // 2. 聲明帶TTL的隊(duì)列（設(shè)置20秒過期）
    @Bean("ttlQueueWithTtl")
    public Queue ttlQueueWithTtl() {
        // 方式1：使用QueueBuilder.ttl()（文檔推薦，簡潔）
        return QueueBuilder.durable(TTL_QUEUE_WITH_TTL)
                .ttl(20 * 1000) // 20秒過期，單位：毫秒
                .build();
        // 方式2：使用withArguments() //底層方式
        // Map<String, Object> args = new HashMap<>();
        // args.put("x-message-ttl", 20000); // 20秒
        // return QueueBuilder.durable(TTL_QUEUE_WITH_TTL)
        //         .withArguments(args)
        //         .build();
    }
    // 3. 聲明不帶TTL的隊(duì)列（用于對比過期效果）
    @Bean("ttlQueueNoTtl")
    public Queue ttlQueueNoTtl() {
        return QueueBuilder.durable(TTL_QUEUE_NO_TTL)
                .build();
    }
    // 4. 綁定：交換機(jī)與帶TTL的隊(duì)列
    @Bean("bindingWithTtl")
    public Binding bindingWithTtl(
            @Qualifier("ttlExchange") FanoutExchange exchange,
            @Qualifier("ttlQueueWithTtl") Queue queue) {
        return BindingBuilder.bind(queue).to(exchange);
    }
    // 5. 綁定：交換機(jī)與不帶TTL的隊(duì)列
    @Bean("bindingNoTtl")
    public Binding bindingNoTtl(
            @Qualifier("ttlExchange") FanoutExchange exchange,
            @Qualifier("ttlQueueNoTtl") Queue queue) {
        return BindingBuilder.bind(queue).to(exchange);
    }
}

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/producer")
public class TtlProducerController {
    @Autowired
    private RabbitTemplate rabbitTemplate;
    // 發(fā)送消息到TTL交換機(jī)（同時投遞到帶TTL和不帶TTL的隊(duì)列）
    @RequestMapping("/ttl/queue")
    public String sendQueueTtlMessage() {
        String message = "Queue TTL test: " + System.currentTimeMillis();
        // Fanout交換機(jī)無需指定routingKey，設(shè)為空字符串
        rabbitTemplate.convertAndSend(TtlQueueConfig.TTL_EXCHANGE_NAME, "", message);
        return "消息發(fā)送成功（隊(duì)列級TTL）：" + message;
    }
}

import org.springframework.amqp.core.MessagePostProcessor;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/producer")
public class TtlProducerController {
    @Autowired
    private RabbitTemplate rabbitTemplate;
    // 發(fā)送消息級TTL的消息（10秒過期）
    @RequestMapping("/ttl/message")
    public String sendMessageTtlMessage() {
        String message = "Message TTL test: " + System.currentTimeMillis();
        String ttlTime = "10000"; // 10秒過期，單位：毫秒（必須為字符串）
        // 通過MessagePostProcessor設(shè)置消息的expiration屬性
        rabbitTemplate.convertAndSend(
                TtlQueueConfig.TTL_EXCHANGE_NAME, 
                "", 
                message,
                messagePostProcessor -> {
                    // 設(shè)置消息過期時間
                    messagePostProcessor.getMessageProperties().setExpiration(ttlTime);
                    return messagePostProcessor;
                }
        );
        return "消息發(fā)送成功（消息級TTL）：" + message;
    }
}

// 發(fā)送TTL=0的消息
@RequestMapping("/ttl/zero")
public String sendTtlZeroMessage() {
    String message = "TTL=0 test: " + System.currentTimeMillis();
    rabbitTemplate.convertAndSend(
            TtlQueueConfig.TTL_EXCHANGE_NAME,
            "",
            message,
            msgPostProcessor -> {
                msgPostProcessor.getMessageProperties().setExpiration("0"); // TTL=0
                return msgPostProcessor;
            }
    );
    return "TTL=0消息發(fā)送完成（無消費(fèi)者則丟棄）";
}

// 為帶TTL的隊(duì)列綁定死信交換機(jī)
@Bean("ttlQueueWithDlx")
public Queue ttlQueueWithDlx() {
    return QueueBuilder.durable("ttl_queue_with_dlx")
            .ttl(20000) // 20秒過期
            .deadLetterExchange("dlx_exchange") // 綁定死信交換機(jī)
            .deadLetterRoutingKey("dlx.routing.key") // 死信路由鍵
            .build();
}