如何在 actix-web 路由中缓存或记忆数据?
How to cache or memoize data in actix-web route?
我有一个 API 我正在实现一个需要调用的昂贵函数。我想记住这个函数或使用键值缓存来查找以前的结果。我也会考虑 Mutex
或类似的结构,但我想避免像 Redis 或 Memcached 这样的外部结构。根据我的阅读,Mutex
的缓存性能不佳。如何使用 HashMap
之类的键值存储或在 actix_web 异步路由中记忆函数?现在,我正在尝试一个简单的 HashMap
但我收到此错误:can't borrow data in an Arc as mutable
.
async fn index(
kv: web::Data<HashMap<&str, i64>>,
) -> Result<HttpResponse> {
dbg!(kv);
kv.insert("four", 4);
Ok(HttpResponse::Ok().json(kv)
}
#[actix_web::main]
async fn main() -> std::io::Result<()> {
let tuples: Vec<(&str, i64)> = vec![("one", 1), ("two", 2), ("three", 3)];
let mut m = tuples.into_iter().collect::<HashMap<&str, i64>>();
let mut kv = web::Data::new(m);
// move is necessary to give closure below ownership of counter1
HttpServer::new(move || {
App::new()
.app_data(kv.clone())
.route("/", web::get().to(index))
})
.bind("127.0.0.1:8080")?
.run()
.await
}
看来您可以使用 cached 板条箱。
将逻辑移至另一个函数。类似以下代码的作品:
use actix_web::{web, App, HttpServer, HttpResponse};
use cached::proc_macro::cached;
async fn index() -> HttpResponse {
dbg!("in index");
let number = get_number(2);
HttpResponse::Ok().body(number.to_string())
}
#[cached]
fn get_number(n: i32) -> i32 {
dbg!("in get_number");
n * 2
}
#[actix_web::main]
async fn main() -> std::io::Result<()> {
HttpServer::new(move || {
App::new()
.route("/", web::get().to(index))
})
.bind("127.0.0.1:8080")?
.run()
.await
}
我有一个 API 我正在实现一个需要调用的昂贵函数。我想记住这个函数或使用键值缓存来查找以前的结果。我也会考虑 Mutex
或类似的结构,但我想避免像 Redis 或 Memcached 这样的外部结构。根据我的阅读,Mutex
的缓存性能不佳。如何使用 HashMap
之类的键值存储或在 actix_web 异步路由中记忆函数?现在,我正在尝试一个简单的 HashMap
但我收到此错误:can't borrow data in an Arc as mutable
.
async fn index(
kv: web::Data<HashMap<&str, i64>>,
) -> Result<HttpResponse> {
dbg!(kv);
kv.insert("four", 4);
Ok(HttpResponse::Ok().json(kv)
}
#[actix_web::main]
async fn main() -> std::io::Result<()> {
let tuples: Vec<(&str, i64)> = vec![("one", 1), ("two", 2), ("three", 3)];
let mut m = tuples.into_iter().collect::<HashMap<&str, i64>>();
let mut kv = web::Data::new(m);
// move is necessary to give closure below ownership of counter1
HttpServer::new(move || {
App::new()
.app_data(kv.clone())
.route("/", web::get().to(index))
})
.bind("127.0.0.1:8080")?
.run()
.await
}
看来您可以使用 cached 板条箱。
将逻辑移至另一个函数。类似以下代码的作品:
use actix_web::{web, App, HttpServer, HttpResponse};
use cached::proc_macro::cached;
async fn index() -> HttpResponse {
dbg!("in index");
let number = get_number(2);
HttpResponse::Ok().body(number.to_string())
}
#[cached]
fn get_number(n: i32) -> i32 {
dbg!("in get_number");
n * 2
}
#[actix_web::main]
async fn main() -> std::io::Result<()> {
HttpServer::new(move || {
App::new()
.route("/", web::get().to(index))
})
.bind("127.0.0.1:8080")?
.run()
.await
}