python实现 redis订阅与发布

订阅者可以订阅一个或多个频道，发布者向一个频道发送消息后，所有订阅这个频道的订阅者都将收到消息，而发布者也将收到一个数值，这个数值是收到消息的订阅者的数量。订阅者只能收到自它开始订阅后发布者所发布的消息，之前发布的消息呢，就不可能收到了。
多的不说看代码！！！

面向过程的方法
#!/usr/bin/python
#coding:utf-8

#服务器端
import redis
r = redis.Redis(host='127.0.0.1',port='6379') #连接redis
p = r.pubsub() #开启订阅
p.subscribe('6379') #接收订阅的数据,订阅的频道

for item in p.listen(): #读取接收的数据
print item

if item['type'] == 'message': #判断数据是否是用户发布的数据
data = item['data'] #取出用户要发布的数据
print data #打印要发布的数据

if item['data'] == 'Q' or item['data'] == 'q':
break; #退出程序

p.unsubscribe('6379') #关闭频道
print '取消订阅'

#客户端

#!/usr/bin/py
#coding:utf-8
import redis
r = redis.Redis(host='127.0.0.1',port=6379) #连接redis

while True:
my_input = raw_input("请输入发布内容:") #输入发布的内容
r.publish('6379', my_input) #发送到的频道,发布的内容

if my_input == 'Q' or my_input == 'q': #判断用户是否要退出程序
print '停止发布'
break;

面向对象的方法
#服务器端
#!/usr/bin/python
#coding:utf-8
import redis

class server(object):
def __init__(self,ip='127.0.0.1',port=6379,sub='A'):
self.ip = ip
self.port = port
self.connect = redis.Redis(host=self.ip,port=self.port) #连接redis
self.sub = sub #监听频道
def se(self):
spub = self.connect.pubsub() #打开订阅
spub.subscribe(self.sub) #开始监听
spub.listen() #用户发布的数据
return spub

x = server()
p = x.se()
for item in p.listen(): #打印接收到的数据
print item

#客户端
#!/usr/bin/python
#coding:utf-8
import redis

class client(object):
def __init__(self,ip='127.0.0.1',port=6379,pub='A'):
self.ip = ip
self.port = port
self.connect = redis.Redis(host=self.ip,port=self.port)
self.pub = pub #连接的频道
def cl(self,content):
self.connect.publish(self.pub,content) #频道,发送的数据

x = client()
while True:
my_input = raw_input('请输入发布内容：') #发布的数据
x.cl(my_input)

个人比较喜欢第二种方法，也推荐各位朋友使用第二种方法，第二种方法中我没有对接收到的数据进行过多的处理，如果各位朋友喜欢可以拿去自行修改