Redis 发布/订阅机制原理分析

ゞ浴缸里的玫瑰 2022-05-25 13:38 188阅读 0赞

转载：https://blog.csdn.net/clh604/article/details/19754939

发布订阅中使用到的命令就只有三个：PUBLISH,SUBSCRIBE,PSUBSCRIBE

*  PUBLISH 用于发布消息
 *  SUBSCRIBE 也叫频道订阅，用于订阅某一特定的频道
 *  PSUBSCRIBE 也叫模式订阅，用于订阅某一组频道，使用glob的方式，比如xxx-\*可以匹配xxx-a，和xxx-b,xxx-ddd等等

## 订阅频道: pubsub\_channels ##

![449064-20151010171636581-1404085038.png][]

关联操作：

*  如果已经存在订阅者，则添加到链表的尾部
 *  如果没有订阅者，那么创建频道，然后添加订阅者

删除操作：

*  找到对应的链表，进行删除
 *  如果删除后，链表为空，则删除频道

## 模式订阅: pubsub\_patterns ##

<table style="border-spacing:0px;width:620px;border:0px;margin:0px;padding:0px;font-size:12px;background:none;float:none;height:auto;line-height:1.1em;vertical-align:baseline;min-height:auto;"> 
 <tbody style="margin:0px;padding:0px;background:none;float:none;height:auto;line-height:1.1em;vertical-align:baseline;width:auto;min-height:auto;"> 
  <tr style="border-top:0px;margin:0px;padding:0px;background:none;float:none;height:auto;line-height:1.1em;vertical-align:baseline;width:auto;min-height:auto;"> 
   <td style="border-width:0px;margin:0px;padding:0px;font-size:12px;vertical-align:baseline;background:none;float:none;height:auto;line-height:1.1em;width:auto;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;min-height:auto;color:rgb(175,175,175);"> 
    <div style="border-width:0px 3px 0px 0px;border-right-style:solid;border-right-color:rgb(108,226,108);margin:0px;padding:0px .5em 0px 1em;background-image:none;float:none;height:auto;line-height:1.1em;text-align:right;vertical-align:baseline;width:auto;min-height:auto;white-space:pre;">
      1 
    </div> 
    <div style="border-width:0px 3px 0px 0px;border-right-style:solid;border-right-color:rgb(108,226,108);margin:0px;padding:0px .5em 0px 1em;background-image:none;float:none;height:auto;line-height:1.1em;text-align:right;vertical-align:baseline;width:auto;min-height:auto;white-space:pre;">
      2 
    </div> 
    <div style="border-width:0px 3px 0px 0px;border-right-style:solid;border-right-color:rgb(108,226,108);margin:0px;padding:0px .5em 0px 1em;background-image:none;float:none;height:auto;line-height:1.1em;text-align:right;vertical-align:baseline;width:auto;min-height:auto;white-space:pre;">
      3 
    </div></td> 
   <td style="width:592px;border-width:0px;margin:0px;padding:0px;font-size:12px;vertical-align:baseline;background:none;float:none;height:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;min-height:auto;"> 
    <div style="margin-left:-10px;width:640px;border:0px;margin-top:0px;margin-right:0px;margin-bottom:0px;padding:0px;background:none;float:none;height:auto;line-height:1.1em;vertical-align:baseline;min-height:auto;"> 
     <div style="border:0px;margin:0px;padding:0px 1em;background-image:none;float:none;height:auto;line-height:1.1em;vertical-align:baseline;width:auto;min-height:auto;white-space:pre;"> 
      <code style="border:0px;margin:0px;padding:0px;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;background:none;float:none;height:auto;line-height:1.1em;vertical-align:baseline;width:auto;min-height:auto;color:#000000;">client-</code> 
      <code style="border:0px;margin:0px;padding:0px;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;background:none;float:none;height:auto;line-height:1.1em;vertical-align:baseline;width:auto;min-height:auto;color:rgb(0,153,0);">7</code> 
      <code style="border:0px;margin:0px;padding:0px;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;background:none;float:none;height:auto;line-height:1.1em;vertical-align:baseline;width:auto;min-height:auto;color:#000000;">订阅music.*</code> 
     </div> 
     <div style="border:0px;margin:0px;padding:0px 1em;background-image:none;float:none;height:auto;line-height:1.1em;vertical-align:baseline;width:auto;min-height:auto;white-space:pre;"> 
      <code style="border:0px;margin:0px;padding:0px;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;background:none;float:none;height:auto;line-height:1.1em;vertical-align:baseline;width:auto;min-height:auto;color:#000000;">client-</code> 
      <code style="border:0px;margin:0px;padding:0px;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;background:none;float:none;height:auto;line-height:1.1em;vertical-align:baseline;width:auto;min-height:auto;color:rgb(0,153,0);">8</code> 
      <code style="border:0px;margin:0px;padding:0px;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;background:none;float:none;height:auto;line-height:1.1em;vertical-align:baseline;width:auto;min-height:auto;color:#000000;">订阅book.*</code> 
     </div> 
     <div style="border:0px;margin:0px;padding:0px 1em;background-image:none;float:none;height:auto;line-height:1.1em;vertical-align:baseline;width:auto;min-height:auto;white-space:pre;"> 
      <code style="border:0px;margin:0px;padding:0px;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;background:none;float:none;height:auto;line-height:1.1em;vertical-align:baseline;width:auto;min-height:auto;color:#000000;">client-</code> 
      <code style="border:0px;margin:0px;padding:0px;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;background:none;float:none;height:auto;line-height:1.1em;vertical-align:baseline;width:auto;min-height:auto;color:rgb(0,153,0);">9</code> 
      <code style="border:0px;margin:0px;padding:0px;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;background:none;float:none;height:auto;line-height:1.1em;vertical-align:baseline;width:auto;min-height:auto;color:#000000;">订阅news.*</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

![449064-20151010171644940-1270908200.png][]

订阅模式：

*  新建一个pubsubPattern结构
 *  添加到链表的尾部

退订模式：

*  查找相应的pubsubPattern然后删除

发送消息：

*  将消息发送给channel频道的所有订阅者
 *  遍历整个pubsub\_patterns表，查找匹配的模式，如果有一个或者多个模式与频道匹配，将消息发送给pattern模式的订阅者

相关命令：

*  查看所有的频道：PUBSUB CHANNELS
 *  查询订阅者的数量：PUBSUB NUMSUB
 *  查询服务器被订阅者的数量：PUBSUB NUMPAT

### 原理实现如下： ###

这些命令被广泛用于构建即时通信应用，比如网络聊天室(chatroom)和实时广播、实时提醒等。

本文通过分析 Redis 源码里的 pubsub.c 文件，了解发布和订阅机制的底层实现，籍此加深对 Redis 的理解。

订阅、发布和退订

在开始研究源码之前，不妨先来回顾一下几个相关命令的使用方式。

PUBLISH 命令用于向给定的频道发送信息，返回值为接收到信息的订阅者数量：

SUBSCRIBE 命令订阅给定的一个或多个频道：

SUBSCRIBE 的返回值当中， 1) 为 subscribe 的是订阅的反馈信息，而 1) 为 message 的则是订阅的频道所发送的信息。

SUBSCRIBE 还可以订阅多个频道，这样一来它接收到的信息就可能来自多个频道：

PSUBSCRIBE 提供了一种订阅符合给定模式的所有频道的方法，比如说，使用 it.\* 为输入，就可以订阅所有以 it. 开头的频道，比如 it.news 、 it.blog 、 it.tweets ，诸如此类：

当然， PSUBSCRIBE 也可以接受多个参数，从而匹配多种模式。

最后， UNSUBSCRIBE 命令和 PUNSUBSCRIBE 负责退订给定的频道或模式。

发布和订阅机制

当一个客户端通过 PUBLISH 命令向订阅者发送信息的时候，我们称这个客户端为发布者(publisher)。

而当一个客户端使用 SUBSCRIBE 或者 PSUBSCRIBE 命令接收信息的时候，我们称这个客户端为订阅者(subscriber)。

为了解耦发布者(publisher)和订阅者(subscriber)之间的关系，Redis 使用了 channel (频道)作为两者的中介 —— 发布者将信息直接发布给 channel ，而 channel 负责将信息发送给适当的订阅者，发布者和订阅者之间没有相互关系，也不知道对方的存在：

![2012-08-10-10-08-12.jpg][]

点击放大

知道了发布和订阅的机制之后，接下来就可以开始研究具体的实现了，我们从 Redis 的订阅命令开始说起。

SUBSCRIBE 命令的实现

前面说到，Redis 将所有接受和发送信息的任务交给 channel 来进行，而所有 channel 的信息就储存在 redisServer 这个结构中：

pubsub\_channels 是一个字典，字典的键就是一个个 channel ，而字典的值则是一个链表，链表中保存了所有订阅这个 channel 的客户端。

举个例子，如果在一个 redisServer 实例中，有一个叫做 news 的频道，这个频道同时被client\_123 和 client\_456 两个客户端订阅，那么这个 redisServer 结构看起来应该是这样子：

![2012-08-10-10-08-53.jpg][]点击放大

可以看出，实现 SUBSCRIBE 命令的关键，就是将客户端添加到给定 channel 的订阅链表中。

函数 pubsubSubscribeChannel 是 SUBSCRIBE 命令的底层实现，它完成了将客户端添加到订阅链表中的工作：

<table style="border-spacing:0px;width:851.818px;color:rgb(51,51,51);font-size:14px;background-color:rgb(255,255,255);"> 
 <tbody style="padding:0px;margin:0px;"> 
  <tr style="padding:0px;margin:0px;"> 
   <td style="padding:0px;margin:0px;font-family:'微软雅黑';">//&nbsp;订阅指定频道&nbsp;<br style="padding:0px;margin:0px;">　　//&nbsp;订阅成功返回&nbsp;1&nbsp;，如果已经订阅过，返回&nbsp;0&nbsp;<br style="padding:0px;margin:0px;">　　int&nbsp;pubsubSubscribeChannel(redisClient&nbsp;*c,&nbsp;robj&nbsp;*channel)&nbsp;{&nbsp;<br style="padding:0px;margin:0px;">　　struct&nbsp;dictEntry&nbsp;*de;&nbsp;<br style="padding:0px;margin:0px;">　　list&nbsp;*clients&nbsp;=&nbsp;NULL;&nbsp;<br style="padding:0px;margin:0px;">　　int&nbsp;retval&nbsp;=&nbsp;0;&nbsp;<br style="padding:0px;margin:0px;">　　/*&nbsp;Add&nbsp;the&nbsp;channel&nbsp;to&nbsp;the&nbsp;client&nbsp;-&gt;&nbsp;channels&nbsp;hash&nbsp;table&nbsp;*/&nbsp;<br style="padding:0px;margin:0px;">　　//&nbsp;dictAdd&nbsp;在添加新元素成功时返回&nbsp;DICT_OK&nbsp;<br style="padding:0px;margin:0px;">　　//&nbsp;因此这个判断句表示，如果新订阅&nbsp;channel&nbsp;成功，那么&nbsp;。。。&nbsp;<br style="padding:0px;margin:0px;">　　if&nbsp;(dictAdd(c-&gt;pubsub_channels,channel,NULL)&nbsp;==&nbsp;DICT_OK)&nbsp;{&nbsp;<br style="padding:0px;margin:0px;">　　retval&nbsp;=&nbsp;1;&nbsp;<br style="padding:0px;margin:0px;">　　incrRefCount(channel);&nbsp;<br style="padding:0px;margin:0px;">　　/*&nbsp;Add&nbsp;the&nbsp;client&nbsp;to&nbsp;the&nbsp;channel&nbsp;-&gt;&nbsp;list&nbsp;of&nbsp;clients&nbsp;hash&nbsp;table&nbsp;*/&nbsp;<br style="padding:0px;margin:0px;">　　//&nbsp;将&nbsp;client&nbsp;添加到订阅给定&nbsp;channel&nbsp;的链表中&nbsp;<br style="padding:0px;margin:0px;">　　//&nbsp;这个链表是一个哈希表的值，哈希表的键是给定&nbsp;channel&nbsp;<br style="padding:0px;margin:0px;">　　//&nbsp;这个哈希表保存在&nbsp;server.pubsub_channels&nbsp;里&nbsp;<br style="padding:0px;margin:0px;">　　de&nbsp;=&nbsp;dictFind(server.pubsub_channels,channel);&nbsp;<br style="padding:0px;margin:0px;">　　if&nbsp;(de&nbsp;==&nbsp;NULL)&nbsp;{&nbsp;<br style="padding:0px;margin:0px;">　　//&nbsp;如果&nbsp;de&nbsp;等于&nbsp;NULL&nbsp;<br style="padding:0px;margin:0px;">　　//&nbsp;表示这个客户端是首个订阅这个&nbsp;channel&nbsp;的客户端&nbsp;<br style="padding:0px;margin:0px;">　　//&nbsp;那么创建一个新的列表，&nbsp;并将它加入到哈希表中&nbsp;<br style="padding:0px;margin:0px;">　　clients&nbsp;=&nbsp;listCreate();&nbsp;<br style="padding:0px;margin:0px;">　　dictAdd(server.pubsub_channels,channel,clients);&nbsp;<br style="padding:0px;margin:0px;">　　incrRefCount(channel);&nbsp;<br style="padding:0px;margin:0px;">　　}&nbsp;else&nbsp;{&nbsp;<br style="padding:0px;margin:0px;">　　//&nbsp;如果&nbsp;de&nbsp;不为空，就取出这个&nbsp;clients&nbsp;链表&nbsp;<br style="padding:0px;margin:0px;">　　clients&nbsp;=&nbsp;dictGetVal(de);&nbsp;<br style="padding:0px;margin:0px;">　　}&nbsp;<br style="padding:0px;margin:0px;">　　//&nbsp;将客户端加入到链表中&nbsp;<br style="padding:0px;margin:0px;">　　listAddNodeTail(clients,c);&nbsp;<br style="padding:0px;margin:0px;">　　}&nbsp;<br style="padding:0px;margin:0px;">　　/*&nbsp;Notify&nbsp;the&nbsp;client&nbsp;*/&nbsp;<br style="padding:0px;margin:0px;">　　addReply(c,shared.mbulkhdr[3]);&nbsp;<br style="padding:0px;margin:0px;">　　addReply(c,shared.subscribebulk);&nbsp;<br style="padding:0px;margin:0px;">　　//&nbsp;返回订阅的频道&nbsp;<br style="padding:0px;margin:0px;">　　addReplyBulk(c,channel);&nbsp;<br style="padding:0px;margin:0px;">　　//&nbsp;返回客户端当前已订阅的频道和模式数量的总和&nbsp;<br style="padding:0px;margin:0px;">　　addReplyLongLong(c,dictSize(c-&gt;pubsub_channels)+listLength(c-&gt;pubsub_patterns));&nbsp;<br style="padding:0px;margin:0px;">　　return&nbsp;retval;&nbsp;<br style="padding:0px;margin:0px;">　　}</td> 
  </tr> 
 </tbody> 
</table>

PSUBSCRIBE 命令的实现

除了直接订阅给定 channel 外，还可以使用 PSUBSCRIBE 订阅一个模式(pattern)，订阅一个模式等同于订阅所有匹配这个模式的 channel 。

和 redisServer.pubsub\_channels 属性类似， redisServer.pubsub\_patterns 属性用于保存所有被订阅的模式，和 pubsub\_channels 不同的是， pubsub\_patterns 是一个链表(而不是字典)：

pubsub\_patterns 的每一个节点都是一个 pubsubPattern 结构的实例，它保存了被订阅的模式，以及订阅这个模式的客户客户端：

举个例子，假设在一个 redisServer 实例中，有一个叫做 news.\* 的模式同时被客户端client\_789 和 client\_999 订阅，那么这个 redisServer 结构看起来应该是这样子：

![2012-08-10-10-09-54.jpg][]点击放大

现在可以知道，实现 PSUBSCRIBE 命令的关键，就是将客户端和订阅的模式添加到redisServer.pubsub\_patterns 当中。

pubsubSubscribePattern 是 PSUBSCRIBE 的底层实现，它将客户端和所订阅的模式添加到redisServer.pubsub\_patterns 当中：

PUBLISH 命令的实现

使用 PUBLISH 命令向订阅者发送消息，需要执行以下两个步骤：

1) 使用给定的频道作为键，在 redisServer.pubsub\_channels 字典中查找记录了订阅这个频道的所有客户端的链表，遍历这个链表，将消息发布给所有订阅者。

2) 遍历 redisServer.pubsub\_patterns 链表，将链表中的模式和给定的频道进行匹配，如果匹配成功，那么将消息发布到相应模式的客户端当中。

举个例子，假设有两个客户端分别订阅 it.news 频道和 it.\* 模式，当执行命令PUBLISH it.news "hello moto" 的时候， it.news 频道的订阅者会在步骤 1 收到信息，而当PUBLISH 进行到步骤 2 的时候， it.\* 模式的订阅者也会收到信息。

PUBLISH 命令的实际实现由 pubsubPublishMessage 函数完成，它的完整定义如下：

<table style="border-spacing:0px;width:851.818px;color:rgb(51,51,51);font-size:14px;background-color:rgb(255,255,255);"> 
 <tbody style="padding:0px;margin:0px;"> 
  <tr style="padding:0px;margin:0px;"> 
   <td style="padding:0px;margin:0px;font-family:'微软雅黑';">//&nbsp;发送消息&nbsp;<br style="padding:0px;margin:0px;">　　int&nbsp;pubsubPublishMessage(robj&nbsp;*channel,&nbsp;robj&nbsp;*message)&nbsp;{&nbsp;<br style="padding:0px;margin:0px;">　　int&nbsp;receivers&nbsp;=&nbsp;0;&nbsp;<br style="padding:0px;margin:0px;">　　struct&nbsp;dictEntry&nbsp;*de;&nbsp;<br style="padding:0px;margin:0px;">　　listNode&nbsp;*ln;&nbsp;<br style="padding:0px;margin:0px;">　　listIter&nbsp;li;&nbsp;<br style="padding:0px;margin:0px;">　　/*&nbsp;Send&nbsp;to&nbsp;clients&nbsp;listening&nbsp;for&nbsp;that&nbsp;channel&nbsp;*/&nbsp;<br style="padding:0px;margin:0px;">　　//&nbsp;向所有频道的订阅者发送消息&nbsp;<br style="padding:0px;margin:0px;">　　de&nbsp;=&nbsp;dictFind(server.pubsub_channels,channel);&nbsp;<br style="padding:0px;margin:0px;">　　if&nbsp;(de)&nbsp;{&nbsp;<br style="padding:0px;margin:0px;">　　list&nbsp;*list&nbsp;=&nbsp;dictGetVal(de);&nbsp;//&nbsp;取出所有订阅者&nbsp;<br style="padding:0px;margin:0px;">　　listNode&nbsp;*ln;&nbsp;<br style="padding:0px;margin:0px;">　　listIter&nbsp;li;&nbsp;<br style="padding:0px;margin:0px;">　　//&nbsp;遍历所有订阅者，&nbsp;向它们发送消息&nbsp;<br style="padding:0px;margin:0px;">　　listRewind(list,&amp;li);&nbsp;<br style="padding:0px;margin:0px;">　　while&nbsp;((ln&nbsp;=&nbsp;listNext(&amp;li))&nbsp;!=&nbsp;NULL)&nbsp;{&nbsp;<br style="padding:0px;margin:0px;">　　redisClient&nbsp;*c&nbsp;=&nbsp;ln-&gt;value;&nbsp;<br style="padding:0px;margin:0px;">　　addReply(c,shared.mbulkhdr[3]);&nbsp;<br style="padding:0px;margin:0px;">　　addReply(c,shared.messagebulk);&nbsp;<br style="padding:0px;margin:0px;">　　addReplyBulk(c,channel);&nbsp;//&nbsp;打印频道名&nbsp;<br style="padding:0px;margin:0px;">　　addReplyBulk(c,message);&nbsp;//&nbsp;打印消息&nbsp;<br style="padding:0px;margin:0px;">　　receivers++;&nbsp;//&nbsp;更新接收者数量&nbsp;<br style="padding:0px;margin:0px;">　　}&nbsp;<br style="padding:0px;margin:0px;">　　}&nbsp;<br style="padding:0px;margin:0px;">　　/*&nbsp;Send&nbsp;to&nbsp;clients&nbsp;listening&nbsp;to&nbsp;matching&nbsp;channels&nbsp;*/&nbsp;<br style="padding:0px;margin:0px;">　　//&nbsp;向所有被匹配模式的订阅者发送消息&nbsp;<br style="padding:0px;margin:0px;">　　if&nbsp;(listLength(server.pubsub_patterns))&nbsp;{&nbsp;<br style="padding:0px;margin:0px;">　　listRewind(server.pubsub_patterns,&amp;li);&nbsp;//&nbsp;取出所有模式&nbsp;<br style="padding:0px;margin:0px;">　　channel&nbsp;=&nbsp;getDecodedObject(channel);&nbsp;<br style="padding:0px;margin:0px;">　　while&nbsp;((ln&nbsp;=&nbsp;listNext(&amp;li))&nbsp;!=&nbsp;NULL)&nbsp;{&nbsp;<br style="padding:0px;margin:0px;">　　pubsubPattern&nbsp;*pat&nbsp;=&nbsp;ln-&gt;value;&nbsp;//&nbsp;取出模式&nbsp;<br style="padding:0px;margin:0px;">　　//&nbsp;如果模式和&nbsp;channel&nbsp;匹配的话&nbsp;<br style="padding:0px;margin:0px;">　　//&nbsp;向这个模式的订阅者发送消息&nbsp;<br style="padding:0px;margin:0px;">　　if&nbsp;(stringmatchlen((char*)pat-&gt;pattern-&gt;ptr,&nbsp;<br style="padding:0px;margin:0px;">　　sdslen(pat-&gt;pattern-&gt;ptr),&nbsp;<br style="padding:0px;margin:0px;">　　(char*)channel-&gt;ptr,&nbsp;<br style="padding:0px;margin:0px;">　　sdslen(channel-&gt;ptr),0))&nbsp;{&nbsp;<br style="padding:0px;margin:0px;">　　addReply(pat-&gt;client,shared.mbulkhdr[4]);&nbsp;<br style="padding:0px;margin:0px;">　　addReply(pat-&gt;client,shared.pmessagebulk);&nbsp;<br style="padding:0px;margin:0px;">　　addReplyBulk(pat-&gt;client,pat-&gt;pattern);&nbsp;//&nbsp;打印被匹配的模式&nbsp;<br style="padding:0px;margin:0px;">　　addReplyBulk(pat-&gt;client,channel);&nbsp;//&nbsp;打印频道名&nbsp;<br style="padding:0px;margin:0px;">　　addReplyBulk(pat-&gt;client,message);&nbsp;//&nbsp;打印消息&nbsp;<br style="padding:0px;margin:0px;">　　receivers++;&nbsp;//&nbsp;更新接收者数量&nbsp;<br style="padding:0px;margin:0px;">　　}&nbsp;<br style="padding:0px;margin:0px;">　　}&nbsp;<br style="padding:0px;margin:0px;">　　decrRefCount(channel);&nbsp;//&nbsp;释放用过的&nbsp;channel&nbsp;<br style="padding:0px;margin:0px;">　　}&nbsp;<br style="padding:0px;margin:0px;">　　return&nbsp;receivers;&nbsp;//&nbsp;返回接收者数量&nbsp;<br style="padding:0px;margin:0px;">　　}</td> 
  </tr> 
 </tbody> 
</table>

UNSUBSCRIBE 和 PUNSUBSCRIBE 的实现

UNSUBSCRIBE 和 PUNSUBSCRIBE 分别是 SUBSCRIBE 和 PSUBSCRIBE 的反操作，如果明白了SUBSCRIBE 和 PSUBSCRIBE 的工作机制的话，应该不难理解这两个反操作的原理，所以这里就省略详细的分析了，有兴趣的可以直接看代码。

小节

Redis 的 pubsub 机制的分析就到此结束了，跟往常一样，带有注释的完整 pubsub.c 文件可以到我的 GITHUB 上找： [https://github.com/huangz1990/reading\_redis\_source][https_github.com_huangz1990_reading_redis_source]

[449064-20151010171636581-1404085038.png]: /images/20220525/aded64404006496cb7b98972fe953049.png
[449064-20151010171644940-1270908200.png]: /images/20220525/be3b6f76eb2d47d4bba267f386533842.png
[2012-08-10-10-08-12.jpg]: /images/20220525/35723fbd132746459919dba16656c37e.png
[2012-08-10-10-08-53.jpg]: /images/20220525/33aa732d48b14eefb80970696512e153.png
[2012-08-10-10-09-54.jpg]: /images/20220525/5eeec19fdc75430ab1b471b184becddd.png
[https_github.com_huangz1990_reading_redis_source]: https://github.com/huangz1990/reading_redis_source