30天拿下Rust之实战Web Server

news2024/11/29 10:40:37

概述

        随着互联网技术的飞速发展,Web服务器作为承载网站与应用的核心组件,其性能、稳定性和安全性都显得至关重要。Rust语言凭借其独特的内存安全保证、高效的性能以及丰富的生态系统,成为了构建现代Web服务器的理想选择。

新建项目

        首先,使用下面的命令创建一个新的Cargo项目web_server。

cargo new web_server

        然后,修改Cargo.toml文件,添加必要的依赖项actix-web。actix-web是一个用Rust语言编写的高性能、高度可扩展的Web框架,专为构建安全、快速且资源效率高的Web应用程序而设计。作为Rust生态系统中较早出现且持续发展的项目,Actix-web享有良好的生态环境与活跃的社区支持,使其成为众多Rust Web开发者首选的框架之一。

[dependencies]
actix-web = { version = "4.5.0"}

基础Web服务器

        接下来,我们创建一个最基础的Web服务器,它能够响应HTTP请求并返回简单的字符串响应。

        在下面的示例代码中,我们首先导入了actix_web中的App和HttpServer,它们分别用于构建应用程序和启动HTTP服务器。我们还导入了HttpResponse,用于构建HTTP响应。

        然后,我们定义一个处理HTTP请求的函数index(),这个函数简单地返回一个包含“Hello Rust”文本的HTTP 200 OK响应。

        接下来,在main函数中,我们使用HttpServer::new来创建一个新的HTTP服务器。我们传递一个闭包给new方法,该闭包返回一个App实例。在App实例上,我们使用route方法来定义路由。这里我们定义了一个根路由/,并使用actix_web::web::get()来指定这是一个GET请求。然后,我们将index函数与这个路由关联起来。

        最后,我们使用bind()方法来指定服务器要监听的地址和端口(这里是127.0.0.1:8080),并调用run方法来启动服务器。

use actix_web::HttpResponse;
use actix_web::{App, HttpServer};

async fn index() -> HttpResponse {
    HttpResponse::Ok().body("Hello Rust")
}

#[actix_web::main]
async fn main() -> std::io::Result<()> {
    HttpServer::new(|| App::new().route("/", actix_web::web::get().to(index)))
        .bind("127.0.0.1:8080")?
        .run()
        .await
}

        在命令行中运行cargo run来启动程序,此时服务器开始监听localhost:8080。现在,我们可以使用任何Web浏览器来测试服务器。在浏览器中打开http://localhost:8080或者http://127.0.0.1:8080,我们应该能看到服务器返回的“Hello Rust”响应。

处理路由

        为了构建更复杂的Web应用,我们需要引入路由机制。

        在下面的示例代码中,我们添加了一个新的路由/new_route,它映射到一个新的处理函数new_route_handler。这个处理函数简单地返回一个包含文本"New route handler"的HTTP 200 OK响应。现在,服务器将能够响应两个路由:根路径/和新的路径/new_route。

use actix_web::HttpResponse;
use actix_web::{App, HttpServer};

async fn index() -> HttpResponse {
    HttpResponse::Ok().body("Hello Rust")
}

async fn new_route_handler() -> HttpResponse {
    HttpResponse::Ok().body("New route handler")
}

#[actix_web::main]
async fn main() -> std::io::Result<()> {
    HttpServer::new(|| App::new().
        route("/", actix_web::web::get().to(index))
        .route("/new_route", actix_web::web::get().to(new_route_handler)))
        .bind("127.0.0.1:8080")?
        .run()
        .await
}

处理JSON请求

        对于API服务,经常需要处理JSON格式的请求与响应。修改Cargo.toml文件,引入serde和serde_json来简化工作。

[dependencies]
actix-web = { version = "4.5.0"}
serde = { version = "1", features = ["derive"] }
serde_json = "1"

        在下面的示例代码中,我们首先导入了serde库中的Deserialize和Serialize特质,它们用于定义结构体可以被自动序列化和反序列化为JSON格式。

        然后,定义了一个名为FormData的结构体,它有一个字段field_name,类型为String。通过derive属性,该结构体获得了从JSON字符串自动反序列化(Deserialize)的能力,以及将自身序列化为JSON字符串(Serialize)的能力,Debug特征使得结构体可以方便地输出调试信息。我们还定义了一个名为JsonResponse的结构体,它有一个字段message,类型也为String。这里只应用了Serialize特质,因为这个结构体是用来构造返回给客户端的JSON响应报文的,不需要反序列化能力。

        最后,我们定义了处理POST请求的异步函数handle_post,它接受一个类型为web::Json<FormData>的参数。web::Json是一个wrapper类型,表示请求体应该被解析为FormData结构体。函数内部首先打印接收到的POST数据,然后创建一个JsonResponse实例,其中message字段内容为"Hello from Rust Server"。函数的最后,返回一个201 Created状态码的响应,主体内容为序列化后的JsonResponse实例。

use actix_web::{web, App, HttpResponse, HttpServer, Result};
use serde::{Deserialize, Serialize};

#[derive(Deserialize, Serialize, Debug)]
struct FormData {
    field_name: String,
}

#[derive(Serialize)]
struct JsonResponse {
    message: String,
}

async fn index() -> HttpResponse {
    HttpResponse::Ok().body("Hello Rust")
}

async fn new_route_handler() -> HttpResponse {
    HttpResponse::Ok().body("New route handler")
}

async fn handle_post(form_data: web::Json<FormData>) -> Result<HttpResponse> {
    println!("Received POST data: {:?}", form_data.into_inner());
    let response_data = JsonResponse {
        message: format!("Hello from {}", "Rust Server".to_string()),
    };
    Ok(HttpResponse::Created().json(response_data))
}

#[actix_web::main]
async fn main() -> std::io::Result<()> {
    HttpServer::new(|| {
        App::new()
            .route("/", web::get().to(index))
            .route("/new_route", web::get().to(new_route_handler))
            .route("/post_data", web::post().to(handle_post))
    })
    .bind("127.0.0.1:8080")?
    .run()
    .await
}

        在命令行中运行cargo run来启动程序,此时服务器开始监听localhost:8080。我们可以使用Postman来模拟浏览器发送POST请求的行为,方法选择POST,路径为localhost:8080/post_data,Body选择raw/JSON,输入:{"field_name": "Hello from client"}。点击Send按钮,我们会收到Rust Web Server返回的POST响应,Body为:{"message": "Hello from Rust Server"}。

处理动态路由参数

        要实现动态路由参数,我们可以使用actix-web提供的路径参数功能。路径参数允许我们在URL路径中定义占位符,这些占位符在请求到来时会被解析为具体的值。

        在下面的示例代码中,我们新增了一个异步函数handle_dynamic_route,它接受一个类型为web::Path<String>的参数。web::Path<T>是actix-web提供的一个类型,用于捕获路径参数。这里我们使用String类型来捕获动态路由中的ID。接着,在应用程序配置中,我们添加了一个新的路由。这里的/{id}路径模板中,{id}是一个占位符,表示任何非斜杠字符组成的字符串。当一个请求到达,其URL路径匹配/{id}模板时,actix-web会将路径中对应的值作为web::Path<String>传递给handle_dynamic_route函数。

use actix_web::{web, App, HttpResponse, HttpServer, Result};
use serde::{Deserialize, Serialize};

#[derive(Deserialize, Serialize, Debug)]
struct FormData {
    field_name: String,
}

#[derive(Serialize)]
struct JsonResponse {
    message: String,
}

async fn index() -> HttpResponse {
    HttpResponse::Ok().body("Hello Rust")
}

async fn new_route_handler() -> HttpResponse {
    HttpResponse::Ok().body("New route handler")
}

async fn handle_post(form_data: web::Json<FormData>) -> Result<HttpResponse> {
    println!("Received POST data: {:?}", form_data.into_inner());
    let response_data = JsonResponse {
        message: format!("Hello from {}", "Rust Server".to_string()),
    };
    Ok(HttpResponse::Created().json(response_data))
}

async fn handle_dynamic_route(id: web::Path<String>) -> HttpResponse {
    HttpResponse::Ok().body(format!(
        "Process dynamic route with ID: {}",
        id.into_inner()
    ))
}

#[actix_web::main]
async fn main() -> std::io::Result<()> {
    HttpServer::new(|| {
        App::new()
            .route("/", web::get().to(index))
            .route("/new_route", web::get().to(new_route_handler))
            .route("/post_data", web::post().to(handle_post))
            .route("/{id}", web::get().to(handle_dynamic_route))
    })
    .bind("127.0.0.1:8080")?
    .run()
    .await
}

        我们仍使用Postman来模拟浏览器的动态路由参数,方法选择GET,路径为localhost:8080/666,Body选择none。点击Send按钮,我们会收到Rust Web Server返回的GET响应,Body为:Process dynamic route with ID: 666。

总结

        在本文中,我们不仅搭建了一个基础的Web服务器,还实现了路由、JSON请求、动态路由参数等功能。Rust凭借其严谨的安全模型、出色的性能和丰富的生态系统,为构建高效、安全的Web服务器提供了坚实的基础。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1576577.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

工业视觉检测

目录 我对工业视觉检测的了解 一、关键组成部分 二、应用场景 三、技术挑战 我对工业视觉检测的了解 工业视觉检测是利用机器视觉技术对产品质量进行自动化检查的过程&#xff0c;它在制造业中扮演着至关重要的角色&#xff0c;用于确保产品质量、提高生产效率、减少人工成…

数仓开发之Flume《一》:Flume的概述及安装

目录 1. &#x1f959;Flume概述 1.1 Flume简介 1.2 Flume的架构 1. &#x1f9c0;agent介绍 2. ​Agent 主要有 3 个部分组成&#xff0c;Source、Channel、Sink。 &#x1f957;2.1 Source &#x1f957;2.2 Sink &#x1f957;2.3 Channel 3. &#x1f9c0;Flume 自…

2.k8s架构

目录 k8s集群架构 控制平面 kube-apiserver kube-scheduler etcd kube-controller-manager node 组件 kubelet kube-proxy 容器运行时&#xff08;Container Runtime&#xff09; cloud-controller-manager 相关概念 k8s集群架构 一个Kubernetes集群至少包含一个控制…

蓝桥杯刷题day14——盖印章【算法赛】

一、问题描述 小 Z 喜欢盖印章。 有一天,小 Z 得到了一个 nm 的网格图,与此同时,他的手上有两种印章(分别称为 A,B),如下图所示。 他想将这两种印章盖在这个网格图上。 由于小 Z 是一个有原则的人,他将按照以下规则进行操作。 每个印章所形成的图案的边必须和网格图…

三防平板定制服务:亿道信息与个性化生产的紧密结合

在当今数字化时代&#xff0c;个性化定制已经成为了市场的一大趋势&#xff0c;而三防平板定制服务作为其中的一部分&#xff0c;展现了数字化技术与个性化需求之间的紧密结合。这种服务是通过亿道信息所提供的技术支持&#xff0c;为用户提供了满足特定需求的定制化三防平板&a…

面向电力行业定制安全云工作站解决方案,麒麟信安出席2024年电力企业信创替代技术研讨会

日前&#xff0c;由中国电子企业协会主办的“2024年电力企业信创替代技术研讨会”在江苏南京正式召开。会议以国家推进实现自主可控、加快建设“数字中国”为大背景&#xff0c;聚焦电力企业紧抓“信创替代”机遇&#xff0c;通过安全可靠的软硬件迭代升级&#xff0c;实现企业…

2024/4/2—力扣—连续数列

代码实现&#xff1a; 思路&#xff1a;最大子数组和 解法一&#xff1a;动态规划 #define max(a, b) ((a) > (b) ? (a) : (b))int maxSubArray(int* nums, int numsSize) {if (numsSize 0) { // 特殊情况return 0;}int dp[numsSize];dp[0] nums[0];int result dp[0];fo…

day03 51单片机

51单片机学习 1 模块化编程 1.1 什么是模块化编程 随着我们的代码越来越复杂,我们的main.c越来越长,阅读性也越来越差。如果将来开始做项目,我们可能要同时操作好几个模块,这种情况下我们无法再把代码写到同一个文件,而是要分模块管理代码。 具体实现方法,就是将源码…

【go】模板展示不同k8s命名空间的deployment

gin模板展示k8s命名空间的资源 这里学习如何在前端单页面&#xff0c;调用后端接口展示k8s的资源 技术栈 后端 -> go -> gin -> gin模板前端 -> gin模板 -> html jsk8s -> k8s-go-client &#xff0c;基本资源(deployment等) 环境 go 1.19k8s 1.23go m…

单点登录系统设计

一、介绍 token鉴权最佳的实践场景就是在单点登录系统上。 在企业发展初期&#xff0c;使用的后台管理系统还比较少&#xff0c;一个或者两个。 以电商系统为例&#xff0c;在起步阶段&#xff0c;可能只有一个商城下单系统和一个后端管理产品和库存的系统。 随着业务量越来…

腾讯云流量怎么计算的?轻量服务器流量价格表

腾讯云轻量应用服务器套餐带流量包&#xff0c;就是有月流量限制的意思&#xff0c;超出轻量套餐的流量需要另外支付流量费&#xff0c;轻量服务器地域不同超额流量费用也不同&#xff0c;北京上海广州等中国内地地域流量价格是0.8元每GB&#xff0c;中国香港地域流量价格是1元…

单片机IGBT驱动电路一例

概述&#xff1a; 驱动的作用有三个&#xff1a; 1.是作为放大器获得所需要的驱动电压。 2.是提高输出电流能力。 3.是进行功率回路和控制回路的隔离 信号从MCU到IGBT驱动芯片 首先驱动电流需要放大 MCU的输出电流是mA级别&#xff0c;而IGBT需要的驱动电流可能达到几安培…

解锁ETLCloud中Kettle的用法

随着大数据时代的到来&#xff0c;数据的处理和管理成为各行各业不可或缺的一环。ETL&#xff08;Extract-Transform-Load&#xff09;工具作为数据处理的重要环节&#xff0c;扮演着将数据从源端抽取出来、经过转换处理&#xff0c;最终加载至目标端的关键角色。在众多ETL工具…

香港科技大学(广州)智能制造学域可持续能源与环境学域博士招生宣讲会——重庆大学专场(暨全额奖学金政策)

两个学域代表教授亲临现场&#xff0c;面对面答疑解惑助攻申请&#xff01;可带简历现场咨询和面试&#xff01; &#x1f4b0;一经录取&#xff0c;享全额奖学金1.5万/月&#xff01; 报名链接&#xff1a;https://www.wjx.top/vm/wmuN2ea.aspx# 地点&#xff1a;重庆大学A区…

docker一键部署GPU版ChatGLM3

一键运行 docker run --gpus all -itd --name chatglm3 -p 81:80 -p 6006:6006 -p 8888:8888 -p 7860:7860 -p 8501:8501 -p 8000:8000 --shm-size32gb registry.cn-hangzhou.aliyuncs.com/cwp-docker/chatglm3-gpu:1.0 进入容器 docker exec -it chatglm3 /bin/bash cd /…

MacOS Docker 部署 Redis 数据库

一、简介 Redis是一个开源的、使用C语言编写的、基于内存亦可持久化的Key-Value数据库&#xff0c;它提供了多种语言的API&#xff0c;并支持网络交互。Redis的数据存储在内存中&#xff0c;因此其读写速度非常快&#xff0c;每秒可以处理超过10万次读写操作&#xff0c;是已知…

Vue项目打包成exe文件(electron)

1.将写好的vue项目打包 1.1运行vue ui命令 输出目标文件 如果打开index.html是空白的&#xff0c;而且控制台报错获取xxx资源失败的问题&#xff0c;你需要在vue.config.js 上加一个命令&#xff0c;如果没有你需要创建一个。 2.下载electron官方示例 git clone https://gith…

Go 项目依赖注入wire工具最佳实践介绍与使用

文章目录 一、引入二、控制反转与依赖注入三、为什么需要依赖注入工具3.1 示例3.2 依赖注入写法与非依赖注入写法 四、wire 工具介绍与安装4.1 wire 基本介绍4.2 安装 五、Wire 的基本使用5.1 前置代码准备5.2 使用 Wire 工具生成代码 六、Wire 核心技术5.1 抽象语法树分析5.2 …

idea开发 java web 疫情信息查询系统bootstrap框架web结构java编程计算机网页接口查询

一、源码特点 java 疫情信息查询系统是一套完善的完整信息系统&#xff0c;结合java web开发和bootstrap UI框架完成本系统 &#xff0c;对理解JSP java编程开发语言有帮助&#xff0c;系统具有完整的源代码和数据库&#xff0c;系统主要采用B/S模式开发。 前段主要技术 css j…

复习知识点整理

零碎语法 1.导入某个文件夹的index文件&#xff0c;index可以省略&#xff08;这里导入的是router和store文件下的index.js文件&#xff09; 2.路由懒加载 this 1.在vue文件中使用router\store对象时 this&#xff1a;普通函数的this指向vue实例对象(在没有明确指向的时候…