位置: 编程技术 - 正文

详解Python的Twisted框架中reactor事件管理器的用法(python traits)

编辑:rootadmin

推荐整理分享详解Python的Twisted框架中reactor事件管理器的用法(python traits),希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:python traits,python twisted,python twinter,python twinter,python twinter,python twisted,python twisted,详解python的垃圾回收机制,内容如对您有帮助,希望把文章链接给更多的朋友!

铺垫在大量的实践中,似乎我们总是通过类似的方式来使用异步编程:

监听事件 事件发生执行对应的回调函数 回调完成(可能产生新的事件添加进监听队列) 回到1,监听事件

因此我们将这样的异步模式称为Reactor模式,例如在iOS开发中的Run Loop概念,实际上非常类似于Reactor loop,主线程的Run Loop监听屏幕UI事件,一旦发生UI事件则执行对应的事件处理代码,还可以通过GCD等方式产生事件至主线程执行。

上图是boost对Reactor模式的描绘,Twisted的设计就是基于这样的Reactor模式,Twisted程序就是在等待事件、处理事件的过程中不断循环。

reactor是Twisted程序中的单例对象。

reactorreactor是事件管理器,用于注册、注销事件,运行事件循环,当事件发生时调用回调函数处理。关于reactor有下面几个结论:

Twisted的reactor只有通过调用reactor.run()来启动。 reactor循环是在其开始的进程中运行,也就是运行在主进程中。 一旦启动,就会一直运行下去。reactor就会在程序的控制下(或者具体在一个启动它的线程的控制下)。 reactor循环并不会消耗任何CPU的资源。 并不需要显式的创建reactor,只需要引入就OK了。

最后一条需要解释清楚。在Twisted中,reactor是Singleton(也就是单例模式),即在一个程序中只能有一个reactor,并且只要你引入它就相应地创建一个。上面引入的方式这是twisted默认使用的方法,当然了,twisted还有其它可以引入reactor的方法。例如,可以使用twisted.internet.pollreactor中的系统调用来poll来代替select方法。

若使用其它的reactor,需要在引入twisted.internet.reactor前安装它。下面是安装pollreactor的方法:

如果你没有安装其它特殊的reactor而引入了twisted.internet.reactor,那么Twisted会根据操作系统安装默认的reactor。正因为如此,习惯性做法不要在最顶层的模块内引入reactor以避免安装默认reactor,而是在你要使用reactor的区域内安装。下面是使用 pollreactor重写上上面的程序:

那么reactor是如何实现单例的?来看一下from twisted.internet import reactor做了哪些事情就并明白了。

下面是twisted/internet/reactor.py的部分代码:

注:Python中所有加载到内存的模块都放在sys.modules,它是一个全局字典。当import一个模块时首先会在这个列表中查找是否已经加载了此模块,如果加载了则只是将模块的名字加入到正在调用import的模块的命名空间中。如果没有加载则从sys.path目录中按照模块名称查找模块文件,找到后将模块载入内存,并加入到sys.modules中,并将名称导入到当前的命名空间中。

详解Python的Twisted框架中reactor事件管理器的用法(python traits)

假如我们是第一次运行from twisted.internet import reactor,因为sys.modules中还没有twisted.internet.reactor,所以会运行reactory.py中的代码,安装默认的reactor。之后,如果导入的话,因为sys.modules中已存在该模块,所以会直接将sys.modules中的twisted.internet.reactor导入到当前命名空间。

default中的install:

很明显,default中会根据平台获取相应的install。Linux下会首先使用epollreactor,如果内核还不支持,就只能使用pollreactor。Mac平台使用pollreactor,windows使用selectreactor。每种install的实现差不多,这里我们抽取selectreactor中的install来看看。

在installReactor中,向sys.modules添加twisted.internet.reactor键,值就是再install中创建的单例reactor。以后要使用reactor,就会导入这个单例了。

implementer表示SelectReactor实现了IReactorFDSet接口的方法,这里用到了zope.interface,它是python中的接口实现,有兴趣的同学可以去看下。

IReactorFDSet接口主要对描述符的获取、添加、删除等操作的方法。这些方法看名字就能知道意思,所以我就没有加注释。

示例中的reactor.listenTCP()注册了一个监听事件,它是父类PosixReactorBase中方法。

整个逻辑很简单,和正常的server端一样,创建套接字、绑定、监听。不同的是将套接字的描述符添加到了reactor的读集合。那么假如有了client连接过来的话,reactor会监控到,然后触发事件处理程序。

reacotr.run()事件主循环

mianLoop就是最终的主循环了,在循环中,调用doIteration方法监控读写描述符的集合,一旦发现有描述符准备好读写,就会调用相应的事件处理程序。

那么假如客户端有连接请求了,就会调用读集合中tcp.Port的doRead方法。

doRead方法中,调用accept产生了用于接收客户端数据的套接字,将套接字与transport绑定,然后把transport加入到reactor的读集合。当客户端有数据到来时,就会调用transport的doRead方法进行数据读取了。

Connection是Server(transport实例的类)的父类,它实现了doRead方法。

_dataReceived中调用了示例中我们自定义的EchoProtocol的dataReceived方法处理数据。

至此,一个简单的流程,从创建监听事件,到接收客户端数据就此结束了。

实例解析Python的Twisted框架中Deferred对象的用法 Deferred对象结构Deferred由一系列成对的回调链组成,每一对都包含一个用于处理成功的回调(callbacks)和一个用于处理错误的回调(errbacks)。初始状态

剖析Python的Twisted框架的核心特性 一.reactortwisted的核心是reactor,而提到reactor不可避免的是同步/异步,阻塞/非阻塞,在Dave的第一章概念性介绍中,对同步/异步的界限有点模糊,关于同

Java Web开发过程中登陆模块的验证码的实现方式总结 验证码及它的作用验证码为全自动区分计算机和人类的图灵测试的缩写,是一种区分用户是计算机的公共全自动程序,这个问题可以由计算机生成并评判,

标签: python traits

本文链接地址:https://www.jiuchutong.com/biancheng/386912.html 转载请保留说明!

上一篇:使用Python的Twisted框架编写非阻塞程序的代码示例(pythonsetter)

下一篇:实例解析Python的Twisted框架中Deferred对象的用法(python程序解读举例)

  • 二手车经纪公司和中介的区别
  • 简易计税差额抵扣
  • 固定资产转固后发现少转费用了怎么办
  • 营业外支出罚款所得税怎么处理
  • 个体工商户出租商铺个人所得税
  • 权益法下股权投资
  • 结转税金为贷方怎么结转?
  • 民事诉讼的适用范围和基本制度
  • 所得税网上申报表
  • 代收水电费如何开票商品分类编码
  • 抵税必须要有发票
  • 减半征收城建税文件
  • 增值税纳税申报表在哪里打印
  • 付款账号姓名是什么意思
  • 跨年度的费用发票做错了怎么办
  • 冲销暂估购入原材料的账务处理?
  • 买入返售金融资产是资产还是负债
  • 购买方开具红字信息表
  • 企业房租收入如何申报
  • 小规模开票软件服务费账务处理
  • 计提个税怎么做
  • mac上安装homebrew
  • 关闭自动更新应用程序
  • windows10 电脑
  • 产品外包装的作用
  • 提示语是什么意思?
  • 分公司的股东怎么填
  • 财务专用章是干啥的
  • 预付账款的会计编码是多少?
  • php代码报错
  • phpseessid
  • 办公室装修费怎么入账
  • 员工不愿意缴纳个税 需要公司承担吗
  • 费用报销单怎么划线
  • html编写
  • 如何设置长期有效的群二维码安卓手机
  • download github
  • icse论文
  • pytorch创建模型
  • 融资交易的会计处理
  • 计提减值准备是利空吗
  • sqlserver导入导出数据库
  • 没进项发票开销项发票是可以吗?
  • 入库单入账税务会查吗
  • 货物退回并补货什么意思
  • 企业增值税包含哪些税项及税率
  • 股本减少是利好吗
  • 工会应付下级经费
  • 上个月进项发票在哪查询
  • 预存话费发票能报销吗
  • 长期合同价格怎么定
  • 生产成本的会计科目分录
  • 建造合同收入怎么算
  • 银行业现金流量表
  • 净资产总计等于什么
  • sqlserver中delete、update中使用表别名和oracle的区别
  • mysql日志记录
  • sql server数据库怎么使用
  • 资源管理器操作教程
  • WINDOWS操作系统最新版本
  • linux中链接
  • win10电脑版微信字体大小怎么设置方法
  • macbookpro怎么测声音
  • win7旗舰版显示器亮度调节
  • windows8笔记本电脑
  • 怎样修改linux用户名和密码
  • Win7旗舰版系统镜像文件
  • win8启动设置选哪个
  • win8怎么删除所有东西
  • opengl es programming guide
  • js canvas压缩图片
  • perl-dbd-mysql是什么
  • unity连接数据库能做什么
  • [置顶]JM259194
  • android判断应用是否在前台
  • js创建对象的方法有哪些
  • A级纳税人和一般纳税人区别
  • 上饶二手房契税
  • 加油发票如何抵扣
  • 定额发票怎么查流向
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设