Java 设计代码redis在缓存销毁前，把数值存到库里

以下是 Java 设计代码 Redis 在缓存销毁前，把数值存到库里的示例代码：

public class RedisCache {
    private RedisTemplate<String, Object> redisTemplate;
    private CacheManager cacheManager;
    private String cacheName;
    private Long expireTime;
    private String lockKey;

    public RedisCache(RedisTemplate<String, Object> redisTemplate, CacheManager cacheManager, String cacheName, Long expireTime, String lockKey) {
        this.redisTemplate = redisTemplate;
        this.cacheManager = cacheManager;
        this.cacheName = cacheName;
        this.expireTime = expireTime;
        this.lockKey = lockKey;
    }

    public Object get(Object key) {
        Cache cache = cacheManager.getCache(cacheName);
        Cache.ValueWrapper valueWrapper = cache.get(key);
        if (valueWrapper != null) {
            return valueWrapper.get();
        }
        return null;
    }

    public void put(Object key, Object value) {
        Cache cache = cacheManager.getCache(cacheName);
        cache.put(key, value);
        redisTemplate.opsForValue().set(key.toString(), value, expireTime, TimeUnit.SECONDS);
    }

    public void evict(Object key) {
        Cache cache = cacheManager.getCache(cacheName);
        cache.evict(key);
        redisTemplate.delete(key.toString());
    }

    public void clear() {
        Cache cache = cacheManager.getCache(cacheName);
        cache.clear();
        redisTemplate.delete(cacheName + ":*");
    }

    public void setExpireTime(Long expireTime) {
        this.expireTime = expireTime;
    }

    public void setLockKey(String lockKey) {
        this.lockKey = lockKey;
    }

    public void onRemove(Object key, Object value, Cache cache) {
        // 异步执行回调函数
        new Thread(() -> {
            // 加分布式锁
            RLock lock = redisTemplate.getLock(lockKey);
            try {
                lock.lock();
                // 判断缓存是否存在
                if (redisTemplate.hasKey(key.toString())) {
                    // 更新数据库中的数值
                    updateDatabase(key, value);
                } else {
                    // 插入一条新的数据到数据库中
                    insertIntoDatabase(key, value);
                }
            } finally {
                lock.unlock();
            }
        }).start();
    }

    private void updateDatabase(Object key, Object value) {
        // 更新数据库中的数值
        // ...
    }

    private void insertIntoDatabase(Object key, Object value) {
        // 插入一条新的数据到数据库中
        // ...
    }
}

在上述代码中，我们在 `put` 方法中将缓存的值存到 Redis 中，并设置了过期时间。在 `evict` 方法中，我们删除了 Redis 中的缓存。在 `onRemove` 方法中，我们在删除 Redis 缓存前异步执行了一个回调函数，用于将缓存中的数据存到数据库中。回调函数的执行放到了一个异步线程中，避免阻塞 Redis 服务器。我们还使用了分布式锁，保证了数据的一致性。