Redis 订阅者

#-*- coding: utf8 -*-

import redis

r = redis.Redis()

# 获取订阅对象
pub = r.pubsub()
pub.subscribe("104.5fm")
# pub.parse_response()

while True:
    msg = pub.parse_response()
    print(msg)

　

Redis 发布者

#!/usr/bin/env python
#-*- coding: utf8 -*-

import redis
r=redis.Redis()

r.publish("104.5fm","666")