发布消息

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

import redis

redis_con = redis.Redis(host='127.0.0.1')

redis_con.publish(channel='test', message='hi-1')

订阅消息

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

import redis

redis_con = redis.Redis(host='127.0.0.1')

pubsub = redis_con.pubsub()
pubsub.subscribe('test')
for item in pubsub.listen():
    print(item)

接收到的消息

# 阻塞监听，第一条是测试数据
{'type': 'subscribe', 'pattern': None, 'channel': b'test', 'data': 1}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'hi'}