redis list 实现消息队列 多线程消费

redis list 实现消息队列 多线程消费

利用redis list 命令:

Redis Brpoplpush 命令从列表中取出最后一个元素,并插入到另外一个列表的头部; 如果列表没有元素会阻塞列表直到等待超时或发现可弹出元素为止。

BRPOPLPUSH msg reciver 500
假如在指定时间内没有任何元素被弹出,则返回一个 nil 和等待时长。 反之,返回一个含有两个元素的列表,第一个元素是被弹出元素的值,第二个元素是等待时长。

多个线程分别拉去公共list中消息,并保存到各自线程命名的redis list 中,待成功消费消息后各自将自己的redis list 中的item 移除,如果消费过程中线程异常中断,则自己的list 中的item不被移除,重新启动线程时先从自己的list中拉去并保存到自己list中,得到item进行消费之后再从公共的list中消费item。

移到自己的list
正常消费后,lpop 掉消息
线程异常中断消费,重启后先消费self list (RPOPLPUSH)
移到自己的list
正常消费后,lpop 掉消息
线程异常中断消费,重启后先消费self list (RPOPLPUSH)
pub list
RPOPLPUSH
线程1 self list
线程1
RPOPLPUSH
线程2 self list
线程2
Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐