基于Redis实现消息队列的6种方案之方案简述（中）-XAMPP中文组官网

在《基于Redis实现消息队列的6种方案之方案简述（上）》中我们讲到了基于List类型实现的消息队列，今天我们来讲下优先队列的实现。

Redis有序集合的特点

回忆下优先队列的特点，能保证每次取出的元素都是队列中优先级别最高的。这一特点是使用List类型无法满足的，数据只能是先进先出的，那我们来看下Sorted Set类型的特点。

有序集合（Sorted Set）是不允许重复的String类型元素的集合，且每个元素都会关联一个Double类型的分数。

有序集合的成员是唯一的，但分数是可以重复。集合中最大的成员数为 2³² – 1 等于4294967295，也就是每个集合可存储40多亿个成员。

基于Sorted Set以上的特点在实际开发中有许多的应用，比如做游戏的实时战绩排行榜、博客中文章点赞排行榜等各类排行榜和优先队列的实现。

基于Sorted Set的实现方案

ZADD在集合中添加一个带有分数的元素。

ZRANGE返回有序集中，指定区间内的成员，其中成员的位置按分数值递增(从小到大)来排序；我们使用0，0区间来获取处于顶部的元素。

ZREVRANGE与ZRANGE不同的是成员的位置按分数值递减(从大到小)来排列。

ZREM用来移除有序集中的一个元素，不存在的成员将被忽略。当消费0，0区间元素成功后，移除该元素。

优点：

Sorted Set类型是基于使用了hash和skiplist两种设计实现；添加和删除都需要修改skiplist，所以复杂度为O(log(n))；查找元素的话可以直接使用hash，其复杂度为O(1)
可以实现按权值取元素
Redis支持消息持久化，在服务端数据是安全的

缺点：

Sorted Set不仅可以实现优先队列，还可以将权值当做有序队列的自定义序号，例如使用时间戳就可以实现一个有序队列了，但是如果是做有序队列当然没有List类型来的方便了。

基于PUB/SUB，订阅/发布模式的实现方案

SUBSCRIBE用于订阅一个给定模式信道

PUBLISH用于将消息发送到指定的信道

UNSUBSCRIBE用于取消订阅指定信道

生产者和消费者通过相同的一个信道进行交互。信道其实也就是队列。通常会有多个消费者。多个消费者订阅同一个信道，当生产者向信道发布消息时，该信道会立即将消息逐一发布给每个消费者。所以该信道对于消费者是发散的信道，每个消费者都可以得到相同的消息。典型的一对多的关系。

优点：

缺点：

可见，Pub/Sub 模式不适合做消息存储，消息积压类的业务，而是擅长处理广播，即时通讯，即时反馈的业务。

懂了啵！！！

会在《基于Redis实现消息队列的6种方案之方案简述（下）》主要介绍使用Stream类型实现的消息队列的方案。

感觉用就点个关注、点个看一看噢

基于Redis实现消息队列的6种方案之方案简述（中）