过期时间（TTL）

RabbitMQ 可以对消息和队列设置过期时间（TTL，全称 Time To Live）。目前有两种方法可以设置过期时间：

第一种方法是通过队列属性设置，队列中所有消息都有相同的过期时间。
第二种方法是对消息进行单独设置，每条消息的过期时间可以不同。

如果同时设置队列和消息的过期时间，则消息的过期时间以两者之间过期时间较小的那个数值为准。消息在队列的生存时间一旦超过设置的过期时间值，就成为“死信”（Dead Message），消费者将无法再收到该消息。

设置消息TTL

方式一：通过消息属性

如果需要为每条消息单独设置过期时间，则可以使用信道（Channel）的 channel.basicPublish() 方法，通过往 AMQP.BasicProperties 属性中添加 expiration 属性来实现（单位：毫秒）。代码如下：

// 创建连接
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("127.0.0.1");
factory.setPort(5672);
Connection connection = factory.newConnection();

// 创建信道
Channel channel = connection.createChannel();

// 声明交换器
System.out.println("[Sender] Send Message...");
channel.exchangeDeclare(EXCHANGE_NAME, "topic");

// 发送消息
AMQP.BasicProperties properties = new AMQP.BasicProperties.Builder()
        .deliveryMode(2) // 持久化消息
        .expiration("6000") // 设置过期时间为 6 秒
        .build();

channel.basicPublish(EXCHANGE_NAME, "www.hxstrive.com",
        properties, "ttl message".getBytes());
System.out.println("[Sender] message = “ttl message”");

// 关闭连接
channel.close();
connection.close();

运行上面代码，然后打开 RabbitMQ 管理界面，查看队列的消息，等待 6 秒钟后消息将会自动删除。

方法二：通过队列属性

在声明队列的时候通过队列属性设置消息过期时间的方法是在 channel.queueDeclare() 方法中加入 x-message-ttl 参数实现，参数单位是毫秒。示例代码如下：

// 创建连接
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("127.0.0.1");
factory.setPort(5672);
Connection connection = factory.newConnection();

// 创建信道
Channel channel = connection.createChannel();

// 声明交换器
channel.exchangeDeclare(EXCHANGE_NAME, "topic");

// 声明队列
Map<String,Object> argss =new HashMap<String,Object>() ;
argss.put("x-message-ttl", 6000); // 设置过期时间为 6 秒
channel.queueDeclare(QUEUE_NAME, true, false, true, argss) ;
channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "*.hxstrive.com");

// 发送消息
System.out.println("[Sender] Send Message...");
channel.basicPublish(EXCHANGE_NAME, "www.hxstrive.com",
        null, "ttl message".getBytes());
System.out.println("[Sender] message = “ttl message”");

// 关闭连接
channel.close();
connection.close();

运行上面代码，然后打开 RabbitMQ 管理界面，查看队列的消息，等待 6 秒钟后消息将会自动删除。

设置队列TTL

队列的过期时间，可通过 channel.queueDeclare() 方法中的 x-expires 参数控制队列被自动删除前处于未使用状态的时间。未使用的意思是队列上没有任何的消费者，队列也没有被重新声明，并且在过期时间段内也未调用过 Basic.Get 命令。

设置队列里的过期时间可以应用于类似 RPC 方式的回复队列。在 RPC 中，许多队列会被创建出来，但是却是未被使用的。

RabbitMQ 会确保在过期时间到达后将队列删除，但是不能保证队列会被及时删除。在 RabbitMQ 重启后，持久化的队列的过期时间会被重新计算。

注意：x-expires 参数以毫秒为单位，不能设置为 0。如果将 x-expires 参数设置为 6000，则表示该队列如果在 6 秒钟之内未使用则会被删除。

示例代码如下：

// 创建连接
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("127.0.0.1");
factory.setPort(5672);
Connection connection = factory.newConnection();

// 创建信道
Channel channel = connection.createChannel();

// 声明交换器
channel.exchangeDeclare(EXCHANGE_NAME, "topic");

// 声明队列
Map<String,Object> argss =new HashMap<String,Object>() ;
argss.put("x-expires", 6000); // 设置过期时间为 6 秒
channel.queueDeclare(QUEUE_NAME, true, false, false, argss) ;
channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "*.hxstrive.com");

// 关闭连接
channel.close();
connection.close();

运行上面代码，将声明了一个交换器和一个队列，然后通过“*.hxstrive.com”绑定键将队列绑定到该交换器上面。然后，通过 RabbitMQ 管理界面查看队列情况。

点击查看完整示例：