Rust 实战练习 - 12. Axum Web 简单demo

Rust Web 历程

Rust 的异步框架tokio非他莫属,而web框架一直是悬而未决,说到底还是因为没有官方成熟的方案指引,大家各玩各的,互不兼容,白白浪费精力。

这个事情一直等到半官方组织tokio推出axum有了改善。但是市场上仍然乱七八糟,具体细节可以参考:https://zhuanlan.zhihu.com/p/398232138

现在相对靠谱的发展方向参考如下图:
在这里插入图片描述

但是 tower和tower-http这2个项目比较奇葩,sample和docment严重缺少,所以建议做如下研究:

  • tokio
  • axum
  • tonic
  • sqlx

axum 简单demo

这个框架也不是特别成熟,在multipart有大坑!
注意仔细参考我的代码!

use axum::{extract::{DefaultBodyLimit, Form, Multipart, Path, Query}, http::{Method, StatusCode}, response::{Html, IntoResponse}, routing::{get, post}, Json, Router};
use serde::{Deserialize, Serialize};#[tokio::main]
async fn main() {let routes = Router::new().route("/", get(page_index)).route("/hello", get(|| async {println!("{:<12} - hello", "HANDLER");Html("hello world!")})).route("/user", post(page_user)).route("/user2", get(page_user2)).route("/user3/:username", get(page_user3)).route("/form", get(form_get).post(form_post))// 复杂的提取,需要参考 https://docs.rs/axum/latest/axum/extract/index.html.route("/form2", get(form_get_file).post(form_post_file).layer(DefaultBodyLimit::disable()));let listener = tokio::net::TcpListener::bind("0.0.0.0:8080").await.unwrap();println!("Server listen on: {:?}", listener.local_addr());axum::serve(listener, routes).await.unwrap();}#[derive(Deserialize, Debug)]
struct ReqUser {username: String,
}#[derive(Serialize, Debug,Deserialize)]
struct RespUser {id: u64,username: String,
}async fn page_index() -> &'static str{"welcome to axum based on tokio!"
}// e.g.: Post /user  Body: {"username": "xxxx"}
async fn page_user(Json(req): Json<ReqUser>,
) -> (StatusCode, Json<RespUser>) {println!("{:<12} - page_user - {req:?}", "HANDLER");let user = RespUser {id: 1337,username: req.username,};(StatusCode::OK, Json(user))
}// e.g.: GET /user2?username=abc
async fn page_user2(Query(req) : Query<ReqUser>
) -> impl IntoResponse {println!("{:<12} - page_user2 - {req:?}", "HANDLER");let user = RespUser {id: 1338,username: req.username,};Html(format!("{user:?}"))
}// e.g.: GET /user3/username
async fn page_user3(Path(req_name) : Path<String>
) -> impl IntoResponse {println!("{:<12} - page_user3 - {req_name:?}", "HANDLER");let user = RespUser {id: 1339,username: req_name,};Html(format!("{user:?}"))
}async fn form_get() -> Html<&'static str> {Html(r#"<!doctype html><html><head>form test</head><body><h2> normal form </h2><form action="/form" method="post"><label for="username">Enter your name:<input type="text" name="username"></label><br><label>Enter your id:<input type="text" name="id"></label><br><input type="submit" value="Ok"></form></body></html>"#,)
}
async fn form_get_file() -> Html<&'static str> {Html(r#"<!doctype html><html><head>form test</head><body><h2> normal form </h2><form action="/form2" method="post" enctype="multipart/form-data"><label>Enter your id:<input type="text" name="id"></label><br><label>Upload file:<input type="file" name="myfile" multiple></label><br><input type="submit" value="Upload files"></form></body></html>"#,)
}// 支持多个提取器
async fn form_post(_method: Method,Form(user): Form<RespUser>
) -> String {//dbg!(&user);format!("{user:?}")
}// body 部分只支持一种,不冲突的支持多种
// Form与Multipart冲突,保留multipart
async fn form_post_file(_method: Method,mut multipart: Multipart,
) -> String {while let Some(field) = multipart.next_field().await.unwrap() {let name = field.name().unwrap().to_string();if name == "myfile" {let file_name = field.file_name().unwrap().to_string();let content_type = field.content_type().unwrap().to_string();let data = field.bytes().await.unwrap();println!("form upload [{name}] = {file_name}, data len: {}, type: {content_type}",data.len());}else{let val = field.text().await.unwrap();println!("form field [{name}] = {val}");}}format!("{_method:?}")
}

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

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Python赋值运算符

目录 赋值运算符 将值赋给变量&#xff1a; 做加法运算之后完成赋值&#xff1a; 做减法运算之后完成赋值&#xff1a;- 做乘法运算之后完成赋值&#xff1a;* 做除法运算之后完成赋值&#xff1a;/ 做整除运算之后完成赋值&#xff1a;// 做幂次运算之后完成赋值&#xff1a;*…

西湖大学赵世钰老师【强化学习的数学原理】学习笔记2节

强化学习的数学原理是由西湖大学赵世钰老师带来的关于RL理论方面的详细课程&#xff0c;本课程深入浅出地介绍了RL的基础原理&#xff0c;前置技能只需要基础的编程能力、概率论以及一部分的高等数学&#xff0c;你听完之后会在大脑里面清晰的勾勒出RL公式推导链条中的每一个部…

基于FastGPT搭建知识库问答系统

什么是 FastGPT &#xff1f; FastGPT 是一个基于 LLM 大语言模型的知识库问答系统&#xff0c;提供开箱即用的数据处理、模型调用等能力。同时可以通过 Flow 可视化进行工作流编排&#xff0c;从而实现复杂的问答场景&#xff01; FastGPT 允许用户构建本地知识库&#xff0c;…

【kettle003】kettle访问SQL Server数据库并处理数据至execl文件

一直以来想写下基于kettle的系列文章&#xff0c;作为较火的数据ETL工具&#xff0c;也是日常项目开发中常用的一款工具&#xff0c;最近刚好挤时间梳理、总结下这块儿的知识体系。 熟悉、梳理、总结下Microsoft SQL Server 2022关系数据库相关知识体系 kettle访问SQL Server数…

【C++ | 复合类型】结构体、共用体、枚举、引用

&#x1f601;博客主页&#x1f601;&#xff1a;&#x1f680;https://blog.csdn.net/wkd_007&#x1f680; &#x1f911;博客内容&#x1f911;&#xff1a;&#x1f36d;嵌入式开发、Linux、C语言、C、数据结构、音视频&#x1f36d; ⏰发布时间⏰&#xff1a; 本文未经允许…

图形化编程要怎么做

0. 简介 Scratch其实应该算得上最早做图形化编程的工程了。Scratch 是麻省理工学院的“终身幼儿园团队”在 2007 年 [5]发布的一种图形化编程工具&#xff0c;主要面对全球青少年开放&#xff0c;是图形化编程工具当中最广为人知的一种&#xff0c;所有人都可以在软件中创作自…

【python技术】使用akshare、pandas、mplfinance绘制红绿色K线图简单示例

python中的mplfinance库是基于matplotlib库开发的一个专门用于绘制股票数据的图表的第三方库&#xff0c;它提供了一系列函数和类,用于绘制各种类型的股票图表,包括K线图、成交量图和技术指标图等。 这里简单写个示例&#xff0c;我用的mac系统&#xff0c;字体采用STHeiti。…

docker部署的nacos2.2x开启鉴权功能

注意在2.2.0版本之后如果不开启鉴权&#xff0c;那么默认不需要登录就可以访问 所以我们需要手动开启鉴权&#xff0c;nacos启动好以后来到容器内部修改 docker exec -it nacos /bin/shvim conf/application.properties在第34行下面添加 nacos.core.auth.enabledtrue nacos.cor…

pytest-asyncio:协程异步测试案例

简介&#xff1a;pytest-asyncio是一个pytest插件。它便于测试使用异步库的代码。具体来说&#xff0c;pytest-asyncio提供了对作为测试函数的协同程序的支持。这允许用户在测试中等待代码。 历史攻略&#xff1a; asyncio并发访问websocket Python&#xff1a;协程 - 快速创…

数据结构——二叉树的顺序存储(堆)(C++实现)

数据结构——二叉树的顺序存储&#xff08;堆&#xff09;&#xff08;C实现&#xff09; 二叉树可以顺序存储的前提堆的定义堆的分类大根堆小根堆 整体结构把握两种调整算法向上调整算法递归版本 非递归版本向下调整算法非递归版本 向上调整算法和向下调整算法的比较 我们接着…

5、Flink事件时间之Watermark详解

1&#xff09;生成 Watermark 1.Watermark 策略简介 为了使用事件时间语义&#xff0c;Flink 应用程序需要知道事件时间戳对应的字段&#xff0c;即数据流中的每个元素都需要拥有可分配的事件时间戳。 通过使用 TimestampAssigner API 从元素中的某个字段去访问/提取时间戳。…

STM32之串口中断接收丢失数据

五六年没搞STM32了&#xff0c;这个项目一切都挺顺利&#xff0c;万万没想到被串口接收中断恶心到了。遇到的问题很奇怪 HAL_UART_Receive_IT(&huart1, &rx_buffer[rx_index], LCD_UART_LEN); 这个代码中 LCD_UART_LEN1的时候&#xff0c;接收过来的数据&#xff0c;数…

CentOS 9 (stream) 安装 nginx

1.我们直接使用安装命令 dnf install nginx 2.安装完成后启动nginx服务 # 启动 systemctl start nginx # 设置开机自启动 systemctl enable nginx# 重启 systemctl restart nginx# 查看状态 systemctl status nginx# 停止服务 systemctl stop nginx 3.查看版本确认安装成功…

Taro引入echarts【兼容多端小程序(飞书/微信/支付宝小程序)】

近期接到公司新需求&#xff0c;开发飞书小程序&#xff0c;并且原型中含有大量的图表&#xff0c;本想使用飞书内置图表组件 —— chart-space&#xff0c;但官方表示已经停止维护了&#xff0c;无奈之下&#xff0c;只能另寻他路&#xff0c;于是乎&#xff0c;图表之王&…

Apollo 7周年大会:百度智能驾驶的展望与未来

本心、输入输出、结果 文章目录 Apollo 7周年大会&#xff1a;百度智能驾驶的展望与未来前言百度集团副总裁、智能驾驶事业群组总裁王云鹏发言 直播回放大会相关内容先了解 Apollo&#xfeff;开放平台 9.0架构图 发布产品Apollo 定义自己对于智能化的认知百度集团副总裁 王云鹏…

Vue入门到关门之Vue介绍与使用

一、vue框架介绍 1、什么是Vue&#xff1f; Vue (读音 /vjuː/&#xff0c;类似于 view) 是一套用于构建用户界面的渐进式框架。与其它大型框架不同的是&#xff0c;Vue 被设计为可以自底向上逐层应用。Vue 的核心库只关注视图层&#xff0c;不仅易于上手&#xff0c;还便于与…

1、Flink DataStreamAPI 概述(上)

一、DataStream API 1、概述 1&#xff09;Flink程序剖析 1.Flink程序组成 a&#xff09;Flink程序基本组成 获取一个执行环境&#xff08;execution environment&#xff09;&#xff1b;加载/创建初始数据&#xff1b;指定数据相关的转换&#xff1b;指定计算结果的存储…

图像处理的魔法师:Pillow 库探秘

文章目录 图像处理的魔法师&#xff1a;Pillow 库探秘第一部分&#xff1a;背景介绍第二部分&#xff1a;库是什么&#xff1f;第三部分&#xff1a;如何安装这个库&#xff1f;第四部分&#xff1a;库函数使用方法第五部分&#xff1a;场景应用第六部分&#xff1a;常见Bug及解…

字符串类型漏洞之updatexml函数盲注

UPDATEXML 是 MySQL 数据库中的一个函数&#xff0c;它用于对 XML 文档数据进行修改和查询。然而&#xff0c;当它被不当地使用或与恶意输入结合时&#xff0c;它可能成为 SQL 注入攻击的一部分&#xff0c;从而暴露敏感信息或导致其他安全漏洞。 在 SQL 注入攻击中&#xff0…

Prompt Engineering,提示工程

什么是提示工程&#xff1f; 提示工程也叫【指令工程】。 Prompt发送给大模型的指令。比如[讲个笑话]、[用Python编个贪吃蛇游戏]、[给男/女朋友写情书]等看起来简单&#xff0c;但上手简单精通难 [Propmpt]是AGI时代的[编程语言][Propmpt]是AGI时代的[软件工程][提示工程]是…