Rust 构建 TCP/UDP 网络服务
第四章 异步编程与网络通信
第二节 构建 TCP/UDP 网络服务
在现代应用程序中,网络通信是核心功能之一。本节将重点介绍如何在 Rust 中构建基本的 TCP 和 UDP 网络服务,涵盖实际的代码示例、最佳实践以及最新的技术方案,以帮助开发者掌握网络编程的技巧。
1. 实现一个基本的 TCP 服务器和客户端
1.1 TCP 服务器的实现
我们首先创建一个简单的 TCP 服务器,能够接受客户端的连接并进行数据交互。使用 Tokio 作为异步运行时来处理 TCP 连接。
基本 TCP 服务器代码示例:
use tokio::net::{TcpListener, TcpStream};
use tokio::prelude::*;async fn handle_client(mut stream: TcpStream) {let mut buffer = [0; 1024];loop {let bytes_read = match stream.read(&mut buffer).await {Ok(0) => return, // 连接关闭Ok(n) => n,Err(e) => {eprintln!("读取错误: {}", e);return;}};println!("收到: {}", String::from_utf8_lossy(&buffer[..bytes_read]));if let Err(e) = stream.write_all(&buffer[..bytes_read]).await {eprintln!("写入错误: {}", e);return;}}
}#[tokio::main]
async fn main() {let listener = TcpListener::bind("127.0.0.1:8080").await.unwrap();println!("TCP 服务器在 127.0.0.1:8080 启动");loop {let (socket, _) = listener.accept().await.unwrap();tokio::spawn(handle_client(socket));}
}
关键点:
TcpListener用于监听传入连接。- 每当接收到连接时,
handle_client函数在新的任务中处理该连接。 - 服务器能并发处理多个连接。
1.2 TCP 客户端的实现
接下来,我们将实现一个简单的 TCP 客户端,与服务器进行连接并发送数据。
基本 TCP 客户端代码示例:
use tokio::net::TcpStream;
use tokio::prelude::*;#[tokio::main]
async fn main() {let mut stream = TcpStream::connect("127.0.0.1:8080").await.unwrap();let message = "Hello, TCP Server!";stream.write_all(message.as_bytes()).await.unwrap();let mut buffer = [0; 1024];let size = stream.read(&mut buffer).await.unwrap();println!("服务器回复: {}", String::from_utf8_lossy(&buffer[..size]));
}
关键点:
- 客户端连接到 TCP 服务器并发送消息。
- 等待并接收服务器的回复。
2. UDP 的使用案例与实践
UDP 是一种无连接的协议,适用于实时性要求高的场景,如视频会议、在线游戏等。以下是如何在 Rust 中实现一个基本的 UDP 服务器和客户端。
2.1 UDP 服务器的实现
基本 UDP 服务器代码示例:
use tokio::net::UdpSocket;
use tokio::prelude::*;#[tokio::main]
async fn main() {let socket = UdpSocket::bind("127.0.0.1:8080").await.unwrap();println!("UDP 服务器在 127.0.0.1:8080 启动");let mut buf = [0; 1024];loop {let (size, addr) = socket.recv_from(&mut buf).await.unwrap();println!("收到来自 {:?} 的消息: {}", addr, String::from_utf8_lossy(&buf[..size]));// 回送数据socket.send_to(&buf[..size], &addr).await.unwrap();}
}
关键点:
- 使用
UdpSocket创建一个 UDP 服务器。 - 服务器接收数据并将其回送给客户端。
2.2 UDP 客户端的实现
基本 UDP 客户端代码示例:
use tokio::net::UdpSocket;
use tokio::prelude::*;#[tokio::main]
async fn main() {let socket = UdpSocket::bind("127.0.0.1:8081").await.unwrap();let message = b"Hello, UDP Server!";socket.send_to(message, "127.0.0.1:8080").await.unwrap();let mut buf = [0; 1024];let (size, _) = socket.recv_from(&mut buf).await.unwrap();println!("服务器回复: {}", String::from_utf8_lossy(&buf[..size]));
}
关键点:
- 客户端发送数据到 UDP 服务器并接收回复。
- 使用
send_to和recv_from进行数据传输。
3. 处理并发连接的实现方式
在实际的应用中,处理并发连接是非常重要的。我们将讨论几种不同的处理方式,包括使用 Tokio 的任务和通道。
3.1 使用 Tokio 的任务处理并发连接
在 TCP 服务器示例中,我们使用 tokio::spawn 为每个连接创建一个新的异步任务,这样可以处理多个连接而不会阻塞主线程。
示例回顾:
tokio::spawn(handle_client(socket));
3.2 使用通道进行消息传递
通过 Tokio 的通道,我们可以在不同的任务之间传递消息。这对于处理复杂的并发逻辑非常有用。
使用通道的示例:
use tokio::sync::mpsc;#[tokio::main]
async fn main() {let (tx, mut rx) = mpsc::channel(32);tokio::spawn(async move {while let Some(message) = rx.recv().await {println!("接收到消息: {}", message);}});tx.send("Hello from the main task!").await.unwrap();
}
3.3 实现连接池
对于高并发场景,连接池是一种常见的解决方案。连接池管理一组 TCP/UDP 连接,以减少连接的创建和关闭开销。
基本的连接池结构:
use std::collections::VecDeque;
use tokio::net::TcpStream;struct ConnectionPool {connections: VecDeque<TcpStream>,
}impl ConnectionPool {fn new(size: usize) -> Self {Self {connections: VecDeque::with_capacity(size),}}// 获取连接fn get_connection(&mut self) -> Option<TcpStream> {self.connections.pop_front()}// 返回连接fn return_connection(&mut self, conn: TcpStream) {self.connections.push_back(conn);}
}
连接池的应用:
- 连接池可以在高并发的场景中显著提高性能。
- 适当的连接管理策略可以减少连接建立的开销。
4. 实际应用场景
在实际项目中,网络服务的实现通常涉及复杂的业务逻辑和多个组件的协作。我们将讨论几个常见的应用场景以及实现的要点。
4.1 实时聊天应用
- 设计:使用 TCP 或 WebSocket 协议。
- 关键点:
- 使用 JSON 或 Protobuf 进行消息格式化。
- 实现用户认证和授权机制。
- 管理用户的在线状态。
4.2 视频流服务
- 设计:通常使用 UDP 或 RTP 协议。
- 关键点:
- 数据包丢失的处理和重传机制。
- 使用流式传输技术,如 HLS 或 DASH。
- 处理并发用户的性能优化。
4.3 物联网设备通信
- 设计:使用 MQTT 或 CoAP 协议。
- 关键点:
- 低功耗、高延迟网络的适应性。
- 设备的状态监控和管理。
- 安全性和数据加密。
小结
本节深入探讨了如何在 Rust 中构建 TCP 和 UDP 网络服务。通过实际的代码示例和并发处理的实现方式,开发者可以掌握基本的网络编程技能。无论是实现基本的客户端和服务器,还是处理并发连接和消息传递,Rust 提供了强大而灵活的工具。
进一步学习
- Rust 官方文档:Rust Networking
- Tokio 官方文档:Tokio
- 使用 UDP 的最佳实践:关注性能和数据包丢失的处理。
相关文章:
Rust 构建 TCP/UDP 网络服务
第四章 异步编程与网络通信 第二节 构建 TCP/UDP 网络服务 在现代应用程序中,网络通信是核心功能之一。本节将重点介绍如何在 Rust 中构建基本的 TCP 和 UDP 网络服务,涵盖实际的代码示例、最佳实践以及最新的技术方案,以帮助开发者掌握网络…...
docker镜像文件导出导入
1. 导出容器(包含内部服务)为镜像文件(docker commit方法) 原理:docker commit命令允许你将一个容器的当前状态保存为一个新的镜像。这个新镜像将包含容器内所有的文件系统更改,包括安装的软件、配置文件等…...
ViT面试知识点
文章目录 VITCLIPBlipSAMLSegFast TransformerYOLO系列问题 BatchNorm是对一个batch-size样本内的每个特征做归一化,LayerNorm是对每个样本的所有特征做归一化。 Layer Normalization(层归一化,简称LayerNorm)是一种在深度学习中…...
ChatGPT 和 RAG(检索增强生成)的区别;ChatGPT 和 RAG 的联系
目录 ChatGPT 和 RAG(检索增强生成)的区别 知识来源与利用方式 回答准确性和可靠性 模型架构和复杂性 适用场景 ChatGPT 和 RAG 的联系 ChatGPT 和 RAG(检索增强生成)的区别 知识来源与利用方式 ChatGPT:是基于大规模预训练的语言模型,知识是在预训练过程中从大量的…...
qt获取本机IP和定位
前言: 在写一个天气预报模块时,需要一个定位功能,在网上翻来翻去才找着,放在这里留着回顾下,也帮下有需要的人 正文: 一开始我想着直接调用百度地图的API来定位, 然后我就想先获取本机IP的方…...
CodeQL学习笔记(5)-CodeQL for Java(AST、元数据、调用图)
最近在学习CodeQL,对于CodeQL就不介绍了,目前网上一搜一大把。本系列是学习CodeQL的个人学习笔记,根据个人知识库笔记修改整理而来的,分享出来共同学习。个人觉得QL的语法比较反人类,至少与目前主流的这些OOP语言相比&…...
服装品牌零售业态融合中的创新发展:以开源 AI 智能名片 S2B2C 商城小程序为视角
摘要:本文以服装品牌零售业态融合为背景,探讨信息流优化和资金流创新的重要作用,并结合开源 AI 智能名片 S2B2C 商城小程序,分析其如何进一步推动服装品牌在零售领域的发展,提高运营效率和用户体验,实现商业…...
前端将网页转换为pdf并支持下载与上传
1.pdf下载 handleExport() {const fixedH document.getElementById("fixed-h");const pageOne document.getElementById("mix-print-box-one");const pageTwo document.getElementById("mix-print-box-two");fixedH.style.height 30vh;pageO…...
Android 依赖统一配置管理(Version Catalogs)
最近升级了Android Studio版本到Koala Feature Drop | 2024.1.2,新建项目后发现项目配置又有变化,默认开始使用了一个名叫 Gradle 版本目录的东西,当然也可以称之为依赖统一配置管理,一开始还有点陌生,但是经过一番了解…...
如何为数据看板产品接入实时行情接口并展示行情
在金融科技领域,实时数据是分析和决策的关键因素。通过AllTick的实时行情API,您可以轻松将实时市场数据集成到数据看板产品中,为用户提供丰富的市场洞察。本文将详细介绍如何使用AllTick API,通过WebSocket协议接收并展示实时市场…...
数据结构 C/C++(实验一:线性表)
(大家好,今天分享的是数据结构的相关知识,大家可以在评论区进行互动答疑哦~加油!💕) 目录 提要:实验题目 一、实验目的 二、实验内容及要求 三、算法思想 实验1 实验2 四、源程序及注释 …...
使用WebStorm开发Vue3项目
记录一下使用WebStorm开发Vu3项目时的配置 现在WebStorm可以个人免费使用啦!🤩 基本配置 打包工具:Vite 前端框架:ElementPlus 开发语言:Vue3、TypeScript、Sass 代码检查:ESLint、Prettier IDE…...
Linux高阶——1103——Signal信号机制
1、信号机制 在linux和unix系统下,如果想要处置(挂起,结束)进程,可以使用信号,经典消息机制,所以进程包括系统进程都是利用信号处置进程的 kill -l——查看所有系统支持的信号 1-31号信号——Unix经典信号ÿ…...
如何编写STM32的定时器程序
编写STM32的定时器程序通常涉及以下步骤: 1. 选择定时器和时钟配置 首先,你需要选择一个可用的定时器(TIM),并配置其时钟源。时钟源可以是内部时钟或外部时钟,通常通过RCC(Reset and Clock Con…...
【C++】C++的单例模式、跟踪内存分配的简单方法
二十四、C的单例模式、跟踪内存分配的简单方法 1、C的单例模式 本小标题不是讨论C的语言特性,而是一种设计模式,用于确保一个类在任何情况下都只有一个实例,并提供一个全局访问点来获取这个实例。即C的单例模式。这种模式常用于资源管理&…...
构建一个导航栏web
<!DOCTYPE html> <html><head><meta charset"utf-8"><title></title><style>*{margin: 0;padding: 0;}#menu{background-color:purple;width: 100px;height: 50px;}.item{float: left;/* 浮动标签可以让块标签,…...
【Linux】Linux安全与密钥登录指南
在使用Linux服务器时,确保服务器的安全至关重要。本文将为你介绍一些关键的Linux安全措施,包括开启密钥登录、查看登录日志、限制登录IP以及查看系统中能够登录的账号。以下内容适合小白用户,通过简单的操作就能有效提升服务器的安全性。 目录…...
数据采集之scrapy框架
本博文使用基本框架完成搜房网或者其他网站的数据爬取(重点理解 scrapy 框架的构建过程,使用回调函数,完成数据采集和数据处理) 包结构目录如下图所示: 主要代码: (sfw.py) # -*- …...
ReactPress—基于React的免费开源博客CMS内容管理系统
ReactPress Github项目地址:https://github.com/fecommunity/reactpress 欢迎提出宝贵的建议,感谢Star。  2.常见面试问题: sync出…...
基于大模型的 UI 自动化系统
基于大模型的 UI 自动化系统 下面是一个完整的 Python 系统,利用大模型实现智能 UI 自动化,结合计算机视觉和自然语言处理技术,实现"看屏操作"的能力。 系统架构设计 #mermaid-svg-2gn2GRvh5WCP2ktF {font-family:"trebuchet ms",verdana,arial,sans-…...
解决Ubuntu22.04 VMware失败的问题 ubuntu入门之二十八
现象1 打开VMware失败 Ubuntu升级之后打开VMware上报需要安装vmmon和vmnet,点击确认后如下提示 最终上报fail 解决方法 内核升级导致,需要在新内核下重新下载编译安装 查看版本 $ vmware -v VMware Workstation 17.5.1 build-23298084$ lsb_release…...
关于iview组件中使用 table , 绑定序号分页后序号从1开始的解决方案
问题描述:iview使用table 中type: "index",分页之后 ,索引还是从1开始,试过绑定后台返回数据的id, 这种方法可行,就是后台返回数据的每个页面id都不完全是按照从1开始的升序,因此百度了下,找到了…...
JVM垃圾回收机制全解析
Java虚拟机(JVM)中的垃圾收集器(Garbage Collector,简称GC)是用于自动管理内存的机制。它负责识别和清除不再被程序使用的对象,从而释放内存空间,避免内存泄漏和内存溢出等问题。垃圾收集器在Ja…...
2.Vue编写一个app
1.src中重要的组成 1.1main.ts // 引入createApp用于创建应用 import { createApp } from "vue"; // 引用App根组件 import App from ./App.vue;createApp(App).mount(#app)1.2 App.vue 其中要写三种标签 <template> <!--html--> </template>…...
Keil 中设置 STM32 Flash 和 RAM 地址详解
文章目录 Keil 中设置 STM32 Flash 和 RAM 地址详解一、Flash 和 RAM 配置界面(Target 选项卡)1. IROM1(用于配置 Flash)2. IRAM1(用于配置 RAM)二、链接器设置界面(Linker 选项卡)1. 勾选“Use Memory Layout from Target Dialog”2. 查看链接器参数(如果没有勾选上面…...
零基础设计模式——行为型模式 - 责任链模式
第四部分:行为型模式 - 责任链模式 (Chain of Responsibility Pattern) 欢迎来到行为型模式的学习!行为型模式关注对象之间的职责分配、算法封装和对象间的交互。我们将学习的第一个行为型模式是责任链模式。 核心思想:使多个对象都有机会处…...
关于 WASM:1. WASM 基础原理
一、WASM 简介 1.1 WebAssembly 是什么? WebAssembly(WASM) 是一种能在现代浏览器中高效运行的二进制指令格式,它不是传统的编程语言,而是一种 低级字节码格式,可由高级语言(如 C、C、Rust&am…...
高防服务器能够抵御哪些网络攻击呢?
高防服务器作为一种有着高度防御能力的服务器,可以帮助网站应对分布式拒绝服务攻击,有效识别和清理一些恶意的网络流量,为用户提供安全且稳定的网络环境,那么,高防服务器一般都可以抵御哪些网络攻击呢?下面…...
