直接上代码:
首先需要明确的是,客户端向服务端去发送消息,服务端只需要订阅是哪些各频道即可,然后客户端向这些个频道发送消息
在客户端的代码:
#!/usr/bin/env python
#coding:utf-8 import redis rc = redis.Redis(host='127.0.0.1')
rc.pubsub()
rc.publish('fm100','test100')
rc.publish('fm99','test99')
服务端的代码:
#!/usr/bin/env python
#coding:utf-8 import redis rc = redis.Redis(host='127.0.0.1') ps = rc.pubsub() ps.subscribe(['fm100','fm99']) while True:
for item in ps.listen():
print item
这上面是一个死循环,表示不断的监听来自客户端发送的消息
其实更类似于一个socket的实现
我们在进行分布式监控机器的各项性能的时候,可以使用上述的代码