Redis管道发布订阅

管道（pipe）：
redis-py默认在执行每次请求都会创建（连接池申请连接）和断开（归还连接池）一次连接操作，如果想要在一次请求中指定多个命令，则可以使用pipline实现一次请求指定多个命令。
代码范例：

import redis
pool = redis.ConnectionPool(host='192.168.33.6', port=6379)
r = redis.Redis(connection_pool=pool)
pipe = r.pipeline(transaction=True)
print(r.get('name'), r.get('role'))
pipe.set('name', 'alex')
pipe.set('role', 'sb')
pipe.execute()
print(r.get('name'), r.get('role'))# 输出：None Nonealex sb

订阅发布：只要有主播说话，所有收听者都能听到。

代码范例：

import redisclass RedisHelper:def __init__(self):self.__conn = redis.Redis(host='192.168.33.6')self.chan_sub = 'fm104.5'self.chan_pub = 'fm104.5'def public(self, msg):self.__conn.publish(self.chan_pub, msg)return Truedef subscribe(self):pub = self.__conn.pubsub()   # 打开收音机pub.subscribe(self.chan_sub)  # 调频道pub.parse_response()   # 准备接收return pub

订阅者：

# -*- coding: utf-8 -*-
from Redis_helper import RedisHelperobj = RedisHelper()
redis_sub = obj.subscribe()while True:msg = redis_sub.parse_response()print(msg)

发送者：

# -*- coding: utf-8 -*-from Redis_helper import RedisHelperobj = RedisHelper()
obj.public('hello')

转载于:https://www.cnblogs.com/fone933/p/8306457.html

Redis管道发布订阅相关推荐

【springboot】【redis】springboot+redis实现发布订阅功能，实现redis的消息队列的功能...
springboot+redis实现发布订阅功能,实现redis的消息队列的功能参考:https://www.cnblogs.com/cx987514451/p/9529611.html 思考一个问 ...
4 Redis的发布订阅
Redis 的发布订阅(pub/sub)是一种消息通信模式:发送者(pub)发送消息,订阅者(sub)接收消息 Redis 客户端可以订阅任意数量的频道. 先订阅后发布才能收到消息 1 打开一个客户端 ...
.net core 使用Redis的发布订阅
Redis是一个性能非常强劲的内存数据库,它一般是作为缓存来使用,但是他不仅仅可以用来作为缓存,比如著名的分布式框架dubbo就可以用Redis来做服务注册中心.接下来介绍一下.net core 使用 ...
redis的发布订阅缺陷
虽然redis实现了发布订阅(publish/subscribe)的功能,但是在通常的情况下是不推荐使用的,如果想使用消息队列这种功能,最好还是使用专业的各种MQ中间件,例如rabbitMQ,rock ...
SpringBoot整合redis实现发布订阅模式
Redis的发布订阅模式发布订阅(Pub/Sub):目前广泛使用的通信模型,它采用事件作为基本的通信机制,提供大规模系统所要求的松散耦合的交互模式:订阅者(如客户端)以事件订阅的方式表达出它有兴趣接 ...
Spring boot整合Redis实现发布订阅（超详细）
Redis发布订阅基础知识相关命令订阅者/等待接收消息发布者/发送消息订阅者/成功接收消息常用命令汇总原理 Spring boot整合redis 导入依赖 Redis配置消息封装类(M ...
java实现Redis消息发布订阅
Redis发布订阅架构 Redis提供了发布订阅功能,可以用于消息的传输,Redis的发布订阅机制包括三个部分,发布者,订阅者和Channel. 发布者和订阅者都是Redis客户端,Channel则为 ...
Redis 实现发布/订阅消息对列
Redis实现发布/订阅消息对列前言发布订阅是一种典型的异步通信模型,可以让消息的发布者和订阅者充分解耦一.什么是发布/订阅 Redis 发布订阅 (pub/sub) 是一种消息通信模式:发 ...
Redis的发布订阅模式
本文源码参看:https://github.com/duktig666/learn-example/tree/5586febea31c2fb368e19fbdba11ed08afd463e0/Redi ...

Redis管道发布订阅

Redis管道发布订阅相关推荐

最新文章

热门文章

Redis管道 发布订阅

Redis管道 发布订阅相关推荐

最新文章

热门文章

Redis管道发布订阅

Redis管道发布订阅相关推荐