緩存

@Autowired
StringRedisTemplate stringRedisTemplate;

@Test
void test1() {
    ValueOperations<String, String> ops = stringRedisTemplate.opsForValue();
    ops.set("hello", "world_" + UUID.randomUUID());
    System.out.println("ops.get(\"hello\") = " + ops.get("hello"));
}

// 從redis獲取所有分類
@Override
public Map<String, List<Catalogs2Vo>> getCatalogJson() {
    // 先去緩存拿
    ValueOperations<String, String> ops = stringRedisTemplate.opsForValue();
    String catalogJson = ops.get("catalogJson");
    if (StringUtils.isBlank(catalogJson)) {
        // 緩存沒資料，去DB拿，且存到緩存中
        Map<String, List<Catalogs2Vo>> catalogJsonFromDb = this.getCatalogJsonFromDb();
        // 為了方便統一交流，redis放的都是JSON序列化後的
        String s = JSON.toJSONString(catalogJsonFromDb);
        // 設定過期時間
        ops.set("catalogJson", s, 10, TimeUnit.MINUTES);
        return catalogJsonFromDb;
    }
    // 把取出的JSONstring反序列化，使用TypeReference指名泛型
    Map<String, List<Catalogs2Vo>> stringListMap = JSON.parseObject(catalogJson, new TypeReference<Map<String,
            List<Catalogs2Vo>>>() {
    });
    return stringListMap;
}

// 從DB獲取所有分類，且二、三級分類以封裝好
public Map<String, List<Catalogs2Vo>> getCatalogJsonFromDb() {
    // spring預設是單例所以可以用this
    synchronized (this) {
        // 雙重檢驗，拿到鎖也不急著查DB，先看看緩存
        ValueOperations<String, String> ops = stringRedisTemplate.opsForValue();
        String catalogJson = ops.get("catalogJson");
        if (!StringUtils.isBlank(catalogJson)) {
            // 緩存有了，拿緩存的就滾吧
            return JSON.parseObject(catalogJson,
                    new TypeReference<Map<String,
                            List<Catalogs2Vo>>>() {
                    });
        }
        // 查庫，放緩存的動作省略
    }

// 分布式鎖
public Map<String, List<Catalogs2Vo>> getCatalogJsonFromRedisLock() {
    Boolean lock = stringRedisTemplate.opsForValue().setIfAbsent("lock", "123", 30, TimeUnit.SECONDS);
    if (lock) {
        // 能放到值，相當於搶到鎖了，執行業務，並且走之前要刪掉值
        // stringRedisTemplate.expire("lock",30,TimeUnit.SECONDS); 不保險，沒原子性，如果在這之前斷電就GG
        stringRedisTemplate.delete("lock");
        return getCatalogJsonFromDb();
    } else {
        // 沒搶到，等會重試
        return getCatalogJsonFromRedisLock(); // 自旋
        // 等待一段時間之類的操作
    }
}

// 分布式鎖
public Map<String, List<Catalogs2Vo>> getCatalogJsonFromRedisLock() {
    String uuid = UUID.randomUUID().toString();
    Boolean lock = stringRedisTemplate.opsForValue().setIfAbsent("lock", uuid, 30, TimeUnit.SECONDS);
    if (lock) {
        // 能放到值，相當於搶到鎖了，執行業務，並且走之前要刪掉值
        try {
            return getCatalogJsonFromDb();
        } finally {
            // 刪除鎖的lua腳本，不用太在意複製貼上就好
            String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else" +
                    " " +
                    "return 0 end";
            stringRedisTemplate.execute(new DefaultRedisScript<Long>(script, Long.class), Arrays.asList("lock"),
                    uuid);
        }
    } else {
        // 沒搶到，等會重試
        // 等待一段時間
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return getCatalogJsonFromRedisLock(); // 自旋
    }
}