Python：Redis发布订阅模式

# -*- 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'}