13 个版本 (8 个破坏性版本)
0.13.0 | 2024 年 6 月 11 日 |
---|---|
0.12.0 | 2024 年 3 月 31 日 |
0.11.0 | 2024 年 3 月 5 日 |
0.8.2 | 2023 年 12 月 24 日 |
0.7.0 | 2023 年 11 月 27 日 |
#305 in 异步
2,946 每月下载量
17KB
102 代码行
tower-sessions-redis-store
通过 `fred` 实现的 Redis 会话存储,用于 `tower-sessions`。
🤸 用法
use std::net::SocketAddr;
use axum::{response::IntoResponse, routing::get, Router};
use serde::{Deserialize, Serialize};
use time::Duration;
use tower_sessions::{Expiry, Session, SessionManagerLayer};
use tower_sessions_redis_store::{fred::prelude::*, RedisStore};
const COUNTER_KEY: &str = "counter";
#[derive(Debug, Serialize, Deserialize, Default)]
struct Counter(usize);
async fn handler(session: Session) -> impl IntoResponse {
let counter: Counter = session.get(COUNTER_KEY).await.unwrap().unwrap_or_default();
session.insert(COUNTER_KEY, counter.0 + 1).await.unwrap();
format!("Current count: {}", counter.0)
}
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
let pool = RedisPool::new(RedisConfig::default(), None, None, None, 6)?;
let redis_conn = pool.connect();
pool.wait_for_connect().await?;
let session_store = RedisStore::new(pool);
let session_layer = SessionManagerLayer::new(session_store)
.with_secure(false)
.with_expiry(Expiry::OnInactivity(Duration::seconds(10)));
let app = Router::new().route("/", get(handler)).layer(session_layer);
let addr = SocketAddr::from(([127, 0, 0, 1], 3000));
let listener = tokio::net::TcpListener::bind(&addr).await?;
axum::serve(listener, app.into_make_service()).await?;
redis_conn.await??;
Ok(())
}
依赖项
~11–32MB
~640K SLoC