python asyncio tcp server_asyncio异步IO——Streams详解

前言

本文翻译自python3.7官方文档——asyncio-stream,译者马鸣谦,邮箱 1612557569@qq.com。转载请注明出处。

数据流(Streams)

数据流(Streams)是用于处理网络连接的高阶异步/等待就绪(async/await-ready)原语,可以在不使用回调和底层传输协议的情况下发送和接收数据。

以下是一个用asyncio实现的TCP回显客户端:

import asyncio

async def tcp_echo_client(message):

reader, writer = await asyncio.open_connection(

'127.0.0.1', 8888)

print(f'Send: {message!r}')

writer.write(message.encode())

data = await reader.read(100)

print(f'Received: {data.decode()!r}')

print('Close the connection')

writer.close()

await writer.wait_closed()

asyncio.run(tcp_echo_client('Hello World!'))

完整代码见例子一节。

Stream方法

以下所列的高层asyncio方法可以被用作创建和处理Stream:

coroutine asyncio.open_connection(host=None,*,loop=None,limit=None,ssl=None,family=0,proto=0,flags=0,sock=None,local_addr=None,server_hostname=None,ssl_handshake_timeout=None)

创建一个网络连接,并返回一对(reader,writer)对象。

返回的reader和writer对象是StreamReader和StreamWriter类的实例。

loop是可选参数,在此方法被某个协程await时能够自动确定。

limit限定返回的StreamReader实例使用的缓冲区大小。默认情况下,缓冲区限制为64KiB。

其余的参数被直接传递给loop.create_connection()。

python3.7新增:ssl_handshake_timeout参数。

coroutine asyncio.start_server(client_connected_cb,host=None,port=None,*,loop=None,limit=None,family=socket.AF_UNSPEC,flags=socket.AI_PASSIVE,sock=None,backlog=100,ssl=None,reuse_address=None,reuse_port=None,ssl_handshake_timeout=None,start_serving=True)

启动一个socket服务端。

client_connected_cb指定的回调函数,在新连接建立的时候被调用。该回调函数接收StreamReader和StreamWriter类的‘实例对’(reader,writer)作为两个参数。

client_connected_cb可以是普通的可调用函数,也可以是协程函数。如果是协程函数,那么会被自动封装为Task对象处理。

loop是可选参数,在此方法被某个协程await时能够自动确定。

limit限定返回的StreamReader实例使用的缓冲区大小。默认情况下,缓冲区限定值为64KiB。

其余的参数被直接传递给loop.create_server()。

python3.7新增:ssl_handshake_timeout和start_serving参数。

Unix Sockets

coroutine asyncio.open_unix_connection(path=None,*,loop=None,limit=None,ssl=None,sock=None,server_hostname=None,ssl_handshake_timeout=None)

创建一个Unix socket连接,并返回一对(reader,writer)对象。

与open_connection类似,只是运行在Unix sockets上。

可用于:Unix

python3.7新增:ssl_handshake_timeout参数。

python3.7修正:path参数可以为类path(path-like)对象

coroutine *asyncio.start_unix_server(client_connected_cb, path=None, , loop=None, limit=None, sock=None, backlog=100, ssl=None, ssl_handshake_timeout=None, start_serving=True)

启动一个Unix socket 服务端。

类似于start_server,只是运行在Unix sockets上。

可用于:Unix

python3.7新增:ssl_handshake_timeout参数。

python3.7修正:path参数可以为类path(path-like)对象

StreamReader

class asyncio.StreamReader

定义一个读取器对象,提供从IO数据流中读取数据的API。

不建议 直接实例化StreamReader对象。建议通过open_connection()或start_server()创建此类对象。

coroutine read(n=-1)

最多读取n字节数据。如果n未设置,或被设置为-1,则读取至EOF标志,并返回读到的所有字节。

如果在缓冲区仍为空时遇到EOF,则返回一个空的bytes对象。

coroutine readline()

读取一行(以\n为标志)。

如果在找到\n之前遇到EOF,则返回已读取到的数据段。

如果遇到EOF时内部缓冲区仍为空,则返回空的bytes对象。

coroutine readexactly(n)

精确读取n字节数据。

如果在尚未读够n字节时遇到EOF,则引发IncompleteReadError异常。已经读取的部分数据可以通过IncompleteReadError.partial属性获取。

coroutine readuntil(separator=b'\n')

从数据流中读取数据直到遇到separator。

如果执行成功,读到的数据和分隔符将从内部缓冲区里移除。返回的数据会在末尾包含分隔符。

如果读取数据的总量超过了配置的数据流缓冲区限制,则引发LimitOverrunError,数据会被留在内部缓冲区中,可以被再次读取。

如果在找到separator分隔符之前遇到EOF,则引发IncompleteReadError异常,内部缓冲区会被重置。IncompleteReadError.partial属性会包含部分separator。

python3.5.2新增。

at_eof()

如果缓冲区为空,且feed_eof()被调用,则返回True。

StreamWriter

class asyncio.StreamWriter

定义一个写入器对象,提供向IO数据流中写入数据的API。

不建议直接实例化StreamWriter对象,建议通过open_connection或start_server实例化对象。

can_writer_eof()

如果下层传输支持write_eof方法,则返回True,否则返回False。

write_eof()

在缓冲的写入数据被刷新后,关闭数据流的写入端。

transport

返回下层的asyncio传输。

get_extra_info(name,default=None)

访问可选的传输信息。

write(data)

向数据流中写入数据。

此方法不受流量控制的影响。write()应同drain()一同使用。

writelines()

向数据流中写入bytes列表(或任何的可迭代对象)。

此方法不受流量控制的影响。应与drain()一同使用。

coroutine drain()

等待恢复数据写入的时机。例如:

writer.write(data)

await writer.drain()

这是一个与底层IO输入缓冲区交互的流量控制方法。当缓冲区达到上限时,drain()阻塞,待到缓冲区回落到下限时,写操作可以被恢复。当不需要等待时,drain()会立即返回。

close()

关闭数据流。

is_closing()

如果数据流已经关闭或正在关闭,则返回True。

coroutine wait_closed()

保持等待,直到数据流关闭。

保持等待,直到底层连接被关闭,应该在close()后调用此方法。

Python3.7新增。

示例

利用Stream实现TCP回显客户端

import asyncio

async def tcp_echo_client(message):

reader, writer = await asyncio.open_connection(

'127.0.0.1', 8888)

print(f'Send: {message!r}')

writer.write(message.encode())

data = await reader.read(100)

print(f'Received: {data.decode()!r}')

print('Close the connection')

writer.close()

asyncio.run(tcp_echo_client('Hello World!'))

利用Stream实现TCP回显服务端

import asyncio

async def handle_echo(reader, writer):

data = await reader.read(100)

message = data.decode()

addr = writer.get_extra_info('peername')

print(f"Received {message!r} from {addr!r}")

print(f"Send: {message!r}")

writer.write(data)

await writer.drain()

print("Close the connection")

writer.close()

async def main():

server = await asyncio.start_server(

handle_echo, '127.0.0.1', 8888)

addr = server.sockets[0].getsockname()

print(f'Serving on {addr}')

async with server:

await server.serve_forever()

asyncio.run(main())

获取HTTP头

import asyncio

import urllib.parse

import sys

async def print_http_headers(url):

url = urllib.parse.urlsplit(url)

if url.scheme == 'https':

reader, writer = await asyncio.open_connection(

url.hostname, 443, ssl=True)

else:

reader, writer = await asyncio.open_connection(

url.hostname, 80)

query = (

f"HEAD {url.path or '/'} HTTP/1.0\r\n"

f"Host: {url.hostname}\r\n"

f"\r\n"

)

writer.write(query.encode('latin-1'))

while True:

line = await reader.readline()

if not line:

break

line = line.decode('latin1').rstrip()

if line:

print(f'HTTP header> {line}')

# Ignore the body, close the socket

writer.close()

url = sys.argv[1]

asyncio.run(print_http_headers(url))

用法:

python example.py http://example.com/path/page.html

或:

python example.py https://example.com/path/page.html

利用Stream注册等待数据的开放socket

import asyncio

import socket

async def wait_for_data():

# Get a reference to the current event loop because

# we want to access low-level APIs.

loop = asyncio.get_running_loop()

# Create a pair of connected sockets.

rsock, wsock = socket.socketpair()

# Register the open socket to wait for data.

reader, writer = await asyncio.open_connection(sock=rsock)

# Simulate the reception of data from the network

loop.call_soon(wsock.send, 'abc'.encode())

# Wait for data

data = await reader.read(100)

# Got data, we are done: close the socket

print("Received:", data.decode())

writer.close()

# Close the second socket

wsock.close()

asyncio.run(wait_for_data())

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/552075.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

java轻量分布式框架_5个强大的Java分布式缓存框架推荐

在开发中大型Java软件项目时,很多Java架构师都会遇到数据库读写瓶颈,如果你在系统架构时并没有将缓存策略考虑进去,或者并没有选择更优的 缓存策略,那么到时候重构起来将会是一个噩梦。本文主要是分享了5个常用的Java分布式缓存框…

python三次样条插值拟合的树行线_数学建模笔记——插值拟合模型(一)

啊好像距离上次写作又过了七天,啊好像我之前计划的一周两三篇,啊辣鸡小说毁我青春,啊我是一只可怜的鸽子。不管怎样,我又回来了,并坚定地更新着hhh。再过两三天就是我们学校数学建模选拔,再过八九天就是期末…

python内置函数open的解释_在python的内置open()函数中缓冲的用途是什么?

Python文档:http:/ / / 2 /图书馆/ functions.html docs.python.org #开放open(name[, mode[, buffering]])上面的文档应该提醒说"可选参数文件缓冲的缓冲所需的缓冲区大小:0均值,均值线1具有积极的价值,任何其他…

keep行走和计步_‎App Store 上的“Keep - 跑步健身计步瑜伽”

【Keep - App Store 年度精选 App】【App Store 官方推荐的移动健身工具】在「Keep」,和2亿运动爱好者共同开启健康生活!跟随你的移动健身教练,随时随地练就完美身材。健身中经常遇到的问题:- 工作太忙没有时间去健身房&#xff0…

密度图的密度估计_不同类型的二维密度图小教程

R相关小教程链接:用R构建气泡图案例小教程【小教程】散点图、饼图怎么在我的文章中完美展示小教程热图在论文发表中完美呈现小教程R与密度、函数、变量的微妙关系北京市计算中心医用数据库建设解决方案更多内容,请关注“生信会议”公众号Different types…

python 输出纯音频_Python如何录制系统音频(扬声器的输出)?

我从上周就开始找这个了。我也尝试过pyaudio,当我使用它的另一个fork时,系统音频和麦克风音频混合在一起。我找不到任何其他模块来解决这个问题,因此我最终提出了这个问题。在编辑:import pyaudioimport waveCHUNK 1024FORMAT p…

python 读取xml获取包含指定标签的数据_用Python元素提取XML的特定行

我有点困在我正在做的一个项目上,它使用Python——我对它非常陌生。我被告知使用ElementTree并从传入的XML文件中获取指定的数据。听起来很简单,但我不擅长编程。非常低(a!)一个传入文件的小例子以及我试图使用的代码。在我想知道下一步该怎么…

Nginx/Tomcat/SpringBoot配置自生成SSL证书

1.配置自生成证书(方式一,无需密码) 1.1.生成证书 1.下载 nginx windows 版本并解压,这里不过多描述 2.下载 OpenSSL windows 版本并安装,用于生成证书 3.添加 C:\OpenSSL-Win64,C:\nginx-1.16.1 到环境变量 PATH …

python 找质数的个数_用Python打造一款文件搜索工具,所有功能自己定义!

一、前言大家好,又到了Python办公自动化系列。在日常的办公中,我们经常会从一堆不同格式的文件(夹)中搜索特定的文件,可能你是凭着记忆去找或是借助软件,但你有想过如何用Python实现吗?本文将基于几个常见的搜索操作讲…

nessus安装_Nessus忘记密码怎么办?

最近公司购买了Nessus,才安装好,然后隔天密码就忘了,唉,人老了呀,记性不行了。网上看了一下,还是有比较多的同学也遇到这个问题,现将密码重置方法,分享给大家。系统环境:操作系统&am…

python爬取百度域名注册_python爬取百度域名_python爬取百度搜索結果url匯總

寫了兩篇之后,我覺得關於爬蟲,重點還是分析過程分析些什么呢:1)首先明確自己要爬取的目標比如這次我們需要爬取的是使用百度搜索之后所有出來的url結果2)分析手動進行的獲取目標的過程,以便以程序實現比如百度,我們先進…

python自动生成表格_Python自动整理 Excel 表格

相信有不少朋友日常工作会用到 Excel 处理各式表格文件,更有甚者可能要花大把时间来做繁琐耗时的表格整理工作。最近有朋友问可否编程来减轻表格整理工作量,今儿我们就通过实例来实现 Python 对表格的自动化整理。 首先我们有这么一份数据表 source.csv&…

flag的具体用法python_Python Qt.WindowFlags方法代码示例

# 需要导入模块: from PyQt5.QtCore import Qt [as 别名]# 或者: from PyQt5.QtCore.Qt import WindowFlags [as 别名]def updatePreview(self):flags Qt.WindowFlags()if self.windowRadioButton.isChecked():flags Qt.Windowelif self.dialogRadioButton.isChecked():flags…

graphpad prism画折线图_如何用Graphpad Prism 8作折线图

如何用Graphpad Prism 8作折线图如何用Graphpad Prism 8作折线图Prism 8 有8种数据类型,Prism数据表的格式决定可制作的图表种类和可执行的分析类型。选择一个数据表格式可以使Prism创建合适数据的数据表,然后创建所需的图形,执行适当的分析。…

sqlserver可视化工具_数据分析之基础分析工具篇(修订版)

原创:海峰996已经火了,你正在经历996吗,怎样才能避免,而又能在职场立足,工作效率是关键,那么先从选对工具开始吧。进入数据时代,大家都会进行或多或少的数据分析,那么现在的你正在使…

python中日期和时间格式化输出的方法小结_python中日期和时间格式化输出的方法小结...

本文实例总结了python中日期和时间格式化输出的方法。分享给大家供大家参考。具体分析如下:python格式化日期时间的函数为datetime.datetime.strftime();由字符串转为日期型的函数为:datetime.datetime.strptime(),两个函数都涉及…

java断点续传 http_http断点续传简单实现(java)

[月影读书频道 http://wf66.com/]fileSplitterFetch.splitterStop();}}//负责部分文件的抓取**FileSplitterFetch.java*/package NetFox;import java.io.*;import java.net.*;public class FileSplitterFetch extends Thread {String sURL; //File URLlong nStartPos; //File S…

windows下python环境搭建_Linux/Windows下Python环境搭建步骤

Python环境搭建首先到官网(www.python.org)下载相应的安装版本。主要分为Windows和Linux两种: 一、Linux下Python环境搭建 一般情况下,Linux系统都已经预安装好Python,但是版本都比较低,需要安装新的版本方…

oracle 同一列数据不同条件分组求和_艾瑞教育:有关Oracle数据库,你需要知道的几件事...

Oracle一、Oracle数据库在存储过程中,如何在字符串中使用变量?例:select to_char(sysdate,yyyymmdd) into v_yyyymmdd from dual;execute immediate(create table tableName_bk_ || v_yyyymmdd || as select * from TableName);将B表中符合关联条件的A…

java 对象流传输socket_Java Socket(二)使用TCP传输对象

在Java Socket使用TCP的基础上,通过ObjectInputStream和ObjectOutputStream来读写对象。//传输的对象,需要序列化package socket;import java.io.Serializable;public class MsgTO implements Serializable{private static final long serialVersionUID …