RabbitMQ设置消息和队列过期时间（五）

た入场券 2022-09-02 00:50 244阅读 0赞

## 设置消息过期时间 ##

RabbitMQ设置消息的过期时间有两种方式：在队列设置所有消息的过期时间；发送消息的时候设置单个消息的过期时间，每条消息的TTL可以不同。如果两种方式同时使用则以最小时间为准。

### 通过队列设置TTL ###

通过队列设置消息TTL的方法时在channel.queueDeclare的时候添加x-message-ttl参数实现，单位毫秒。

Map<String,Object> map = new HashMap<>();
            map.put("x-message-ttl",2000);
            channel.queueDeclare(queueName,true,false,false,map);
            channel.queueBind(queueName,exchangeName,"ttl.#");
            channel.basicPublish(exchangeName,"ttl.message",null,"我要进入过期队列".getBytes());

### 发送消息的时候设置单条消息的过期时间 ###

发送消息的时候设置消息的过期时间是在channel.basicPublish方法中加入expiration参数，单位毫秒。

AMQP.BasicProperties.Builder builder = new AMQP.BasicProperties.Builder();
            builder.expiration("5000");
            channel.basicPublish(exchangeName,"ttl.message",builder.build(),"我的过期时间时5秒".getBytes());

## 设置队列过期时间 ##

通过channel.queueDeclare方法中的x-expires属性给队列设置被自动删除时间。前提是当前队列没有消费者，也没有被重新声明，并且没有使用channel.basicGet调用。如果在过期时间内有消费者，在消费者断开之后会重置过期时间。

Map<String, Object> map = new HashMap<>();
            map.put("x-expires", 20000);
            channel.queueDeclare(queueName, true, false, false, map);
            channel.queueBind(queueName,exchangeName,"expires.#");