linux - MIO EventLoop 未针对 TcpStream 运行

Question

我是一名 Rust 初学者，正在为异步 IO 问题而苦苦挣扎。我决定使用 mio .

我已经阅读了一些源代码和教程，但仍有一些基本部分我不明白。我正在使用 netcat -k -l 127.0.0.1 9999 设置服务器。然后我用 cargo(下面的代码)运行简单的测试。我期待看到“准备好”或“滴答声”的 panic 。但它永远不会发生，测试会永远运行。

extern crate mio;
use mio::*;
#[allow(unused_imports)]
use mio::tcp::TcpStream;

#[allow(dead_code)]
struct MyHandler;

impl Handler for MyHandler {
    type Timeout = ();
    type Message = ();

    fn ready(&mut self, _event_loop: &mut EventLoop<Self>, _token: Token, _event_set: EventSet) {
        panic!("ready");
    }

    fn tick(&mut self, _event_loop: &mut EventLoop<Self>) {
        panic!("tick");
    }
}

#[test]
fn mio_test1() {
    let addr = "127.0.0.1:9999".parse().unwrap();
    let mut event_loop = EventLoop::<MyHandler>::new().unwrap();
    event_loop.register(&TcpStream::connect(&addr).unwrap(), Token(0), EventSet::readable(), PollOpt::level()).unwrap();
    event_loop.run(&mut MyHandler).unwrap();
}

Answer 1

您的问题是因为您打开的套接字在您的事件循环有机会运行之前关闭。

您当前的代码大致等同于:

let addr = "127.0.0.1:9999".parse().unwrap();
let mut event_loop = EventLoop::<MyHandler>::new().unwrap();
{
    let sock = TcpStream::connect(&addr).unwrap();
    event_loop.register(&sock, Token(0), EventSet::readable(), PollOpt::level()).unwrap();
}   // The socket is closed here, before the event loop runs
event_loop.run(&mut MyHandler).unwrap();

所以修复只是将套接字绑定(bind)到一个变量，这样当您调用事件循环时它会保持打开状态。

let addr = "127.0.0.1:9999".parse().unwrap();
let mut event_loop = EventLoop::<MyHandler>::new().unwrap();
let sock = TcpStream::connect(&addr).unwrap();
event_loop.register(&sock, Token(0), EventSet::readable(), PollOpt::level()).unwrap();
event_loop.run(&mut MyHandler).unwrap();

然后您的代码将按照您的预期运行，并在套接字上有可读取的内容时立即出现错误。