订阅
# 订阅功能终端
>>> import redis
>>> r = redis.Redis()
# 打开订阅功能
>>> sub = r.pubsub()
# 声明订阅的频道
>>> sub.subscribe('fm87.7')
# 开始订阅,第一次会返回一条订阅信息，第二次开始持续订阅
>>> sub.parse_response()
['subscribe', 'fm87.7', 1L]
>>> sub.parse_response() #此时会一直等待数据
发布
打开新的终端，执行发布部分
# 发布功能终端
>>> import redis
>>> r = redis.Redis()
# 指定频道发送数据
>>> r.publish('fm87.7', 'send msg')
执行后，订阅终端会受到发布终端发布信息，如下：
['message', 'fm87.7', 'send msg']
可以将订阅终端使用while循环，进行持续订阅。如下
>>> import redis
>>> r = redis.Redis()
>>> sub = r.pubsub()
>>> sub.subscribe('fm87.7')
>>> while True:
... sub.parse_response()
...
# 可以持续接受消息。
网友评论