目录
1. 异步流
2. 如何打开连接
3. 如何启动服务器
4. 如何使用 StreamWriter 写入数据
5. 如何使用 StreamReader 读取数据
6. 如何关闭连接
首页 后端开发 Python教程 Python异步之非阻塞流如何使用

Python异步之非阻塞流如何使用

May 21, 2023 pm 10:02 PM
python

1. 异步流

asyncio 的一个主要好处是能够使用非阻塞流。

Asyncio 提供非阻塞 I/O 套接字编程。这是通过流提供的。

可以打开提供对流写入器和流写入器的访问的套接字。在合适的时候,使用协同程序可以从流中写入和读取数据并暂停。完成后,可以关闭套接字。

异步流功能是低级的,这意味着必须手动实现所需的任何协议。

这可能包括常见的 Web 协议,例如:

  • 用于与 Web 服务器交互的 HTTP 或 HTTPS

  • 用于与电子邮件服务器交互的 SMTP

  • 用于与文件服务器交互的 FTP。

这些流还可用于创建服务器以使用标准协议处理请求,或开发您自己的特定于应用程序的协议。

现在我们知道什么是异步流,让我们看看如何使用它们。

2. 如何打开连接

可以使用 asyncio.open_connection() 函数打开 asyncio TCP 客户端套接字连接。

这是一个必须等待的协程,一旦套接字连接打开就会返回。

该函数返回用于与套接字交互的 StreamReader 和 StreamWriter 对象。

...
# open a connection
reader, writer = await asyncio.open_connection(...)
登录后复制

There are multiple parameters that can be used to configure the socket connection in the asyncio.open_connection() function.。两个必需的参数是主机和端口。

host 是一个字符串,指定要连接的服务器,例如域名或 IP 地址。

port为socket端口号,如HTTP服务器为80,HTTPS服务器为443,SMTP为23等。

...
# open a connection to an http server
reader, writer = await asyncio.open_connection('www.google.com', 80)
登录后复制

通过 SSL 协议支持加密套接字连接。最常见的例子可能是正在取代 HTTP 的 HTTPS。这可以通过将“ssl”参数设置为 True 来实现。

...
# open a connection to an https server
reader, writer = await asyncio.open_connection('www.google.com', 443, ssl=True)
登录后复制

3. 如何启动服务器

可以使用 asyncio.start_server() 函数打开 asyncio TCP 服务器套接字。这是一个必须等待的协程。

该函数返回一个代表正在运行的服务器的 asyncio.Server 对象。

...
# start a tcp server
server = await asyncio.start_server(...)
登录后复制

三个必需的参数是回调函数、主机和端口。当客户端连接到服务器时,回调函数会被调用,它是一个有名称的自定义函数。

主机是客户端将指定连接的域名或 IP 地址。FTP使用的端口是21,HTTP使用的端口是80。这些端口是用于接收连接的套接字端口号。

# handle connections
async def handler(reader, writer):
	# ...
...
# start a server to receive http connections
server = await asyncio.start_server(handler, '127.0.0.1', 80)
登录后复制

4. 如何使用 StreamWriter 写入数据

可以借助 asyncio.StreamWriter 将数据传输到套接字。数据以字节形式写入。可以使用 write() 方法将字节数据写入套接字。

...
# write byte data
writer.write(byte_data)
登录后复制

或者,可以使用 writelines() 方法写入组织成列表或可迭代的多“行”字节数据。

...
# write lines of byte data
writer.writelines(byte_lines)
登录后复制

写入数据块或挂起调用协程的方法都没有。写入字节数据后,最好通过 drain() 方法清空套接字。这是一个协程,会使呼叫者暂停,直到数据传输并且插座就绪。

...
# write byte data
writer.write(byte_data)
# wait for data to be transmitted
await writer.drain()
登录后复制

5. 如何使用 StreamReader 读取数据

使用 asyncio.StreamReader 可以读取套接字中的数据。数据以字节格式读取,因此字符串在使用前可能需要进行编码。所有读取方法都是必须等待的协程。

可以通过 read() 方法读取任意数量的字节,该方法将一直读取到文件末尾 (EOF)。

...
# read byte data
byte_data = await reader.read()
登录后复制

此外,可以通过“n”参数指定要读取的字节数。如果您知道下一个响应的预期字节数,这可能会有所帮助。

...
# read byte data
byte_data = await reader.read(n=100)
登录后复制

可以使用 readline() 方法读取单行数据。这将返回字节,直到遇到换行符“\n”或 EOF。

这在阅读使用文本行操作的标准协议时很有用。

...
# read a line data
byte_line = await reader.readline()
登录后复制

此外,还有一个 readexactly() 方法来读取确切数量的字节,否则会引发异常,还有一个 readuntil() 方法将读取字节,直到读取字节形式的指定字符。

6. 如何关闭连接

可以使用 asyncio.StreamWriter 对象关闭网络套接字。可以调用 close() 方法来关闭套接字。此方法不会阻塞。

...
# close the socket
writer.close()
登录后复制

尽管 close() 方法是非阻塞的,我们可以等待套接字完全关闭后再继续。这可以通过 wait_closed() 方法来实现。这是一个可以等待的协程。

...
# close the socket
writer.close()
# wait for the socket to close
await writer.wait_closed()
登录后复制

我们可以通过 is_closing() 方法检查套接字是否已经关闭或正在关闭。

...
# check if the socket is closed or closing
if writer.is_closing():
	# ...
登录后复制

以上是Python异步之非阻塞流如何使用的详细内容。更多信息请关注PHP中文网其他相关文章!

本站声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover

AI Clothes Remover

用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool

Undress AI Tool

免费脱衣服图片

Clothoff.io

Clothoff.io

AI脱衣机

AI Hentai Generator

AI Hentai Generator

免费生成ai无尽的。

热门文章

R.E.P.O.能量晶体解释及其做什么(黄色晶体)
2 周前 By 尊渡假赌尊渡假赌尊渡假赌
仓库:如何复兴队友
4 周前 By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island冒险:如何获得巨型种子
3 周前 By 尊渡假赌尊渡假赌尊渡假赌

热工具

记事本++7.3.1

记事本++7.3.1

好用且免费的代码编辑器

SublimeText3汉化版

SublimeText3汉化版

中文版,非常好用

禅工作室 13.0.1

禅工作室 13.0.1

功能强大的PHP集成开发环境

Dreamweaver CS6

Dreamweaver CS6

视觉化网页开发工具

SublimeText3 Mac版

SublimeText3 Mac版

神级代码编辑软件(SublimeText3)

如何在LAMP架构下高效整合Node.js或Python服务? 如何在LAMP架构下高效整合Node.js或Python服务? Apr 01, 2025 pm 02:48 PM

在LAMP架构下整合Node.js或Python服务许多网站开发者都面临这样的问题:已有的LAMP(Linux Apache MySQL PHP)架构网站需要...

使用Scapy爬虫时,管道持久化存储文件无法写入的原因是什么? 使用Scapy爬虫时,管道持久化存储文件无法写入的原因是什么? Apr 01, 2025 pm 04:03 PM

使用Scapy爬虫时,管道持久化存储文件无法写入的原因探讨在学习使用Scapy爬虫进行数据抓取时,经常会遇到一�...

Python进程池处理并发TCP请求导致客户端卡死的原因是什么? Python进程池处理并发TCP请求导致客户端卡死的原因是什么? Apr 01, 2025 pm 04:09 PM

Python进程池处理并发TCP请求导致客户端卡死的解析在使用Python进行网络编程时,高效处理并发TCP请求至关重要。...

如何查看Python functools.partial对象内部封装的原始函数? 如何查看Python functools.partial对象内部封装的原始函数? Apr 01, 2025 pm 04:15 PM

深入探讨Pythonfunctools.partial对象的查看方法在使用Python的functools.partial...

如何解决Linux终端中查看Python版本时遇到的权限问题? 如何解决Linux终端中查看Python版本时遇到的权限问题? Apr 01, 2025 pm 05:09 PM

Linux终端中查看Python版本时遇到权限问题的解决方法当你在Linux终端中尝试查看Python的版本时,输入python...

Python跨平台桌面应用开发:哪个GUI库最适合你? Python跨平台桌面应用开发:哪个GUI库最适合你? Apr 01, 2025 pm 05:24 PM

Python跨平台桌面应用开发库的选择许多Python开发者都希望开发出能够在Windows和Linux系统上都能运行的桌面应用程...

Python沙漏图形绘制:如何避免变量未定义错误? Python沙漏图形绘制:如何避免变量未定义错误? Apr 01, 2025 pm 06:27 PM

Python入门:沙漏图形绘制及输入校验本文将解决一个Python新手在沙漏图形绘制程序中遇到的变量定义问题。代码...

如何用Python高效统计并排序大型商品数据集? 如何用Python高效统计并排序大型商品数据集? Apr 01, 2025 pm 08:03 PM

数据转换与统计:高效处理大型数据集本文将详细介绍如何将一个包含商品信息的数据列表,转换为另一个包含...

See all articles