cco网站素材,做网站优化的教程,硬件开发工程师薪资,信息流优化师是什么目录 简介参数配置代码模板 简介
Redis发布订阅功能是Redis的一种消息传递模式#xff0c;允许多个客户端之间通过消息通道进行实时的消息传递。在发布订阅模式下#xff0c;消息的发送者被称为发布者#xff08;publisher#xff09;#xff0c;而接收消息的客户端被称为… 目录 简介参数配置代码模板 简介
Redis发布订阅功能是Redis的一种消息传递模式允许多个客户端之间通过消息通道进行实时的消息传递。在发布订阅模式下消息的发送者被称为发布者publisher而接收消息的客户端被称为订阅者subscriber。
在Redis中发布者可以将消息发布到一个或多个频道channel而订阅者可以选择订阅感兴趣的频道以接收相关的消息。同时一个订阅者也可以订阅多个频道。当有消息发布到已被订阅的频道时所有订阅该频道的客户端都能够接收并处理这些消息。
发布订阅功能在实时消息推送、事件通知、即时通讯等场景中具有广泛的应用。在分布式系统中它也经常被用于解耦消息的发送和接收实现松耦合的消息通信机制。
通过发布订阅功能Redis为开发者提供了一种简单而高效的消息传递机制使得不同的模块或系统之间可以实现解耦、实时通信和消息广播等操作。
参数配置
安装redis后在redis.conf内将bind 127.0.0.1一行注掉然后重启redis查找redis-server
代码模板
import json
import redisclass RedisChannelManager:def __init__(self):# 初始化 Redis 连接和订阅发布功能# 通过传递这些参数StrictRedis 类将创建一个与 Redis 服务器的连接# 并使用指定的主机地址、端口号和数据库。你可以通过这个连接执行各种 Redis 命令和操作包括发布和订阅消息。self.redisClient redis.StrictRedis(host127.0.0.1, port6379, db0)#方法用于创建一个 Redis 发布/订阅对象。通过这个对象你可以订阅一个或多个通道并接收其他客户端发布到这些通道的消息。self.pubsub self.redisClient.pubsub()def subscribe(self,channelName):# 订阅指定通道self.pubsub.subscribe(channelName)self.channelName channelName# pubsub.listen() 是 Redis 发布/订阅对象的方法用于监听订阅的通道并等待接收消息。# 当有消息到达时listen() 方法将会阻塞当前线程并返回一个生成器对象通过这个生成器对象可以迭代获取消息。for item in self.pubsub.listen():if item[type] message:self.processMessage(item[data])def processMessage(self, message):messagemessage.decode(utf-8)# 处理收到的消息print(fReceived message: {message})data json.loads(message)if data.get(type) pic:self.handlePicBusiness(data)def handlePicBusiness(self, data):# 处理特定业务类型为 pic 的消息pic_list data.get(pic_list)print(pic_list)# 进行业务操作比如存储到数据库或者处理图片#发布报警信息def handleAlarm(self, data):self.publishMessage(data)def publishMessage(self, data,name):while True:# 发布消息到指定通道message json.dumps(data)self.redisClient.publish(name, message)time.sleep(2)# 创建两个通道管理对象
channel_manager1 RedisChannelManager()
channel_manager2 RedisChannelManager()# 在不同的线程中订阅两个通道
import threading
import time
thread1 threading.Thread(targetchannel_manager1.subscribe,args(c1,))# 发布业务类型为 pic 的消息
pic_data {type: pic,pic_list: [pic1.jpg, pic2.jpg]
}thread2 threading.Thread(targetchannel_manager1.publishMessage,args(pic_data,c1))
thread2.start()
thread1.start()
thread2.join()
thread1.join()
