消息 TTL 过期（消息生存时间过期）

消息生存时间过期就是说给消息设置一个生存时间，假如是10s那么10秒后消息就过期了，这个消息就变成了死信。大部分代码都是引用的上一章的代码rabbitMq 死信队列（一）消息被拒绝成为死信

消息消费者C1编写

public class CustomerOne {
    /**
     * 普通交换机
     */
    public static final String NORMAL_EXCHANGE="normal_exchange";
    /**
     * 死信交换机
     */
    public static final String DEAD_EXCHANGE="dead_exchange";
    /**
     * 普通队列
     */
    public static final String NORMAL_QUEUE="normal_queue";
    /**
     * 死信队列
     */
    public static final String DEAD_QUEUE="dead_queue";

    public static void main(String[] args) throws Exception{
        Channel channel = RabbitMqUtils.getChannel();
        // 声明普通交换机
        channel.exchangeDeclare(NORMAL_EXCHANGE, BuiltinExchangeType.DIRECT);
        // 声明死信交换机
        channel.exchangeDeclare(DEAD_EXCHANGE,BuiltinExchangeType.DIRECT);
        // 普通队列相关参数
        Map<String, Object> arguments=new HashMap<>(16);
        // 消息成为死信交换机
        arguments.put("x-dead-letter-exchange",DEAD_EXCHANGE);
        // 设置死信routingKey
        arguments.put("x-dead-letter-routing-key","lisi");
        // 设置队列消息存在时间
         arguments.put("x-message-ttl",10000);
        // 声明普通队列
        channel.queueDeclare(NORMAL_QUEUE,false,false,false,arguments);
        // 绑定普通交换机
        channel.queueBind(NORMAL_QUEUE,NORMAL_EXCHANGE,"zhangsan");
        // 声明死信队列
        channel.queueDeclare(DEAD_QUEUE,false,false,false,null);
        // 绑定死信交换机
        channel.queueBind(DEAD_QUEUE,DEAD_EXCHANGE,"lisi");
        System.out.println("消息的接收.......");
        DeliverCallback deliverCallback = (String consumerTag, Delivery message) -> {
            String msg = new String(message.getBody());
            if("".equals(msg)){
                System.out.println("此消息被拒绝了 "+msg);
                /**
                 * 拒绝消息
                 * 1.消息的id
                 * 2.是否放回队列
                 */
                channel.basicReject(message.getEnvelope().getDeliveryTag(),false);
            }else {
                System.out.println("消息消费: "+msg);
                channel.basicAck(message.getEnvelope().getDeliveryTag(),false);
            }
        };
        CancelCallback cancelCallback=(consumerTag)->{
            System.out.println("消息消费被中断");
        };
        channel.basicConsume(NORMAL_QUEUE,false,deliverCallback,cancelCallback);
    }
}

上边这是在消息的消费端设置的消息生存时间，也可以在消费端设置消息的生存时间效果是一样的，添加相关的代码如下

启动项目

启动消息消费者C1构建相关的队列和交换机，然后启动消息的生产者，发现普通队列中有10条消息

10秒之后消息都没有了

死信队列中有10条消息，说明消息都变为了死信消息进入了死信队列