当前位置：首页 > news >正文

Rust 文件IO操作实战：读写文件的艺术

news 2026/5/7 19:19:55

Rust 文件IO操作实战：读写文件的艺术

文件IO的重要性

在软件开发中，文件IO操作是一项基本而重要的任务。无论是读取配置文件、处理数据文件还是持久化应用状态，都需要与文件系统进行交互。Rust作为一种系统编程语言，提供了强大而安全的文件IO操作支持。本文将介绍Rust文件IO操作的核心概念、常用API和最佳实践。

基本概念

文件操作模式

Rust中文件操作的常见模式包括：

读取模式（Read）：用于读取文件内容
写入模式（Write）：用于写入文件内容
追加模式（Append）：用于在文件末尾添加内容
创建模式（Create）：用于创建新文件
截断模式（Truncate）：用于清空文件内容

文件句柄

在Rust中，文件操作通过File类型表示，它是对底层文件的句柄。

基本文件操作

读取文件

use std::fs::File; use std::io::{self, Read}; fn read_file() -> io::Result<String> { // 打开文件 let mut file = File::open("example.txt")?; // 创建缓冲区 let mut content = String::new(); // 读取文件内容 file.read_to_string(&mut content)?; Ok(content) } fn main() { match read_file() { Ok(content) => println!("文件内容: {}", content), Err(e) => println!("错误: {}", e), } }

写入文件

use std::fs::File; use std::io::{self, Write}; fn write_file() -> io::Result<()> { // 创建或截断文件 let mut file = File::create("output.txt")?; // 写入内容 file.write_all(b"Hello, Rust file IO!\n")?; file.write_all(b"This is a test.\n")?; Ok(()) } fn main() { match write_file() { Ok(_) => println!("文件写入成功"), Err(e) => println!("错误: {}", e), } }

追加文件

use std::fs::OpenOptions; use std::io::{self, Write}; fn append_file() -> io::Result<()> { // 打开文件，设置为追加模式 let mut file = OpenOptions::new() .append(true) .open("output.txt")?; // 追加内容 file.write_all(b"Appended content.\n")?; Ok(()) } fn main() { match append_file() { Ok(_) => println!("文件追加成功"), Err(e) => println!("错误: {}", e), } }

高级文件操作

读取二进制文件

use std::fs::File; use std::io::{self, Read}; fn read_binary_file() -> io::Result<Vec<u8>> { let mut file = File::open("image.png")?; let mut buffer = Vec::new(); file.read_to_end(&mut buffer)?; Ok(buffer) } fn main() { match read_binary_file() { Ok(buffer) => println!("读取了 {} 字节的二进制数据", buffer.len()), Err(e) => println!("错误: {}", e), } }

按行读取文件

use std::fs::File; use std::io::{self, BufRead, BufReader}; fn read_lines() -> io::Result<()> { let file = File::open("example.txt")?; let reader = BufReader::new(file); for line in reader.lines() { match line { Ok(line) => println!("行: {}", line), Err(e) => println!("错误: {}", e), } } Ok(()) } fn main() { if let Err(e) = read_lines() { println!("错误: {}", e); } }

内存映射

内存映射允许我们将文件映射到内存中，从而可以像访问内存一样访问文件内容。

use std::fs::File; use std::io; use memmap2::Mmap; fn memory_map() -> io::Result<()> { let file = File::open("example.txt")?; let mmap = unsafe { Mmap::map(&file)? }; // 将内存映射转换为字符串 let content = std::str::from_utf8(&mmap)?; println!("文件内容: {}", content); Ok(()) } fn main() { if let Err(e) = memory_map() { println!("错误: {}", e); } }

目录操作

创建目录

use std::fs; use std::io; fn create_directory() -> io::Result<()> { fs::create_dir("new_directory")?; println!("目录创建成功"); Ok(()) } fn main() { if let Err(e) = create_directory() { println!("错误: {}", e); } }

读取目录内容

use std::fs; use std::io; fn list_directory() -> io::Result<()> { let entries = fs::read_dir(".")?; for entry in entries { let entry = entry?; let path = entry.path(); if path.is_dir() { println!("目录: {:?}", path); } else { println!("文件: {:?}", path); } } Ok(()) } fn main() { if let Err(e) = list_directory() { println!("错误: {}", e); } }

复制文件

use std::fs; use std::io; fn copy_file() -> io::Result<()> { fs::copy("source.txt", "destination.txt")?; println!("文件复制成功"); Ok(()) } fn main() { if let Err(e) = copy_file() { println!("错误: {}", e); } }

删除文件

use std::fs; use std::io; fn delete_file() -> io::Result<()> { fs::remove_file("unwanted.txt")?; println!("文件删除成功"); Ok(()) } fn main() { if let Err(e) = delete_file() { println!("错误: {}", e); } }

异步文件操作

使用tokio进行异步文件操作：

use tokio::fs::File; use tokio::io::{self, AsyncReadExt, AsyncWriteExt}; async fn async_read_file() -> io::Result<String> { let mut file = File::open("example.txt").await?; let mut content = String::new(); file.read_to_string(&mut content).await?; Ok(content) } async fn async_write_file() -> io::Result<()> { let mut file = File::create("async_output.txt").await?; file.write_all(b"Hello, async file IO!\n").await?; Ok(()) } #[tokio::main] async fn main() { match async_read_file().await { Ok(content) => println!("文件内容: {}", content), Err(e) => println!("读取错误: {}", e), } match async_write_file().await { Ok(_) => println!("文件写入成功"), Err(e) => println!("写入错误: {}", e), } }

文件元数据

获取文件信息

use std::fs::File; use std::io; use std::os::unix::fs::MetadataExt; fn file_metadata() -> io::Result<()> { let file = File::open("example.txt")?; let metadata = file.metadata()?; println!("文件大小: {} 字节", metadata.len()); println!("是否是文件: {}", metadata.is_file()); println!("是否是目录: {}", metadata.is_dir()); println!("权限: {:o}", metadata.mode()); println!("修改时间: {:?}", metadata.mtime()); Ok(()) } fn main() { if let Err(e) = file_metadata() { println!("错误: {}", e); } }

文件路径操作

use std::path::Path; fn path_operations() { let path = Path::new("/home/user/example.txt"); println!("路径: {:?}", path); println!("文件名: {:?}", path.file_name()); println!("父目录: {:?}", path.parent()); println!("扩展名: {:?}", path.extension()); println!("是否存在: {}", path.exists()); println!("是否是文件: {}", path.is_file()); println!("是否是目录: {}", path.is_dir()); } fn main() { path_operations(); }

实用应用

配置文件读写

use serde::{Deserialize, Serialize}; use std::fs::File; use std::io::{self, Read, Write}; #[derive(Serialize, Deserialize, Debug)] struct Config { host: String, port: u16, database: DatabaseConfig, } #[derive(Serialize, Deserialize, Debug)] struct DatabaseConfig { url: String, username: String, password: String, } fn load_config() -> io::Result<Config> { let mut file = File::open("config.json")?; let mut content = String::new(); file.read_to_string(&mut content)?; let config: Config = serde_json::from_str(&content)?; Ok(config) } fn save_config(config: &Config) -> io::Result<()> { let mut file = File::create("config.json")?; let content = serde_json::to_string_pretty(config)?; file.write_all(content.as_bytes())?; Ok(()) } fn main() { // 加载配置 match load_config() { Ok(config) => println!("加载的配置: {:?}", config), Err(e) => println!("加载配置错误: {}", e), } // 保存配置 let config = Config { host: "localhost".to_string(), port: 8080, database: DatabaseConfig { url: "postgres://localhost:5432/mydb".to_string(), username: "admin".to_string(), password: "password".to_string(), }, }; if let Err(e) = save_config(&config) { println!("保存配置错误: {}", e); } else { println!("配置保存成功"); } }

日志文件管理

use std::fs::OpenOptions; use std::io::{self, Write}; use std::time::{SystemTime, UNIX_EPOCH}; fn log_message(level: &str, message: &str) -> io::Result<()> { // 打开日志文件，设置为追加模式 let mut file = OpenOptions::new() .create(true) .append(true) .open("app.log")?; // 获取当前时间 let now = SystemTime::now() .duration_since(UNIX_EPOCH) .unwrap() .as_secs(); // 写入日志 writeln!(file, "[{}] [{}] {}", now, level, message)?; Ok(()) } fn main() { log_message("INFO", "应用启动").unwrap(); log_message("ERROR", "发生错误").unwrap(); log_message("INFO", "应用关闭").unwrap(); }

文件备份

use std::fs; use std::io; use std::time::{SystemTime, UNIX_EPOCH}; fn backup_file(source: &str) -> io::Result<()> { // 获取当前时间戳 let timestamp = SystemTime::now() .duration_since(UNIX_EPOCH) .unwrap() .as_secs(); // 构建备份文件名 let backup_path = format!("{}.bak.{}", source, timestamp); // 复制文件 fs::copy(source, &backup_path)?; println!("文件备份到: {}", backup_path); Ok(()) } fn main() { if let Err(e) = backup_file("important.txt") { println!("备份错误: {}", e); } else { println!("备份成功"); } }