位置: 编程技术 - 正文

Python的Tornado框架的异步任务与AsyncHTTPClient(python tornado框架)

编辑:rootadmin

推荐整理分享Python的Tornado框架的异步任务与AsyncHTTPClient(python tornado框架),希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:python tornado django,python tornado orm,python tornado框架,python tor,python tornado orm,python toad,python tornado django,python tornado框架,内容如对您有帮助,希望把文章链接给更多的朋友!

高性能服务器TornadoPython的web框架名目繁多,各有千秋。正如光荣属于希腊,伟大属于罗马。Python的优雅结合WSGI的设计,让web框架接口实现千秋一统。WSGI 把应用(Application)和服务器(Server)结合起来。Django 和 Flask 都可以结合 gunicon 搭建部署应用。

与 django 和 flask 不一样,tornado 既可以是 wsgi 应用,也可以是 wsgi 服务。当然,选择tornado更多的考量源于其单进程单线程异步IO的网络模式。高性能往往吸引人,可是有不少朋友使用之后会提出疑问,tornado号称高性能,实际使用的时候却怎么感受不到呢?

实际上,高性能源于Tornado基于Epoll(unix为kqueue)的异步网络IO。因为tornado的单线程机制,一不小心就容易写出阻塞服务(block)的代码。不但没有性能提高,反而会让性能急剧下降。因此,探索tornado的异步使用方式很有必要。

Tornado 异步使用方式简而言之,Tornado的异步包括两个方面,异步服务端和异步客户端。无论服务端和客户端,具体的异步模型又可以分为回调(callback)和协程(coroutine)。具体应用场景,也没有很明确的界限。往往一个请求服务里还包含对别的服务的客户端异步请求。

服务端异步方式服务端异步,可以理解为一个tornado请求之内,需要做一个耗时的任务。直接写在业务逻辑里可能会block整个服务。因此可以把这个任务放到异步处理,实现异步的方式就有两种,一种是yield挂起函数,另外一种就是使用类线程池的方式。请看一个同步例子:

使用ab测试一下:

qps 仅有可怜的 0.,姑且当成每秒处理一个请求吧。

下面祭出异步大法:

尽管在执行异步任务的时候选择了timeout 1秒,主线程的返回还是很快的。ab压测如下:

上述的使用方式,通过tornado的IO循环,把可以把耗时的任务放到后台异步计算,请求可以接着做别的计算。可是,经常有一些耗时的任务完成之后,我们需要其计算的结果。此时这种方式就不行了。车道山前必有路,只需要切换一异步方式即可。下面使用协程来改写:

可以看到异步在处理,而结果值也被返回了。

qps提升还是很明显的。有时候这种协程处理,未必就比同步快。在并发量很小的情况下,IO本身拉开的差距并不大。甚至协程和同步性能差不多。例如你跟博尔特跑米肯定输给他,可是如果跟他跑2米,鹿死谁手还未定呢。

yield挂起函数协程,尽管没有block主线程,因为需要处理返回值,挂起到响应执行还是有时间等待,相对于单个请求而言。另外一种使用异步和协程的方式就是在主线程之外,使用线程池,线程池依赖于futures。Python2需要额外安装。

下面使用线程池的方式修改为异步处理:

再运行ab测试:

qps瞬间达到了.。同时,可以看到服务器的log还在不停的输出ping的结果。想要返回值也很容易。再切换一下使用方式接口。使用tornado的gen模块下的with_timeout功能(这个功能必须在tornado>3.2的版本)。

线程池的方式也可以通过使用tornado的yield把函数挂起,实现了协程处理。可以得出耗时任务的result,同时不会block住主线程。

qps为,使用yield协程的方式,仅为非reponse的十分之一左右。看起来性能损失了很多,主要原因这个协程返回结果需要等执行完毕任务。

Python的Tornado框架的异步任务与AsyncHTTPClient(python tornado框架)

好比打鱼,前一种方式是撒网,然后就完事,不闻不问,时间当然快,后一种方式则撒网之后,还得收网,等待收网也是一段时间。当然,相比同步的方式还是快了千百倍,毕竟撒网还是比一只只钓比较快。

具体使用何种方式,更多的依赖业务,不需要返回值的往往需要处理callback,回调太多容易晕菜,当然如果需要很多回调嵌套,首先优化的应该是业务或产品逻辑。yield的方式很优雅,写法可以异步逻辑同步写,爽是爽了,当然也会损失一定的性能。

异步多样化Tornado异步服务的处理大抵如此。现在异步处理的框架和库也很多,借助redis或者celery等,也可以把tonrado中一些业务异步化,放到后台执行。

此外,Tornado还有客户端异步功能。该特性主要是在于 AsyncHTTPClient的使用。此时的应用场景往往是tornado服务内,需要针对另外的IO进行请求和处理。顺便提及,上述的例子中,调用ping其实也算是一种服务内的IO处理。接下来,将会探索一下AsyncHTTPClient的使用,尤其是使用AsyncHTTPClient上传文件与转发请求。

异步客户端前面了解Tornado的异步任务的常用做法,姑且归结为异步服务。通常在我们的服务内,还需要异步的请求第三方服务。针对HTTP请求,Python的库Requests是最好用的库,没有之一。官网宣称:HTTP for Human。然而,在tornado中直接使用requests将会是一场恶梦。requests的请求会block整个服务进程。

上帝关上门的时候,往往回打开一扇窗。Tornado提供了一个基于框架本身的异步HTTP客户端(当然也有同步的客户端)--- AsyncHTTPClient。

AsyncHTTPClient 基本用法AsyncHTTPClient是 tornado.httpclinet 提供的一个异步http客户端。使用也比较简单。与服务进程一样,AsyncHTTPClient也可以callback和yield两种使用方式。前者不会返回结果,后者则会返回response。

如果请求第三方服务是同步方式,同样会杀死性能。

使用ab测试大概如下:

性能相当慢了,换成AsyncHTTPClient再测:

qps 提高了很多

同样,为了获取response的结果,只需要yield函数。

AsyncHTTPClient 转发使用Tornado经常需要做一些转发服务,需要借助AsyncHTTPClient。既然是转发,就不可能只有get方法,post,put,delete等方法也会有。此时涉及到一些 headers和body,甚至还有https的waring。

下面请看一个post的例子, yield结果,通常,使用yield的时候,handler是需要 tornado.gen.coroutine。

AsyncHTTPClient 构造请求如果业务处理并不是在handlers写的,而是在别的地方,当无法直接使用tornado.gen.coroutine的时候,可以构造请求,使用callback的方式。

用法也比较简单,AsyncHTTPClient中的fetch方法,第一个参数其实是一个HTTPRequest实例对象,因此对于一些和http请求有关的参数,例如method和body,可以使用HTTPRequest先构造一个请求,再扔给fetch方法。通常在转发服务的时候,如果开起了validate_cert,有可能会返回timeout之类,这是一个warning,官方却认为是合理的。

AsyncHTTPClient 上传图片AsyncHTTPClient 更高级的用法就是上传图片。例如服务有一个功能就是请求第三方服务的图片OCR服务。需要把用户上传的图片,再转发给第三方服务。

对比上述的用法,上传图片仅仅是多了一个图片的编码。将图片的二进制数据按照multipart 方式编码。编码的同时,还需要把传递的相关的字段处理好。相比之下,使用requests 的方式则非常简单:

总结通过AsyncHTTPClient的使用方式,可以轻松的实现handler对第三方服务的请求。结合前面关于tornado异步的使用方式。无非还是两个key。是否需要返回结果,来确定使用callback的方式还是yield的方式。当然,如果不同的函数都yield,yield也可以一直传递。这个特性,tornado的中的tornado.auth 里面对oauth的认证。

大致就是这样的用法。

结合Python的SimpleHTTPServer源码来解析socket通信 何谓socket计算机,顾名思义即是用来做计算。因而也需要输入和输出,输入需要计算的条件,输出计算结果。这些输入输出可以抽象为I/O(inputoutput)。

总结网络IO模型与select模型的Python实例讲解 网络I/O模型人多了,就会有问题。web刚出现的时候,光顾的人很少。近年来网络应用规模逐渐扩大,应用的架构也需要随之改变。Ck的问题,让工程师

Python的Flask框架及Nginx实现静态文件访问限制功能 Nginx配置Ngnix,一个高性能的web服务器,毫无疑问它是当下的宠儿。卓越的性能,灵活可扩展,在服务器领域里攻城拔寨,征战天下。静态文件对于大多

标签: python tornado框架

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

上一篇:深入解析Python中的descriptor描述器的作用及用法(python 解析)

下一篇:结合Python的SimpleHTTPServer源码来解析socket通信(python simple)

  • 石油税费是多少
  • 增值税欠缴
  • 汇算清缴需要传什么资料
  • 三栏式明细账适用于银行存款吗
  • 开票地址一定要写全吗
  • 金税盘锁死日期16号几点
  • 对公付款对方不开发票怎么处理
  • 签订合同后付款
  • 待抵扣进项税额转入进项税额
  • 汇算清缴所得税是什么意思
  • 销售费用与管理的关系
  • 物业公司可以开租赁发票吗
  • 税务变更需要哪些材料
  • 税收的组成
  • 核定征收企业有利润如何注销税务登记
  • 网银费用及回单箱费用账务处理?
  • 增值税申报收入和企业所得税申报收入
  • 怎么去税务局报账流程
  • 公司装修费用必须交税吗
  • 注册资本没有缴足前贷款利息
  • 停车场会计科目设置
  • 上月预付款项 这月开了发票会计分录
  • 主机倒地后打不开电脑
  • 以前年度损益的一级科目
  • 非货币性资产交换的会计处理
  • 手撕票怎么做会计分录
  • 从对公账户取现金有什么影响
  • 建筑企业挂靠账务怎么处理?
  • 玩游戏的显示器要高刷还是高分辨率
  • php提交post数据
  • thinkphp3.2框架
  • 谷歌插件下载网址
  • 以前年度损益调整在利润表中怎么填
  • php排序方法有几种区别
  • java中通配符作用
  • 金融机构存放的保证金存款
  • 购买加油卡如何做会计分录
  • 报税报错了能否下月调整
  • 印花税都有什么类目
  • 电子口岸无纸化报关
  • 一般纳税人什么情况可以开3%的发票
  • 小规模纳税人会自动转为一般纳税人
  • 残疾人保障金为负数
  • 物业公司水费差额征税如何申报
  • 福利费发票抵扣了有什么后果
  • 车船使用税应该怎么交
  • 事业单位开办费与注册资本的关系
  • 打车费会计分录怎么写
  • 建账选用什么会计制度
  • 发票专用章需要备案吗?
  • 会计科目的设置原则包括( )
  • sqlserver 创建索引与使用
  • Windows(x86,64bit)升级MySQL 5.7.17免安装版的详细教程
  • win7小技巧
  • DxO Optics Pro 9 激活破解安装详细图文教程
  • 让windows10蓝屏
  • ubuntu 18.04防火墙
  • centos7查看性能监控
  • mac如何关闭开机密码
  • centos7打开命令行
  • 注意 Win/WP8.1开发者账户现已迁移到全新Win10开发者中心仪表盘
  • u盘怎么安装win7镜像文件
  • win10预览版好吗
  • windows2008无法识别usb
  • 打开应用通知栏
  • 安卓百分百
  • 不错的mod_perl编程的简单应用实例介绍
  • js去除hover样式
  • 用正则表达式替换掉两汉字间的括号
  • 简单强悍是哪首歌
  • linux 服务器重启
  • linuxtop命令详解
  • python parser解析
  • android network
  • Django1.7+python 2.78+pycharm配置mysql数据库
  • python优先级顺序
  • javascript基础
  • 税务局着装规定文件
  • 税务局试用期
  • 企业所得税季报资产总额怎么填
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

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

    友情链接: 武汉网站建设