如何设置rockemq消息过期时间？

如何解决如何设置rockemq消息过期时间？

这里我使用 spring-cloud-starter-stream-rocketmq 和 spring-message 发送消息 dn， 例如

Message m = MessageBuilder.withPayload(obj).setHeader(RocketMQHeaders.TAGS,tag).build();
MessageChannel.output().send(m);

但是我想在队列中设置消息过期时间，如果没有被消费。

我知道rocketmq可以设置ttl，但不知道是否可以为不同的消息设置，以及如何在之前的代码中使用？

解决方法

恐怕你错了。

RocketMQ 不支持 ttl，这意味着消息不会被客户端参数控制删除，尽管消息确实会在一段时间（例如 7 天）后被删除。

因此，如果您需要实现 ttl 之类的消费，您应该在您的消费者中这样做：

  if (System.currentTimeMills()-msg.getStoreTimestamp > SOME_TIME) {
     //DO NOT CONSUME
  }