python 消息分发组件 blinker 学习
blinker 是一个通过消息机制来实现解耦合库，提供了强大的功能。不过这个来的消息是通过的消息并非异步消息，像实现异步消息的自己修改下。
官网地址： ?http://discorporate.us/projects/Blinker/
?
看代码学技术?
?
#!/usr/bin/env python
#coding=utf-8
'''
Created on 2011-9-6
?
@author: bruce
'''
from blinker import signal
from blinker.base import Signal
?
#注册一个命名消息
ready = signal('ready')
?
#创建一个消息订阅者
def subscriber(sender):
# ? ?print sender.name
? ? print("Got a signal sent by %r" % sender)
?
#消息发送者
class Processor:
? ? def __init__(self, name):
? ? ? ? self.name = name
? ? ? ? self.id = 'test_001'
?
? ? def go(self):
? ? ? ? #发送消息
? ? ? ? ready.send(self)
? ? ? ? print("Processing.")
?
? ? def __repr__(self):
? ? ? ? return '<Processor %s>' % self.name
?
def b_subscriber(sender):
? ? print("Caught signal from processor_b.")
?
def xxx(sender):
? ? print 'xxxx'
?
?
processor_b = Processor('b')
ready.connect(subscriber)
ready.connect(b_subscriber, sender=processor_b)
ready.connect(xxx, sender=processor_b)
?
#processor_b.go()
?
?
?
?
#----------------------------------------------
#注册一个消息
send_data = signal('send-data')
?
#关联消息
@send_data.connect
def receive_data(sender, **kw):
? ? print("Caught signal from %r, data %r" % (sender, kw))
? ? return 'received!'
?
#发送消息
result = send_data.send('anonymous', abc=123)
?
?
?
#----------------------------------------------
#匿名消息
class AltProcessor:
? ? on_ready = Signal()
? ? on_complete = Signal()
?
? ? def __init__(self, name):
? ? ? ? self.name = name
?
? ? def go(self):
? ? ? ? self.on_ready.send(self)
? ? ? ? print("Alternate processing.")
? ? ? ? self.on_complete.send(self)
?
? ? def __repr__(self):
? ? ? ? return '<AltProcessor %s>' % self.name
?
apc = AltProcessor('c')
?
@apc.on_complete.connect
def completed(sender):
? ? print "AltProcessor %s completed!" % sender.name
?
apc.go()
?
?
?
#----------------------------------------------
dice_roll = signal('dice_roll')
?
@dice_roll.connect_via(1)
@dice_roll.connect_via(3)
@dice_roll.connect_via(5)
def odd_subscriber(sender):
? ? print("Observed dice roll %r." % sender)
?
result = dice_roll.send(3)
?
