在Rust中使用``tokio rustls`从TlsStream<TcpStream>读取
在Rust中使用tokio rustls从TlsStream<TcpStream>读取，可以通过以下步骤进行：
- 首先，确保你的Rust项目中已经引入了
tokio和tokio-rustls的依赖，可以在项目的Cargo.toml文件中添加以下内容：
[dependencies]
tokio = { version = "1.0", features = ["full"] }
tokio-rustls = "0.22"- 在代码中导入需要的模块：
use tokio::net::TcpStream;
use tokio_rustls::TlsStream;- 创建一个
TlsConnector实例并配置其相应参数，例如证书验证模式等。以下是一个示例：
use rustls::ClientConfig;
use std::sync::Arc;
let mut config = ClientConfig::new();
config
.root_store
.add_server_trust_anchors(&webpki_roots::TLS_SERVER_ROOTS);
let config = Arc::new(config);
let connector = tokio_rustls::TlsConnector::from(config);- 连接到远程服务器并通过
TlsConnector将TcpStream包装成TlsStream。以下是一个示例：
let tcp_stream = TcpStream::connect("your_server_address").await?;
let tls_stream = connector.connect("your_server_hostname", tcp_stream).await?;在这个例子中，your_server_address是远程服务器的地址，your_server_hostname是服务器的主机名。
- 之后，你就可以使用
tokio提供的异步方法从TlsStream中读取数据了。例如，你可以使用tokio::io::AsyncReadExt提供的read方法。以下是一个示例：
use tokio::io::AsyncReadExt;
let mut buffer = [0; 1024];
let n = tls_stream.read(&mut buffer).await?;在这个例子中，我们从TlsStream中读取最多1024字节的数据到buffer中。
这样，你就可以使用tokio rustls从TlsStream<TcpStream>中读取数据了。
关于tokio rustls的更多详细信息和用法，可以参考腾讯云提供的Tokio Rustls文档。请注意，这个链接是指向腾讯云的相关产品和产品介绍，仅供参考。
相关·内容
我使用的是rustls，我想把TlsStream读到一个缓冲区，就像我们读TcpStream一样。, err)));}; 它抛出错误 'error[E0599]: no method named `read` found for struct `tokio_rustls::server::TlsStream<tokio::net::tcp::stream::TcpStream>` in the cu
浏览 33提问于2020-04-23得票数 0
回答已采纳
我正在尝试用Rust构建一个websockets客户端。；所以在我的实现中没有使用代码片段中tokio::select!::stream::Stream<tokio::net::TcpStream, tokio_tls::TlsStream<tokio::net::TcpStream>>>>`
145 |::stream::Stream<<
浏览 78提问于2021-11-11得票数 0
回答已采纳
我遇到的问题是，我试图使用Rust的新async-await语法将转换为代码。[feature(async_await)]
use std::sync::Arc;use futures::ClientConfig;
use std::net::ToSo
浏览 15提问于2019-08-01得票数 2
我正在试验如何使用Rust的tokio来停止异步TCP连接和数据包读取。我已经编写了一种在CTRL+C上停止循环或使用channel和select停止超时事件的方法，但是循环中的select会发生移动，但它无法编译。::net::TcpStream> { tokio::select!{ _ = shutdown => return None
浏览 8提问于2022-03-18得票数 1
我有一个未来，它使用Framed将一个TCP流封装在LinesCodec中。当我试图将其封装在测试中时，我会在大约20%的时间内遇到阻塞，但是由于没有监听到我试图连接到的套接字，所以我希望始终得到错误：#[macro_use(try_ready)]extern crate tokio</e
浏览 0提问于2018-09-19得票数 7
回答已采纳
2回答
我刚开始在铁锈里试验期货/东京。我可以用期货或溪流来做一些基本的事情。我想知道你怎样才能在未来和溪流之间做出选择。use tokio_core::net::TcpStream;use tokio_tls::TlsConnectorExtmain() {
let mut c
浏览 1提问于2017-03-21得票数 7
回答已采纳
我正在尝试在Rust中实现一个TCP客户端。我可以读取来自服务器的数据，但我无法发送数据。下面是我正在编写的代码：extern crate futures;extern crate tokio_io;
use self::futures::{Future, Poll, Stream};
use self::tokio_co
浏览 26提问于2018-07-17得票数 4
回答已采纳
我想使用异步IO创建一个SOCKS5代理的变体。我以前在Haskell做过这件事，所以我认为这将是一个很好的学习挑战。我从开始。在本例中，Transfer结构要求读取器和写入器的类型为TcpStream。在我的代码中，这些需要是多态的，所以我首先定义： fn poll_read(&self) -> Async<()>;{
浏览 0提问于2018-01-26得票数 0
回答已采纳
我有一个名为Connection的结构，它接收tokio::net::TcpStream或tokio::net::UnixStream来与远程服务器对话。由于Rust没有构造函数，我在我的结构中添加了一个静态new()方法，并在那里执行身份验证握手，然后将流的实例传递给一个新的Connection实例，并将该实例从new()返回给我的最终用户。我的问题是如何创建一个可以设置为UnixStream或TcpStream的临时对象，以便我可以在</e
浏览 13提问于2021-01-31得票数 0
回答已采纳
1回答
我对Rust非常陌生，愿意为Actix-web中的Orange Pi Zero提供一些Linux服务，它将充当其他网络设备的“网关”(一些哑巴的中国网络中继有4个输入和4个输出，这是由AT命令通过TCP我想做2个不同的角色，第一个应该是TCP客户端角色，通过run_interval()轮询中继，用适当的AT命令发出网络请求，读取响应并发送消息到WebSocket角色，将输入状态的消息推送到网页。我成功地实现了WebSocket one，并尝试使用TcpStream、FramedWrite和LinesCod
浏览 30提问于2020-10-26得票数 0
回答已采纳
1回答
我使用tokio::net::TcpStream连接一个小型TCP服务器，我编写了几个字节并期望从服务器读取响应。但是从我的Rust客户端，我可以写字节，但是只要我想从服务器读取数据use std::collections::HashMap;
use std::op
浏览 23提问于2022-02-20得票数 0
回答已采纳
我试图使用机箱在Rust中编写一个简单的TCP客户端。我的代码非常接近减去TLS：extern crate tokio_core;use tokio_core::net::TcpStream;use tokio_io:
浏览 9提问于2017-10-07得票数 11
回答已采纳
1回答
我正在尝试使用Rust及其Tokio运行时创建一个客户端，并使用pyo3和pyo3-asyncio将其绑定到python。我希望函数返回一个Python协程，这样我就可以在我的Python代码库中与async函数一起使用它。示例用例：from client import Client # pyo3-bound rust code
asyncio.run(c.echo我写了这个(希望是最小的)
浏览 3提问于2021-10-07得票数 0
1回答
我正在尝试使用在Rust中实现一个超文本传输协议客户端。我是由rust-lang.org网站通过他们在TcpStream页面上的一个rust- by -example建议发送到这个链接的。我正在研究如何从TcpStream中读取数据。我试着遵循下面的代码： // read
浏览 24提问于2019-06-06得票数 -6
1回答
我有一个代码需要从几个TcpStream中读取。其中一个TcpStream将永远存在，但另一个可能存在，也可能不存在。use tokio::net::TcpStream;
async fn main() {
let mut stream1: TcpStream = TcpS
浏览 8提问于2022-05-16得票数 1
回答已采纳
目前，我们正在切换的API网关引擎，由c到tokio，超级，锈锈。
下面是我所想到的流程:当收到一个具有较大正文大小的POST请求时，所有http主体在读取到内容长度后都会读取→，然后执行传递给make_service_fn的未来代码(示例中的回显操作)。但是，一旦收到请求，就会执行传递
浏览 2提问于2022-05-16得票数 2
回答已采纳
例如，在客户端，通常不可能阻止主线程读取数据。所以要么使用非阻塞套接字，要么使用多线程或异步io。作为一般实践，由于tcp连接在两个线程中使用，所以通常我们必须使用Arc<Mutex<TcpStream>>来<em
浏览 8提问于2022-08-15得票数 1
回答已采纳
我有两个Rust方法，根据两个不同的参数，从同一个SQLite表中选择使用sqlx的数据。码use tokio;依赖关系：anyhow = "1.0.44"
sqlx = { version = "0.5", features = [ "runtime-tokio-rustls", "sqlite&q
浏览 3提问于2022-02-17得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
