不同的微服务之间做异步通迅时通常会使用Kafka,它非常适用于对消费次序或时间没有强一致性需要的场景。如果消息需要在指定的时间才可以被消费,Kafka并没有原生支持此类消费场景,需要较复杂的实现。我们把支持此类场景的队列称为延迟队列

逻辑上,延迟队列中的消息按延迟时间排序
{
"time": "2018-03-14T00:00:00Z",
"message": "发布《Redis延迟队列》"
}
  • RabbitMQ通过RabbitMQ Delayed Message Plugin可支持延迟队列。可惜我司的基础设施中没有RabbitMQ。
  • Redis的Sorted Set可被用于实现简单的延迟队列。利用Redis的Lua支持我们也可以将基建设成一个功能全面的延迟队列服务。
127.0.0.1:6379> ZADD delay-queue 1520985600 "publish article"
127.0.0.1:6379> ZRANGEBYSCORE delay-queue -inf 1520985599
(empty list or set)
127.0.0.1:6379> ZRANGEBYSCORE delay-queue -inf 1520985600 WITHSCORES
1) "publish article"
2) "1520985600"
127.0.0.1:6379> ZRANGEBYSCORE delay-queue -inf 1520985601 WITHSCORES
1) "publish article"
2) "1520985600"
127.0.0.1:6379> ZREM delay-queue "publish article"