RabbitMQ(高级特性)设置单条消息存活时间

设置单条消息存活时间

@Test
public void testSendMessage() {
  //设置消息属性
  MessageProperties messageProperties = new MessageProperties();
  //设置存活时间
  messageProperties.setExpiration("10000");
  // 创建消息对象
  Message message = new Message("send message...".getBytes(StandardCh服务器托管网arsets.UTF_8), messageProperties);
  // 发送消息
  rabbitTemplate.convertAndSend("my_topic_exchange", "my_routing", message);
}

注意：
1 如果设置了单条消息的存活时间，也设置了队列的存活时间，以时间短的为准。
2 消息过期后，并不会马上移除消息，只有消息消费到队列顶端时，才会移除该消息。

第二条测试：

@Test
public void testSendMessage2() {
  for (int i = 0; i  10; i++) {
    if (i == 5) {
      // 1.创建消息属性
      MessageProperties messageProperties = new MessageProperties();
      // 2.设置存活时间
      messageProperties.setExp服务器托管网iration("10000");
      // 3.创建消息对象
      Message message = new Message(("send message..." + i).getBytes(), messageProperties);
      // 4.发送消息
      rabbitTemplate.convertAndSend("my_topic_exchange", "my_routing", message);
     } else {
      rabbitTemplate.convertAndSend("my_topic_exchange", "my_routing", "send message..." + i);
     }
   }
}

在以上案例中，i=5的消息才有过期时间，10s后消息并没有马上被移除，但该消息已经不会被消费了，当它到达队列顶端时会被移除。

服务器托管，北京服务器托管，服务器租用 http://www.fwqtg.net

相关推荐: 分布式搜索引擎es-3

文章目录 数据聚合 聚合的种类 RestAPI实现聚合 自动补全 自定义拼音分词器 自动补全查询 案例：实现酒店搜索框自动补全 自动补全的javaAPI 实现搜索框自动补全 口述自动补全 数据同步 集群 集群的分布式存储 集群分布式查询 集群故障转移 数据聚合…