如何用redis做一个可靠的消息队列

List

这是大家最常用的队列方式，就是在一个list上用lpush & rpop，如下图所示：

由于空队列的问题，要引入for循环加上一定的sleep时间，伪代码如下：

for {
  if msg:=redis.rpop();msg!=nil{
    handle(msg)
  }else{
    time.sleep(1000)
  }
}

这种方案可能存在1s处理不及时的风险（虽说在大多场景下基本没有影响）

不过redis有block算子，通过brpop实现阻塞式拉取，可以及时获得数据，伪代码如下：

for {
  # 超时时间为 0，代表无限等待
  if msg:=redis.brpop(0);msg!=nil{
    handle(msg)
  }
}

看起来很完美，解决了不处理不及时的问题，但由于redis client把超时时间设置成0后，redis server在长时间没有接受到消息的情况下，可能会判定该client为无效的链接，从而强制踢下线，所以在消息不是很密集的时候，直接设为0时，还是有一定的风险，建议保留非0的最小等待值（1s即可），伪代码如下：

for {
  if msg:=redis.