我不能编译一个简单的应用程序来测试tokio-codec。tokio::net::tcp::stream::TcpStream实现了AsyncRead和-Write。我仍然是Rust和Tokio的新手，所以毫无疑问我错过了一些明显的东西(我希望)…… main.rs： use tokio::net::TcpListener;tok
浏览 65提问于2019-12-30得票数 5
回答已采纳
1回答
在尝试从tokio TcpStream反序列化为JSON Value时，我尝试使用以下函数： use futures::prelude::*;use tokio::io::{AsyncReadExt, AsyncWriteExt};use tokio::stream::StreamExt::tcp::<
浏览 58提问于2020-08-29得票数 2
在tokio.rs文档中，我们可以看到以下代码片段 // split the socket stream into readable and writable parts// copy bytes from the reader into the writer
let amount = io::copy(reader, writer); 我假设split确实是Stream::split，但是我不知道这个特性如何应用于TcpStr
浏览 16提问于2019-05-29得票数 3
回答已采纳
这是我目前所拥有的：use tokio::net::TcpStream;
async fn main() -> Result<(), Box<dyn std::error::Error>> {
浏览 7提问于2020-06-06得票数 1
回答已采纳
std::io;use tokio::codec::{Framed, LinesCodec};use tokio::prelude::*;
addr: SocketAddr, type<Framed<TcpStream,
浏览 0提问于2018-09-19得票数 7
回答已采纳
1回答
我试图编写一个函数，该函数从服务器读取响应，并返回等待时应该返回实现tokio AsyncRead特性的未来流： --> src/lib.rs:350:12<Output = Result<t
浏览 1提问于2022-09-04得票数 1
回答已采纳
在当前的实现中，我使用了Arc<Mutex<TcpStream>>，但是它编译时有错误：use std::sync::{Arc, Mutex};use std::time::Duration;use tokio::net::TcpStream---------- has type `std::s
浏览 8提问于2022-03-05得票数 1
回答已采纳
2回答
生锈单线程持久TCP服务器
、、、、
我试图使用tcp协议在Rust中制作一个服务器。我可以通过语言文档制作一个正常的服务器，但我不希望每当建立新连接时创建一个新线程，也不希望使用线程池，因为tcp连接将是持久的，也就是说，它们将持续很长时间(大约30分钟-2h)。因此，我遍历了所有的连接，在1毫秒的超时时间内，我尝试读取是否有任何新的数据包。然而，有些事情告诉我，这不是正确的做法。有什么想法吗？提前谢谢。
浏览 7提问于2021-12-25得票数 1
1回答
= "1.11.0", features = ["full"] }use tokio::prelude::*; let addr = "93.184.216.34:9243".parse().unwrap();
<
浏览 15提问于2021-09-09得票数 1
python，所以我尝试遵循下面这段代码：https://github.com/bedroombuilds/python2rust/tree/main/23 我只想收听一个频道并打印到屏幕上；所以在我的实现中没有使用代码片段中tokio::select!::stream::Stream<tokio::net::TcpStream, tokio_tls::TlsStream<
浏览 78提问于2021-11-11得票数 0
回答已采纳
在tokio::net::TcpStream的情况下，我坚持正确地处理恐慌。use tokio::*;async fn main() {let mut stream = TcpStream::connect("10.20.30.40:6142").await.u
浏览 1提问于2022-02-07得票数 0
回答已采纳
我开始关注tokio::net::TcpStream::connect()和朋友，他们似乎没有办法做到这一点。我退了一步，看了看std::net::TcpStream，它也没有。
浏览 7提问于2019-12-12得票数 4
1回答
use tokio::net::TcpStream;use tokio_util::codec::Decoder; inner: Framed<TcpStream, MqttCodec>, async fn::net::<em
浏览 35提问于2021-01-15得票数 0
回答已采纳
这种类型的T实现了和。如何获得和？
我找到了板条箱和，但我不知道如何用它们来做我想做的事。
浏览 13提问于2022-05-15得票数 1
回答已采纳
我正在试验如何使用Rust的tokio来停止异步TCP连接和数据包读取。::net::TcpStream> { tokio::select!{ _ = shutdown => return None,
r = tokio::net::TcpStream:::net::TcpStream</e
浏览 8提问于2022-03-18得票数 1
该项目正在实现一个TcpListener服务。它监视pc事件并向TCP客户端广播。作为需求(一个生产者和许多消费者)。但是，代码会引发“未来无法安全地在线程之间发送”错误：use tokio::{io::AsyncWriteExt, net::TcpStream, sync::watch};
let mut stream = TcpStream::connect("127.0.0.1:8080").awa
浏览 13提问于2022-11-25得票数 1
, AsyncWriteExt}, time::sleep, stream.write_all(b"testing").await.unwrap("new connection");
浏览 18提问于2022-05-05得票数 0
回答已采纳
我尝试使用tokio(tokio={version="1", features=["full"]})实现一个简单的http服务器。代码在下面。use tokio::{self, net};use tokio::net::TcpStream;
async fn process(
浏览 6提问于2022-12-02得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
