建设静态网站,wordpress post下载,WordPress评论第页,安居网站建设在使用actix-web框架的时候#xff0c;如果使用zip解压任务将会占用一个工作线程#xff0c;因为zip库是同步阻塞的#xff0c;想用异步非阻塞需要用另一个库#xff0c;下面列出同步解压#xff0c;跟异步解压的两个方法实现#xff0c;异步解压不会占用工作线程。 阻塞… 在使用actix-web框架的时候如果使用zip解压任务将会占用一个工作线程因为zip库是同步阻塞的想用异步非阻塞需要用另一个库下面列出同步解压跟异步解压的两个方法实现异步解压不会占用工作线程。 阻塞解压
依赖库
zip 0.6.6rust代码
pub fn unzipP: AsRefstd::path::Path(file_path: P,unzip_path: P,
) - Result(), std::io::Error {let file_path file_path.as_ref();let unzip_path unzip_path.as_ref();let unzip_path std::path::Path::new(unzip_path);if unzip_path.exists() {std::fs::remove_dir_all(unzip_path)?;} else {std::fs::create_dir_all(unzip_path)?;}let file std::fs::File::open(file_path)?;let mut archive zip::ZipArchive::new(file)?;for index in 0..archive.len() {let mut file archive.by_index(index)?;let file_name file.mangled_name();let outpath unzip_path.join(file_name);if file.is_dir() {std::fs::create_dir_all(outpath)?;} else {if let Some(p) outpath.parent() {if !p.exists() {std::fs::create_dir_all(p)?;}}let mut outfile std::fs::File::create(outpath)?;std::io::copy(mut file, mut outfile)?;}}return Ok(());
}异步解压
依赖库
async_zip { version 0.0.17, features [tokio, tokio-fs, deflate] }
futures-lite 2.3.0
tokio { version 1.35.1, features [macros] }
tokio-util 0.7.10rust代码
use async_zip::base::read::seek::ZipFileReader;
use async_zip::base::write::ZipFileWriter;
use async_zip::ZipEntryBuilder;
use tokio::fs::OpenOptions;
use tokio_util::compat::{TokioAsyncReadCompatExt, TokioAsyncWriteCompatExt};pub async fn unzip_asyncP: AsRefstd::path::Path(file_path: P,unzip_path: P,
) - Result(), ApiError {let unzip_path unzip_path.as_ref();if unzip_path.exists() {std::fs::remove_dir_all(unzip_path)?;} else {std::fs::create_dir_all(unzip_path)?;}let file tokio::fs::File::open(file_path.as_ref()).await?;let reader tokio::io::BufReader::new(file);let mut zip ZipFileReader::with_tokio(reader).await.map_err(ApiError::from)?;for index in 0..zip.file().entries().len() {let entry zip.file().entries().get(index).ok_or(ApiError::msg(zip entry not found))?;let raw entry.filename().as_bytes();let mut file_name String::from_utf8_lossy(raw).to_string(); //必需转换为utf8不能使用自带的会乱码let outpath unzip_path.join(file_name);if file_name.ends_with(/) {tokio::fs::create_dir_all(outpath).await?;} else {if let Some(p) outpath.parent() {if !p.exists() {tokio::fs::create_dir_all(p).await?;}}let mut entry_reader zip.reader_without_entry(index).await.map_err(ApiError::from)?;let mut writer OpenOptions::new().write(true).create_new(true).open(outpath).await.map_err(ApiError::from)?;futures_lite::io::copy(mut entry_reader, mut writer.compat_write()).await?;}}Ok(())
}
