python实现 redis订阅与发布

wxin

　　订阅者可以订阅一个或多个频道，发布者向一个频道发送消息后，所有订阅这个频道的订阅者都将收到消息，而发布者也将收到一个数值，这个数值是收到消息的订阅者的数量。订阅者只能收到自它开始订阅后发布者所发布的消息，之前发布的消息呢，就不可能收到了。
　　多的不说看代码！！！
　　面向过程的方法
　　#!/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)
　　个人比较喜欢第二种方法，也推荐各位朋友使用第二种方法，第二种方法中我没有对接收到的数据进行过多的处理，如果各位朋友喜欢可以拿去自行修改