實現代碼

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.TypeReference;
import lombok.extern.slf4j.Slf4j;
import org.redisson.api.RBucket;
import org.redisson.api.RedissonClient;
import org.redisson.client.codec.Codec;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;import java.util.Collections;
import java.util.List;
import java.util.Optional;
import java.util.concurrent.TimeUnit;
import java.util.function.Supplier;@Slf4j
@Component
public class RedissonDataUtils {private static RedissonClient redissonClient;@Autowiredpublic void setRedissonClient(RedissonClient client) {RedissonDataUtils.redissonClient = client;}/*** 校驗 RedissonClient 是否已注入*/private static boolean clientReady() {if (redissonClient == null) {log.error("[RedissonDataUtils] RedissonClient 未注入，無法執行Redis操作");return false;}return true;}/*** 從 Redis 獲取數據，如果不存在或解析失敗則返回默認值** @param key          Redis 鍵* @param type         目標數據類型* @param defaultValue 默認值* @param <T>          數據類型* @return 解析后的數據對象或默認值*/public static <T> T getOrDefault(String key, Class<T> type, T defaultValue) {return get(key, type, null).orElse(defaultValue);}public static <T> T getOrDefault(String key, Class<T> type, T defaultValue, Codec codec) {return get(key, type, codec).orElse(defaultValue);}/*** 從 Redis 獲取數據，如果不存在或解析失敗則通過 Supplier 獲取默認值** @param key             Redis 鍵* @param type            目標數據類型* @param defaultSupplier 默認值提供者（延遲執行）* @param <T>             數據類型* @return 解析后的數據對象或默認值*/public static <T> T getOrDefaultSupplier(String key, Class<T> type, Supplier<T> defaultSupplier) {return get(key, type, null).orElseGet(defaultSupplier);}public static <T> T getOrDefaultSupplier(String key, Class<T> type, Supplier<T> defaultSupplier, Codec codec) {return get(key, type, codec).orElseGet(defaultSupplier);}/*** 從 Redis 獲取對象并進行安全解析* 1. 首選類型直返（與緩存編解碼一致時）* 2. 若為字符串則嘗試 JSON 反序列化* 3. 任何異常均捕獲并記錄，返回 Optional.empty()** @param key  緩存鍵* @param type 目標類型* @param <T>  泛型* @return Optional<T> 安全返回*/public static <T> Optional<T> get(String key, Class<T> type, Codec codec) {if (StrUtil.isBlank(key) || ObjectUtil.isNull(type)) {return Optional.empty();}if (!clientReady()) {return Optional.empty();}try {RBucket<Object> bucket;if (codec != null) {bucket = redissonClient.getBucket(key, codec);} else {bucket = redissonClient.getBucket(key);}Object cacheVal = bucket.get();if (cacheVal == null) {return Optional.empty();}T parsed = tryParse(cacheVal, type);return Optional.ofNullable(parsed);} catch (Exception e) {log.error("[RedissonDataUtils] 獲取并解析緩存異常, key={}, type={}, error:", key, type.getSimpleName(), e);return Optional.empty();}}public static <T> List<T> getList(String key, Class<T> elementType) {return getList(key, elementType, null);}/*** 從 Redis 獲取列表并進行安全解析** @param key         緩存鍵* @param elementType 列表元素類型* @param <T>         泛型* @return 不為 null，若無數據返回空列表*/public static <T> List<T> getList(String key, Class<T> elementType, Codec codec) {if (StrUtil.isBlank(key) || ObjectUtil.isNull(elementType)) {return Collections.emptyList();}if (!clientReady()) {return Collections.emptyList();}try {RBucket<Object> bucket;if (codec != null) {bucket = redissonClient.getBucket(key, codec);} else {bucket = redissonClient.getBucket(key);}Object cacheVal = bucket.get();if (cacheVal == null) {return Collections.emptyList();}// 優先處理已反序列化的列表if (cacheVal instanceof List) {try {@SuppressWarnings("unchecked")List<T> list = (List<T>) cacheVal;return CollUtil.isEmpty(list) ? Collections.emptyList() : list;} catch (ClassCastException ex) {// 繼續嘗試 JSON 解析}}// 處理字符串 JSONif (cacheVal instanceof String) {String json = (String) cacheVal;if (StrUtil.isBlank(json)) {return Collections.emptyList();}List<T> list = JSON.parseObject(json, new TypeReference<List<T>>() {});return CollUtil.isEmpty(list) ? Collections.emptyList() : list;}// 兜底：將對象轉字符串再嘗試解析String json = JSON.toJSONString(cacheVal);List<T> list = JSON.parseObject(json, new TypeReference<List<T>>() {});return CollUtil.isEmpty(list) ? Collections.emptyList() : list;} catch (Exception e) {log.error("[RedissonDataUtils] 獲取并解析列表緩存異常, key={}, elementType={}", key, elementType.getSimpleName(), e);return Collections.emptyList();}}/*** 獲取緩存，若不存在則通過回源函數加載并寫入緩存（帶可選 TTL）* 注意：此方法未加分布式鎖，若有并發回源風險，請在業務層配合 Redisson 鎖控制** @param key        緩存鍵* @param type       目標類型* @param loader     回源加載器，返回空時不寫緩存* @param ttlSeconds 過期秒數，<=0 表示不過期* @param <T>        泛型* @return 數據實例或 null* @example redissonDataUtils.getOrLoad("scrm:xx", CustomerDTO.class, () -> service.findById(0L).map(CustomerMapper::toDTO).orElse(null), 1800L);*/public static <T> T getOrLoad(String key, Class<T> type, Supplier<T> loader, long ttlSeconds, Codec codec) {// 先取緩存Optional<T> cached = get(key, type, codec);if (cached.isPresent()) {return cached.get();}if (!clientReady()) {// 客戶端未準備好時，直接回源，但不寫緩存try {return loader == null ? null : loader.get();} catch (Exception e) {log.error("[RedissonDataUtils] 回源加載異常(客戶端未就緒), key={}, type={}", key, type == null ? "null" : type.getSimpleName(), e);return null;}}// 回源加載T loaded;try {loaded = loader == null ? null : loader.get();} catch (Exception e) {log.error("[RedissonDataUtils] 回源加載異常, key={}, type={}", key, type == null ? "null" : type.getSimpleName(), e);return null;}if (loaded == null) {return null;}// 寫緩存（盡量容錯，不影響主流程）try {set(key, loaded, ttlSeconds, codec);} catch (Exception e) {log.warn("[RedissonDataUtils] 寫入緩存失敗(忽略), key={}", key, e);}return loaded;}/*** 寫入緩存（可設置過期時間）** @param key        緩存鍵* @param value      緩存值* @param ttlSeconds 過期秒數，<=0 表示不過期*/public static void set(String key, Object value, long ttlSeconds, Codec codec) {if (StrUtil.isBlank(key)) {return;}if (!clientReady()) {return;}try {RBucket<Object> bucket;if (codec != null) {bucket = redissonClient.getBucket(key, codec);} else {bucket = redissonClient.getBucket(key);}if (ttlSeconds > 0) {bucket.set(value, ttlSeconds, TimeUnit.SECONDS);} else {bucket.set(value);}} catch (Exception e) {log.error("[RedissonDataUtils] 寫入緩存異常, key={}", key, e);}}/*** 嘗試將緩存值解析為目標類型*/private static <T> T tryParse(Object cacheVal, Class<T> type) {if (cacheVal == null) {return null;}// 1) 已經是目標類型if (type.isInstance(cacheVal)) {return type.cast(cacheVal);}// 2) 字符串 JSONif (cacheVal instanceof String) {String json = (String) cacheVal;if (StrUtil.isBlank(json)) {return null;}return JSON.parseObject(json, type);}// 3) 兜底：轉 JSON 再解析String json = JSON.toJSONString(cacheVal);return JSON.parseObject(json, type);}
}

使用示例

• 獲取對象，未獲取到使用默認值

// 1. 使用直接默認值
InfoVo info = RedissonDataUtils.getOrDefault("employee:1001", InfoVo.class, new InfoVo("默認員工", "默認部門")
);// 2. 使用 Supplier 默認值（延遲創建）
InfoVo Info = RedissonDataUtils.getOrDefault("employee:1001", InfoVo.class, () -> {InfoVo defaultVo = new InfoVo();defaultVo.setName("系統生成員工");defaultVo.setDepartment("技術部");defaultVo.setCreateTime(new Date());return defaultVo;}
);// 3. 基本類型示例
Integer userScore = RedissonDataUtils.getOrDefault("user:score:1001", Integer.class, 0
);// 4. 字符串示例
String userName = RedissonDataUtils.getOrDefault("user:name:1001", String.class, "匿名用戶"
);

• 獲取對象

Optional<InfoVo> empOpt = RedissonDataUtils.get(rKey, InfoVo.class);

• 獲取列表

List<InfoVo> list = RedissonDataUtils.getList(rKey, InfoVo.class);

• 緩存未命中則回源并寫緩存（TTL 30 分鐘）

InfoVo vo = RedissonDataUtils.getOrLoad(rKey,InfoVo.class,() -> ucService.loadVo(req.getInfoId()),1800L
);

• 寫緩存

RedissonDataUtils.set(rKey, infoVo, 1800L);