python 消息分发组件 blinker 学习

fgdfg

　　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)