1. 发布/订阅
发布/订阅(Publish/subscribe 或pub/sub)是一种消息范式,消息的发送者(发布者)不是计划发送其消息给特定的接收者(订阅者)。而是发布的消息分为不同的类别,而不需要知道什么样的订阅者订阅。订阅者对一个或多个类别表达兴趣,于是只接收感兴趣的消息,而不需要知道什么样的发布者发布的消息。
这种发布者和订阅者的解耦可以允许更好的可扩展性和更为动态的网络拓扑.
如果对redis的发布订阅功能还不了解的话,可以参考官方文档翻译版
Redis 发布/订阅(Pub/Sub)
2. 数据结构
redis里面发布订阅相对来说是独立的一个模块,代码也比较简单。
先看数据结构定义。
struct redisServer {
dict *pubsub_channels; //订阅频道哈希表
list *pubsub_patterns; //订阅模式链表
};
/*
* 记录订阅模式的结构
*/
typedef struct pubsubPattern {
// 订阅模式的客户端
redisClient *client;
// 被订阅的模式
robj *pattern;
} pubsubPattern;
typedef struct redisClient {
dict *pubsub_channels; //这个字典记录了客户端所有订阅的频道
list *pubsub_patterns; //这个链表记录了客户端所有订阅的模式
} redisClient;
可以看到服务端和客户端都记录了订阅的频道、模式。
然后看一下订阅频道和订阅模式的代码
pubsub.c中
int pubsubSubscribeChannel(redisClient *c, robj *channel) {
dictEntry *de;
if (dictAdd(c->pubsub_channels,channel,NULL) == DICT_OK) { //首先加入客户端的哈希表里
de = dictFind(server.pubsub_channels,channel); //找服务端的哈希表
if (de == NULL) {
clients = listCreate();
dictAdd(server.pubsub_channels,channel,clients);
incrRefCount(channel);
} else {
clients = dictGetVal(de);
}
// 将客户端添加到链表的末尾
listAddNodeTail(clients,c);
}
}
int pubsubSubscribePattern(redisClient *c, robj *pattern) {
if (listSearchKey(c->pubsub_patterns,pattern) == NULL) {
pubsubPattern *pat;
// 将 pattern 添加到客户端的链表中
listAddNodeTail(c->pubsub_patterns,pattern);
// 创建并设置新的 pubsubPattern 结构
pat = zmalloc(sizeof(*pat));
pat->pattern = getDecodedObject(pattern);
pat->client = c;
// 将 pattern 添加到服务端的链表中
listAddNodeTail(server.pubsub_patterns,pat);
}
}
代码是自解释的,清晰明了。
3. 性能问题疑惑
3.1 关于退订所有消息,
pubsubUnsubscribeAllChannels
pubsubUnsubscribeAllPatterns
作者用了一个迭代来遍历哈希表,但是迭代里面又重新用key来查哈希表,这个其实有性能问题。这个问题和java里面的iterate map一样,是个经常会犯的错误。
3.2 订阅模式只是用了一个链表,没有用哈希表,如果模式多了性能会有大问题。
可能作者认为订阅模式和订阅频道不会很多,所以这里的编码显得不那么精雕细刻。当然这部分代码改起来也是很简单的,如果发现性能问题了随时可以改。
4. 模式匹配
util.c里面自己实现了一个glob匹配,又不得不惊叹用C语言编程太亲力亲为了。
/* Glob-style pattern matching. */
int stringmatchlen(const char *pattern, int patternLen,
const char *string, int stringLen, int nocase)
{
}
分享到:
相关推荐
Redis是一款高性能的键值对数据库,其内部使用了许多优化的数据结构来存储数据,其中ziplist是Redis为了节省内存而设计...在阅读Redis源码时,深入分析ziplist的实现细节将有助于我们更好地理解和调试Redis的内存管理。
在Redis源码阅读笔记(10)——事件中,我们将探讨Redis如何利用事件模型来实现非阻塞I/O,以及相关的编程模型如Reactor模式和NIO。 Redis使用了一个基于epoll的事件处理器,epoll是Linux系统提供的一种高效I/O多路...
这篇源码阅读笔记主要关注Redis中的对象系统,它是Redis实现高效数据操作的关键。 在Redis中,每个数据都有一个特定的对象类型,比如`OBJ_STRING`、`OBJ_HASH`等,这些类型定义了数据的存储方式和操作行为。对象...
本篇笔记将聚焦于Redis源码中的“sds”(Simple Dynamic Strings,简单动态字符串)部分,这是Redis中处理字符串的基础数据结构。 首先,我们要明白sds是什么。在C语言中,字符串是以字符数组的形式存在的,而sds是...
redis源码阅读中文分析注释
本项目提供了一个基于C#的Redis发布与订阅(Publish/Subscribe)系统的源码,帮助开发者了解如何在Windows Forms(Winform)应用中实现这一功能。 首先,我们需要了解Redis的发布/订阅模式。在这个模式下,发送者...
通过阅读“狂神redis源码笔记”和解压的“redis-study”文件,你将能够深入理解Redis的内部运作,掌握Java客户端的使用技巧,提升在实际项目中运用Redis的能力。这包括但不限于了解Redis的设计模式、源码实现细节、...
Redis,即远程字典服务,是一个开源的使用ANSI C语言编写、支持网络、可基于内存亦可持久化的日志型、Key-Value数据库,并提供多种语言的API。...本文适合Redis初学者和进阶者阅读,是一份全面而实用的学习笔记。
Redis是一个开源的使用ANSI C语言编写、支持网络、可基于内存亦可持久化的日志型、Key-Value数据库,并提供多种语言的API。 附件里面包括redis源码,phpredis源码,redis指令及文档
本教程将详细讲解如何在C#环境中利用Redis的发布订阅(Publish-Subscribe,简称Pub/Sub)机制实现跨进程通信,并且会涉及到Key过期通知的处理。 首先,我们需要了解Redis的发布订阅机制。在Redis中,发布订阅是一种...
Redis以其丰富的数据结构、高性能、持久化特性、复制、集群以及发布/订阅等特性而闻名。 以下是Redis的一些主要特点: 数据结构丰富:Redis支持多种数据结构,包括字符串(string)、哈希(hash)、列表(list)、...
Redis全套学习笔记 Redis是一种基于内存的NoSQL数据库,具有高性能、可扩展性和灵活性等特点。以下是Redis的详细知识点: 安装和启动 * 安装Redis可以通过下载软件包或使用yum、apt-get等安装工具进行安装。 * ...
Redis 安装遇到的问题——Linux Centos7.5 Redis 是一个开源的、基于内存的数据结构存储系统,常用于数据库、缓存、消息队列等场景。但是,在 Linux Centos7.5 环境中安装 Redis 时可能会遇到一些问题,这篇文章将...
Redis具备数据复制、Lua脚本、事务、不同级别的持久化等多种功能,并通过发布/订阅模式支持消息系统。 哨兵模式是Redis的高可用解决方案之一。在哨兵模式下,一个或多个哨兵会监控主从服务器,并在指定的主服务器不...
在Redis中,发布订阅(Publish/Subscribe)模式是一种重要的通信机制,允许发送者(Publisher)将消息发送到频道(Channel),而无需知道任何接收者(Subscriber)的存在。接收者只需要订阅感兴趣的频道,就可以接收...
它支持多种数据结构,包括字符串(String)、链表(List)、哈希(Hash)、集合(Set)和有序集合(Zset),这些丰富的数据结构使得Redis在缓存、计数、发布订阅系统等多种场景下表现出色。 1. Redis 概述与安装: Redis ...
5. **导入与导出**:可以将Redis中的数据导出为JSON、CSV或文本格式,同时支持从这些格式导入数据到Redis,方便数据迁移和备份。 6. **搜索功能**:提供搜索功能,帮助用户快速定位到目标键,对于大型Redis实例尤其...
在Windows环境下,Redis的源码分析和部署对于开发者来说具有重要意义,尤其是在Windows服务端开发中。以下是对"Redis Windows源码"的详细解析: 1. Redis核心架构: Redis基于单线程模型,通过事件驱动机制处理...
Redis全套学习笔记 完整版pdf.rar set:添加键值对 get:获取值 apend:追价值 strlen:获取值的长度 setnx:key不存在时,设置key的值 incr:原子递增1 decr:原子递减1 incrby/decrby:递增或者递减指定的数字 ...