用泛型写Redis缓存与数据库操作工具类

/**
 * 普通数据获取器
 * 
 */
public interface DataGeter<T> {

    /**
     * 获取数据接口
     * @return
     */
    public T getData();
}

public class DataUtil {

    /**json转换工具*/
    private static Gson gson = new Gson();
    
    /**一天的过期秒数*/
    private static final int ONE_DAY_EXPIRE_SECONDS = 1 * 24 * 60 * 60;

    /**
     * 获取redis中获取指定data，如果redis中不存在，则从DataGeter接口中获取，并且写入redis<br/>
     * 注：该方法会自动创建一个cacheKey + "_flag"的缓存key，作为标记flagKey
     * @param cacheKey-缓存key
     * @param clazz-获取目标类型
     * @param dataGeter-数据获取器，原始数据源
     * @param expireSeconds-缓存失效时间
     * @return
     */
    public static <T> T getDataFromRedisOrDataGeter(String cacheKey, Class<T> clazz, DataGeter<T> dataGeter,int expireSeconds) {
        
        T val = RedisClient.getValue(cacheKey, clazz);
        if (val != null) {
            //让热数据一直热下去 <单个key/value>，设置缓存有效期。
            haveChanceToSetKeyExpireTime( cacheKey, expireSeconds) ;
            return val;
        }
        if (RedisClient.existsKey(RedisClient.getFlagKey(cacheKey))) {
            return null;
        }
        
        try {
　　　　　　　　//本地锁
            Object lockObject = LockObjectUtil.getLockObject(cacheKey);
            synchronized (lockObject) {// 为提升性能 这里不使用分布式锁
                // 标记key，防止集合为空时还不停从数据库中读取数据
                T data = null;
                try {
                    data = dataGeter.getData();
                } catch (DBException e) {
                    e.printStackTrace();
                    throw e;
                }
                if (data != null) {
                    // 这里最后才设置flag，以免分布式环境下dataGeter.getData();获取慢，导致后续请求从缓存中取不到数据
                    //有值不设置flag
                    RedisClient.setValue(cacheKey, data, expireSeconds <= 0 ? RedisDataSource.DEFAULT_EXPIRE_SECONDS : expireSeconds, false);
                } else {
                    // 不存在数据则往缓存中插入一个flag，过期时间为一天
                    RedisClient.setValue(RedisClient.getFlagKey(cacheKey), true, ONE_DAY_EXPIRE_SECONDS);
                }
                return data;
            }
        } finally {
            //释放锁
            LockObjectUtil.disposeLock(cacheKey);
        }
    
    }

}