Redis 发布订阅

Redis 发布订阅可以用在像消息通知，群聊，定向推送，参数刷新加载等业务场景

发布订阅模型有三个角色：

发布者（Publisher）
订阅者(Subscriber)
频道(channel)

每个订阅者可以订阅多个频道，发布者可以在某个频道里发布消息，订阅者会接受到自己订阅频道里发布的消息。

1.相关命令 (参考)

publish channel message         发布消息
subscribe [channel]             订阅频道
unsubscribe [channel]           取消订阅
psubscribe [pattern...]         订阅指定模式的频道
punsubscribe [pattern...]       退订指定模式的频道
pubsub channels                 列出至少有一个订阅者的频道
pubsub numsub [channel...]      列表给定频道的订阅者数量
pubsub numpat                   列表被订阅模式的数量

在终端使用示例

# 在 终端1 订阅cctv1
127.0.0.1:8100> subscribe cctv1
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "cctv1"
3) (integer) 1

# 在 终端2 向cctv1 发布消息
127.0.0.1:8100> publish cctv1 "this is cctv1"
(integer) 1

# 终端1 接受到终端2发的消息
127.0.0.1:8100> subscribe cctv1
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "cctv1"
3) (integer) 1
1) "message"
2) "cctv1"
3) "this is cctv1"

2. python 实现

订阅者类，只写了订阅功能，退订原理是一样的，偷了懒，把订阅频道和接收消息写到了一个方法里面，如果严格按面向对象的思想应该分开。

from PublishAndSubscribe.Channel import Channel
from PublishAndSubscribe.RedisTool import RedisToolclass Subscriber:def __init__(self, conn):self._conn = conndef subscribe(self, channel: Channel):# 获取发布/订阅对象pub = self._conn.pubsub()# 选择要订阅的频道pub.subscribe(channel.name)while True:# 接收消息msg = pub.parse_response()print(msg)if __name__ == '__main__':client = RedisTool.redis_connection("0.0.0.0", 8100, "password")cctv1 = Channel("CCTV1")Subscriber(client).subscribe(cctv1)

发布者类

from PublishAndSubscribe.Channel import Channel
from PublishAndSubscribe.RedisTool import RedisToolclass Publisher:def __init__(self, conn):self._conn = conndef publish(self, channel: Channel, mess: str):# 向特定频道发布消息self._conn.publish(channel.name, mess)if __name__ == '__main__':cctv1 = Channel("CCTV1")client = RedisTool.redis_connection("0.0.0.0", 8100, "password")publisher = Publisher(client)while True:publisher.publish(cctv1, input("请输入要发送的消息："))

频道类，Redis中频道的概念只是一个字符串

class Channel:def __init__(self, name: str):self.name = name

一个工具类，用来连接redis

import redisclass RedisTool:@staticmethoddef redis_connection(address: str, port: int, password: str):"""用来连接RedisArgs:address: Redis 服务端IP地址port: [int] Redis 服务端口password: Redis client 登录凭证Return:type[Redis]: 返回一个redis对象"""return redis.StrictRedis(address, port, password=password)

为了简便在订阅者和发布者两处都实例化了一个“CCTV1”的频道，虽然用起来不会有什么问题（Redis中简单的通过字符串区分频道），但在实际中这应该是同一个对象。

结果：

python实现Redis订阅发布相关推荐

python 实现redis订阅发布功能
redis是一个key-value存储系统.和Memcached类似,它支持存储的value类型相对更多,包括string(字符串).list(链表).set(集合).zset(sorted set ...
爬山的蜗牛旅程：redis 订阅发布
学习的旅程,就像蜗牛爬山,一点点的往上爬,一点点的欣赏旅途的风景某天,小猿向小编讲了个很好笑的笑话,第二天,全世界都知道了!这是为啥呢?请看下图: 现在大家大概知道什么是订阅和发布的概念(就是上图的 ...
redis 订阅发布
redis 订阅发布 subscribe 订阅者 publish 发布者 1.我们启用四个进程,三个为订阅者(subscribe),一个为发布者(publish) 订阅者加入demo 发布者发布消息 ...
Redis基础—九、Redis订阅发布、Redis集群
Redis基础-九.Redis订阅发布.Redis集群一.Redis订阅发布 Redis 发布订阅 (pub/sub) 是一种消息通信模式:发送者 (pub) 发送消息,订阅者 (sub) 接收消息 ...
python redis 订阅发布_【Python之旅】第七篇（三）：使用Redis订阅服务
在C/S架构中,可以充分地利用Redis订阅服务,实现服务器端和客户端的信息收发,下面说说在Python中如何使用Redistribute的订阅服务. 这里要举的例子是,Server端进行服务的订阅, ...
python redis 订阅发布_python 实现redis订阅发布功能
redis是一个key-value存储系统.和Memcached类似,它支持存储的value类型相对更多,包括string(字符串).list(链表).set(集合).zset(sorted set ...
python redis 订阅发布_Python-Redis的发布与订阅
封装的redis_config # -*- coding:utf-8 -*- __author__ = "MuT6 Sch01aR" import redis class Redi ...
2.6_10 Redis订阅发布(消息队列)
相关链接 Excel目录 redis官网 redis中文网 1. Redis发布订阅(消息队列) 替代产品:ActiveMQ,RabiitMQ,Kafka 订阅/发布消息图:第一个(消息发送者),第二 ...
初次使用Fleck+redis订阅发布实现学习小demo
https://www.cnblogs.com/SupPilot/p/10396333.html 首先安装Fleck的程序包添加引用下面是客户端代码: 客户端代码: 运行效果: 遇到的问题: Q:通常 ...

python实现Redis订阅发布

Redis 发布订阅

1.相关命令 (参考)

2. python 实现

python实现Redis订阅发布相关推荐

最新文章

热门文章