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

设置消息过期时间 【rabbitmq|RabbitMQ设置消息和队列过期时间（五）】RabbitMQ设置消息的过期时间有两种方式：在队列设置所有消息的过期时间；发送消息的时候设置单个消息的过期时间，每条消息的TTL可以不同。如果两种方式同时使用则以最小时间为准。
通过队列设置TTL
通过队列设置消息TTL的方法时在channel.queueDeclare的时候添加x-message-ttl参数实现，单位毫秒。

Map 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 map = new HashMap<>(); map.put("x-expires", 20000); channel.queueDeclare(queueName, true, false, false, map); channel.queueBind(queueName,exchangeName,"expires.#");