支持异步的PyJoyment的低级别事件反应器。

Pyjo-Reactor-Asyncio的Python项目详细描述


https://img.shields.io/pypi/v/Pyjo-Reactor-Asyncio.pnghttps://travis-ci.org/dex4er/Pyjo-Reactor-Asyncio.png?branch=masterhttps://readthedocs.org/projects/pyjo-reactor-asyncio/badge/?version=latest

Pyjo反应器异步

低级别事件反应器,对pyjoyment提供异步支持。

快乐

python编程语言的异步事件驱动程序web框架。

pyjoyment提供了自己的reactor,它自己处理i/o和计时器事件。 主事件循环,但它支持其他循环,即libevasyncio

http://www.pyjoyment.net/

异步

此模块提供了编写单线程并发代码的基础结构 使用协同程序,在套接字和其他资源上复用I/O访问, 运行网络客户端和服务器以及其他相关原语。

异步模块是在PEP3156中设计的。作为一个激励性的入门 传输和协议,请参见PEP3153

http://asyncio.org/

特罗利乌斯

trollius是python 2上异步项目(PEP3156)的移植。 trollius在python 2.6-3.5上工作。

https://trollius.readthedocs.org/

示例

非阻塞TCP客户端/服务器

importPyjo.Reactor.AsyncioimportPyjo.IOLoop# Listen on port 3000@Pyjo.IOLoop.server(port=3000)defserver(loop,stream,cid):@stream.ondefread(stream,chunk):# Process input chunkprint("Server: {0}".format(chunk.decode('utf-8')))# Write responsestream.write(b"HTTP/1.1 200 OK\x0d\x0a\x0d\x0a")# Disconnect clientstream.close_gracefully()# Connect to port 3000@Pyjo.IOLoop.client(port=3000)defclient(loop,err,stream):@stream.ondefread(stream,chunk):# Process inputprint("Client: {0}".format(chunk.decode('utf-8')))# Write requeststream.write(b"GET / HTTP/1.1\x0d\x0a\x0d\x0a")# Add a timer@Pyjo.IOLoop.timer(3)deftimeouter(loop):print("Timeout")# Shutdown serverloop.remove(server)# Start event loopPyjo.IOLoop.start()

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
java Grid loadmask(true)在gxt中不起作用   java将字符串索引转换为整数   为什么Java泛型适用于基元数组,但不适用于基元数组?   java如何让Azure应用程序服务Tomcat将所有80/443流量转发到运行在同一应用程序服务上的JBoss   具有多个值的java转换映射到树?   java如何设置SQL server连接URL?   java设置了多个相互独立的JFrame   安全性在JAVA中如何使用RSAPrivateKey的密码短语?   java不能使用比Apache Velocity中更大的条件   如何在Java中打印字符串的所有排列   停止Android Studio自动导入java。sql。日期   对象简单计算器程序java   java如何在安卓中使用“&”符号作为字符串?   java Connect,为我的安卓应用程序从REST API发布和获取数据