两天机器做，host要写订阅主机的ip，客户端发消息，服务端订阅消息
cat redis_connector.py
#!/usr/bin/env python
__author__ = 'Q.Li'
import redis
r = redis.Redis(host='localhost',port=6379,db=0)
#r['YourKey'] = 'YourValue'
cat monitor_server.py
import redis_connector as redis
import pickle
channel = 'monitor_queue'
msg_queue = redis.r.pubsub()
msg_queue.subscribe(channel)
msg_queue.parse_response()
count = 0
while True:
date = msg_queue.parse_response()
print 'round %s :: ' % count,pickle.loads(data[2])
count +=1
一、A:主机操作
1.首先运行redis-server服务
root@ubuntu:/usr/local/src/redis-2.8.17/src# ./redis-server
2.运行redis-cli
root@ubuntu:/usr/local/src/redis-2.8.17/src# ./redis-cli
127.0.0.1:6379>
3.制定订阅频道号，设定为chan_107
127.0.0.1:6379> help SUBSCRIBE #订阅使用方法，可以订阅多个频道
SUBSCRIBE channel [channel ...]
summary: Listen for messages published to the given channels
since: 2.0.0
group: pubsub
127.0.0.1:6379> SUBSCRIBE chan_107
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "chan_107"
3) (integer) 1
这样就一直等待接受消息...
B:主机
1.运行python编译器
root@liqian-python:/pythonShare/monitor/m_server/core# python
Python 2.7.10 (default, Oct 14 2015, 16:09:02)
[GCC 5.2.1 20151010] on linux2
Type "help", "copyright", "credits" or "license" for more information.
>>>
>>> import redis_connector as redis,tab
>>> redis.r.publish('chan_107','hello,ubuntu')
1L
>>>
1L就发送成功，chan_107为订阅频道，hello,ubuntu为发送字符
A:主机
1.自动接受消息
1) "message"
2) "chan_107"
3) "hello,ubuntu"
二、循环接受消息，按照上面的案列来实现
在同一台B机器上做的操作
1.再打开一个B终端，进入python交互器，
root@liqian-python:/pythonShare/monitor/m_server/core# python
Python 2.7.10 (default, Oct 14 2015, 16:09:02)
[GCC 5.2.1 20151010] on linux2
Type "help", "copyright", "credits" or "license" for more information.
>>> import redis_connector as redis
>>> msg_q = redis_connector.r.pubsub()
>>> msg_q.subscribe('chan_107')
>>> msg_q.parse_response() #接受消息，
['subscribe', 'chan_107', 1L]
>>> msg_q.parse_response() #需要手动来查看消息，每次执行都查收消息，如果没有消息就会阻塞，会一直等消息。
['message', 'chan_107', 'Hello，world']