#async #async-io #io

tokio

一个用于编写异步 I/O 支持应用程序的事件驱动、非阻塞 I/O 平台

151 个版本 (88 个稳定版)

新版本 1.39.3 2024 年 8 月 17 日
1.39.2 2024 年 7 月 27 日
1.38.0 2024 年 5 月 30 日
1.37.0 2024 年 3 月 28 日
0.0.0 2016 年 7 月 1 日

#2 in 异步

Download history 1780371/week @ 2024-05-04 1874006/week @ 2024-05-11 1871026/week @ 2024-05-18 1862768/week @ 2024-05-25 2164673/week @ 2024-06-01 2057814/week @ 2024-06-08 2021480/week @ 2024-06-15 2028454/week @ 2024-06-22 1864765/week @ 2024-06-29 2017187/week @ 2024-07-06 2093899/week @ 2024-07-13 2301349/week @ 2024-07-20 2297953/week @ 2024-07-27 2180821/week @ 2024-08-03 2308399/week @ 2024-08-10 1963771/week @ 2024-08-17

9,140,711 每月下载量
用于 31,603 个 crate (21,331 直接使用)

MIT 许可证

3MB
45K SLoC

Tokio

Tokio 是 Rust 编程语言编写可靠、异步和精简应用程序的运行时。它是

  • 快速:Tokio 的零成本抽象为您提供裸机性能。

  • 可靠:Tokio 利用 Rust 的所有权、类型系统和并发模型来减少错误并确保线程安全。

  • 可扩展:Tokio 脚本最小,并能自然地处理背压和取消。

Crates.io MIT licensed Build Status Discord chat

网站 | 指南 | API 文档 | 聊天

概述

Tokio 是 Rust 编程语言编写异步应用程序的事件驱动、非阻塞 I/O 平台。在较高层次上,它提供了一些主要组件

  • 一个基于工作窃取的多线程任务 调度器
  • 一个由操作系统的事件队列(epoll、kqueue、IOCP 等)支持的反应器。
  • 异步 TCP 和 UDP 套接字。

这些组件为构建异步应用程序提供了必要的运行时组件。

示例

使用 Tokio 的基本 TCP 回显服务器。

确保在 Cargo.toml 上激活了 tokio crate 的全部功能

[dependencies]
tokio = { version = "1.39.3", features = ["full"] }

然后,在 main.rs 中

use tokio::net::TcpListener;
use tokio::io::{AsyncReadExt, AsyncWriteExt};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let listener = TcpListener::bind("127.0.0.1:8080").await?;

    loop {
        let (mut socket, _) = listener.accept().await?;

        tokio::spawn(async move {
            let mut buf = [0; 1024];

            // In a loop, read data from the socket and write the data back.
            loop {
                let n = match socket.read(&mut buf).await {
                    // socket closed
                    Ok(n) if n == 0 => return,
                    Ok(n) => n,
                    Err(e) => {
                        eprintln!("failed to read from socket; err = {:?}", e);
                        return;
                    }
                };

                // Write the data back
                if let Err(e) = socket.write_all(&buf[0..n]).await {
                    eprintln!("failed to write to socket; err = {:?}", e);
                    return;
                }
            }
        });
    }
}

更多示例可以在 这里 找到。更大的“真实世界”示例,请参阅 mini-redis 仓库。

要查看可启用的功能标志列表,请参阅我们的 文档

获取帮助

首先,查看你的问题是否可以在指南API文档中找到。如果答案不在那里,Tokio Discord服务器中有一个活跃的社区。我们很乐意尝试回答你的问题。你还可以在讨论页面上提出你的问题。

贡献

🎈 感谢你的帮助,让我们改进项目!我们非常高兴有你!我们有一个贡献指南,帮助你参与到Tokio项目中。

除了本存储库中的crates,Tokio项目还维护了几个其他库,包括

  • axum:一个专注于舒适性和模块化的Web应用程序框架。

  • hyper:一个快速且正确的Rust的HTTP/1.1和HTTP/2实现。

  • tonic:一个专注于高性能、互操作性和灵活性的gRPC over HTTP/2实现。

  • warp:一个超级简单、可组合的、高速的Web服务器框架。

  • tower:一个用于构建健壮的网络客户端和服务器模块化和可重用组件的库。

  • tracing(之前称为tokio-trace):一个用于应用程序级跟踪和异步感知诊断的框架。

  • mio:一个低级、跨平台的抽象,用于操作系统的I/O API,为tokio提供动力。

  • bytes:用于处理字节的实用程序,包括高效的字节缓冲区。

  • loom:一个用于并发Rust代码的测试工具。

变更日志

Tokio存储库包含多个crates。每个crates都有自己的变更日志。

支持的Rust版本

Tokio将保持至少6个月的滚动MSRV(最小支持Rust版本)政策。当增加MSRV时,新的Rust版本必须至少发布6个月。当前的MSRV是1.70。

请注意,MSRV不会自动增加,并且仅作为次要版本的组成部分。以下是过去次要版本中MSRV的历史

  • 1.39到如今 - Rust 1.70
  • 1.30到1.38 - Rust 1.63
  • 1.27到1.29 - Rust 1.56
  • 1.17到1.26 - Rust 1.49
  • 1.15到1.16 - Rust 1.46
  • 1.0到1.14 - Rust 1.45

请注意,尽管我们尽量避免Tokio的依赖关系间接增加MSRV的情况,但我们不能保证这种情况不会发生。然而,每个次要版本都将有一组与该次要版本的MSRV兼容的依赖版本。

发布计划

Tokio不遵循固定的发布计划,但我们通常每个月发布一到两个新的次要版本。根据需要,我们还会发布补丁版本以修复错误。

错误修补策略

为了制作带有错误修复的补丁版本,我们已将某些小版本指定为LTS(长期支持)版本。每当有错误需要发布带有错误修复的补丁版本时,它将被回滚并作为每个LTS小版本的新的补丁版本发布。我们的当前LTS版本如下:

  • 1.32.x - LTS版本,至2024年9月。(MSRV 1.63)
  • 1.36.x - LTS版本,至2025年3月。(MSRV 1.63)
  • 1.38.x - LTS版本,至2025年7月。(MSRV 1.63)

每个LTS版本将继续至少一年内接收回滚的修复。如果您想在项目中使用修复的小版本,我们建议您使用LTS版本。

要使用修复的小版本,您可以指定带波浪线的版本。例如,要指定您想使用最新的1.32.x补丁版本,您可以使用以下依赖项规范

tokio = { version = "~1.32", features = [...] }

之前的LTS版本

  • 1.8.x - LTS版本,至2022年2月。
  • 1.14.x - LTS版本,至2022年6月。
  • 1.18.x - LTS版本,至2023年6月。
  • 1.20.x - LTS版本,至2023年9月。
  • 1.25.x - LTS版本,至2024年3月。

许可证

本项目采用MIT许可证

贡献

除非您明确说明,否则您提交给Tokio的任何有意包含在内的贡献,都应按照MIT许可证发布,不附加任何额外条款或条件。

依赖项

~0-9MB
~77K SLoC