https://www.bilibili.COM/video/BV15k4y1k7Ep?p=26

https://www.bilibili.com/video/BV15k4y1k7Ep?p=27

<?XMl version="1.0" encoding="UTF-8"?>
<beans xMLns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:rabbit="http://www.springframework.org/schema/rabbit"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
       http://www.springframework.org/schema/context
       https://www.springframework.org/schema/context/spring-context.xsd
       http://www.springframework.org/schema/rabbit
       http://www.springframework.org/schema/rabbit/spring-rabbit.xsd">
    <!--加载配置文件-->
    <context:proPErty-placeholder location="classpath:rabbitmq.properties"/>

    <!-- 定义rabbitmq connectionFactory

        publisher-confirms="true" 消息发送可确认
        publisher-returns="true"
    -->
    <rabbit:connection-factory id="connectionFactory" host="${rabbitmq.host}"
                               port="${rabbitmq.port}"
                               username="${rabbitmq.username}"
                               password="${rabbitmq.password}"
                               virtual-host="${rabbitmq.virtual-host}"
                               publisher-confirms="true"
                               publisher-returns="true"
    />
    <!--定义管理交换机、队列-->
    <rabbit:admin connection-factory="connectionFactory"/>

    <!--定义rabbitTemplate对象操作可以在代码中方便发送消息-->
    <rabbit:template id="rabbitTemplate" connection-factory="connectionFactory"/>

    <rabbit:queue id="ttl-queue" name="confirm-test-queue" >
        <rabbit:queue-arguments>
            <!--  过期时间设置10秒 注意这里要指定类型数字 -->
            <entry key="x-message-ttl" value="10000" value-type="java.lang.Integer" />
        </rabbit:queue-arguments>
    </rabbit:queue>
    <!-- 交换机设置-->
    <rabbit:topic-exchange name="ttl-exchange" >
        <rabbit:bindings>
            <rabbit:binding queue="ttl-queue" pattern="ttl.#"  />
        </rabbit:bindings>
    </rabbit:topic-exchange>
</beans>

    /**
     * 消息存活设置
     */
    @Test
    public void ttlTest() {
        for (int i = 0; i < 10; i++) {
            rabbitTemplate.convertAndSend("ttl-exchange", "ttl.info", "hello ttl timeout test ....");
        }
    }

    /**
     * 消息存活设置
     */
    @Test
    public void ttlTest() {
//        for (int i = 0; i < 10; i++) {
//            rabbitTemplate.convertAndSend("ttl-exchange", "ttl.info", "hello ttl timeout test ....");
//        }

        rabbitTemplate.convertAndSend(
                "ttl-exchange",
                "ttl.info",
                "hello ttl timeout test ....",
                message -> {
                    message.getMessageProperties().setExpiration("60000"); // 消息的过期时间 字符串设置  这个时间不能超过队列销毁的时间
                    return message;
                });
    }