liyunjia/chuanyue-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

暂时屏蔽request-id

Browse Source
This commit is contained in:
李运家 2024-11-06 10:02:52 +08:00
parent b07125713c
commit 5eb57f4570
3 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app.toml
View File

@ -20,8 +20,8 @@ expires = 1800
refresh_expires = 3600 refresh_expires = 3600
[redis] [redis]
url = "47.95.198.7:33000" #url = "47.95.198.7:33000"
#url = "127.0.0.1:33001" url = "127.0.0.1:33001"
password = "3aB7kRt9pDf1nQzW" password = "3aB7kRt9pDf1nQzW"
db = 0 db = 0

12
library/src/cache/inner_cache.rs vendored
View File

@ -68,8 +68,8 @@ where
/// 初始化缓存，从redis中读取缓存数据 /// 初始化缓存，从redis中读取缓存数据
pub async fn init(&self) { pub async fn init(&self) {
let cache_datas = RedisCache::get(self.cache_type.clone()).await; let cache_data = RedisCache::get(self.cache_type.clone()).await;
for element in cache_datas { for element in cache_data {
let cache_key = element.cache_key.clone(); let cache_key = element.cache_key.clone();
let data_json = element.data; let data_json = element.data;
let cache_data = serde_json::from_str::<D>(&data_json).unwrap(); let cache_data = serde_json::from_str::<D>(&data_json).unwrap();
@ -114,8 +114,11 @@ where
/// Redis缓存封装 /// Redis缓存封装
#[derive(Debug, Clone, Default)] #[derive(Debug, Clone, Default)]
struct RedisCache { struct RedisCache {
// 缓存类型，内存缓存可能包含多种缓存数据，每种缓存数据作为一个类型
pub cache_type: Arc<String>, pub cache_type: Arc<String>,
// 缓存key，作为redis中的key
pub cache_key: String, pub cache_key: String,
// 缓存数据
pub data: String, pub data: String,
} }
@ -142,8 +145,8 @@ impl RedisCache {
pub async fn get(cache_type: Arc<String>) -> Vec<RedisCache> { pub async fn get(cache_type: Arc<String>) -> Vec<RedisCache> {
let mut result = Vec::new(); let mut result = Vec::new();
match REDIS_CACHE.hgetall(&cache_type).await { match REDIS_CACHE.hgetall(&cache_type).await {
Ok(cache_datas) => { Ok(cache_data) => {
for (key, value) in cache_datas { for (key, value) in cache_data {
let cache_data = RedisCache { let cache_data = RedisCache {
cache_type: cache_type.clone(), cache_type: cache_type.clone(),
cache_key: key, cache_key: key,
@ -156,7 +159,6 @@ impl RedisCache {
tracing::error!("从缓存Hash获取数据失败: {:?}", err); tracing::error!("从缓存Hash获取数据失败: {:?}", err);
} }
} }
result result
} }

2
server/src/lib.rs
View File

@ -51,10 +51,10 @@ fn init() -> Router {
.nest(&config!().server.prefix_url, auth) .nest(&config!().server.prefix_url, auth)
.layer( .layer(
ServiceBuilder::new() ServiceBuilder::new()
.layer(trace_layer)
.layer(axum::middleware::from_fn( .layer(axum::middleware::from_fn(
library::middleware::req_id::handle, library::middleware::req_id::handle,
)) ))
.layer(trace_layer)
.layer(axum::middleware::from_fn(library::middleware::cors::handle)) .layer(axum::middleware::from_fn(library::middleware::cors::handle))
.layer(axum::middleware::from_fn( .layer(axum::middleware::from_fn(
library::middleware::req_log::handle, library::middleware::req_log::handle,