目录
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脱衣机

Video Face Swap

Video Face Swap

使用我们完全免费的人工智能换脸工具轻松在任何视频中换脸!

热工具

记事本++7.3.1

记事本++7.3.1

好用且免费的代码编辑器

SublimeText3汉化版

SublimeText3汉化版

中文版,非常好用

禅工作室 13.0.1

禅工作室 13.0.1

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

Dreamweaver CS6

Dreamweaver CS6

视觉化网页开发工具

SublimeText3 Mac版

SublimeText3 Mac版

神级代码编辑软件(SublimeText3)

PHP和Python:解释了不同的范例 PHP和Python:解释了不同的范例 Apr 18, 2025 am 12:26 AM

PHP主要是过程式编程,但也支持面向对象编程(OOP);Python支持多种范式,包括OOP、函数式和过程式编程。PHP适合web开发,Python适用于多种应用,如数据分析和机器学习。

在PHP和Python之间进行选择:指南 在PHP和Python之间进行选择:指南 Apr 18, 2025 am 12:24 AM

PHP适合网页开发和快速原型开发,Python适用于数据科学和机器学习。1.PHP用于动态网页开发,语法简单,适合快速开发。2.Python语法简洁,适用于多领域,库生态系统强大。

Python vs. JavaScript:学习曲线和易用性 Python vs. JavaScript:学习曲线和易用性 Apr 16, 2025 am 12:12 AM

Python更适合初学者,学习曲线平缓,语法简洁;JavaScript适合前端开发,学习曲线较陡,语法灵活。1.Python语法直观,适用于数据科学和后端开发。2.JavaScript灵活,广泛用于前端和服务器端编程。

visual studio code 可以用于 python 吗 visual studio code 可以用于 python 吗 Apr 15, 2025 pm 08:18 PM

VS Code 可用于编写 Python,并提供许多功能,使其成为开发 Python 应用程序的理想工具。它允许用户:安装 Python 扩展,以获得代码补全、语法高亮和调试等功能。使用调试器逐步跟踪代码,查找和修复错误。集成 Git,进行版本控制。使用代码格式化工具,保持代码一致性。使用 Linting 工具,提前发现潜在问题。

vscode 扩展是否是恶意的 vscode 扩展是否是恶意的 Apr 15, 2025 pm 07:57 PM

VS Code 扩展存在恶意风险,例如隐藏恶意代码、利用漏洞、伪装成合法扩展。识别恶意扩展的方法包括:检查发布者、阅读评论、检查代码、谨慎安装。安全措施还包括:安全意识、良好习惯、定期更新和杀毒软件。

vs code 可以在 Windows 8 中运行吗 vs code 可以在 Windows 8 中运行吗 Apr 15, 2025 pm 07:24 PM

VS Code可以在Windows 8上运行,但体验可能不佳。首先确保系统已更新到最新补丁,然后下载与系统架构匹配的VS Code安装包,按照提示安装。安装后,注意某些扩展程序可能与Windows 8不兼容,需要寻找替代扩展或在虚拟机中使用更新的Windows系统。安装必要的扩展,检查是否正常工作。尽管VS Code在Windows 8上可行,但建议升级到更新的Windows系统以获得更好的开发体验和安全保障。

PHP和Python:深入了解他们的历史 PHP和Python:深入了解他们的历史 Apr 18, 2025 am 12:25 AM

PHP起源于1994年,由RasmusLerdorf开发,最初用于跟踪网站访问者,逐渐演变为服务器端脚本语言,广泛应用于网页开发。Python由GuidovanRossum于1980年代末开发,1991年首次发布,强调代码可读性和简洁性,适用于科学计算、数据分析等领域。

vscode怎么在终端运行程序 vscode怎么在终端运行程序 Apr 15, 2025 pm 06:42 PM

在 VS Code 中,可以通过以下步骤在终端运行程序:准备代码和打开集成终端确保代码目录与终端工作目录一致根据编程语言选择运行命令(如 Python 的 python your_file_name.py)检查是否成功运行并解决错误利用调试器提升调试效率

See all articles