Redis 实现队列优先级

通常使用一个list来实现队列操作,这样有一个小限制,所以的任务统一都是先进先出,如果想优先处理某个任务就不太好处理了 这就需要让队列有优先级的概念,我们就可以优先处理高级别的任务 实现方式 (1)单一列表实现 队列正常的操作是 左进右出(lpush,rpop) 为了先处理高优先级任务,在遇到高级别任务时,可以直接插队,直接放入队列头部(rpush),这样,从队列头部(右侧)获取任务时,取到的就是高优先级的任务(rpop) 相当于普通任务按照队列结构,碰到高优先级任务,就按照堆栈结构 优点是实现简单,缺点是高级别任务总是后进先出 适用于简单的队列需求,高优先级任务较少的情况 (2)多队列实现 使用两个队列,一个普通队列,一个高级队列,针对任务的级别放入不同的队列 获取任务时也很简单,redis的BRPOP命令可以按顺序从多个队列中取值 BRPOP会按照给出的 key 顺序查看,并在找到的第一个非空 list 的尾部弹出一个元素 redis> BRPOP list1 list2 0 list1 做为高优先级任务队列 list2 做为普通任务队列 这样就实现了先处理高优先级任务,当没有高优先级任务时,就去获取普通任务 (3)使用权值实现 如果优先级比较复杂,比如有10几个甚至更多的优先级别,方法2就不太方便了 例如有3个级别(1 2 3),用权值来表示 有4个元素需要入队 a级别1,b级别2,c级别3,d级别3 使用 lpush 把他们入队,同时设置权值 redis> lpush mylist a redis> set mylist_score_a 1 redis> lpush mylist b redis> set mylist_score_b 2 redis> lpush mylist c redis> set mylist_score_a 3 redis> lpush mylist d redis> set mylist_score_a 3 根据权值排序,并取出排名第一的元素 redis> sort mylist by mylist_score_* limit 0 1 结果为:c,正是我们想要的,c 的级别最高,并且是先进入队列的 获取完成后,要移除此元素 redis> lrem mylist 0 c 总结 方式1最简单,但实际应用比较局限,方式3可以实现复杂优先级,但实现比较复杂,不利于维护 方式2是推荐用法,实际应用最为合适 方式1、3可以作为redis应用思路的一个拓展

原文发布于微信公众号 - 性能与架构(yogoup)

原文发表时间:2015-12-25

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏大内老A

ASP.NET Core的配置(3): 将配置绑定为对象[下篇]

我们在《读取配置信息》通过实例的形式演示了如何利用Options模型以依赖注入的方式直接获取由指定配置节绑定生成的Options对象,我们再次回顾一下当初我们编...

21890
来自专栏崔庆才的专栏

爬虫速度太慢?来试试用异步协程提速吧!

在执行一些 IO 密集型任务的时候,程序常常会因为等待 IO 而阻塞。比如在网络爬虫中,如果我们使用 requests 库来进行请求的话,如果网站响应速度过慢,...

49410
来自专栏轻量级微服务

微服务下跨语言 RPC 实现

目前主流的 Java 开发框架 Spring Boot,为了更方便集成 gRPC,自己开发了 spring-boot-starter-grpc,仅需简单的几行配...

29330
来自专栏深度学习之tensorflow实战篇

python文件打开方式详解——a、a+、r+、w+区别

第一步 排除文件打开方式错误: r只读,r+读写,不创建 w新建只写,w+新建读写,二者都会将文件内容清零 (以w方式打开,不能读出。w+可读写) **w+与r...

60770
来自专栏思考的代码世界

Python编程从入门到实践之文件和异常处理|第12天

要使用文本文件中的信息,首先需要将信息读取到内存中。为此,我们可以一次性读取文件的 全部内容,也可以以每次一行的方式逐步读取。

45770
来自专栏抠抠空间

django之urls系统

Django的urls系统简介 Django 1.11版本 URLConf官方文档:https://docs.djangoproject.com/en/1.11...

30370
来自专栏JMCui

Git 中 .gitignore 的配置语法

    在日常的开发中,当我们需要将一个项目提交到 Git 时,并不是所有的文件都需要提交,比如一些自动生成的文件,类似于 .idea 文件、class 文件等...

30030
来自专栏程序员的知识天地

Python使用os模块、Try语句、pathlib模块判断文件是否存在

通常在读写文件之前,需要判断文件或目录是否存在,不然某些处理方法可能会使程序出错。所以最好在做任何操作之前,先判断文件是否存在。

19520
来自专栏小二的折腾日记

day5(面向对象2)

wait notify notifyAll 都使用在同步中,因为要对持有监视器(锁)的线程操作。所以要使用在同步中,以为只有同步才具有锁。 为什么这些操作线程...

6110
来自专栏MasiMaro 的技术博文

C/C++中define定义的常量与const常量

常量是在程序中不能更改的量,在C/C++中有两种方式定义常量,一种是利用define宏定义的方式,一种是C++中新提出来的const型常变量,下面主要讨论它们之...

11710

扫码关注云+社区

领取腾讯云代金券