Struct RedisBackend 

pub struct RedisBackend { /* private fields */ }

Redis 分布式缓存后端

基于 redis crate 0.27 + tokio-comp 异步 IO + connection-manager 自动重连。

实现要点

• 连接管理：使用 redis::aio::ConnectionManager（内部自动重连的连接池）
• get → redis::cmd("GET") 异步执行
• set → SET key value + 可选 EX seconds（合并为单次 SET 命令，原子性保证）
• delete → redis::cmd("DEL")
• invalidate_prefix → SCAN + 批量 DEL（避免 KEYS 阻塞 Redis 主线程）
  • 使用 COUNT 100 分批扫描，避免单次 SCAN 拉取过多 key 导致阻塞
  • 多次 DEL 调用合并为单次 pipeline 批量执行，减少 RTT 开销

错误处理

• 连接失败 → CacheError::Internal，由调用方决定是否重试
• Redis 命令错误 → 原始错误字符串包装为 CacheError::Internal

启用方式

在 Cargo.toml 中启用 redis feature：

[dependencies]
sz-orm-core = { version = "1.0", features = ["redis"] }

使用示例

let backend = RedisBackend::new("redis://127.0.0.1:6379/0").await?;
backend.set("user:1", b"alice", Some(Duration::from_secs(60))).await?;
let val = backend.get("user:1").await?;
assert_eq!(val, Some(b"alice".to_vec()));
backend.delete("user:1").await?;

Implementations

impl RedisBackend

pub async fn new(url: impl Into<String>) -> Result<Self, CacheError>

创建 Redis 后端

url 格式：redis://[:password@]host:port[/db]

• redis://127.0.0.1:6379/0 — 默认 DB 0
• redis://:secret@127.0.0.1:6379/1 — 带密码，DB 1

错误

• 连接失败 → CacheError::Internal

pub fn from_manager(manager: ConnectionManager) -> Self

使用已有 ConnectionManager 创建后端（用于复用连接池）

Trait Implementations

impl L2CacheBackend for RedisBackend

Available on crate feature redis only.

fn get<'a>(&'a self, key: &'a str) -> L2CacheFuture<'a, Option<Vec<u8>>>

获取缓存值，不存在或已过期返回 None

fn set<'a>( &'a self, key: &'a str, value: &'a [u8], ttl: Option<Duration>, ) -> L2CacheFuture<'a, ()>

设置缓存值，ttl 为 None 表示永不过期

fn delete<'a>(&'a self, key: &'a str) -> L2CacheFuture<'a, ()>

删除单个缓存键

fn invalidate_prefix<'a>(&'a self, prefix: &'a str) -> L2CacheFuture<'a, ()>

按前缀批量失效缓存项（用于表级失效）