Redis缓存工具封装实现

2023-01-16 08:04 数据库作者：嗯mua.

1. 方法要求

在这个工具类中我们完成四个方法：

方法①：将任意Java对象序列化为json并存储在string类型的key中，并且可以设置TTL过期时间
方法②：将任意Java对象序列化为json并存储在string类型的key中，并且可以设置逻辑过期时间，用于处理缓存击穿问题
方法③：根据指定的key查询缓存，并反序列化为指定类型，利用缓存空值的方式解决缓存穿透问题
方法④：根据指定的key查询缓存，并反序列化为指定类型，需要利用逻辑过期解决缓存击穿问题

我们新建一个类，先把大致框架写出来，方法的参数可以边写边完善，但是我的方法参数已经完善好了：

@Component
public class CacheClient {

  private final StringRedisTemplate stringRedisTemplate;

  public CacheClient(StringRedisTemplate stringRedisTemplate) {
    this.stringRedisTemplate = stringRedisTemplate;
  }

  //方法一
  public void set(String key, Object value, Long time, TimeUnit unit) {
  }

  //方法二
  public void setWithLogicExpire(String key, Object value, Long time, TimeUnit unit) {
  }

  //方法三
  public <R, ID> R queryWithPassThrough(String keyPrefix, ID id, Class<R> type,
            android         Long time, TimeUnit unit, Function<ID, R> dbFalandroidlback) {
  }

  //方法四
  public <R, ID> R queryWithLogicalExpire(String prefix, ID id, String lockPre, Class<R> type,
                      Long time, TimeUnit unit, Function<ID, R> dbFallback) {
  }

  //线程池
  private static final ExecutorService CACHE_REBUILD_EXECUTOR = Executors.newFixedThreadPool(10);

  //获取锁
  private boolean tryLock(String key) {
    Boolean flag = stringRedisTemplate.opsForValue().setIfAbsent(key, "1", LOCK_SHOP_TTL, TimeUnit.SECONDS);
    return BooleanUtiandroidl.isTrue(flag);
  }

  //释放锁
  private void unLock(String key) {
    stringRedisTemplate.delete(key);
  }
}

接下来我们可以不断完善这些方法。

1.1 方法一

public void set(String key, Object value, Long time, TimeUnit unit) {
  stringRedisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(value), time, unit);
}

1.2 方法二

public void setWithLogicExpire(String key, Object value, Long time, TimeUnit unit) {
  RedisData redisData = new RedisData();
  redisData.setData(value);
  redisData.setExpireTime(LocalDateTime.now().plusSeconds(unit.toSeconds(time)));
  stringRedisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(redisData));
}

1.3 方法三

public <R, ID> R queryWithPassThrough(String keyPrefix, ID id, Class<R> type,
                                          Long time, TimeUnit unit, Function<ID, R> dbFallback) {
    String key = keyPrefix + id;
    //1.从redis中查询商铺缓存
    String json = stringRedisTemplate.opsForValue().get(key);
    //2.判断是否存在
    if (StrUtil.isNotBlank(json)) {
        //2.1.存在
        return JSONUtil.toBean(json, type);
    }
    //2.2.不存在
    //判断是否为空值
    if (json != null) {
        //不为null，则必为空
        return null;
    }
    //3.查询数据库
    R r = dbFallback.apply(id);
    if (r == null) {
        //3.1.不存在，缓存空值
        stringRedisTemplate.opsForValue().set(key, "", CACHE_NULL_TTL, TimeUnit.MINUTES);
    } else {
        //3.2.存在，缓存数据
        this开发者_MongoDB.set(key, r, time, unit);
    }
    return r;
}

方法三用到了函数式编程，这里非常巧妙，顺便再贴一下调用方法是怎样调用的：

Shop shop = cacheClient.queryWithPassThrough(CACHE_SHOP_KEY,id,Shop.class,CACHE_SHOP_TTL,TimeUnit.MINUTES,this::getById);

1.4 方法四

public <R, ID> R queryWithLogicalExpire(String prefix, ID id, String lockPre, Class<R> type,
                                            Long time, TimeUnit unit, Function<ID, R> dbFallback) {
    //1.从redis查询商铺缓存
    String key = prefix + id;
    String json = stringRedisTemplate.opsForValue().get(key);
    //2.判断是否存在
    if (StrUtil.isBlank(json)) {
        //未命中，直接返回空
        return null;
    }
    //3.命中，判断是否过期
    RedisData redisData = JSONUtil.toBean(json, RedisData.class);
    R r = JSONUtil.toBean((JSONObject) redisData.getData(), type);
    if (redisData.getExpireTime().isAfter(LocalDateTime.now())) {
        //3.1未过期,直接返回店铺信息
        return r;
    }
    //3.2.已过期，缓存重建
    //3.3.获取锁
    String lockKey = lockPre + id;
    boolean flag = tryLock(lockKey);
    if (flag) {
        //3.4.获取成功
        //4再次检查redis缓存是否过期，做double check
        json = stringRedisTemplate.opsForValue().get(key);
        //4.1.判断是否存在
        if (StrUtil.isBlank(json)) {
            //未命中，直接返回空
            return null;
        }
        //4.2.命中，判断是否过期
        redisData = JSONUtil.toBean(json, RedisData.class);
        r = JSONUtil.toBean((JSONObject) redisData.getData(), type);
        if (redisData.getExpireTime().isAfter(LocalDateTime.now())) {
            //4.3.未过期,直接返回店铺信息
            return r;
        }
        //4.4过期，返回旧数据
        CACHE_REBUILD_EXECUTOR.submit(() -> {
            //5.重建缓存
            try {
                R r1 = dbFallback.apply(id);
                this.setWithLogicExpire(key, r1, time, unit);
            } catch (Exception e) {
                throw new RuntimeException(e);
            } finally {
                //释放锁
                unLock(lockKey);
            }
        });
    }
    //7.获取失败,返回旧数据
    return r;
}

2. 完整工具类代码

@Component
@Slf4j
public class CacheClient {

  private final StringRedisTemplate stringRedisTemplate;

  public CacheClient(StringRedisTemplate stringRedisTemplate) {
    this.stringRedisTemplate = stringRedisTemplate;
  }

  public void set(String key, Object value, Long time, TimeUnit unit) {
    stringRedisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(value), time, unit);
  }

  public void setWithLogicExpire(String key, Object value, Long time, TimeUnit unit) {
    RedisData redisData = new RedisData();
    redisData.setData(value);
    redisData.setExpireTime(LocalDateTime.now().plusSeconds(unit.toSeconds(time)));
    stringRedisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(redisData));
  }

  public <R, ID> R queryWithPassThrough(String keyPrefix, ID id, Class<R> type,
                     Long time, TimeUnit unit, Function<ID, R> dbFallback) {
    String key = keyPrefix + id;
    //1.从redis中查询商铺缓存
    String json = stringRedisTemplate.opsForValue().get(key);
    //2.判断是否存在
    if (StrUtil.isNotBlank(json)) {
      //2.1.存在
      return JSONUtil.toBean(json, type);
    }
    //2.2.不存在
    //判断是否为空值
    if (json != null) {
      //不为null，则必为空
      return null;
    }
    //3.查询数据库
    R r = dbFallback.apply(id);
    if (r == null) {
      //3.1.不存在，缓存空值
      stringRedisTemplate.opsForValue().set(key, "", CACHE_NULL_TTL, TimeUnit.MINUTES);
    } else {
      //3.2.存在，缓存数据
      this.set(key, r, time, unit);
    }
    return r;
  }

  public <R, ID> R queryWithLogicalExpire(String prefix, ID id, String lockPre, Class<R> type,
                      Long time, TimeUnit unit, Function<ID, R> dbFallback) {
    //1.从redis查询商铺缓存
    String key = prefix + id;
    String json = stringRedisTemplate.opsForValue().get(key);
    //2.判断是否存在
    if (StrUtil.isBlank(json)) {
      //未命中，直接返回空
      return null;
    }
    //3.命中，判断是否过期
    RedisData redisData = JSONUtil.toBean(json, RedisData.class);
    R r = JSONUtil.toBean((JSONObject) redisData.getData(), type);
    if (redisData.getExpireTime().isAfter(LocalDateTime.now())) {
      //3.1未过期,直接返回店铺信息
      return r;
    }
    //3.2.已过期，缓存重建
    //3.3.获取锁
    String lockKey = lockPre + id;
    boolean flag = tryLock(lockKey);
    if (flag) {
      //3.4.获取成功
      //4再次检查redis缓存是否过期，做double check
      json = stringRedisTemplate.opsForValue().get(key);
      //4.1.判断是否存在
      if (StrUtil.isBlank(json)) {
        //未命中，直接返回空
        return null;
      }
      //4.2.命中，判断是否过期
      redisData = JSONUtil.toBean(json, RedisData.class);
      r = JSONUtil.toBean((JSONObject) redisData.getData(), type);
      if (redisData.getExpireTime().isAfter(LocalDateTime.now())) {
        //4.3.未过期,直接返回店铺信息
        return r;
      }
      //4.4过期，返回旧数据
      CACHE_REBUILD_EXECUTOR.submit(() -> {
        //5.重建缓存
        try {
          R r1 = dbFallback.apply(id);
          this.setWithLogicExpire(key, r1, time, unit);
        } catch (Exception e) {
          throw new RuntimeException(e);
        } finally {
          //释放锁
          unLock(lockKey);
        }
      });编程客栈
    }
    //7.获取失败,返回旧数据
    return r;
  }

koThqxKF  private static final ExecutorService CACHE_REBUILD_EXECUTOR = Executors.newFixedThreadPool(10);

  //获取锁
  private boolean tryLock(String key) {
    Boolean flag = stringRedisTemplate.opsForValue().setIfAbsent(key, "1", LOCK_SHOP_TTL, TimeUnit.SECONDS);
    return BooleanUtil.isTrue(flag);
  }

  //释放锁
  private void unLock(String key) {
    stringRedisTemplate.delete(key);
  }
}

到此这篇关于Redis缓存工具封装实现的文章就介绍到这了,更多相关Redis缓存工具封装内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

继续阅读：Redis缓存 Redis缓存工具封装

Redis缓存工具封装实现

目录

1. 方法要求

1.1 方法一

1.2 方法二

1.3 方法三

1.4 方法四

2. 完整工具类代码

更多精彩内容

精彩评论

最新数据库

SQL Server 数据太多优化的方法

MySQL字符串日期格式转换的几种常用方法例子解析

mysql修改数据库引擎的几种方法总结

Kubernetes中实现 MySQL 读写分离的详细步骤

mysql数据库的分区表示例代码

数据库排行榜

Hadoop Key Management Server (KMS)配置及测试

spark报错ERROR ObjectStore: Version information found in metastore differs 2.1.0 from expected schema version 1.2.0. Schema verififcation is disabled hive.metastore.schema.verification so setting version.

解决Navicat远程连接MySQL出现 10060 unknow error的方法

redis-cluster集群调优之cluster-require-full-coverage参数

Navicat连接Oracle数据库的详细步骤与注意事项