RabbitMQ高階特性-TTL佇列/訊息
阿新 • • 發佈:2020-06-24
TTL
time to live,即生存時間
RabbitMQ
支援訊息的過期時間,可以在發訊息是指定
RabbitMQ
支援佇列的過期時間,從訊息入隊開始計算,只要超過了佇列的超時時間配置,那麼訊息會自動清除
程式碼
package com.wyg.rabbitmq.javaclient.ttl;
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
/**
* ttl佇列/訊息
*
* @author [email protected]
* @date 2019-11-22 13:25
* @since JDK1.8
* @version V1.0
*/
public class Producer {
private static final String HOST = "localhost";
private static final int PORT = 5672;
private static final String USERNAME = "guset";
private static final String PASSWORD = "guset";
public static void main(String[] args) throws IOException,TimeoutException {
ConnectionFactory factory = new ConnectionFactory();
factory.setHost(HOST);
factory.setVirtualHost("/" );
factory.setPort(PORT);
factory.setUsername(USERNAME);
factory.setPassword(PASSWORD);
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
String exchangeName = "test_ttl_exchange";
String routingKey = "ttl.abc";
String queueName = "test_ttl_queue";
// 申明exchange
channel.exchangeDeclare(exchangeName,"topic");
// 申明 queue
channel.queueDeclare(queueName,true,false,null);
Map<String,Object> arguments = new HashMap<>();
// 佇列ttl,設定為8s
arguments.put("message-ttl",8000);
channel.queueBind(queueName,exchangeName,routingKey,arguments);
for (int i = 0; i < 3; i++) {
// expiration("10000") 設定訊息8s過期,訊息的ttl
AMQP.BasicProperties props = new AMQP.BasicProperties.Builder().deliveryMode(2).contentEncoding("UTF-8")
.expiration("8000").build();
String msg = "這是第" + i + "條ack訊息";
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
channel.basicPublish(exchangeName,props,msg.getBytes("UTF-8"));
}
channel.close();
connection.close();
}
}
複製程式碼
執行結果(動圖),觀察管理控制檯,到期自動清除