RabbitMQ —— 延迟队列

RabbitMQ实现延迟队列一：在队列上设置TTL

Publish --> delaysync.exchange --> delay.5m.queue(延迟队列) --> delay.exchange --> test.queue(正常队列) --> Consumer

1//延迟队列start
2Map<String,Object> map = new HashMap<String,Object>();
3map.put("x-message-ttl", 10000);//消息过期时间
4map.put("x-max-length", 500000);//最大积压的消息个数
5map.put("x-dead-letter-exchange", "delay.exchange");//消息过期后会投递到delay.exchange
6channel.queueDeclare("delay.5m.queue", true, false, false, map);

RabbitMQ实现延迟队列二：在消息上设置TTL

Publish --> default exchange --> delay_queue(延迟队列) --> amq.direct --> message_ttl_queue(正常队列) --> Consumer

队列：

1//延迟队列
2Map<String,Object> arguments = new HashMap<String,Object>();
3arguments.put("x-dead-letter-exchange", "amq.direct");//消息过期后会投递到amq.direct
4arguments.put("x-dead-letter-routing-key", "message_ttl_routingKey");//出现dead letter之后将重新按照指定的routing-key发送
5channel.queueDeclare("delay_queue", true, false, false, arguments);

消息发送：

1//设置延迟属性
2AMQP.BasicProperties.Builder builder = new AMQP.BasicProperties.Builder();
3//deliveryMode：将消息标记为持久（值为2）或瞬态（任何其他值）
4AMQP.BasicProperties properties = builder.expiration("10000").deliveryMode(2).build();
5channel.basicPublish("", "delay_queue", properties, msg.getBytes());