Redis+Guava，性能炸裂！

// 伪代码示例 Xx代表你的的业务对象 如User Goods等等public class XxLazyCache {
    @Autowired    private RedisTemplate<String, Xx> redisTemplate;        @Autowired    private XxService xxService;// 你的业务service        /**     * 查询 通过查询缓存是否存在驱动缓存加载 建议在前置业务保证id对应数据是存在于数据库中的     */    public Xx getXx(int id) {        // 1.查询缓存里面有没有数据        Xx xxCache = getXxFromCache(id);        if(xxCache != null) {            return xxCache;// 卫语句使代码更有利于阅读        }        // 2.查询数据库获取数据 我们假定到业务这一步，传过来的id都在数据库中有对应数据        Xx xx = xxService.getXxById(id);        // 3.设置缓存、这一步相当于Redis缓存懒加载，下次再查询此id，则会走缓存        setXxFromCache(xx);        return xx;        }    }        /**     * 对xx数据进行修改或者删除操作 操作数据库成功后 删除缓存     * 删除请求 - 删除数据库数据 删除缓存     * 修改请求 - 更新数据库数据 删除缓存 下次在查询时候就会从数据库拉取新的数据到缓存中     */    public void deleteXxFromCache(long id) {        String key = "Xx:" + xx.getId();        redisTemplate.delete(key);    }        private void setXxFromCache(Xx xx) {        String key = "Xx:" + xx.getId();        redisTemplate.opsForValue().set(key, xx);    }        private Xx getXxFromCache(int id) {        // 通过缓存前缀拼装主键作为缓存Key 如Xxx信息 就是Xxx:id        String key = "Xx:" + id;        return redisTemplate.opsForValue().get(key);    }    }// 业务类public class XxServie {    @Autowired    private XxLazyCache xxLazyCache;    // 查询数据库    public Xx getXxById(long id) {        // 省略实现        return xx;    }        public void updateXx(Xx xx) {        // 更新MySQL数据 省略        // 删除缓存        xxLazyCache.deleteXxFromCache(xx.getId());    }        public void deleteXx(long id) {        // 删除MySQL数据 省略        // 删除缓存        xxLazyCache.deleteXxFromCache(xx.getId());    }}// 实体类@Datapublic class Xx {    // 业务主键    private Long id;    // ...省略}

/** * 此缓存演示如何结合redis自增数 hash 本地缓存使用进行设备自增数的生成、缓存、本地缓存 * 本地缓存使用Guava Cache */public class DeviceIncCache {
    /**     * 本地缓存     */    private Cache<String, Integer> localCache = CacheBuilder.newBuilder()        .concurrencyLevel(16) // 并发级别        .initialCapacity(1000) // 初始容量        .maximumSize(10000) // 缓存大长度        .expireAfterAccess(1, TimeUnit.HOURS) // 缓存1小时没被使用就过期        .build();
    @Autowired    private RedisTemplate<String, Integer> redisTemplate;        /**     * redis自增数缓存的key     */    private static final String DEVICE_INC_COUNT = "device_inc_count";        /**     * redis设备编码对应自增数的hash缓存key     */    private static final String DEVICE_INC_VALUE = "device_inc_value";        /**     * 获取设备自增数     */    public int getInc(String deviceCode){        // 1.从本地缓存获取        Integer inc = localCache.get(deviceCode);        if(inc != null) {            return inc;        }        // 2.本地缓存未命中，从redis的hash缓存获取        inc = (Integer)redisTemplate.opsForHash().get(DEVICE_INC_VALUE, deviceCode);        // 3. redis的hash缓存中没有，说明是新设备，先为设备生成一个自增号        if(inc == null) {            inc = redisTemplate.opsForValue().increment(DEVICE_INC_COUNT).intValue;            // 添加到redis hash缓存            redisTemplate.opsForHash().put(DEVICE_INC_VALUE, deviceCode, inc);        }        // 4.添加到本地缓存        localCache.put(deviceCode, inc);        // 4.返回自增数        return inc;    }    }