Rust 同步方式访问 REST API 的完整指南

Rust 同步方式访问 REST API 的完整指南

在 Rust 中不使用异步机制访问 REST API 是完全可行的，特别适合简单应用、脚本或不需要高并发的场景。以下是完整的同步实现方案：

📦 依赖选择

推荐库：

[dependencies]
reqwest = { version = "0.11", features = ["blocking", "json"] }
serde = { version = "1.0", features = ["derive"] }
serde_json = "1.0"

🔧 基础 GET 请求

1. 简单文本响应

use reqwest::blocking::get;fn main() -> Result<(), Box<dyn std::error::Error>> {let url = "https://jsonplaceholder.typicode.com/posts/1";let response = get(url)?;if response.status().is_success() {let body = response.text()?;println!("Response body: {}", body);} else {println!("Request failed with status: {}", response.status());}Ok(())
}

2. 解析 JSON 响应

use serde::Deserialize;#[derive(Debug, Deserialize)]
struct Post {userId: u32,id: u32,title: String,body: String,
}fn main() -> Result<(), Box<dyn std::error::Error>> {let url = "https://jsonplaceholder.typicode.com/posts/1";let response = get(url)?;if response.status().is_success() {let post: Post = response.json()?;println!("Post title: {}", post.title);println!("Full post: {:#?}", post);} else {println!("Request failed with status: {}", response.status());}Ok(())
}

📤 POST 请求示例

1. 发送 JSON 数据

use reqwest::blocking::Client;
use serde::Serialize;#[derive(Debug, Serialize)]
struct NewPost {title: String,body: String,userId: u32,
}fn main() -> Result<(), Box<dyn std::error::Error>> {let client = Client::new();let new_post = NewPost {title: "My New Post".to_string(),body: "This is the body of my new post".to_string(),userId: 1,};let response = client.post("https://jsonplaceholder.typicode.com/posts").json(&new_post).send()?;println!("Status: {}", response.status());println!("Response: {}", response.text()?);Ok(())
}

2. 发送表单数据

use reqwest::blocking::Client;fn main() -> Result<(), Box<dyn std::error::Error>> {let client = Client::new();let params = [("username", "john_doe"), ("password", "secret123")];let response = client.post("https://example.com/login").form(&params).send()?;println!("Login response: {}", response.text()?);Ok(())
}

🔐 高级功能

1. 添加请求头

use reqwest::blocking::Client;
use reqwest::header;fn main() -> Result<(), Box<dyn std::error::Error>> {let client = Client::new();let mut headers = header::HeaderMap::new();headers.insert(header::AUTHORIZATION, "Bearer token123".parse()?);headers.insert(header::USER_AGENT, "MySyncRustClient/1.0".parse()?);let response = client.get("https://api.example.com/protected").headers(headers).send()?;println!("Protected resource: {}", response.text()?);Ok(())
}

2. 超时设置

use reqwest::blocking::Client;
use std::time::Duration;fn main() -> Result<(), Box<dyn std::error::Error>> {let client = Client::builder().timeout(Duration::from_secs(5)).build()?;let response = client.get("https://api.example.com/slow-endpoint").send()?;println!("Response: {}", response.text()?);Ok(())
}

3. 处理分页

use reqwest::blocking::Client;
use serde::Deserialize;#[derive(Debug, Deserialize)]
struct Page {items: Vec<Item>,next_page: Option<u32>,
}#[derive(Debug, Deserialize)]
struct Item {id: u32,name: String,
}fn fetch_all_items() -> Result<Vec<Item>, Box<dyn std::error::Error>> {let client = Client::new();let mut all_items = Vec::new();let mut page_num = 1;loop {let url = format!("https://api.example.com/items?page={}", page_num);let response = client.get(&url).send()?;if !response.status().is_success() {return Err(format!("Request failed: {}", response.status()).into());}let page: Page = response.json()?;all_items.extend(page.items);match page.next_page {Some(next) => page_num = next,None => break,}}Ok(all_items)
}

🛡️ 错误处理最佳实践

1. 自定义错误类型

use thiserror::Error;#[derive(Error, Debug)]
enum ApiError {#[error("HTTP request failed: {0}")]HttpError(#[from] reqwest::Error),#[error("API returned error: {0}")]ApiError(String),#[error("Invalid response format")]ParseError,
}fn fetch_data() -> Result<String, ApiError> {let response = reqwest::blocking::get("https://api.example.com/data")?;if response.status().is_success() {response.text().map_err(|_| ApiError::ParseError)} else {let status = response.status();let body = response.text().unwrap_or_default();Err(ApiError::ApiError(format!("{}: {}", status, body)))}
}

2. 重试机制

use reqwest::blocking::Client;
use std::thread;
use std::time::Duration;fn fetch_with_retry(url: &str, max_retries: u32) -> Result<String, Box<dyn std::error::Error>> {let client = Client::new();let mut retries = 0;loop {match client.get(url).send() {Ok(response) if response.status().is_success() => {return response.text().map_err(|e| e.into());}Ok(response) => {eprintln!("Request failed: {}", response.status());}Err(e) => {eprintln!("Request error: {}", e);}}retries += 1;if retries >= max_retries {return Err("Max retries exceeded".into());}// 指数退避let delay = 2u64.pow(retries);eprintln!("Retrying in {} seconds...", delay);thread::sleep(Duration::from_secs(delay));}
}

📊 性能优化

1. 复用 HTTP 客户端

use reqwest::blocking::Client;fn main() -> Result<(), Box<dyn std::error::Error>> {// 创建一次，多次复用let client = Client::new();let response1 = client.get("https://api.example.com/resource1").send()?;// 处理响应1...let response2 = client.get("https://api.example.com/resource2").send()?;// 处理响应2...Ok(())
}

2. 多线程处理（有限并发）

use reqwest::blocking::Client;
use std::thread;fn fetch_urls(urls: &[&str]) -> Vec<String> {let client = Client::new();let handles: Vec<_> = urls.iter().map(|url| {let url = (*url).to_string();thread::spawn(move || {match client.get(&url).send() {Ok(resp) => resp.text().unwrap_or_else(|_| "Error reading response".into()),Err(_) => "Request failed".into(),}})}).collect();handles.into_iter().map(|h| h.join().unwrap()).collect()
}fn main() {let urls = ["https://jsonplaceholder.typicode.com/posts/1","https://jsonplaceholder.typicode.com/posts/2","https://jsonplaceholder.typicode.com/posts/3",];let results = fetch_urls(&urls);for (i, result) in results.iter().enumerate() {println!("Response {}: {}", i + 1, result);}
}

📝 完整示例：天气查询工具

use reqwest::blocking::Client;
use serde::Deserialize;
use std::env;#[derive(Debug, Deserialize)]
struct WeatherData {name: String,main: Main,weather: Vec<Weather>,
}#[derive(Debug, Deserialize)]
struct Main {temp: f32,feels_like: f32,humidity: u32,
}#[derive(Debug, Deserialize)]
struct Weather {description: String,
}fn main() -> Result<(), Box<dyn std::error::Error>> {let api_key = env::var("OPENWEATHER_API_KEY").expect("请设置 OPENWEATHER_API_KEY 环境变量");let city = env::args().nth(1).unwrap_or_else(|| "London".to_string());let url = format!("https://api.openweathermap.org/data/2.5/weather?q={}&appid={}&units=metric",city, api_key);let client = Client::new();let response = client.get(&url).send()?;if !response.status().is_success() {return Err(format!("API请求失败: {}", response.status()).into());}let weather: WeatherData = response.json()?;println!("\n{} 的天气:", weather.name);println!("温度: {:.1}°C", weather.main.temp);println!("体感温度: {:.1}°C", weather.main.feels_like);println!("湿度: {}%", weather.main.humidity);println!("天气状况: {}", weather.weather[0].description);Ok(())
}

⚠️ 同步方法的局限性

  1. 阻塞主线程：每个请求都会阻塞当前线程
  2. 低并发能力：不适合高并发场景
  3. 资源利用低效：线程在等待响应时无法处理其他任务
  4. 扩展性差：大规模请求需要大量线程

💡 何时使用同步方法

  1. 命令行工具：简单的数据获取工具
  2. 脚本任务：一次性数据处理脚本
  3. 低流量服务：内部工具或低流量API
  4. 学习阶段：理解HTTP请求的基础
  5. 简单嵌入式系统：资源受限环境

📚 总结

同步 REST API 访问核心步骤：

  1. 使用 reqwest::blocking 模块
  2. 创建 Client 实例（可复用）
  3. 构建请求（GET/POST/PUT/DELETE）
  4. 发送请求并获取响应
  5. 检查状态码
  6. 解析响应体（文本/JSON/二进制）

最佳实践：

  • 复用 Client：减少连接开销
  • 设置超时：防止无限等待
  • 添加重试：处理临时故障
  • 优雅错误处理：使用自定义错误类型
  • 环境变量管理：安全存储API密钥

对于需要高并发或高性能的场景，建议使用异步方法（如 reqwest 的异步API + tokio 运行时）。但对于许多应用场景，同步方法提供了简单直接的解决方案。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如若转载，请注明出处：http://www.pswp.cn/diannao/94193.shtml
繁体地址，请注明出处：http://hk.pswp.cn/diannao/94193.shtml

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

相关文章

32.【.NET8 实战--孢子记账--从单体到微服务--转向微服务】--单体转微服务--财务服务--账本与预算

32.【.NET8 实战--孢子记账--从单体到微服务--转向微服务】--单体转微服务--财务服务--账本与预算

在我们的孢子记账应用中&#xff0c;账本是用于记录每一笔收支流水的核心模块。通过账本&#xff0c;我们可以清晰地追踪资金的流入与流出&#xff0c;进行数据统计和分析&#xff0c;为后续的报表生成和决策支持提供基础数据。预算模块则是用于设置和管理预算的功能&#xff0…
阅读更多...
模型预估打分对运筹跟踪的影响

模型预估打分对运筹跟踪的影响

在uplift建模中&#xff0c;模型离线指标(QINI、AUUC)提升并不意味着在线A/B实验的收益&#xff0c;因为在线运筹还需要λ\lambdaλ约束。如果模型打分不满足单调增且roi边际递减&#xff0c;那么λ\lambdaλ运筹求解会非常不稳定&#xff0c;导致线上发券偏高&#xff0c;毛利…
阅读更多...
音视频学习（四十六）：声音的三要素

音视频学习（四十六）：声音的三要素

声音是人类感知世界的重要途径之一。在自然界中&#xff0c;声波本质上是介质中传播的机械振动&#xff0c;而人类对声音的主观感受主要通过三种属性来认知和描述&#xff0c;即音调&#xff08;音高&#xff09;、响度&#xff08;强弱&#xff09;、音色&#xff08;音质&…
阅读更多...
spring batch处理数据模板（Reader-Processor-Writer模式）

spring batch处理数据模板（Reader-Processor-Writer模式）

步骤监听器 Component public class StepListener implements StepExecutionListener {private StepExecution stepExecution;public StepExecution getStepExecution() {return this.stepExecution;}Overridepublic void beforeStep(StepExecution stepExecution) {this.stepE…
阅读更多...
【华为OD机试】从小桶里取球

【华为OD机试】从小桶里取球

题目描述 某部门开展Family Day开放日活动，其中有个从桶里取球的游戏，游戏规则如下： 有N个容量一样的小桶等距排开，且每个小桶都默认装了数不等的小球， 每个小桶装的小球数量记录在数组bucketBallNums中， 游戏开始时，要求所有桶的小球总数不能超过SUM， 如果小球总…
阅读更多...
std::unordered_map 和 std::map的区别【C++】

std::unordered_map 和 std::map的区别【C++】

std::unordered_map 和 std::map 是 C 标准库中两种不同的关联容器&#xff0c;它们都用于存储键值对&#xff0c;但在实现方式、性能特点和使用场景上存在显著区别。以下是它们的主要区别&#xff1a; 1. 数据结构 std::map&#xff1a; 基于 红黑树&#xff08;一种自平衡二叉…
阅读更多...
云原生环境里的显示变革：Docker虚拟浏览器与cpolar穿透技术实战

云原生环境里的显示变革：Docker虚拟浏览器与cpolar穿透技术实战

文章目录前言【视频教程】1. 关于neko2. 本地部署neko3. neko简单使用4. 安装内网穿透5. 配置neko公网地址6. 配置固定公网地址前言 现代远程协作本该是无缝衔接的过程&#xff0c;却被这些障碍不断打断&#xff1a;多设备屏幕同步存在延迟、跨平台访问需要复杂配置、公网IP申…
阅读更多...
LVGL + ESP-Brookesia 在Windows下的编译和运行

LVGL + ESP-Brookesia 在Windows下的编译和运行

LVGL ESP-Brookesia 在Windows下的编译和运行 1. 项目介绍 本项目是基于 LVGL&#xff08;轻量级多功能图形库&#xff09;和 ESP-Brookesia 的嵌入式模拟桌面应用开发框架&#xff0c;专为嵌入式设备构建丰富的图形界面而设计。通过在Windows环境下模拟嵌入式设备的图形界面…
阅读更多...
【ip】IP地址能否直接填写255？

【ip】IP地址能否直接填写255？

IP地址数值限制​ 最近有朋友后台问我&#xff0c;IP地址里填255行不行&#xff1f;思索着有一阵子没有分享基础的知识&#xff0c;就在今天大致说一下&#xff0c;关于IP地址里填255行不行&#xff1f;答案当然是否定的。 IP地址由4个段组成&#xff0c;每个段的数值范围其实限…
阅读更多...
力扣热题100----------141.环形链表

力扣热题100----------141.环形链表

给你一个链表的头节点 head &#xff0c;判断链表中是否有环。 如果链表中有某个节点&#xff0c;可以通过连续跟踪 next 指针再次到达&#xff0c;则链表中存在环。 为了表示给定链表中的环&#xff0c;评测系统内部使用整数 pos 来表示链表尾连接到链表中的位置&#xff08;索…
阅读更多...
【Java开发日记】我们来说说 LockSupport 的 park 和 unpark

【Java开发日记】我们来说说 LockSupport 的 park 和 unpark

目录 一、LockSupport 1.1、LockSupport函数列表 1.2、基本使用 先 park 再 unpark 先 unpark 再 park 1.3、特点 与 Object 的 wait & notify 相比 二、LockSupport park & unpark原理 2.1、情况一&#xff0c;先调用park&#xff0c;再调用unpark park 操作…
阅读更多...
AGI｜从“实验室”到“生产线”：企业级AI Agent 如何突围

AGI｜从“实验室”到“生产线”：企业级AI Agent 如何突围

在数字化转型的深水区&#xff0c;企业级 AI Agent 正从技术概念走向产业实践&#xff0c;成为驱动生产力变革的核心引擎。目录 一、风口已至&#xff1a;AI Agent 的崛起逻辑与市场刚需 二、企业级AI Agent&#xff1a;核心能力与独特价值定位 三、AI Agent 的未来目标 一、…
阅读更多...
AtCoder Beginner Contest 417

AtCoder Beginner Contest 417

文章目录A A SubstringB Search and DeleteC Distance IndicatorsD Takahashis ExpectationE A Path in A DictionaryF Random GatheringG Binary CatAtCoder Beginner Contest 417A A Substring You are given an N-character string S consisting of lowercase English lett…
阅读更多...
C++23 Concepts：用类型约束重构泛型编程的终极方案

C++23 Concepts：用类型约束重构泛型编程的终极方案

一、开篇：模板元编程的"类型检查困局" 某金融量化团队曾遇到诡异bug： template<typename T> void process(T data) {static_assert(std::is_arithmetic<T>::value, "需要数值类型");// 业务逻辑... } 当调用process("hello")时…
阅读更多...
【RK3568 看门狗驱动开发详解】

【RK3568 看门狗驱动开发详解】

RK3568 看门狗驱动开发详解一、Linux 看门狗子系统架构​二、设备树配置​三、 看门狗驱动实现四、验证看门狗定时器&#xff08;Watchdog Timer&#xff09;是保障嵌入式系统可靠性的关键硬件&#xff0c;它通过定期接收 “喂狗” 信号监控系统运行状态&#xff0c;当系统故障…
阅读更多...
探索 Vue 3.6 新特性：Vapor Mode 与高性能 Web 应用开发

探索 Vue 3.6 新特性：Vapor Mode 与高性能 Web 应用开发

Vue 3.6 简介 Vue.js 是一个广受欢迎的渐进式 JavaScript 框架&#xff0c;以其简洁的 API、灵活的组件系统和高性能著称。Vue 3.6 是 Vue 3 系列的一个重要版本&#xff0c;引入了多项性能优化和新特性&#xff0c;尤其是备受关注的 Vapor Mode&#xff0c;这是一个无需虚拟 D…
阅读更多...
初识prometheus

初识prometheus

Prometheus&#xff1a;云原生时代的监控利器 在当今快速发展的云原生和微服务架构时代&#xff0c;传统的监控系统面临着巨大的挑战&#xff1a;如何高效地收集海量、动态变化的指标&#xff1f;如何实时告警并快速定位问题&#xff1f;如何实现灵活的可视化和强大的数据查询…
阅读更多...
从源码角度分析导致 JVM 内存泄露的 ThreadLocal

从源码角度分析导致 JVM 内存泄露的 ThreadLocal

文章目录1. 为什么需要ThreadLocal2. ThreadLocal的实现解析1.1 实现分析1.2 具体实现1.3 ThreadLocalMap中Hash冲突的解决1.3.1 Hash冲突解决的几种方法1.3.1.1 开放定值法1.3.1.2 链地址法1.3.1.3再哈希法&#xff1a;1.3.1.4 建立公共溢出区1.3.2 ThreadLocal解决Hash冲突的…
阅读更多...
React组件化的封装

React组件化的封装

1. 组件化封装的结构 1.1. 定义一个类(组件名必须是大写&#xff0c;小写会被认为是html元素), 继续自React.Component1.2. 实现当前组件的render函数 render当中返回的jsx内容&#xff0c;就是之后React会帮助我们渲染的内容 1.3. 结构图如下&#xff1a; data 方法render()…
阅读更多...
嵌入式仿真教学的革新力量：深圳航天科技创新研究院引领高效学习新时代

嵌入式仿真教学的革新力量：深圳航天科技创新研究院引领高效学习新时代

嵌入式系统作为现代信息技术的核心基石&#xff0c;已深度融入工业控制、物联网、智能终端等关键领域。高校肩负着培养嵌入式技术人才的重任&#xff0c;但传统教学方式正面临严峻挑战&#xff1a;硬件实验设备投入巨大、更新滞后、维护繁琐、时空限制严格&#xff0c;难以满足…
阅读更多...
最新文章

Copyright @ 2022~2023