rust - 在Rust中使用 `tokio-ruSTLs`从TlsStream 读取

Question

我正在使用rustls，并且想要像读取TlsStream一样将TcpStream读取到缓冲区中。这是我在做什么:

let acceptor = TlsAcceptor::from(Arc::new(config));

let fut = async {

    let mut listener = TcpListener::bind(&addr).await?;

    loop {

        let (stream, peer_addr) = listener.accept().await?;
        let acceptor = acceptor.clone();

        let fut = async move {

            let mut stream = acceptor.accept(stream).await?;

            //// CURRENTLY THIS .read() is throwing error in compiler
            println!("Stream: {:?}", stream.read(&mut [0; 1024]));

            Ok(()) as io::Result<()>
        };

        handle.spawn(fut.unwrap_or_else(|err| eprintln!("{:?}", err)));
    }
};

引发错误

'error[E0599]: no method named `read` found for struct `tokio_rustls::server::TlsStream<tokio::net::tcp::stream::TcpStream>` in the current scope'

我想读取使用 TlsStream生成的 tokio-rustls进行缓冲。

Answer 1

正如您的错误消息所描述的那样，有一个为该类型实现的特征 AsyncReadExt ，但未导入到范围中。为了能够使用该特征的 read 方法，您需要导入该特征。对于此特征，通常通过导入tokio prelude来完成:

use tokio::prelude::*;

// or you can explicitly import just AsyncReadExt, but I'd recommend the above
use tokio::io::AsyncReadExt;

另外，您需要从 await中专门对结果进行 read()，因为它返回了将来。您还需要在单独的变量中使用缓冲区，因为这是读取数据的存储位置。

let mut buffer = [0; 1024];
let byte_count = stream.read(&mut buffer).await;
//                                       ^^^^^^
println!("Stream: {:?}", &buffer[0..byte_count]);