Struct RedisCache 

pub struct RedisCache { /* private fields */ }

Redis 缓存客户端

克隆廉价：内部通过 Arc 与多路复用连接管理器共享同一连接。

Implementations

impl RedisCache

pub async fn connect(cfg: &RedisConfig) -> Result<Self>

连接 Redis 并校验连通性。

参数

• cfg: Redis 配置（URL / 前缀 / 默认 TTL）

返回

• Ok(RedisCache): 连接成功且 PING 通过
• Err: 无法连接或 PING 失败（调用方应据此终止启动）

副作用

建立到 Redis 的多路复用连接。

pub fn sender_id(&self) -> &str

本实例唯一发送者 ID

pub fn default_ttl_secs(&self) -> u64

JSON 缓存默认 TTL 秒数

pub fn full_key(&self, logical: &str) -> String

把逻辑键加上统一前缀，得到 Redis 实际键

pub fn json_cache_key(key: &str) -> String

生成 JSON 响应缓存逻辑键。

pub fn value_cache_key(namespace: &str, key: &str) -> String

生成结构化值缓存逻辑键。

pub async fn get_bytes(&self, logical: &str) -> Option<Vec<u8>>

读取字节值。

运行期 Redis 抖动时记录告警并返回 None（读路径降级，不影响请求）。

pub async fn set_bytes_ttl(&self, logical: &str, value: &[u8], ttl_secs: u64)

写入字节值并设置 TTL（秒）。

运行期失败仅记录告警，不向上抛错（写缓存属尽力而为）。

pub async fn del(&self, logical: &str)

删除键。

pub async fn del_pattern(&self, logical_pattern: &str)

按逻辑键模式删除 Redis 键。

使用 SCAN MATCH 分批删除，避免 KEYS 阻塞 Redis。

pub async fn get_json_bytes(&self, key: &str) -> Option<Arc<Vec<u8>>>

读取预序列化 JSON 响应缓存。

pub async fn set_json_bytes_ttl(&self, key: &str, value: &[u8], ttl_secs: u64)

写入预序列化 JSON 响应缓存。

pub async fn del_json(&self, key: &str)

删除单个 JSON 响应缓存。

pub async fn del_json_pattern(&self, pattern: &str)

按业务键模式删除 JSON 响应缓存。

pub async fn get_value<T>(&self, namespace: &str, key: &str) -> Option<T>

where T: DeserializeOwned,

读取结构化业务值缓存。

pub async fn set_value_ttl<T>( &self, namespace: &str, key: &str, value: &T, ttl_secs: u64, )

where T: Serialize,

写入结构化业务值缓存。

pub async fn del_value(&self, namespace: &str, key: &str)

删除单个结构化业务值缓存。

pub async fn del_value_pattern(&self, namespace: &str, pattern: &str)

按业务键模式删除结构化业务值缓存。

pub async fn set_str_ttl(&self, logical: &str, value: &str, ttl_secs: u64)

写入字符串值并设置 TTL（秒）。

pub async fn get_str(&self, logical: &str) -> Option<String>

读取字符串值。

pub async fn set_nx_ex(&self, logical: &str, value: &str, ttl_secs: u64) -> bool

条件写入：仅当键不存在时写入并设置 TTL（SET key val NX EX ttl）。

用于协作页面锁的原子抢占。

返回

• true：本次成功抢占（键原先不存在）
• false：键已存在（被他人持有）或 Redis 异常

pub async fn expire(&self, logical: &str, ttl_secs: u64)

刷新键 TTL（秒）。用于续约页面锁。

pub async fn hset_ttl( &self, logical: &str, field: &str, value: &str, ttl_secs: u64, )

写入哈希字段并刷新整哈希 TTL（用于项目在线状态表）。

pub async fn hgetall(&self, logical: &str) -> Vec<(String, String)>

读取哈希全部字段（field, value）。

pub async fn hdel(&self, logical: &str, field: &str)

删除哈希字段。

pub async fn publish(&self, channel: &str, payload: &str)

发布一条消息到指定逻辑频道。

pub async fn subscribe_loop<F>(self, channel: &str, handler: F)

where F: FnMut(String) + Send + 'static,

订阅指定逻辑频道，对每条消息调用 handler。

内部使用独立 pub/sub 连接；连接异常时按退避重连，持续运行直到进程退出。

参数

• channel: 逻辑频道名（自动加前缀）
• handler: 收到消息载荷时的回调

Trait Implementations

impl Clone for RedisCache

fn clone(&self) -> RedisCache

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.