如何将`ReadHalf`和`WriteHalf`重新拼接成一个`TcpStream`
ReadHalf和WriteHalf是TcpStream的两个子流，表示TCP套接字的读取和写入操作的两个部分。要将它们重新拼接成一个完整的TcpStream，可以使用Rust语言的split方法。
首先，通过split方法将一个完整的TcpStream分为ReadHalf和WriteHalf：
use std::net::TcpStream;
let tcp_stream = TcpStream::connect("127.0.0.1:8080").unwrap();
let (read_half, write_half) = tcp_stream.split().unwrap();然后，使用join方法将ReadHalf和WriteHalf重新拼接为一个完整的TcpStream：
let joined_tcp_stream = read_half.join(write_half).unwrap();现在，joined_tcp_stream就是重新拼接后的完整的TcpStream，可以像使用普通的TcpStream一样对其进行读取和写入操作。
对于这个问题，腾讯云提供了与TCP套接字相关的云服务产品和解决方案：
- 腾讯云云服务器（ECS）：提供了云上的虚拟服务器实例，可以使用TCP套接字进行网络通信。了解更多信息：腾讯云云服务器产品介绍
- 腾讯云私有网络（VPC）：提供了隔离的虚拟网络环境，用于部署和管理TCP套接字通信的云资源。了解更多信息：腾讯云私有网络产品介绍
- 腾讯云弹性负载均衡（ELB）：可以将TCP套接字的流量分发到多个后端服务器，提高服务的可用性和负载均衡能力。了解更多信息：腾讯云弹性负载均衡产品介绍
请注意，以上只是腾讯云提供的一些与TCP套接字相关的云服务产品，还有更多其他产品和解决方案可根据具体需求选择和使用。
相关·内容
我正在用Rust编写一个套接字服务器，并且已经实现了响应/发送代码。主要问题是read_to_string方法直到连接关闭，而不是直到出现换行符。
例如，在这个代码中，
use std::net::{TcpListener, TcpStream};
use std::io::Write;
use std::io::Read;
fn handle_client(stream: TcpStream) {
let conn = stream;
let conn = send(conn, "Hello!");
let mut conn = send(conn,
浏览 4提问于2017-03-28得票数 1
回答已采纳
我正在尝试将TcpStream和TlsStream包装在一个对象中，这样我就可以使用一个结构与它们中的任何一个进行交互。我试图根据配置值将io方法委托给一个或另一个，但不知道如何返回具有实现Read和Write特征的泛型类型的结构
我的代码如下
pub struct TcpStream<T: Read + Write> {
io_delegate: T,
config: Config,
}
impl<T> TcpStream<T>
where T: Read + Write
{
pub fn connect<A: To
浏览 0提问于2017-04-03得票数 0
作为一种熟悉锈蚀和网络的方法，我开始编写一个非常基本的telnet聊天服务器。一切看起来都进行得很顺利，但现在我得到了一堆不安全的代码，我想知道是否有更好的方法来做事情。
我产生了一个任务来侦听类似于这样的连接：，一旦用户连接，我得到一个TcpStream，我把它放在一个连接结构中。连接结构使用通道与两个任务进行通信-一个用于从其TcpStream读取，另一个用于写入。读取任务阻塞TcpStream的read()方法，并将任何输入发送回连接结构。写入器阻塞端口的recv()方法，并将接收到的任何内容写入TcpStream。这样，程序的主循环就可以简单地维护一个连接结构向量，以检查用户的输入并随
浏览 3提问于2014-01-16得票数 1
回答已采纳
3回答
我正在编写一个TCP客户端，并且在我的客户端结构中有一个conn字段。我的客户端实现了两个方法new来实例化结构和连接打开到服务器的连接并将其设置为conn字段的值。
pub struct FistClient {
addr: String,
conn: TcpStream,
}
impl FistClient {
pub fn new(ip: &str, port: &str) -> Self {
FistClient {
addr: String::from(ip) + ":" + &a
浏览 1提问于2019-09-16得票数 9
回答已采纳
当字符串存储为String而不是&str时，它无法实现特征ToSocketAddrs。最接近的可能是impl<'a> ToSocketAddrs for (&'a str, u16)。
use std::net::TcpStream;
fn main() {
let url = "www.google.com".to_string(); // String
let url2 = "www.google.com"; // &'static str
let p
浏览 3提问于2015-05-23得票数 6
回答已采纳
我想要一个由一个TcpStream和一个BufReader共享的BufWriter，我在以下方面找到了一个解决方案：
现在我希望它在它自己的数据结构中，但我只从以下方面得到了部分答复：
想要实现的是违反所有权规则。
use std::io::{BufReader, BufWriter};
use std::net::TcpStream;
pub struct BufTcpStream<'a> {
_socket: TcpStream,
input: BufReader<&'a TcpStream>;
output:
浏览 0提问于2019-10-19得票数 6
回答已采纳
1回答
我有一个代码需要从几个TcpStream中读取。其中一个TcpStream将永远存在，但另一个可能存在，也可能不存在。
我之前编写了代码，并(天真地)使用tokio宏上的条件。不幸的是，我很快了解到宏将首先评估arm (以获得未来)，然后才会检查一个条件，并在此基础上启动或跳过它。
因此，当我运行这段代码时，我将得到：thread 'main' panicked at 'called `Option::unwrap()` on a `None` value', src/main.rs:16:35
use tokio::io::AsyncReadExt;
use
浏览 8提问于2022-05-16得票数 1
回答已采纳
在使用预定义脚本和LUA运行时环境测试代码时，LUA不会采用任何形式的字符串键值。但是，如果使用数值键，LUA将按预期使用它。当我使用带有LUA文件的Tshark来解析数据包捕获时，这条规则是个例外。这允许字符串键值语法正常工作。有没有什么地方我可能做错了？
我已经尝试创建了几个具有不同变体的.lua脚本文件，包括：
testArray.NewItem = "value1“testArray"NewItem”= "value1“
NewItemValue = "NewItem“testArrayNewItemValue = "value1”
所有这些都会
浏览 6提问于2019-07-27得票数 2
1回答
对于可读和可写的流(如TcpStream)，我有一个特性：
pub trait MyTraitPool<T: Read + Write> {
fn acquire(&self, &String) -> T;
fn free(&self, T);
}
我想用TcpStream实现该特征作为T，所以我想写
struct MyPool;
impl<T> MyTraitPool<T> for MyPool
where T: Read + Write {
fn acquire(&self, ad
浏览 2提问于2017-02-01得票数 2
回答已采纳
有没有办法在split之后将Tokio ReadHalf和WriteHalf重新加入到TcpStream中 let mut stream = TcpStream::connect("127.0.0.1:8080").await?;
let (reader, writer) = stream.split();
// re-join pseudo-code
let stream: TcpStream = (reader, writer).join();
浏览 21提问于2019-10-05得票数 2
回答已采纳
我试图为服务器编写以下代码：
use std::io::{BufReader, BufWriter};
use std::net::TcpStream;
struct User<'a> {
stream: Arc<TcpStream>,
reader: BufReader<&'a TcpStream>,
writer: BufWriter<&'a TcpStream>,
}
fn accept_socket(users: &mut Vec<User>, str
浏览 8提问于2022-06-09得票数 1
1回答
我似乎不能掌握编译后的抢劫案的概念。无论如何，网络上没有任何例子。我该如何将简单的代码片段从解释转换为编译？
例如：
listUsersH :: AppHandler ()
listUsersH = do
users <- liftIO $ getColList "users"
let userListS = mapSplices userLinkS users
heistLocal (bindSplice "users" userListS) $ render "list-users"
where
userLink
浏览 0提问于2013-06-12得票数 5
1回答
我正在尝试处理从异步调用中收到的错误：
let res: Result<TcpStream, Box<dyn std::error::Error>> = session.runtime().borrow_mut().block_on(async {
let fut = TcpStream::connect(session.configuration().socket()).await?;
Ok(fut)
});
我试着用一个if的老方法来实现它，但是编译器不喜欢它：
if res.is_err() {
return Err(res);
}
在谷歌
浏览 1提问于2020-10-12得票数 0
回答已采纳
我试图编写一个静态HTTP文件服务器，但当我试图通过TcpStream发送一个TcpStream文件时，我陷入了困境。
即使我将文件作为二进制文件，浏览器似乎也无法解码图像：
extern crate chunked_transfer;
use std::net::{TcpListener, TcpStream};
use std::io::{Read, Write};
use std::thread;
use std::fs::File;
use chunked_transfer::Encoder;
fn main() {
let listener = TcpListener::b
浏览 4提问于2017-02-14得票数 1
回答已采纳
3回答
我有一个我用来抽象化tokio::net::TcpStream和tokio::net::UnixStream的特性
/// Interface for TcpStream and UnixStream.
trait TryRead {
// overlapping the name makes it hard to work with
fn do_try_read(&self, buf: &mut [u8]) -> Result<usize, std::io::Error>;
}
impl TryRead for TcpStream {
fn d
浏览 1提问于2021-01-27得票数 20
回答已采纳
我有一个外部类型(protobuf:::CodedInputStream)，它需要一个对引用的特征对象的引用(TcpStream作为&mut Read)。
我想让一个类型或函数Connection包装TcpStream (取得所有权)，以及一个CodedInputStream，以便使用它的功能，将TcpStream的使用和所有权封装为内部细节。
但是，我想不出是怎么回事。我天真的尝试(在伪铁锈中)
struct Connection {
stream: TcpStream,
coded_stream: CodedInputStream,
}
fn new_connec
浏览 0提问于2016-05-18得票数 0
2回答
苹果在iOS 11中引入了一种新的图像格式，名为 (.heic文件扩展名)。我知道您可以从iOS设备中导出图片作为JPG，但是我想将HEIC文件上传到我的服务器上，并将它们转换成可以在所有其他设备上显示的JPEG文件。
有人能推荐一个好的和有效的方法来实现这一点吗？
答：
既然这个问题已经结束了，我将在这里编辑我的答案给你们其他人。我们现在使用这个库将HEIC转换为JPEG：。
还有多亏了
感谢和的伟大贡献！
EDIT1:编辑了问题的措辞，使之更加具体，并符合这样的指导方针。
EDIT2:添加了答案，因为这个主题现在结束了:/
浏览 22提问于2017-08-02得票数 67
特性中的所有方法都接受&mut self。这是有意义的，因为从概念上来说，它需要改变某种内部状态。出于同样的原因，如果是io::Write，那么很自然地就会看到它对io::Write有一个全面的实现。
impl<'_, W: Write + ?Sized> Write for &'_ mut W
另一方面，我感到奇怪的是，除了和本身之外，它也是为和实现的。
这个不一致让我有点困扰。这样做是为了方便吗？或者是因为I/O的性质，才能保证安全？
在尝试时注意到这一点，这是一个堆叠的协同库。它的没有为&TcpStream实现io::Writ
浏览 5提问于2020-02-09得票数 2
回答已采纳
我想做消息广播:当其中一个客户端发送消息时，服务器将其写入每个套接字。我的主要问题是我不知道如何将Vec发送到线程。我不能使用Mutex，因为这将锁定其他线程对Vec读取的访问权限。我不能克隆和发送，因为TcpStream不能被克隆和发送。这是我到现在为止的尝试
use std::net::{TcpStream, TcpListener};
use std::io::prelude::*;
use std::sync::{Arc, Mutex};
use std::thread;
use std::sync::mpsc::{channel, Receiver};
use std::cell::
浏览 2提问于2017-08-14得票数 0
回答已采纳
我已经在这个问题中失去了我生命中的两天；
我想在ubuntu12.04(安装在我的VMWare中)中使用genomotion，我的环境：
Windows7(x64) => VMWareV8.0.3 (桥接网络，Ubuntu12.04)然后，我在Ubuntu中安装了VirtualBox4.2 && Genymotion(2.2)
在一个接一个地解决了问题之后，Android设备的发布给我带来了麻烦(从Genomotion Cloud下载)
➜ genymotion sudo ./genymotion
Logging activities to file: /home/ga
浏览 9提问于2017-12-01得票数 0
回答已采纳
我有一个名为Connection的结构，它接收tokio::net::TcpStream或tokio::net::UnixStream来与远程服务器对话。由于Rust没有构造函数，我在我的结构中添加了一个静态new()方法，并在那里执行身份验证握手，然后将流的实例传递给一个新的Connection实例，并将该实例从new()返回给我的最终用户。 我的问题是如何创建一个可以设置为UnixStream或TcpStream的临时对象，以便我可以在进行握手的消息交换期间对其进行操作。由于UnixStream和TcpStream没有共同的父母，我对如何实现这一点感到困惑： pub struct Con
浏览 13提问于2021-01-31得票数 0
回答已采纳
我正在制作一个应用程序，这是应该创建360全景图像(不仅线性，但也向上和向下，所以在效果上是一个球体全景)。我一直在谷歌上搜索，试图找到一些相关的东西，到目前为止，唯一接近它的就是这个
我已经在示例中测试了该库，但它无法对室内图像执行任何合理的工作。
我正在制作的应用程序应该既可以在室内工作，也可以在室外工作。此外，我仍然不确定如何根据陀螺仪位置自动捕获图像。
任何帮助都将不胜感激。提前谢谢你。
浏览 2提问于2014-01-01得票数 2
1回答
我使用boost：：TCP作为TCP连接，并使用异步流。我想知道最合适的方法是指定要绑定到的源IP/端口。
我在下面举一个例子，
template <typename Stream, typename Endpoints, typename Handler>
static void connect(Stream& stream, const Endpoints& endpoints, Handler handler) {
auto& tcpStream = beast::get_lowest_layer
浏览 6提问于2022-09-15得票数 1
回答已采纳
我正在编写一个应用程序，缝合iOS文本消息屏幕捕获垂直在一起。我把图片裁剪成只包含消息气泡，不包含文本输入栏的导航栏(当然第一个和最后一个截图除外)，但我不知道如何检测图像在哪里排列。我需要检测对话中有重叠的地方，然后在这一点上缝合图像。(我也知道如何将图像绘制到新的图像上下文中。)我正在寻找一个开源框架，可以帮助我实现这一点，以及如何完成这项任务的任何建议。谢谢!
浏览 4提问于2012-09-05得票数 0
在有std::net::TcpStream或native_tls::TlsStream<TcpStream>的场景中，我面临带有动态特性的编译器错误。我的算法的思想如下：
在var " TCP“中创建tcp流
如果方案是https，=>将相同的var替换为新的TlsStream<TcpStream>。
在流中写入和接收数据。
我需要的重要特征是std::io::Read和std::io::Write。因此，我想，我只是把我的"tcp“var建模为Box<dyn Read + Write>。但是无论我怎么尝试，我总是会
浏览 4提问于2021-07-09得票数 0
我有一个包含35个工作表的Excel工作簿，每个工作表都有100+行和30+列。我只想从每个工作表中得到9行(这9行的所有列)。因为有一个模式，所以我以前可以使用skiprows获得行。我使用以下方法从每个工作表中读取所需的行：
xl = pd.ExcelFile('group.xlsx')
locations = (list(xl.sheet_names))
df = pd.concat(pd.read_excel('group.xlsx', sheet_name= locations, skiprows = 62, nrows= 9, usecols= N
浏览 4提问于2022-01-12得票数 0
5回答
在C++标准中，如果使用//some comment\样式对行进行注释(在行的末尾放置\)，则将注释转换为多行？
用g++ 4.8和VS 2012进行测试
//some interesting stuff\
another interesting stuff\
etc
浏览 8提问于2014-08-06得票数 45
回答已采纳
我想使用异步IO创建一个SOCKS5代理的变体。我以前在Haskell做过这件事，所以我认为这将是一个很好的学习挑战。我从开始。
在本例中，Transfer结构要求读取器和写入器的类型为TcpStream。在我的代码中，这些需要是多态的，所以我首先定义：
pub trait Pollable {
fn poll_read(&self) -> Async<()>;
fn poll_write(&self) -> Async<()>;
}
impl Pollable for TcpStream {
fn poll_rea
浏览 0提问于2018-01-26得票数 0
回答已采纳
我有这样的结构：
pub struct Connector {
host: String,
executor: ThreadPool,
}
此结构具有一个方法，它通过TcpStream::connect()在多个线程上分配工作(TCP-connections)。不幸的是，当引用一个struct字段时，我遇到了一个错误。
self.executor.execute(move || {
if let Ok(_) = TcpStream::connect((self.host.as_str(), 8080)) {
println!("Connectio
浏览 3提问于2020-03-27得票数 0
回答已采纳
1回答
我是生锈新来的，并通过尝试它的例子我的方式。我想尝试编程一个套接字库。我在早期遇到的一个问题是如何初始化具有TcpStream的结构。
struct connection{
address: String,
sock: TcpStream,
}
当我开始工作时，我不知道如何初始化该类型的对象
impl connection{
fn new(add: &str)->connection{
connection{
address: add.to_string(),
//i didnt kno
浏览 2提问于2021-12-11得票数 1
我不能编译一个简单的应用程序来测试tokio-codec。tokio::net::tcp::stream::TcpStream实现了AsyncRead和-Write。但是当我尝试编译下面的代码时，我得到了下面的错误。我仍然是Rust和Tokio的新手，所以毫无疑问我错过了一些明显的东西(我希望)…… main.rs： use tokio::net::TcpListener;
use tokio::prelude::*;
use tokio_codec::{ Framed, LinesCodec };
#[tokio::main]
async fn main() -> Result&
浏览 65提问于2019-12-30得票数 5
回答已采纳
我有一个巨大的pcap，其中有上千个tcpstream，我需要分离这些tcpstream并找出每个tcpstream的丢包情况，我正在尝试TSHARK()，它可以帮助我发现丢包、重传，但是它对整个pcap文件来说是这样的。我想在我的Linux盒中为单独的tcpstreams获取它。
提前谢谢。贾恩
浏览 2提问于2013-11-21得票数 0
回答已采纳
我是Rust的新手，我正在尝试创建一个Server结构，它可以侦听地址并启动TCP套接字连接。问题是我希望将客户端连接存储在一个散列映射中，以便以后可以使用它。
我试着写了这个：
use std::collections::HashMap;
use std::net::TcpListener;
use std::net::TcpStream;
use std::sync::{Arc, RwLock};
use std::thread;
#[derive(Clone, Debug)]
pub struct Server {
id: Arc<RwLock<u32>>
浏览 19提问于2020-02-14得票数 0
回答已采纳
我想使用Rust来获取我的GMail电子邮件。我目前使用的是标准库中的库和TcpStream类。
我遇到的问题很简单:下面的代码“卡住”在login方法中的println!("0")和println!("1")之间。流突然“冻结”了。
尽管如此，在执行对另一个URL的HTTP请求时，它工作得很好。
extern crate openssl;
use std::io::{IoResult, TcpStream};
use openssl::ssl::{SslContext, Sslv23, SslStream, SslVerifyPeer};
pub stru
浏览 4提问于2014-07-26得票数 2
在tokio::net::TcpStream的情况下，我坚持正确地处理恐慌。
use tokio::*;
use tokio::{net::{ TcpStream }, io::AsyncWriteExt};
#[tokio::main]
async fn main() {
let mut stream = TcpStream::connect("10.20.30.40:6142").await.unwrap();
println!("created stream");
let result = stream.write(b"
浏览 1提问于2022-02-07得票数 0
回答已采纳
我有一个通过在BufReader中缓冲接收到的行来打印它们的TcpStream。
use std::net::TcpStream;
use std::io::{BufReader, BufRead, Write, BufWriter};
fn main() {
let stream = TcpStream::connect("irc.freenode.org:6667").unwrap();
let mut line = String::new();
let mut reader = BufReader::new(stream);
// le
浏览 0提问于2016-08-27得票数 1
我想使用mio实现tcp客户端。这是我的密码：
pub struct Client<'a> {
pub connected: bool,
connection: Option<&'a TcpStream>,
auth_handler: auth::AuthHandler<'a>,
}
impl Client<'_> {
pub fn connect(&mut self, host: &str, port: i16) {
let addr_li
浏览 2提问于2022-01-27得票数 0
回答已采纳
1回答
我试图发送各种比特的PC信息，如免费的硬盘空间，总RAM等，到一个Windows服务的TCP。我有下面的代码，它基本上创建了一个信息字符串，该字符串由一个\\，可以在Windows服务器中处理，然后放到一个SQL表中。
像我这样做是最好还是有更好的方法？
public static void Main(string[] args)
{
Program stc = new Program(clientType.TCP);
stc.tcpClient(serverAddress, Environment.MachineName.ToString()
浏览 0提问于2014-01-11得票数 0
回答已采纳
2回答
我有一个客户在处理一个做一些事情的Future。有没有可能使用impl Future<Item = (), Error = io::Error>作为返回类型并进行更好的错误处理？
pub fn handle_client(client: Client) -> impl Future<Item = (), Error = io::Error> {
let magic = client.header.magic;
let stream_client = TcpStream::connect(&client.addr).and_then(|str
浏览 0提问于2019-02-28得票数 6
1回答
我想创建一个(require.js风格的) AMD模块，可以在浏览器和节点中使用。做这件事最好的方法是什么？我不断地看到对r.js的引用，但仍然不能100%确定如何使用它，或者是否对我的情况是必要的。
此外，当在节点中包含此模块时，我是否仍然运行require(“模块名称”)，还是也会改变？
浏览 3提问于2013-05-21得票数 3
在这里，我将两个不同的列表转换为一个映射。在我使用normal for循环来做这件事之前。由于性能问题，我现在使用streams。在使用streams时，如何对两个对象列表使用相同的mapObject。
final Set<Object1> objects1 = new HashSet<Object1>();
final Set<Object2> objects2 = new HashSet<Object2>();
final Map<Id, Object> objectMap = new HashMap<Id, Object&
浏览 2提问于2017-03-09得票数 0
1回答
我正在尝试启用TLS功能在流上打开加密的AMQP连接。在amiquip文档中，有一个示例
我复制了代码示例，并实现了所请求的尽可能简单的tcp_stream函数，以便如前所述返回mio::net::TcpStream实例。
use amiquip::{Auth, Connection, ConnectionOptions, ConnectionTuning, Result};
use mio::net::TcpStream;
use std::net::SocketAddr;
use std::{io::Read, time::Duration};
// Examples below ass
浏览 1提问于2021-08-09得票数 0
在ubuntu 17.04上运行genymotion和virtualbox
我试过“自定义平板电脑7.1.0”和“自定义手机7.1.0”，但似乎都不能开机:我只是看到永远的黑屏。
我在终端中得到这个错误：
Failed to connect to VM (TcpStream) for main host connection, IP:Port=192.168.56.101:25000!!!
Failed to connect to VM (TcpStream) for main host connection, IP:Port=192.168.56.101:25000!!!
Failed to
浏览 0提问于2017-06-12得票数 0
1回答
我希望在发送到命令行的引用命令中包含变量domainUser，但是我没有任何运气。我想要完成的是创建一个名为“域名”的日志文件，但是我总是会出错，或者只是得到一个没有标题的txt文件。
Dim domainUser
domainUser = Example123
objInParam.Properties_.Item("CommandLine") = "cmd /c ECHO Test >> c:\UserLogs\"""domainUser""".txt"
所以第4行将被读成这样(或者我在第2行中输
浏览 4提问于2016-07-21得票数 0
回答已采纳
我已经用Rust编写了一个回显服务器和客户端。下面是我的代码：
服务器：
use std::net::{TcpListener, TcpStream};
use std::thread;
use std::io::Write;
use std::io::BufReader;
use std::io::BufRead;
use std::io::BufWriter;
fn handle_connection(stream: TcpStream) {
let stream_clone = stream.try_clone().unwrap();
let mut reader =
浏览 16提问于2018-08-05得票数 2
回答已采纳
1回答
在尝试从tokio TcpStream反序列化为JSON Value时，我尝试使用以下函数： use futures::prelude::*;
use serde_json::Value;
use tokio::io::{AsyncReadExt, AsyncWriteExt};
use tokio::net::{TcpListener, TcpStream};
use tokio::stream::StreamExt;
use tokio_serde_json::ReadJson;
use tokio_util::codec::{FramedRead, LengthDelimitedCod
浏览 58提问于2020-08-29得票数 2
1回答
我有一个线程启动工作线程，所有的预期将永远存在。每个工作线程都维护自己的Socket列表。
有些操作要求我遍历当前活动的所有套接字，但在试图创建一个包含指向另一个列表拥有的套接字的指针的套接字主列表时，我遇到了困难。
use std::{str, thread};
use std::thread::JoinHandle;
use std::io::{Read, Write};
use std::net::{TcpListener, TcpStream};
use std::sync::{Arc, Mutex};
use std::ops::DerefMut;
use std::sync::mp
浏览 1提问于2015-02-22得票数 10
回答已采纳
1回答
我正在尝试使用tokio和mqtt_v5机箱中提供的编解码器创建一个MQTT连接。我的代码不能编译，我不明白为什么。这是我到目前为止所写的代码，发送代码可能不正确。 use tokio::net::TcpStream;
use tokio_util::codec::Framed;
use tokio_util::codec::Decoder;
use std::net::SocketAddrV4;
use mqtt_v5::types::Packet as MqttPacket;
use mqtt_v5::codec::MqttCodec;
use futures_sink::Sink;
u
浏览 35提问于2021-01-15得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
