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完成发布和订阅数据的主要内容,如果未能解决你的问题,请参考以下文章

利用Redis作消息队列,实现生产消费和发布订阅

python中使用redis发布订阅者模型

Redis学习九:Redis的发布订阅

基于redis(订阅发布)实现python和java进程间通信

电脑端微信不能打开订阅号的文章 一片空白?

Redis发布订阅和事务实现原理