sockets - 如何将Tokio设置为多线程UDP服务器？

Question

到目前为止，我发现的唯一示例是Tokio存储库中的单线程示例Echo UDP。如何使用Tokio启动循环，该循环将产生一个新线程来处理新的UDP连接。

Answer 1

回答original version of the question

How does one set up Tokio 0.2 to “listen” for UDP data?

use tokio::net::UdpSocket; // "0.2.20", features = ["full"]

type Error = Box<dyn std::error::Error>;
type Result<T, E = Error> = std::result::Result<T, E>;

#[tokio::main]
async fn main() -> Result<()> {
    let mut socket = UdpSocket::bind("127.0.0.1:9999").await?;

    loop {
        let mut data = [0; 1024];
        let valid_bytes = socket.recv(&mut data).await?;
        let data = &data[..valid_bytes];

        eprintln!("Read {} bytes", data.len());
    }
}

在一个窗口中:

% cargo run
Read 6 bytes
Read 5 bytes
Read 6 bytes

在另一个:

% nc -u 127.0.0.1 9999
alpha
beta
gamma

回答 current version of the question

How to set up Tokio as a multi-threaded UDP server?

上面的代码是多线程的； Tokio is multithreaded by default。您可能正在寻找创建并发(或并行)工作的方法。这可以通过产生一个任务来完成:

task::spawn

task::spawn_local

task::spawn_blocking