博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Redis消息队列
阅读量:5878 次
发布时间:2019-06-19

本文共 1725 字,大约阅读时间需要 5 分钟。

Redis的消息队列使用简单,没有什么配置,比ActiveMQ要轻量级太多,当然功能也比较简单,如果只需要简单的订阅以及发布,可以考虑使用它。

订阅操作

命令为:subscribe [channel] [channel] ..,如【代码1】所示,即成功订阅频道[redis.blog]。

发布操作

命令为publish [channel] [message],如【代码2】所示,【图1】为订阅的客户端展示效果。

【代码1】:

subscribe "redis. blog"

【代码2】

publish "redis.blog" "hello redis"

【图1】

图1

退订操作

命令为:unsubscribe [channel] [channel] ..,如【代码3】所示。

【代码3】

unsubscribe "redis.blog"

模式订阅

命令为:psubscribe [pattern] [pattern]…,如【代码4】所示,如果发布的消息符合当前订阅的模式,亦会收到消息通知,如【图2】所示。

【代码4】

psubscribe "redis.*"

【图2】

这里写图片描述

模式退订

命令为:punsubscribe [pattern] [pattern]…,如【代码5】所示。
【代码5】

punsubscribe "redis.*"

数据结构

关于频道以及模式,redis通过两个struct实现,在redisServer中是如下定义的:

struct rediServer{    dict *pubsub_channels;    list *pubsub_patterns;}

频道是一个dict,pubsub_channels中key为频道名称,value为一个list,list中存储了所有订阅当前频道的client机器;

订阅:如果当前频道还不存在,则subscribe操作即为一次dictAdd操作,如果存在,则相当于将当前的client append到当前channel对应的value list中;
退订:从dict中get(channel)获得list,从list中删除当前client,如果删除后list为空,则表示当前频道已经没有订阅者了,此时将会删除当前channel。

模式是一个list,list中每个node为一个pubsubPattern结构,定义如下:

typedef struct pubsubPattern{redisClient *client;robj *pattern;}

订阅模式:即是在当前list队尾插入一个pubsubPattern;

退订模式:则是遍历list删除匹配节点的过程。
即使不同client订阅同一个模式,也是两个不同的node,或者同一个client订阅2个不同模式,亦为两个node,这一点从pubsubPattern的数据结构上能看出来。

发送消息

发布一条信息,redis服务器会执行2个操作:

  • 将消息发送给相应频道的所有订阅者,具体操作为:
    以当前频道为key,在当前pubsub_channels字典中找到对应的value,value为一个订阅者list,遍历该list,将消息发送给所有的订阅者;
  • 将消息发送给与当前频道相匹配的所有模式,具体操作为:
    以当前频道为key,在当前pubsub_patterns列表中遍历所有节点,如果某个节点(pubsubPattern)的pattern值和key匹配,则将消息发送给当前节点的client,遍历结束为止。

另外的三个命令

  • pubsub channels:查看当前所有频道;也可以使用通配,返回所有匹配的平道(pubsub channels “redis.*”);
  • pubsub numsub: 接收任意多个频道作为输入参数,返回这些频道的订阅者数量;
  • pubsub numpat:返回服务器当前被订阅模式的数量;

至于如何将发布的消息及时反馈给所有订阅者,redis是通过服务器的文件事件来操作的,不单单是消息队列功能,所有的get,set操作都是通过文件事件(file event)来驱动的,事件会单独开一篇来介绍。

你可能感兴趣的文章
发展大数据不能抛弃“小数据”
查看>>
25000个布满恶意软件的摄像头组成的僵尸网络
查看>>
FB全球开放360度直播功能 首先需要一个FB账号
查看>>
量子通信成信息安全领域发展重点 潜在市场望达1000亿元
查看>>
OpenFlow下一步该怎么走?
查看>>
CoreOS为容器安全带来不同方法
查看>>
用EXCEL导入QC需求和测试用例详解
查看>>
中了WannaCry病毒的电脑几乎都是Win 7
查看>>
老男孩最近几年常用的免费的开源软件
查看>>
Cacti 中的 Debugging 技巧
查看>>
我的友情链接
查看>>
利用pt-table-checksum做主从一致性校验
查看>>
部署企业版lync2013之四:持久聊天
查看>>
分布式事务的实现方式
查看>>
MongoDB基本操作、备份还原及用户管理
查看>>
mysql八:ORM框架SQLAlchemy
查看>>
Lamp、MySQL架构介绍及MySQL的安装
查看>>
Spring容器、高级装配回顾
查看>>
linux 下mii-tool ethtool 命令简单的使用
查看>>
窗体包含窗体--MDI多文档界面
查看>>