Tokio

Tokio 是一个用 Rust 编程语言编写可靠、异步和轻量级应用程序的运行时。它具有以下特点：

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

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

• 可扩展：Tokio 占用资源少，能自然地处理背压和取消操作。

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

概述

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

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

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

示例

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

确保在 Cargo.toml 中激活了 tokio crate 的完整功能：

[dependencies]
tokio = { version = "1.39.2", 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];

            // 在循环中，从套接字读取数据并将数据写回。
            loop {
                let n = match socket.read(&mut buf).await {
                    // 套接字关闭
                    Ok(n) if n == 0 => return,
                    Ok(n) => n,
                    Err(e) => {
                        eprintln!("从套接字读取失败；错误 = {:?}", e);
                        return;
                    }
                };

                // 将数据写回
                if let Err(e) = socket.write_all(&buf[0..n]).await {
                    eprintln!("写入套接字失败；错误 = {:?}", e);
                    return;
                }
            }
        });
    }
}

更多示例可以在这里找到。对于更大的"实际"示例，请参见 mini-redis 仓库。

要查看可以启用的可用功能标志列表，请查看我们的文档。

获取帮助

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

贡献

:balloon: 感谢你帮助改进项目！我们很高兴有你的参与！我们有一个贡献指南来帮助你参与 Tokio 项目。

相关项目

除了本仓库中的 crate 外，Tokio 项目还维护着其他几个库，包括：

• [axum]：一个专注于人体工程学和模块化的 Web 应用框架。

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

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

• [warp]：一个超级简单、可组合的 Web 服务器框架，速度极快。

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

• [tracing]（前身为 tokio-trace）：一个用于应用级跟踪和异步感知诊断的框架。

• [mio]：一个为 tokio 提供支持的低级、跨平台的操作系统 I/O API 抽象。

• [bytes]：用于处理字节的实用工具，包括高效的字节缓冲区。

• [loom]：一个用于并发 Rust 代码的测试工具。 [axum]: https://github.com/tokio-rs/axum [warp]: https://github.com/seanmonstar/warp [hyper]: https://github.com/hyperium/hyper [tonic]: https://github.com/hyperium/tonic [tower]: https://github.com/tower-rs/tower [loom]: https://github.com/tokio-rs/loom [tracing]: https://github.com/tokio-rs/tracing [mio]: https://github.com/tokio-rs/mio [bytes]: https://github.com/tokio-rs/bytes

更新日志

Tokio仓库包含多个包。每个包都有自己的更新日志。

• tokio - 查看更新日志
• tokio-util - 查看更新日志
• tokio-stream - 查看更新日志
• tokio-macros - 查看更新日志
• tokio-test - 查看更新日志

支持的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不遵循固定的发布计划，但我们通常每月会发布一到两个新的次要版本。我们会根据需要发布补丁版本来修复bug。

Bug修复政策

为了进行bug修复的补丁版本发布，我们将某些次要版本指定为LTS（长期支持）版本。当出现需要补丁版本修复的bug时，我们会将修复向后移植并为每个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许可证授权，无任何额外条款或条件。