皮皮网

1.Redis 消息队列的三种方案（List、Streams、Pub/Sub）
2.Redis的两种发布/订阅模式
3.万字长文带你解读Redisson分布式锁的源码
4.搞懂Redis (六) - 发布与订阅
5.redis订阅和发布应用场景?

Redis 消息队列的三种方案（List、Streams、Pub/Sub）

       Redis消息队列的三种方案涉及Redis中的List、Streams和Pub/Sub机制。文旅云 源码消息队列作为分布式系统架构中的核心组件，具有低耦合、可靠投递、广播、流量控制、最终一致性等功能，已被广泛应用于企业内部通信。虽然市场上已有多种开源消息队列（如RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、MetaMQ等），但部分数据库如Redis、MySQL以及phxsql，也可通过巧妙设计实现消息队列功能。

       那么，为什么选择使用Redis实现消息队列呢？Redis不仅具备高效的数据操作能力，而且其丰富的数据类型和命令集为构建消息队列提供了灵活多样的方案。Redis的List数据类型可用来实现基本的异步队列功能，通过队列的2048源码c入队（入栈）和出队（出栈）操作，实现消息的存取与消费。而Streams则更进一步，提供了消息持久化、主备复制和时间序列功能，使得消息队列在数据安全性和可靠性方面有了更大的提升。

       在使用Redis实现消息队列时，需要注意一些关键问题。例如，使用List进行消息队列操作时，若采用阻塞式读取（如BLPOP、BRPOP）可以有效避免不必要的CPU开销。为确保消息可靠性，可以采用消息确认机制，如在业务流程安全结束后，将消息从队列中删除，实现消息确认。此外，Redis的Pub/Sub机制允许客户端订阅频道，实现消息的多播，为消息队列提供了更为灵活的通信模式。然而，Pub/Sub模式在消息持久化和可靠性方面存在限制，因此，Redis引入了Streams数据结构，提供了更强大、更安全的mini世界源码消息队列功能。

       总之，Redis提供的List、Streams和Pub/Sub机制为实现高效、可靠、可扩展的消息队列提供了多种选择。在实际项目中，根据业务需求和场景特点，开发者可以灵活运用这些机制构建出满足各种需求的消息队列系统。

Redis的两种发布/订阅模式

       Redis 通过 PUBLISH、SUBSCRIBE 等命令实现订阅与发布模式，提供两种信息机制：订阅/发布到频道与订阅/发布到模式。首先讨论订阅/发布到频道的实现，然后探讨订阅/发布到模式的实现。

       频道订阅与信息发送使用 SUBSCRIBE 命令，允许客户端订阅任意数量的频道。每当新信息发送到被订阅的频道时，信息会发送给所有订阅指定频道的客户端。以频道 channel1 为例，订阅该频道的三个客户端—client2、client5、client1 会接收到信息。

       订阅频道时，Redis服务器维护一个表示服务器状态的 redis.h/redisServer 结构，其中 pubsub_channels 字典保存订阅频道信息。键为频道，值为链表，pcl kinfu源码链表存储所有订阅该频道的客户端。客户端执行 SUBSCRIBE 命令时，将客户端与要订阅的频道关联到字典中。

       发送信息到频道时，程序根据 channel 定位到字典的键，然后将信息发送给字典值链表中的所有客户端。在示例中，客户端执行 PUBLISH channel1 "hello moto" 命令，client2、client5、client1 将接收到 "hello moto" 信息。

       退订频道通过 UNSUBSCRIBE 命令实现，执行订阅的反操作，从 pubsub_channels 字典的给定频道中删除客户端信息，被退订频道的信息不再发送给该客户端。

       模式订阅与信息发送时，使用 PUBLISH 命令发送信息到频道，不仅订阅该频道的客户端会收到信息，如果模式与频道匹配，订阅该模式的客户端同样会收到信息。模式订阅与频道订阅结合，客户端可以接收多种匹配的频道信息。

       模式订阅通过 redisServer.pubsub_patterns 链表实现，链表保存所有与模式相关的信息。每当执行 PSUBSCRIBE 命令订阅模式时，程序创建包含客户端信息和被订阅模式的体验平台源码 pubsubPattern 结构，并添加到链表中。客户端订阅 tweet.shop.* 模式后，可以接收匹配的频道信息。

       发送信息到模式时，除了将信息发送给订阅 channel 的客户端，还会将 channel 和 pubsub_patterns 中的模式进行对比，如果 channel 和模式匹配，同样将信息发送给订阅该模式的客户端。

       退订模式使用 PUNSUBSCRIBE 命令，执行订阅模式的反操作，删除与被退订模式相关联的 pubsubPattern 结构，客户端不再接收与模式匹配的频道信息。

       总结，Redis 的订阅与发布模式通过频道与模式实现，提供高效的信息分发机制，支持多种客户端订阅与接收信息。

万字长文带你解读Redisson分布式锁的源码

       通过深入解读 Redisson 分布式锁的源码，我们了解到其核心功能在于实现加锁、解锁以及设置锁超时这三个基本操作。而分布式锁的实现，离不开对 Redis 发布订阅（pub/sub）机制的利用。订阅者（sub）通过订阅特定频道（channel）来接收发布者（pub）发送的消息，实现不同客户端间的通信。在使用 Redisson 加锁前，需获取 RLock 实例对象，进而调用 lock 或 tryLock 方法来完成加锁过程。

       Redisson 中的 RLock 实例初始化时，会配置异步执行器、唯一 ID、等待获取锁的时间等参数。加锁逻辑主要涉及尝试获取锁（tryLock）和直接获取锁（lock）两种方式。tryLock 方法中，通过尝试获取锁并监听锁是否被释放来实现锁的获取和等待逻辑。这通过调用底层命令（整合成 Lua 脚本）与 Redis 进行交互来实现。Redis 的 Hash 结构被用于存储锁的持有情况，hincrby 命令用于在持有锁的线程释放锁时调整计数，确保锁的可重入性。

       解锁逻辑相对简单，通过调用 unlock 方法，Redisson 使用特定的 Lua 脚本命令来判断锁是否存在，是否为当前线程持有，并相应地执行删除或调整锁过期时间的操作。

       此外，Redisson 支持 RedLock 算法来提供一种更鲁棒的锁实现，通过多个无关联的 Redis 实例（Node）组成的分布式锁来防止单点故障。尽管 RedLock 算法能一定程度上提高系统可靠性，但并不保证强一致性。因此，在业务场景对锁的安全性有较高要求时，可采取业务层幂等处理作为补充。

       Redisson 的设计遵循了简化实现与高效性能的原则，通过 Lua 脚本与 Redis 的直接交互来实现分布式锁的原子操作。在源码中，通过巧妙利用并发工具和网络通信机制，实现了分布式锁的高效执行。尽管 Redisson 在注释方面可能稍显不足，但其源码中蕴含的并发与网络通信的最佳实践仍然值得深入学习与研究。

搞懂Redis (六) - 发布与订阅

       Redis发布与订阅是一种消息通信的模式：发布者（pub）发送消息，订阅者（sub）接收消息。

       Redis通过publish和subscribe等命令实现了订阅与发布模式，这个功能提供两种消息机制，分别是订阅/发布到频道、订阅/发布到模式的客户端

1 频道（channel）

       订阅

       发布 完整流程

       发布者发布消息

       发布者向频道channel:1发布消息 hi

.0.0.1:>?publish?channel:1?hi(integer)?1

       订阅者订阅消息

.0.0.1:>?subscribe?channel:1Reading?messages...?(press?Ctrl-C?to?quit)1)?"subscribe"?//?消息类型2)?"channel:1"?//?频道3)?"hi"?//?消息内容

       执行subscribe后客户端会进入订阅状态，仅可以使subscribe、unsubscribe、psubscribe和punsubscribe这四个属于“发布\订阅”之外的命令

       订阅频道后的客户端可能会收到三种消息类型

       subscribe 表示订阅成功的反馈信息。第二个值是订阅成功的频道名称，第三个是当前客户端订阅的频道数量

       message 表示接受到的消息，第二个值表示产生消息的频道名称，第三个值是消息的内容

       unsubscribe 表示成功取消订阅某个频道，第二个值是对应的频道名称，第三个值是当前客户端订阅的频道数量，当此值为0时，客户端会退出订阅状态，之后就可以执行其他非“发布\订阅”模式的命令了。

       数据结构

       基于频道的发布订阅模式是通过字典数据类型实现的

struct?redisServer?{ //?...dict?*pubsub_channels;//?...};

       其中，字典的键为正在被订阅的频道，而字典的值则是一个链表，链表中保存了所有订阅这个频道的客户端 订阅

       当使用subscribe订阅时，在字典中找到频道key（如没有则创建），并将订阅的client关联在链表后面。 当client 执行subscribe channel1，channel2，channel3时，会将client分别加到channel1，channel2，channel3关联的链表尾部

       发布

       发布时，根据key，找到字典汇总key的地址，然后将msg发送到关联的链表每一台机器

       退订

       遍历关联的链表，将指定的地址删除即可

2 模式（pattern）

       pattern使用了通配符的方式来订阅

       通配符中?表示1个占位符，表示任意个占位符（包括0），?\ 表示1个以上占位符 所以当使用publish命令发送信息到某个频道时，不仅所有订阅该频道的客户端会收到信息，如果有某个\某些模式和这个频道匹配的话，那么所有订阅这个\这些频道的客户端也同样会收到信息

       订阅发布完整流程

       发布者发布消息

.0.0.1:>?publish?b?m1(integer)?.0.0.1:>?publish?b1?m1(integer)?.0.0.1:>?publish?b?m1(integer)?1

       订阅者订阅消息

.0.0.1:>?psubscribe?b*Reading?messages...?(press?Ctrl-C?to?quit)1)?"psubscribe"2)?"b*"3)?(integer)?)?"pmessage"2)?"b*"3)?"b"4)?"m1"1)?"pmessage"2)?"b*"3)?"b1"4)?"m1"1)?"pmessage"2)?"b*"3)?"b"4)?"m1"

       数据结构

       pattern属性是一个链表，链表中保存着所有和模式相关的信息

struct?redisServer?{ //?...list?*pubsub_patterns;//?...};//?链表中的每一个节点结构如下，保存着客户端与模式信息typedef?struct?pubsubPattern?{ redisClient?*client;robj?*pattern;}?pubsubPattern;

       数据结构如下：

       订阅

       当有新的订阅时，会将订阅的客户端和模式信息添加到链表后面

       发布

       当发布者发布消息时，首先会发送到对应的频道上，在遍历模式列表，根据key匹配模式，匹配成功将消息发给对应的订阅者

       完成的发布伪代码如下：

def?PUBLISH(channel,?message):#?遍历所有订阅频道?channel?的客户端for?client?in?server.pubsub_channels[channel]:#?将信息发送给它们send_message(client,?message)#?取出所有模式，以及订阅模式的客户端for?pattern,?client?in?server.pubsub_patterns:#?如果?channel?和模式匹配if?match(channel,?pattern):#?那么也将信息发给订阅这个模式的客户端send_message(client,?message)

       退订

       使用punsubscribe，可以将订阅者退订，将改客户端移除出链表。

       原文：/post/

redis订阅和发布应用场景?

       在Redis中，Pub/Sub功能实现发布与订阅机制，通过设定对特定key值进行消息发布和订阅，实现消息在多个客户端间实时传播。这一机制在构建实时通讯系统中尤为显著，如即时聊天、群聊功能，确保信息实时同步，提升用户体验。

       另一应用场景是在电商系统中实现库存同步。例如，当某商品库存减少时，通过Pub/Sub进行库存更新发布，所有订阅此库存变动的客户端即可实时接收到库存更新信息。商家在后台进行商品上下架或库存调整时，只需发布消息，前端应用通过订阅即可即时获取更新，无需频繁轮询，提高系统响应速度。

       在分布式系统中，Redis Pub/Sub功能还用于状态通知。例如，在微服务架构中，一个服务完成某个操作后，可以发布一个消息通知所有关注此操作状态的服务，从而实现服务间的状态同步，优化系统间通信效率。

       此外，在消息队列应用中，Redis Pub/Sub可以作为轻量级消息队列使用。消息生产者通过发布消息，消息消费者则通过订阅接收消息。此机制简化了消息队列的实现，降低了系统复杂度，同时保持了消息的可靠传输和系统高可用性。

       综上所述，Redis的Pub/Sub功能在实时通讯、库存同步、状态通知和轻量级消息队列等多个场景中发挥重要作用，提高了系统间的通讯效率和用户体验。通过灵活运用这一功能，开发者可以构建出高效、稳定且具有实时交互特性的应用系统。