pythonredis订阅发布_PythonRedis的发布与订阅

封装的redis_config

# -*- coding:utf-8 -*-

__author__ &＃61; "MuT6 Sch01aR"

import redis

class RedisConfig:

def __init__(self):

self.__conn &＃61; redis.Redis(host&＃61;&＃39;192.168.220.144&＃39;)

self.chan_sub &＃61; &＃39;redis_queue&＃39;

self.chan_pub &＃61; &＃39;redis_queue&＃39;

# 一个给发布端&＃xff0c;一个给订阅端

def public(self, msg): # 发布端

self.__conn.publish(self.chan_pub, msg) # 发送消息

return True

def subscribe(self): # 订阅端

pub &＃61; self.__conn.pubsub() # 打开接收

pub.subscribe(self.chan_sub) # 选择要监听的queue

pub.parse_response() # 准备接收

return pub

Redis发布端

# -*- coding:utf-8 -*-

__author__ &＃61; "MuT6 Sch01aR"

from redis_config import RedisConfig

obj &＃61; RedisConfig()

obj.public(&＃39;hello world!&＃39;)

Redis订阅端

# -*- coding:utf-8 -*-

__author__ &＃61; "MuT6 Sch01aR"

from redis_config import RedisConfig

obj &＃61; RedisConfig()

redis_sub &＃61; obj.subscribe()

while True:

msg &＃61; redis_sub.parse_response()

print(msg)

运行结果

也可以直接通过redis发布消息