为什么我收到错误“没有反应器正在运行，必须从 Tokio 运行时的上下文中调用”，即使我有 #[tokio::main]？

Question

我正在关注mdns Rust 文档并粘贴了示例代码，但它引发了以下错误：

thread 'main' panicked at 'there is no reactor running, must be called from the context of Tokio runtime'

这是我拥有的代码：

use futures_util::{pin_mut, stream::StreamExt};
use mdns::{Error, Record, RecordKind};
use std::{net::IpAddr, time::Duration};

const SERVICE_NAME: &'static str = "_googlecast._tcp.local";

#[tokio::main]
async fn main() -> Result<(), Error> {
    // Iterate through responses from each Cast device, asking for new devices every 15s
    let stream = mdns::discover::all(SERVICE_NAME, Duration::from_secs(15))?.listen();
    pin_mut!(stream);

    while let Some(Ok(response)) = stream.next().await {
        let addr = response.records().filter_map(self::to_ip_addr).next();

        if let Some(addr) = addr {
            println!("found cast device at {}", addr);
        } else {
            println!("cast device does not advertise address");
        }
    }

    Ok(())
}

fn to_ip_addr(record: &Record) -> Option<IpAddr> {
    match record.kind {
        RecordKind::A(addr) => Some(addr.into()),
        RecordKind::AAAA(addr) => Some(addr.into()),
        _ => None,
    }
}

依赖项：

[dependencies]
mdns = "1.1.0"
futures-util = "0.3.8"
tokio = { version = "0.3.3", features = ["full"] }

我错过了什么？我尝试在网上查找，但还没有找到如何为此用例创建反应器。

Answer 1

您使用的是较新版本的 Tokio，例如 0.3 或 1.x，并且许多软件包（包括 mdns 1.1.0）依赖于较旧版本的 Tokio，例如 0.2。

% cargo tree -d
tokio v0.2.22
??? mdns v1.1.0
    ??? example_project v0.1.0

tokio v0.3.3
??? example_project v0.1.0

现在，您需要匹配 Tokio 运行时的版本。最简单的方法是自己使用 Tokio 0.2。该TOKIO-COMPAT-02箱也可能在某些情况下非常有用。

也可以看看：

• 为什么 trait 没有为明确实现的类型实现？

具有相同根本原因的各种错误消息：

没有反应器在运行，必须从 Tokio 1.x 运行时的上下文中调用

没有反应器正在运行，必须从 Tokio 运行时的上下文中调用

当前未在 Tokio 运行时上运行

Answer 2

对我来说，解决方法是将其添加到Cargo.toml：

[dependencies]
async-std = { version = "1", features = ["attributes", "tokio1"] }

https://github.com/ATiltedTree/ytexttract/issues/25

Answer 3

在撰写本文时，相当多的板条箱已经在使用 Tokio v1，但其他板条箱可能仍处于实验阶段。检查您的 crate 中是否有预发布版本，这些版本可能已经升级了 tokio 运行时兼容性。

一个相关的例子是actix-web，它从版本 4 开始就使用 Tokio 的运行时 1.0。尽管自 2022 年 1 月 7 日以来就已经预发布了这一主要增量，但 4.0.0 版本仅在 2022 年 2 月 25 日发布。

actix-web = { version = "4.0.0-beta.10" }