redis发布订阅者
2024-10-06 21:31:21
发布者pub.py
import redis conn = redis.Redis(host='127.0.0.1', decode_responses=True) conn.publish('gaoxin', '')
订阅者sub.py
import redis conn = redis.Redis(host='127.0.0.1', decode_responses=True) # 生成一个订阅者对象
pubsub = conn.pubsub() # 订阅一个消息
pubsub.subscribe('gaoxin') # 创建一个接收
while True:
print('working~~~')
msg = pubsub.parse_response()
print(msg)
PS: 运行多个订阅者,每个订阅者会等待接收发布者发送的消息,当发布者发布消息后,订阅者全部接收到
最新文章
- 关于JS变量提升的一些坑
- mssql手工注入
- JAVA正则表达式:Pattern类与Matcher类详解
- Linux下squid代理缓存服务环境部署
- libCEF总结01下载、编译、入门
- 石子归并问题(nyoj737)
- GMT与UTC
- 文件TEXTBOX
- STC89C52单片机内部EEPROM驱动
- HTML入门教程(全套)
- codeforces476D
- python多态和规范
- centos下搭建openstack的环境
- 自学Zabbix9.1 Network Discovery 网络发现原理
- AB Test 是什么
- PAT甲题题解-1102. Invert a Binary Tree (25)-(建树,水题)
- xshell连不上虚拟机linux的解决办法(用的默认NAT模式)
- Python之Django的Model详解
- java 面试题 -- 线程 按序 交替
- 动态rem解决移动前端适配