python redis訂閱_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)

個人比較喜歡第二種方法，也推薦各位朋友使用第二種方法，第二種方法中我沒有對接收到的資料進行過多的處理，如果各位朋友喜歡可以拿去自行修改