管理系统是网站吗,网站建设台州,长春建站,相亲网站怎么做基于StringRedisTemplate封装一个缓存工具类#xff0c;满足下列需求#xff1a; 方法1#xff1a;将任意Java对象序列化为json并存储在string类型的key中#xff0c;并且可以设置TTL过期时间 方法2#xff1a;将任意Java对象序列化为json并存储在string类型的key中…基于StringRedisTemplate封装一个缓存工具类满足下列需求 方法1将任意Java对象序列化为json并存储在string类型的key中并且可以设置TTL过期时间 方法2将任意Java对象序列化为json并存储在string类型的key中并且可以设置逻辑过期时间用于处理缓
存击穿问题 方法3根据指定的key查询缓存并反序列化为指定类型利用缓存空值的方式解决缓存穿透问题 方法4根据指定的key查询缓存并反序列化为指定类型需要利用逻辑过期解决缓存击穿问题
将逻辑进行封装
CacheClient.java
Slf4j
Component
public class CacheClient {private final StringRedisTemplate stringRedisTemplate;public CacheClient(StringRedisTemplate stringRedisTemplate) {this.stringRedisTemplate stringRedisTemplate;}/*** 设置指定key对应的value值使用JSON格式化字符串转换value对象为字符串进行存储。* param key 要设置的key值* param value 要设置的value值* param time 过期时间* param unit 过期时间的单位*/public void set(String key, Object value, Long time, TimeUnit unit) {stringRedisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(value), time, unit);}/*** 设置具有逻辑过期时间的值到指定的 key 中。** param key 要设置的 key* param value 要设置的值* param time 过期时间单位秒* param unit 过期时间的单位*/public void setWithLogicalExpire(String key, Object value, Long time, TimeUnit unit) {// 创建 RedisData 对象用于存储数据和过期时间RedisData redisData new RedisData();redisData.setData(value);// 设置过期时间为当前时间加上传入的秒数redisData.setExpireTime(LocalDateTime.now().plusSeconds(unit.toSeconds(time)));// 将 RedisData 对象转换成 JSON 字符串并设置到指定的 key 中stringRedisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(redisData));}/*** 通过传递的参数进行查询操作并使用PassThroughExecutor进行缓存查询和数据库查询的 fallback 处理。** param keyPrefix 键的前缀* param id 对应的ID值* param type 查询结果的目标类型* param dbFallback 数据库查询的 fallback 函数* param time 缓存有效时间* param unit 时间单位* return 查询结果*/public R, T R queryWithPassThrough(String keyPrefix, T id, ClassR type, FunctionT, R dbFallback, Long time, TimeUnit unit) {String key keyPrefix id;// 从Redis中查询缓存String json stringRedisTemplate.opsForValue().get(key);if (StrUtil.isNotBlank(json)) {return JSONUtil.toBean(json, type);}if (json ! null) {return null;}R r dbFallback.apply(id);if (r null) {stringRedisTemplate.opsForValue().set(CACHE_SHOP_KEY id, , RedisConstants.CACHE_NULL_TTL, TimeUnit.MINUTES);return null;}this.set(key, r, time, unit);return r;}private static final ExecutorService CACHE_REBUILD_EXECUTOR Executors.newFixedThreadPool(10);/*** 使用逻辑过期时间查询缓存* param keyPrefix 键的前缀* param id 对应的id* param type 缓存对象的类型* param dbFallback 数据库回退函数* param time 过期时间* param unit 时间单位* return 查询结果*/public R, T R queryWithLogicalExpire(String keyPrefix, T id, ClassR type, FunctionT, R dbFallback, Long time, TimeUnit unit) {// 从Redis查询缓存String key keyPrefix id;String json stringRedisTemplate.opsForValue().get(key);if (StrUtil.isBlank(json)) {return null;}// 判断过期时间RedisData redisData JSONUtil.toBean(json, RedisData.class);R r JSONUtil.toBean((JSONObject) redisData.getData(), type);LocalDateTime expireTime redisData.getExpireTime();if (expireTime.isAfter(LocalDateTime.now())) {return r;}String locKey LOCK_SHOP_KEY id;boolean isLock tryLock(locKey);if (isLock) {// 开启线程重建缓存CACHE_REBUILD_EXECUTOR.submit(() - {try {R r1 dbFallback.apply(id);this.setWithLogicalExpire(key, r1, time, unit);} catch (Exception e) {throw new RuntimeException(e);} finally {unLock(locKey);}});}return r;}/*** 尝试获取锁* param key 锁的键值* return 如果成功获取锁返回true否则返回false*/private boolean tryLock(String key) {Boolean flag stringRedisTemplate.opsForValue().setIfAbsent(key, 1, 10, TimeUnit.SECONDS);return BooleanUtil.isTrue(flag);}/*** 删除指定key对应的value值** param key 要删除的key值*/private void unLock(String key) {Boolean flag stringRedisTemplate.delete(key);}}
