Rust编程实战：Rust实现简单的Web服务，单线程性能问题
知识点
- tcp 服务
- 多线程处理
实现功能
启动web服务，访问链接获取页面内容。
单线程web服务
TcpListener
使用 TcpListener 开启服务端口
let listener = TcpListener::bind("127.0.0.1:7878").unwrap();
处理客户端连接：
for stream in listener.incoming() {println!("Connection established!");}
当浏览器访问 http://127.0.0.1:7878/ 就打印 “Connection established!”, 表示服务启动成功。
处理接口请求
设计2个接口：
- 访问 http://127.0.0.1:7878 时，显示index.html 的内容
- 访问 http://127.0.0.1:7878/sleep 时，做一个延迟，模拟单线程服务的问题
准备html文件
- index.html
<!DOCTYPE html>
<html lang="en"><head><meta charset="utf-8"><title>Hello!</title></head><body><h1>Hello!</h1><p>Hi from Rust</p></body>
</html>
- 404.html
<!DOCTYPE html>
<html lang="en"><head><meta charset="utf-8"><title>你好!</title></head><body><h1>很抱歉!</h1><p>由于运维删库跑路，我们的数据全部丢失，总监也已经准备跑路，88</p></body>
</html>
实现
- 实现请求路由判断
- 读取 html 文件内容，并且返回
请求路由判断
通过 BufReader 获取请求数据
// 解析buffer. 获取请求的数据let buf_reader = BufReader::new(&mut stream);// 读取请求行let http_request: Vec<_> = buf_reader.lines().map(|result| result.unwrap()).take_while(|line| !line.is_empty()).collect();http_requset 得到数据如下：
["GET / HTTP/1.1","Host: 127.0.0.1:7878","Connection: keep-alive",...]
由此数据可得，只需要判断数组第一个数据就知道请求到哪个路由了。
let request_line = if http_request.len( ) > 0 { &http_request[0] } else {""};let (status_line, filename) = match &request_line[..] {"GET / HTTP/1.1" => ("HTTP/1.1 200 OK", "index.html"),"GET /sleep HTTP/1.1" => {std::thread::sleep(Duration::from_secs(5)); // 添加 5 s 延迟("HTTP/1.1 200 OK", "index.html")}_ => ("HTTP/1.1 404 NOT FOUND", "404.html"),};
处理html文件
通过 文件 处理模块 fs 获取文件的内容。
let contens = fs::read_to_string(filename).unwrap();
设置返回数据
获取文件的内容之后，把数据返回给客户端, 通过 write_all 方法。
let content_length = contens.len();// 组合返回数据let response = format!("{}\r\nContent-Length: {}\r\n\r\n{}",status_line,content_length,contens);stream.write_all(response.as_bytes()).unwrap();
效果
当客户端访问 http://127.0.0.1:7878 就会看到 index.html 的内容。如果客户端先访问 http://127.0.0.1:7878/sleep 新起标签页面访问 http://127.0.0.1:7878，如下图。你会发现 http://127.0.0.1:7878 的请求并没有立即显示，而是等待 sleep 请求结束才会显示。相当于接口会存在排队的处理，这对于web服务是个不好的体验。因此需要多线程去处理这些问题。
处理多线程请求
将每个请求都用 thread 去处理
thread::spawn(|| {handle_connection(stream);});
效果如下，并没有发生排队的问题。这只是简单处理，实际上现在成熟的框架处理单线程的问题。
源码
相关文章：
Rust编程实战：Rust实现简单的Web服务，单线程性能问题
知识点 tcp 服务多线程处理 实现功能 启动web服务，访问链接获取页面内容。 单线程web服务 TcpListener 使用 TcpListener 开启服务端口 let listener TcpListener::bind("127.0.0.1:7878").unwrap();处理客户端连接： for stream in lis…...
GitLab 密钥详解：如何安全地使用 SSH 密钥进行身份验证
目录 一、什么是 GitLab SSH 密钥？二、为什么要使用 SSH 密钥？三、如何生成 SSH 密钥？1. Linux/macOS2. Windows 四、将公钥添加到 GitLab五、配置 SSH 客户端六、常见问题及解决方案七、总结 GitLab 是一个功能强大的 Git 仓库管理平台&…...
《论数据分片技术及其应用》审题技巧 - 系统架构设计师
论数据分片技术及其应用写作框架 一、考点概述 本论题“论数据分片技术及其应用”主要考察的是软件工程中数据分片技术的理解、应用及其实际效果分析。考点涵盖以下几个方面： 首先，考生需对数据分片的基本概念有清晰的认识，理解数据分片是…...
是多少？)
【C++】当一个类A中没有声明任何成员变量和成员函数，sizeof(A)是多少？
在 C 中，即使一个类没有任何数据成员（即空类），它的大小也不会是 0，而是 1。这主要有以下几个原因： 地址唯一性要求 C 标准规定，每个对象都必须有唯一的地址。如果空类的大小为 0，那么…...
Maven 私服的搭建与使用（一）
一、引言 在 Java 项目开发中，Maven 作为强大的项目管理和构建工具，极大地提高了开发效率，而 Maven 私服在开发过程中也扮演着至关重要的角色。私服是一种特殊的远程仓库，架设在局域网内，代理广域网上的远程仓库&…...
Ubuntu20.04双系统安装及软件安装（五）：VSCode
Ubuntu20.04双系统安装及软件安装（五）：VSCode 打开VScode官网，点击中间左侧的deb文件下载： 系统会弹出下载框，确定即可。 在文件夹的**“下载”目录**，可看到下载的安装包，在该目录下…...
linux网络（3）—— socket编程（1）socket基础认识
欢迎来到博主的专栏：linux网络 博主ID：代码小豪 文章目录 IP与端口号socket字节序问题 IP与端口号 我们现在知道了，只要发送的报文的报头包含目的IP地址和源IP地址，就能通过通信设备，是两台主机进行远程通信ÿ…...
【Kubernets】K8S内部nginx访问Service资源原理说明
文章目录 原理概述**一、核心概念****二、Nginx 访问 Service 的流程****1. Service 的作用****2. Endpoint 的作用****3. Nginx Pod 发起请求****(1) DNS 解析****(2) 流量到达 kube-proxy****(3) 后端 Pod 处理请求** **三、不同代理模式的工作原理****1. iptables 模式****2…...
使用Docker搭建Oracle Database 23ai Free并扩展MAX_STRING_SIZE的完整指南
使用Docker搭建Oracle Database 23ai Free并扩展MAX_STRING_SIZE的完整指南 前言环境准备目录创建启动Docker容器 数据库配置修改进入容器启动SQL*PlusPDB操作与字符串扩展设置配置验证 管理员用户创建注意事项总结 前言 本文将详细讲解在Docker环境中配置Oracle Database 23a…...
使用pytorch和opencv根据颜色相似性提取图像
需求：将下图中的花朵提取出来。 代码： import cv2 import torch import numpy as np import timedef get_similar_colors(image, color_list, threshold):# 将图像和颜色列表转换为torch张量device torch.device(cuda if torch.cuda.is_available() el…...
MySQL 8.X 报错处理
1.重新加载配置 reload the configuration mysql> ALTER INSTANCE RELOAD KEYRING; ERROR 1227 (42000): Access denied; you need (at least one of) the ENCRYPTION_KEY_ADMIN privilege(s) for this operation 提示需要ENCRYPTION_KEY_ADMIN权限 重新授权 GRANT ENCR…...
Ubuntu 22.04安装OpenJDK 17
步骤一：更新软件包 sudo apt update步骤二：安装openjdk-17 sudo apt install openjdk-17-jdk当系统要求输入密码时，请输入密码。然后键入 Y 并按 Enter 继续安装 步骤三：查看安装版本 java -version步骤四：查看安装…...
【时序预测】时间序列有哪些鲁棒的归一化方法
时间序列数据在金融、气象、医疗等领域中广泛存在，而股票数据作为典型的时间序列之一，具有非平稳性、噪声多、波动大等特点。为了更好地进行数据分析和建模，归一化是一个重要的预处理步骤。然而，由于时间序列数据的特殊性…...
nlp第九节——文本生成任务
一、seq2seq任务 特点：输入输出均为不定长的序列 自回归语言模型： 由前面一个字预测下一个字的任务 encoder-decoder结构： Encoder-Decoder结构是一种基于神经网络完成seq2seq任务的常用方案 Encoder将输入转化为向量或矩阵，其…...
STM32MP1xx的启动流程
https://wiki.st.com/stm32mpu/wiki/Boot_chain_overview 根据提供的知识库内容，以下是STM32 MPU启动链的详细解析： 1. 通用启动流程 STM32 MPU启动分为多阶段，逐步初始化外设和内存，并建立信任链： 1.1 ROM代码&…...
wgcloud-server端部署说明
Wgcloud 是一款开源的轻量级服务器监控系统，支持多平台，可对服务器的 CPU、内存、磁盘、网络等指标进行实时监控。 以下是 Wgcloud Server端的详细部署步骤： 环境准备 服务器： 至少准备两台服务器，一台作为监控端&a…...
大模型Agent：人工智能的崭新形态与未来愿景
在人工智能技术高歌猛进的当下，大模型 Agent 作为 AI 领域的关键研究方向，正日益彰显出其独有的魅力以及广阔无垠的应用前景。大模型 Agent 不但具备对环境的感知、自主的理解、决策的制定以及行动的执行能力，而且能够游刃有余地应对繁杂任务…...
专题二最大连续1的个数|||
1.题目 题目分析： 给一个数字k，可以把数组里的0改成1，但是只能改k次，然后该变得到的数组能找到最长的子串且都是1。 2.算法原理 这里不用真的把0变成1，因为改了比较麻烦，下次用就要改回成1，这…...
【ORACLE】ORACLE19C在19.13版本前的一个严重BUG-24761824
背景 最近在某客户的ORACLE开发环境(oracle 19.10)中，发现一个非常奇怪情况, 开发人员反馈，有一条SQL，查询了两个sum函数作为两个字段， select sum(c1),sum(c2) from ...当两个sum一起出现时，第一个sum的结果不对&am…...
2025国家护网HVV高频面试题总结来了03（题目+回答）
网络安全领域各种资源，学习文档，以及工具分享、前沿信息分享、POC、EXP分享。不定期分享各种好玩的项目及好用的工具，欢迎关注。 目录 0x1 高频面试题第一套 0x2 高频面试题第二套 0x3 高频面试题第三套 0x4高频面试题第四套 0x1 高频面试题…...
【Axure高保真原型】引导弹窗
今天和大家中分享引导弹窗的原型模板，载入页面后，会显示引导弹窗，适用于引导用户使用页面，点击完成后，会显示下一个引导弹窗，直至最后一个引导弹窗完成后进入首页。具体效果可以点击下方视频观看或打开下方…...
测试微信模版消息推送
进入“开发接口管理”--“公众平台测试账号”，无需申请公众账号、可在测试账号中体验并测试微信公众平台所有高级接口。 获取access_token: 自定义模版消息： 关注测试号：扫二维码关注测试号。 发送模版消息： import requests da…...
在软件开发中正确使用MySQL日期时间类型的深度解析
在日常软件开发场景中，时间信息的存储是底层且核心的需求。从金融交易的精确记账时间、用户操作的行为日志，到供应链系统的物流节点时间戳，时间数据的准确性直接决定业务逻辑的可靠性。MySQL作为主流关系型数据库，其日期时间类型的…...
Java多线程实现之Callable接口深度解析
Java多线程实现之Callable接口深度解析 一、Callable接口概述1.1 接口定义1.2 与Runnable接口的对比1.3 Future接口与FutureTask类 二、Callable接口的基本使用方法2.1 传统方式实现Callable接口2.2 使用Lambda表达式简化Callable实现2.3 使用FutureTask类执行Callable任务 三、…...
ESP32 I2S音频总线学习笔记（四）： INMP441采集音频并实时播放
简介 前面两期文章我们介绍了I2S的读取和写入，一个是通过INMP441麦克风模块采集音频，一个是通过PCM5102A模块播放音频，那如果我们将两者结合起来，将麦克风采集到的音频通过PCM5102A播放，是不是就可以做一个扩音器了呢…...
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. 查看链接器参数（如果没有勾选上面…...
Java入门学习详细版（一）
大家好，Java 学习是一个系统学习的过程，核心原则就是“理论 实践 坚持”，并且需循序渐进，不可过于着急，本篇文章推出的这份详细入门学习资料将带大家从零基础开始，逐步掌握 Java 的核心概念和编程技能。 …...
【C++从零实现Json-Rpc框架】第六弹 —— 服务端模块划分
一、项目背景回顾 前五弹完成了Json-Rpc协议解析、请求处理、客户端调用等基础模块搭建。 本弹重点聚焦于服务端的模块划分与架构设计，提升代码结构的可维护性与扩展性。 二、服务端模块设计目标 高内聚低耦合：各模块职责清晰，便于独立开发…...
ios苹果系统，js 滑动屏幕、锚定无效
现象：window.addEventListener监听touch无效，划不动屏幕，但是代码逻辑都有执行到。 scrollIntoView也无效。 原因：这是因为 iOS 的触摸事件处理机制和 touch-action: none 的设置有关。ios有太多得交互动作，从而会影响…...
视觉slam十四讲实践部分记录——ch2、ch3
ch2 一、使用g++编译.cpp为可执行文件并运行(P30) g++ helloSLAM.cpp ./a.out运行 二、使用cmake编译 mkdir build cd build cmake .. makeCMakeCache.txt 文件仍然指向旧的目录。这表明在源代码目录中可能还存在旧的 CMakeCache.txt 文件，或者在构建过程中仍然引用了旧的路…...