Redis实现消息的发布订阅原理分析

 更新时间:2022年07月25日 10:53:17   作者:我是一棵卷心菜  
本文主要介绍了Redis实现消息的发布订阅原理分析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

一、什么是发布和订阅

  • Redis 发布订阅 (pub/sub) 是一种消息通信模式:发送者 (pub) 发送消息,订阅者 (sub) 接收消息。
  • 特点:Redis 客户端可以订阅任意数量的频道。
  • 这就好比粉丝们关注了我,当我写完文章发布的时候,你们打开CSDN也会接收到我写的文章。此时,我就是发送者(pub);粉丝们就是订阅者(sub)。

结构图如下:发布者发送自己的消息到redis服务器,订阅者从redis服务器中获取发布者发布的消息

在这里插入图片描述

二、Redis的发布和订阅

为了方便后面讲解发布和订阅命令行的使用,我先用两张图简单的介绍redis实现发布和订阅的整体流程。

客户端可以订阅频道如下图:

在这里插入图片描述

当给这个频道发布消息后,消息就会发送给订阅的客户端,如下图:

在这里插入图片描述

三、redis 发布订阅常用命令

下表列出了 redis 发布订阅常用命令:

在这里插入图片描述

四、命令实战

在演示redis消息的发布和订阅之前,我们需要打开两个客户端,一个充当消息发布者,一个充当消息接受者。

1、基本使用

先用一个客户端订阅频道csdn_blog,等待消息:

127.0.0.1:6379> SUBSCRIBE csdn_blog 
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "csdn_blog"
3) (integer) 1

接着一个客户端在csdn_blog频道发送消息hello,cabbage

127.0.0.1:6379> PUBLISH csdn_blog "hello,cabbage"
(integer) 1

最后接受者接收到消息:

1) "message" 
2) "csdn_blog"    # 接收消息所在的频道
3) "hello,cabbage"   # 接收到的消息

2、订阅符合要求的频道

订阅以csdn开头的频道,*表示任意字符

127.0.0.1:6379> PSUBSCRIBE csdn*
Reading messages... (press Ctrl-C to quit)
1) "psubscribe"
2) "csdn*"
3) (integer) 1

发布者在两个频道发布消息:

127.0.0.1:6379> PUBLISH csdn_blog "hello"
(integer) 1
127.0.0.1:6379> PUBLISH csdn_sing "sing"
(integer) 1

最后订阅者接收到两个频道的消息:

1) "pmessage"
2) "csdn*"
3) "csdn_blog"
4) "hello"
1) "pmessage"
2) "csdn*"
3) "csdn_sing"
4) "sing"

3、查看活跃频道

订阅者订阅两条频道:

127.0.0.1:6379> SUBSCRIBE csdn_one csdn_two
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "csdn_one"
3) (integer) 1
1) "subscribe"
2) "csdn_two"
3) (integer) 2

发布者在三条频道发送消息:

127.0.0.1:6379> PUBLISH csdn_one "one"
(integer) 1
127.0.0.1:6379> PUBLISH csdn_two "two"
(integer) 1
127.0.0.1:6379> PUBLISH csdn_three "three"
(integer) 0

在发布者客户端显示活跃的频道:

127.0.0.1:6379> PUBSUB channels
1) "csdn_one"
2) "csdn_two"

五、发布订阅原理

每个Redis服务器进程都维持着一个表示服务器状态的redis.h/redisServer 结构, 结构的pubsub_channels属性是一个字典, 这个字典就用于保存订阅频道的信息,其中,字典的键为正在被订阅的频道, 而字典的值则是一个链表, 链表中保存了所有订阅这个频道的客户端

1、订阅频道原理

假设订阅频道前有如下图所示的频道和订阅该频道的客户端:从图中可以清楚的知道,channelA频道有三个人订阅;channelB频道没有人订阅;channelC频道有两个人订阅。

在这里插入图片描述

当客户端clientF调用SUBSCRIBE命令时,程序就将客户端和要订阅的频道在 pubsub_channels字典中关联起来。执行以下指令,对应的结果图为:

127.0.0.1:6379> SUBSCRIBE channelB channelC channelA

在这里插入图片描述

结论:通过pubsub_channels字典, 程序只要检查某个频道是否为字典的键,就可以知道该频道是否正在被客户端订阅; 只要取出某个键的值, 就可以得到所有订阅该频道的客户端的信息。

2、发布信息原理

原理说明:当调用PUBLISH channel message命令, 程序首先根据channel定位到字典的键, 然后将信息发送给字典值链表中的所有客户端。

对于上图来说,如果客户端channelA执行命令PUBLISH channelA “hello,cabbage”,那么clientAclientBclientCclientF这四个客户端都将接收到"hello,cabbage"信息,通过遍历订阅频道的所有客户端。

3、退订信息原理

原理:使用UNSUBSCRIBE命令可以退订指定的频道,这个命令执行的是订阅的反操作: 它从pubsub_channels字典的给定频道(键)中, 删除关于当前客户端的信息, 这样被退订频道的信息就不会再发送给这个客户端。

参考文章:http://t.zoukankan.com/rxbook-p-12652198.html

到此这篇关于Redis实现消息的发布订阅的文章就介绍到这了,更多相关Redis 消息发布订阅内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • 生产redisson延时队列不消费问题排查解决

    生产redisson延时队列不消费问题排查解决

    这篇文章主要为大家介绍了生产redisson延时队列不消费问题排查解决,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-09-09
  • Redis Value过大问题(键值过大)

    Redis Value过大问题(键值过大)

    这篇文章主要介绍了Redis Value过大问题(键值过大),文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-12-12
  • Redis实现登录注册的示例代码

    Redis实现登录注册的示例代码

    本文主要介绍了Redis实现登录注册的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2022-06-06
  • dubbo服务使用redis注册中心的系列异常解决

    dubbo服务使用redis注册中心的系列异常解决

    这篇文章主要为大家介绍了dubbo服务在使用redis注册中心遇到的一系列异常的解决,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步
    2022-03-03
  • redis分布式锁的8大坑总结梳理

    redis分布式锁的8大坑总结梳理

    这篇文章主要介绍了redis分布式锁的8大坑总结梳理,使用redis的分布式锁,我们首先想到的可能是setNx命令,文章围绕setNx命令展开详细的内容介绍,感兴趣的小伙伴可以参考一下
    2022-07-07
  • 一文教你学会Redis的事务

    一文教你学会Redis的事务

    Redis 作为内存的存储中间件,已经是面试的面试题必问之一了。今天小编就来和大家一起来聊聊Redis的事务吧,希望对大家有所帮助
    2022-08-08
  • Redis持久化AOF示例详解

    Redis持久化AOF示例详解

    AOF(Append-Only File)用于将Redis服务器收到的写操作追加到日志文件,通过该机制可以保证服务器重启后依然可以依靠日志文件恢复数据,这篇文章主要介绍了Redis持久化AOF详解,需要的朋友可以参考下
    2023-12-12
  • Redis数据类型之散列类型hash命令学习

    Redis数据类型之散列类型hash命令学习

    这篇文章主要为大家介绍了Redis数据类型之散列类型hash命令学习,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-07-07
  • Redis exists命令bug分析(案例详解)

    Redis exists命令bug分析(案例详解)

    Redis EXISTS 命令用于检查给定 key 是否存在,本文重点给大家介绍Redis exists命令bug分析,感兴趣的朋友跟随小编一起看看吧
    2022-02-02
  • Redis分布式锁python-redis-lock使用方法

    Redis分布式锁python-redis-lock使用方法

    这篇文章主要介绍了Redis分布式锁python-redis-lock使用方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-11-11

最新评论