实际上rocketmq可以设置一个过期时间TTL(time to live),等到了过期时间就会放到死信队列中,然后在转发到实际消费队列就行了。
方案:
如果有事件需要延迟那么将该事件发送到MQ 队列中,为需要延迟的消息设置一个TTL;
TTL到期后就会自动进入设置好的DLX,然后由DLX转发到配置好的实际消费队列;
消费该队列的延迟消息,处理事件。
版权声明:本文为m0_37731701原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。
实际上rocketmq可以设置一个过期时间TTL(time to live),等到了过期时间就会放到死信队列中,然后在转发到实际消费队列就行了。
方案:
如果有事件需要延迟那么将该事件发送到MQ 队列中,为需要延迟的消息设置一个TTL;
TTL到期后就会自动进入设置好的DLX,然后由DLX转发到配置好的实际消费队列;
消费该队列的延迟消息,处理事件。