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

__author__ = "MuT6 Sch01aR"

import redis

class RedisConfig:

    def __init__(self):

        self.__conn = redis.Redis(host='192.168.220.144')

        self.chan_sub = 'redis_queue'

        self.chan_pub = 'redis_queue'

        # 一个给发布端，一个给订阅端

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

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

        return True

    def subscribe(self):  # 订阅端

        pub = self.__conn.pubsub()  # 打开接收

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

        pub.parse_response()  # 准备接收

        return pub

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

__author__ = "MuT6 Sch01aR"

from redis_config import RedisConfig

obj = RedisConfig()

obj.public('hello world!')

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

__author__ = "MuT6 Sch01aR"

from redis_config import RedisConfig

obj = RedisConfig()

redis_sub = obj.subscribe()

while True:

    msg = redis_sub.parse_response()

    print(msg)