發布和訂閱
首先定義乙個redishelper類，連線redis，定義頻道為monitor，定義發布(publish)及訂閱(subscribe)方法。
#!/usr/bin/env python
#-*- coding:utf-8 -*-
import
redis
class
redishelper(object):
def__init__
(self):
self.
__conn = redis.redis(host='
192.168.0.110
',port=6379)#
連線redis
self.channel = '
monitor'#
定義名稱
def publish(self,msg):#
定義發布方法
self.__conn
.publish(self.channel,msg)
return
true
def subscribe(self):#
定義訂閱方法
pub = self.__conn
.pubsub()
pub.subscribe(self.channel)
pub.parse_response()
return pub
發布者
#!/usr/bin/env python
#-*- coding:utf-8 -*-#發布
from redishelper import
redishelper
obj =redishelper()
obj.publish(
'hello
')#發布
訂閱者
#!/usr/bin/env python
#-*- coding:utf-8 -*-#訂閱
from redishelper import
redishelper
obj =redishelper()
redis_sub = obj.subscribe()#
呼叫訂閱方法
while
true:
msg=redis_sub.parse_response()
print (msg)
Redis教程09 發布和訂閱
redis教程08 zset有序集合介紹 redis教程07 set集合介紹 redis教程06 list型別命令介紹 redis教程05 hash型別命令介紹 redis教程04 string型別之bit redis教程03 string介紹 redis 發布訂閱 pub sub 是一種訊息通訊模...
RabbitMQ 原文譯03 發布和訂閱
在之前的案例中我們建立了乙個工作佇列,這個工作佇列的實現思想就是乙個把每乙個任務平均分配給每乙個執行者,在這個篇文章我們會做一些不一樣的東西,把乙個訊息傳送給多個消費者,這種模式就被稱作 發布 訂閱 為了說明這個模式,我們將要建立乙個簡單的日誌系統,乙個負責發布訊息,另外乙個負責接收列印他們.在我們...
10 發布訂閱模型
icestorm 是乙個高效的用於ice應用的發布 訂閱服務，icestorm有幾個比較重要的概念 訊息 icestorm的訊息和普通的訊息佇列中介軟體中描述的訊息有點區別，icestorm 的訊息是強型別的，由對某個slice 操作的呼叫 代表 操作名 標識 訊息的型別，操作引數 定義 訊息內容。...