python:用Redis完成发布和订阅数据
Posted TimoTong
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了python:用Redis完成发布和订阅数据相关的知识,希望对你有一定的参考价值。
安装:
pip install redis
发布文件:
# coding:utf-8 import redis import json class RedisHelper(): def __init__(self): localhost = ‘192.168.2.x‘ self.__conn = redis.Redis(host=‘localhost‘, port=6379, password=‘password‘) # , decode_responses=True, password=‘password‘ self.channel = "monitor" def publisher(self, msg): self.__conn.publish(self.channel, json.dumps(msg)) def subscriber(self): pub = self.__conn.pubsub() pub.subscribe(self.channel) pub.parse_response() return pub if __name__ == "__main__": msg = { ‘name‘: ‘publisher‘, ‘msg‘: ‘message‘ } red = RedisHelper() red.publisher(msg) print msg
订阅文件:
# coding:utf-8 from redis_practice import * obi = RedisHelper() redis_sub = obi.subscriber() msg = redis_sub.parse_response() print msg
以上是关于python:用Redis完成发布和订阅数据的主要内容,如果未能解决你的问题,请参考以下文章