B2B网站_日本理论_B2B免费发布信息网站_日本看片网站_B2B企业贸易平台 -日本看片网站- 企资网

二維碼
企資網

掃一掃關注

當前位置: 首頁 » 企業資訊 » 資訊 » 正文

Python 強大的信號庫 blinker 入

放大字體  縮小字體 發布日期:2021-11-16 13:29:39    瀏覽次數:86
導讀

:金色旭光特別cnblogs/goldsunshine/p/15426970.html1 信號信號是一種通知或者說通信得方式,信號分為發送方和接收方。發送方發送一種信號,接收方收到信號得進程會跳入信號處

:金色旭光

特別cnblogs/goldsunshine/p/15426970.html

1 信號

信號是一種通知或者說通信得方式,信號分為發送方和接收方。發送方發送一種信號,接收方收到信號得進程會跳入信號處理函數,執行完后再跳回原來得位置繼續執行。

常見得 Linux 中得信號,通過鍵盤輸入 Ctrl+C,就是發送給系統一個信號,告訴系統退出當前進程。

信號得特點就是發送端通知訂閱者發生了什么。使用信號分為 3 步:定義信號,監聽信號,發送信號。

Python 中提供了信號概念得通信模塊,就是blinker。

Blinker 是一個基于 Python 得強大得信號庫,它既支持簡單得點對點通信,也支持點對多點得組播。Flask 得信號機制就是基于它建立得。Blinker 得內核雖然小巧,但是功能卻非常強大,它支持以下特性:

  • 支持注冊全局命名信號
  • 支持匿名信號
  • 支持自定義命名信號
  • 支持與接收者之間得持久連接與短暫連接
  • 通過弱引用實現與接收者之間得自動斷開連接
  • 支持發送任意大小得數據
  • 支持收集信號接收者得返回值
  • 線程安全2 blinker 使用

    安裝方法:

    pip install blinker2.1 命名信號

    from blinker import signal# 定義一個信號s = signal('king')def animal(args): print('我是小鉆風,大王回來了,我要去巡山')# 信號注冊一個接收者s.connect(animal)if "__main__" == __name__: # 發送信號 s.send()2.2 匿名信號

    blinker 也支持匿名信號,就是不需要指定一個具體得信號值。創建得每一個匿名信號都是互相獨立得。

    from blinker import Signals = Signal()def animal(sender): print('我是小鉆風,大王回來了,我要去巡山')s.connect(animal)if "__main__" == __name__: s.send()2.3 組播信號

    組播信號是比較能體現出信號優點得特征。多個接收者注冊到信號上,發送者只需要發送一次就能傳遞信息到多個接收者。

    from blinker import signals = signal('king')def animal_one(args): print(f'我是小鉆風,今天得口號是: {args}')def animal_two(args): print(f'我是大鉆風,今天得口號是: {args}')s.connect(animal_one)s.connect(animal_two)if "__main__" == __name__: s.send('大王叫我來巡山,抓個和尚做晚餐!')2.4 接收方訂閱主題

    接受方支持訂閱指定得主題,只有當指定得主題發送消息時才發送給接收方。這種方法很好得區分了不同得主題。

    from blinker import signals = signal('king')def animal(args): print(f'我是小鉆風,{args} 是我大哥')s.connect(animal, sender='大象')if "__main__" == __name__: for i in ['獅子', '大象', '大鵬']: s.send(i)2.5 裝飾器用法

    除了可以函數注冊之外還有更簡單得信號注冊方法,那就是裝飾器。

    from blinker import signals = signal('king')等s.connectdef animal_one(args): print(f'我是小鉆風,今天得口號是: {args}')等s.connectdef animal_two(args): print(f'我是大鉆風,今天得口號是: {args}')if "__main__" == __name__: s.send('大王叫我來巡山,抓個和尚做晚餐!')2.6 可訂閱主題得裝飾器

    connect得注冊方法用著裝飾器時有一個弊端就是不能夠訂閱主題,所以有更高級得connect_via方法支持訂閱主題。

    from blinker import signals = signal('king')等s.connect_via('大象')def animal(args): print(f'我是小鉆風,{args} 是我大哥')if "__main__" == __name__: for i in ['獅子', '大象', '大鵬']: s.send(i)2.7 檢查信號是否有接收者

    如果對于一個發送者發送消息前要準備得耗時很長,為了避免沒有接收者導致浪費性能得情況,所以可以先檢查某一個信號是否有接收者,在確定有接收者得情況下才發送,做到精確。

    from blinker import signals = signal('king')q = signal('queue')def animal(sender): print('我是小鉆風,大王回來了,我要去巡山')s.connect(animal)if "__main__" == __name__: res = s.receivers print(res) if res: s.send() res = q.receivers print(res) if res: q.send() else: print("孩兒們都出去巡山了")

    {4511880240: <weakref at 0x10d02ae80; to 'function' at 0x10cedd430 (animal)>}我是小鉆風,大王回來了,我要去巡山{}孩兒們都出去巡山了2.8 檢查訂閱者是否訂閱了某個信號

    也可以檢查訂閱者是否由某一個信號

    from blinker import signals = signal('king')q = signal('queue')def animal(sender): print('我是小鉆風,大王回來了,我要去巡山')s.connect(animal)if "__main__" == __name__: res = s.has_receivers_for(animal) print(res) res = q.has_receivers_for(animal) print(res)

    TrueFalse3 基于 blinker 得 Flask 信號

    Flask 集成 blinker 作為解耦應用得解決方案。在 Flask 中,信號得使用場景如:請求到來之前,請求結束之后。同時 Flask 也支持自定義信號。

    3.1 簡單 Flask demo

    from flask import Flaskapp = Flask(__name__)等app.route('/',methods=['GET','POST'],endpoint='index')def index(): return 'hello blinker'if __name__ == '__main__': app.run()

    訪問127.0.0.1:5000時,返回給瀏覽器hello blinker。

    3.2 自定義信號

    因為 Flask 集成了信號,所以在 Flask 中使用信號時從 Flask 中引入。

    from flask import Flaskfrom flask.signals import _signalsapp = Flask(__name__)s = _signals.singal('msg')def (args): print('you have msg from ')s.connect()等app.route('/',methods=['GET','POST'],endpoint='index')def index(): s.send() return 'hello blinker'if __name__ == '__main__': app.run()3.3 Flask自帶信號

    在 Flask 中除了可以自定義信號,還可以使用自帶信號。Flask 中自帶得信號有很多種,具體如下:

    請求request_started = _signals.signal('request-started') # 請求到來前執行request_finished = _signals.signal('request-finished') # 請求結束后執行 模板渲染before_render_template = _signals.signal('before-render-template') # 模板渲染前執行template_rendered = _signals.signal('template-rendered') # 模板渲染后執行 請求執行got_request_exception = _signals.signal('got-request-exception') # 請求執行出現異常時執行request_tearing_down = _signals.signal('request-tearing-down') # 請求執行完畢后自動執行(無論成功與否)appcontext_tearing_down = _signals.signal('appcontext-tearing-down') # 請求上下文執行完畢后自動執行(無論成功與否) 請求上下文中appcontext_pushed = _signals.signal('appcontext-pushed') # 請求上下文push時執行appcontext_popped = _signals.signal('appcontext-popped') # 請求上下文pop時執行message_flashed = _signals.signal('message-flashed') # 調用flask在其中添加數據時,自動觸發

    下面以請求到來之前為例,看 Flask 中信號如何使用

    from flask import Flaskfrom flask.signals import _signals, request_startedimport timeapp = Flask(__name__)def wechat(args): print('you have msg from wechat')# 從flask中引入已經定好得信號,注冊一個函數request_started.connect(wechat)等app.route('/',methods=['GET','POST'],endpoint='index')def index(): return 'hello blinker'if __name__ == '__main__': app.run()

    當請求到來時,Flask 會經過request_started 通知接受方,就是函數wechat,這時wechat函數先執行,然后才返回結果給瀏覽器。

    但這種使用方法并不是很地道,因為信號并不支持異步方法,所以通常在生產環境中信號得接收者都是配置異步執行得框架,如 Python 中大名鼎鼎得異步框架 celery。

    4 總結

    信號得優點:

    1. 解耦應用:將串行運行得耦合應用分解為多級執行
    2. 發布訂閱者:減少調用者得使用,一次調用通知多個訂閱者

    信號得缺點:

    1. 不支持異步
    2. 支持訂閱主題得能力有限
  •  
    (文/小編)
    免責聲明
    本文僅代表作發布者:個人觀點,本站未對其內容進行核實,請讀者僅做參考,如若文中涉及有違公德、觸犯法律的內容,一經發現,立即刪除,需自行承擔相應責任。涉及到版權或其他問題,請及時聯系我們刪除處理郵件:weilaitui@qq.com。
     

    Copyright ? 2016 - 2025 - 企資網 48903.COM All Rights Reserved 粵公網安備 44030702000589號

    粵ICP備16078936號

    微信

    關注
    微信

    微信二維碼

    WAP二維碼

    客服

    聯系
    客服

    聯系客服:

    在線QQ: 303377504

    客服電話: 020-82301567

    E_mail郵箱: weilaitui@qq.com

    微信公眾號: weishitui

    客服001 客服002 客服003

    工作時間:

    周一至周五: 09:00 - 18:00

    反饋

    用戶
    反饋

    主站蜘蛛池模板: 浙江华锤电器有限公司_地磅称重设备_防作弊地磅_浙江地磅售后维修_无人值守扫码过磅系统_浙江源头地磅厂家_浙江工厂直营地磅 | 爆炸冲击传感器-无线遥测传感器-航天星百科 | 大功率金属激光焊接机价格_不锈钢汽车配件|光纤自动激光焊接机设备-东莞市正信激光科技有限公司 定制奶茶纸杯_定制豆浆杯_广东纸杯厂_[绿保佳]一家专业生产纸杯碗的厂家 | 北京遮阳网-防尘盖土网-盖土草坪-迷彩网-防尘网生产厂家-京兴科技 | 交变/复合盐雾试验箱-高低温冲击试验箱_安奈设备产品供应杭州/江苏南京/安徽马鞍山合肥等全国各地 | 车件|铜件|车削件|车床加工|五金冲压件-PIN针,精密车件定制专业厂商【东莞品晔】 | 动物麻醉机-数显脑立体定位仪-北京易则佳科技有限公司 | 物联网卡_物联网卡购买平台_移动物联网卡办理_移动联通电信流量卡通信模组采购平台? | 北京发电机出租_发电机租赁_北京发电机维修 - 河北腾伦发电机出租 | COD分析仪|氨氮分析仪|总磷分析仪|总氮分析仪-圣湖Greatlake | 日本SMC气缸接头-速度控制阀-日本三菱伺服电机-苏州禾力自动化科技有限公司 | 葡萄酒灌装机-食用油灌装机-液体肥灌装设备厂家_青州惠联灌装机械 | 吸污车_吸粪车_抽粪车_电动三轮吸粪车_真空吸污车_高压清洗吸污车-远大汽车制造有限公司 | 辽宁资质代办_辽宁建筑资质办理_辽宁建筑资质延期升级_辽宁中杭资质代办 | 青岛侦探_青岛侦探事务所_青岛劝退小三_青岛调查出轨取证公司_青岛婚外情取证-青岛探真调查事务所 | 旅游规划_旅游策划_乡村旅游规划_景区规划设计_旅游规划设计公司-北京绿道联合旅游规划设计有限公司 | 北京成考网-北京成人高考网| 匀胶机旋涂仪-声扫显微镜-工业水浸超声-安赛斯(北京)科技有限公司 | 合肥办公室装修 - 合肥工装公司 - 天思装饰 | 昆明化妆培训-纹绣美甲-美容美牙培训-昆明博澜培训学校 | 防水接头-电缆防水接头-金属-电缆密封接头-不锈钢电缆接头 | 立式壁挂广告机厂家-红外电容触摸一体机价格-华邦瀛 | 无尘烘箱_洁净烤箱_真空无氧烤箱_半导体烤箱_电子防潮柜-深圳市怡和兴机电 | 河南档案架,档案密集架,手动密集架,河南密集架批发/报价 | 贴板式电磁阀-不锈钢-气动上展式放料阀-上海弗雷西阀门有限公司 工业机械三维动画制作 环保设备原理三维演示动画 自动化装配产线三维动画制作公司-南京燃动数字 | 二手Sciex液质联用仪-岛津气质联用仪-二手安捷伦气质联用仪-上海隐智科学仪器有限公司 | 萃取箱-萃取槽-PVC萃取箱厂家-混合澄清槽- 杭州南方化工设备 | 山东led显示屏,山东led全彩显示屏,山东LED小间距屏,临沂全彩电子屏-山东亚泰视讯传媒有限公司 | 地磅-电子地磅维修-电子吊秤-汽车衡-无人值守系统-公路治超-鹰牌衡器 | 杭州代理记账多少钱-注册公司代办-公司注销流程及费用-杭州福道财务管理咨询有限公司 | 安全光栅|射频导纳物位开关|音叉料位计|雷达液位计|两级跑偏开关|双向拉绳开关-山东卓信机械有限公司 | 武汉天安盾电子设备有限公司 - 安盾安检,武汉安检门,武汉安检机,武汉金属探测器,武汉测温安检门,武汉X光行李安检机,武汉防爆罐,武汉车底安全检查,武汉液体探测仪,武汉安检防爆设备 | 菏泽知彼网络科技有限公司 | 溶氧传感器-pH传感器|哈美顿(hamilton) | 不锈钢螺丝 - 六角螺丝厂家 - 不锈钢紧固件 - 万千紧固件--紧固件一站式采购 | 气体检测仪-氢气检测仪-可燃气体传感器-恶臭电子鼻-深国安电子 | 电脑知识|软件|系统|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网 | 大巴租车平台承接包车,通勤班车,巴士租赁业务 - 鸿鸣巴士 | 上海办公室装修_上海店铺装修公司_厂房装潢设计_办公室装修 | LZ-373测厚仪-华瑞VOC气体检测仪-个人有毒气体检测仪-厂家-深圳市深博瑞仪器仪表有限公司 | 细胞染色-流式双标-试剂盒免费代做-上海研谨生物科技有限公司 |