使用Redis实现优先级队列
2018-01-28 17:55
2086 查看
优先级队列是一种如先进先出队列和堆栈数据结构的抽象数据类型。所不同的是每一个元素关联一个“优先级”。优先级高的元素比优先级低的元素优先得到处理。本文讲解如何基于Redis的SORTED SET数据类型实现优先级队列。
SORTED SET中元素关联一个SCORE,可以按SCORE有序查询元素。
优先级队列基本操作实现如下:
is_empty: 查看队列是否为空。使用EXISTS命令可以实现。
insert_with_priority: 添加一个关联“优先级”的元素到队列中。直接使用ZADD命令可以实现。ZADD命令还有一系列选项可以支持更加复杂的操作。
pull_highest_priority_element: 从队列中删除具有最高优先级的元素并返回。Redis中没有直接的命令支持该操作。本文使用Redis脚本实现该操作。 Redis脚本支持事务原子性和隔离性, 所以下面脚本不会产生竞争条件。具体事务特性请参考https://redis.io/topics/transactions。
通过改写上面的脚本来实现也可以实现一次Pop多个元素。
SORTED SET中元素关联一个SCORE,可以按SCORE有序查询元素。
优先级队列基本操作实现如下:
is_empty: 查看队列是否为空。使用EXISTS命令可以实现。
EXISTS priority_queue
insert_with_priority: 添加一个关联“优先级”的元素到队列中。直接使用ZADD命令可以实现。ZADD命令还有一系列选项可以支持更加复杂的操作。
ZADD priority_queue priority member
pull_highest_priority_element: 从队列中删除具有最高优先级的元素并返回。Redis中没有直接的命令支持该操作。本文使用Redis脚本实现该操作。 Redis脚本支持事务原子性和隔离性, 所以下面脚本不会产生竞争条件。具体事务特性请参考https://redis.io/topics/transactions。
local items = redis.call('zrangebyscore', KEYS[1], '-inf', '+inf', 'LIMIT', 0, 1) if next(items) ~= nil then redis.call('zrem', KEYS[1], unpack(items)) end return items
通过改写上面的脚本来实现也可以实现一次Pop多个元素。
相关文章推荐
- 利用redis实现带优先级的消息队列
- (五)使用最大堆实现优先级队列
- java redis使用之利用jedis实现redis消息队列
- 用redis实现支持优先级的消息队列
- PHP使用php-resque库配合Redis实现MQ消息队列的教程
- 用redis实现支持优先级的消息队列
- 用redis实现支持优先级的消息队列
- 用Redis实现优先级队列
- 使用redis的发布订阅模式实现消息队列
- 使用redis服务器实现队列(欢迎留言讨论)
- Redis 实现队列优先级
- 最小优先级队列 — 使用最小堆实现
- 关于redis中使用锁机制,( 实现分布式锁和任务队列)
- PHP使用php-resque库配合Redis实现MQ消息队列的教程
- [bigdata] 使用Redis队列来实现与机器无关的Job提交与执行 (python实现)
- 用redis实现支持优先级的消息队列
- Redis学习之实现优先级消息队列
- Redis使用总结(3):实现简单的消息队列
- java使用数组实现优先级队列
- 用redis实现支持优先级的消息队列