demo

    1. use mio::net::{TcpListener, TcpStream};
    2. use mio::{Events, Interest, Poll, Token};
    4. const SERVER: Token = Token(0);
    5. const CLINET: Token = Token(1);
    7. fn main() -> std::io::Result<()> {
    8.     let mut poll = Poll::new()?;
    9.     let mut events = Events::with_capacity(128);
    11.     let addr = "127.0.0.1:8080".parse().unwrap();
    12.     let mut server = TcpListener::bind(addr)?;
    14.     poll.registry()
    15.         .register(&mut server, SERVER, Interest::READABLE)?;
    17.     let mut client = TcpStream::connect(addr)?;
    18.     poll.registry()
    19.         .register(&mut client, CLINET, Interest::READABLE | Interest::WRITABLE)?;
    20.     // std::thread::sleep(std::time::Duration::from_secs(3));
    21.     loop {
    22.         poll.poll(&mut events, None)?;
    23.         for event in events.iter() {
    24.             match event.token() {
    25.                 SERVER => {
    26.                     let connection = server.accept();
    27.                     println!("server recv a connection");
    28.                     drop(connection);
    29.                 }
    30.                 CLINET => {
    31.                     if event.is_writable() {
    32.                         println!("client write");
    33.                     }
    34.                     if event.is_readable() {
    35.                         println!("client read");
    36.                     }
    37.                     // return Ok(());
    38.                 }
    39.                 _ => unreachable!(),
    40.             }
    41.         }
    42.     }
    43. }