摘要：和注解的方法返回值要一致刪除緩存在需要刪除緩存的方法上加注解，執行完這個方法之后會將中對應的記錄刪除。代表返回值，意思是當返回碼不等于時不緩存，也就是等于時才緩存。返回值特定值如果被設置了如果沒有被設置例子自動將對應到并且返回原來對應的。

本文主要講 Redis 的使用，如何與 SpringBoot 項目整合，如何使用注解方式和 RedisTemplate 方式實現緩存。最后會給一個用 Redis 實現分布式鎖，用在秒殺系統中的案例。

更多 Redis 的實際運用場景請關注開源項目 coderiver

項目地址：https://github.com/cachecats/...

NoSQL(NoSQL = Not Only SQL )，意即“不僅僅是SQL”，泛指非關系型的數據庫。

隨著互聯網web2.0網站的興起，傳統的關系數據庫在應付web2.0網站，特別是超大規模和高并發的SNS類型的web2.0純動態網站已經顯得力不從心，暴露了很多難以克服的問題，而非關系型的數據庫則由于其本身的特點得到了非常迅速的發展。NoSQL數據庫的產生就是為了解決大規模數據集合多重數據種類帶來的挑戰，尤其是大數據應用難題。 -- 百度百科

鍵值（key-value）存儲

列存儲

文檔數據庫

圖形數據庫

易擴展

靈活的數據模型

大數據量，高性能

高可用

緩存

任務隊列

網站訪問統計

應用排行榜

數據過期處理

分布式集群架構中的 session 分離

網上有很多 Redis 的安裝教程，這里就不多說了，只說下 Docker 的安裝方法：

Docker 安裝運行 Redis

docker run -d -p 6379:6379 redis:4.0.8

如果以后想啟動 Redis 服務，打開命令行，輸入以下命令即可。

redis-server

使用前先引入依賴

    org.springframework.boot
    spring-boot-starter-data-redis

使用緩存有兩個前置步驟

在 pom.xml 引入依賴

    org.springframework.boot
    spring-boot-starter-data-redis

在啟動類上加注解 @EnableCaching

@SpringBootApplication
@EnableCaching
public class SellApplication {
    public static void main(String[] args) {
        SpringApplication.run(SellApplication.class, args);
    }
}

常用的注解有以下幾個

@Cacheable

屬性如下圖

用于查詢和添加緩存，第一次查詢的時候返回該方法返回值，并向 Redis 服務器保存數據。

以后調用該方法先從 Redis 中查是否有數據，如果有直接返回 Redis 緩存的數據，而不執行方法里的代碼。如果沒有則正常執行方法體中的代碼。

value 或 cacheNames 屬性做鍵，key 屬性則可以看作為 value 的子鍵， 一個 value 可以有多個 key 組成不同值存在 Redis 服務器。

驗證了下，value 和 cacheNames 的作用是一樣的，都是標識主鍵。兩個屬性不能同時定義，只能定義一個，否則會報錯。

condition 和 unless 是條件，后面會講用法。其他的幾個屬性不常用，其實我也不知道怎么用…

@CachePut

更新 Redis 中對應鍵的值。屬性和 @Cacheable 相同

@CacheEvict

刪除 Redis 中對應鍵的值。

在需要加緩存的方法上添加注解 @Cacheable(cacheNames = "product", key = "123"),

cacheNames 和 key 都必須填，如果不填 key ，默認的 key 是當前的方法名，更新緩存時會因為方法名不同而更新失敗。

如在訂單列表上加緩存

    @RequestMapping(value = "/list", method = RequestMethod.GET)
    @Cacheable(cacheNames = "product", key = "123")
    public ResultVO list() {

        // 1.查詢所有上架商品
        List productInfoList = productInfoService.findUpAll();

        // 2.查詢類目（一次性查詢）
        //用 java8 的特性獲取到上架商品的所有類型
        List categoryTypes = productInfoList.stream().map(e -> e.getCategoryType()).collect(Collectors.toList());
        List productCategoryList = categoryService.findByCategoryTypeIn(categoryTypes);

        List productVOList = new ArrayList<>();
        //數據拼裝
        for (ProductCategory category : productCategoryList) {
            ProductVO productVO = new ProductVO();
            //屬性拷貝
            BeanUtils.copyProperties(category, productVO);
            //把類型匹配的商品添加進去
            List productInfoVOList = new ArrayList<>();
            for (ProductInfo productInfo : productInfoList) {
                if (productInfo.getCategoryType().equals(category.getCategoryType())) {
                    ProductInfoVO productInfoVO = new ProductInfoVO();
                    BeanUtils.copyProperties(productInfo, productInfoVO);
                    productInfoVOList.add(productInfoVO);
                }
            }
            productVO.setProductInfoVOList(productInfoVOList);
            productVOList.add(productVO);
        }

        return ResultVOUtils.success(productVOList);
    }

可能會報如下錯誤

對象未序列化。讓對象實現 Serializable 方法即可

@Data
public class ProductVO implements Serializable {
    
    private static final long serialVersionUID = 961235512220891746L;

    @JsonProperty("name")
    private String categoryName;

    @JsonProperty("type")
    private Integer categoryType;

    @JsonProperty("foods")
    private List productInfoVOList ;
}

生成唯一的 id 在 IDEA 里有一個插件：GenerateSerialVersionUID 比較方便。

重啟項目訪問訂單列表，在 rdm 里查看 Redis 緩存，有 product::123 說明緩存成功。

在需要更新緩存的方法上加注解： @CachePut(cacheNames = "prodcut", key = "123")

注意

cacheNames 和 key 要跟 @Cacheable() 里的一致，才會正確更新。

@CachePut() 和 @Cacheable() 注解的方法返回值要一致

在需要刪除緩存的方法上加注解：@CacheEvict(cacheNames = "prodcut", key = "123")，執行完這個方法之后會將 Redis 中對應的記錄刪除。

cacheNames 也可以統一寫在類上面， @CacheConfig(cacheNames = "product") ，具體的方法上就不用寫啦。

@CacheConfig(cacheNames = "product")
public class BuyerOrderController {
    @PostMapping("/cancel")
    @CachePut(key = "456")
    public ResultVO cancel(@RequestParam("openid") String openid,
                           @RequestParam("orderId") String orderId){
        buyerService.cancelOrder(openid, orderId);
        return ResultVOUtils.success();
    }
}

Key 也可以動態設置為方法的參數

@GetMapping("/detail")
@Cacheable(cacheNames = "prodcut", key = "#openid")
public ResultVO detail(@RequestParam("openid") String openid,
                             @RequestParam("orderId") String orderId){
    OrderDTO orderDTO = buyerService.findOrderOne(openid, orderId);
    return ResultVOUtils.success(orderDTO);
}

如果參數是個對象，也可以設置對象的某個屬性為 key。比如其中一個參數是 user 對象，key 可以寫成 key="#user.id"

緩存還可以設置條件。

設置當 openid 的長度大于3時才緩存

@GetMapping("/detail")
@Cacheable(cacheNames = "prodcut", key = "#openid", condition = "#openid.length > 3")
public ResultVO detail(@RequestParam("openid") String openid,
                                 @RequestParam("orderId") String orderId){
    OrderDTO orderDTO = buyerService.findOrderOne(openid, orderId);
    return ResultVOUtils.success(orderDTO);
}

還可以指定 unless 即條件不成立時緩存。#result 代表返回值，意思是當返回碼不等于 0 時不緩存，也就是等于 0 時才緩存。

@GetMapping("/detail")
@Cacheable(cacheNames = "prodcut", key = "#openid", condition = "#openid.length > 3", unless = "#result.code != 0")
public ResultVO detail(@RequestParam("openid") String openid,
                                 @RequestParam("orderId") String orderId){
    OrderDTO orderDTO = buyerService.findOrderOne(openid, orderId);
    return ResultVOUtils.success(orderDTO);
}

與使用注解方式不同，注解方式可以零配置，只需引入依賴并在啟動類上加上 @EnableCaching 注解就可以使用；而使用 RedisTemplate 方式麻煩些，需要做一些配置。

第一步還是引入依賴和在啟動類上加上 @EnableCaching 注解。

然后在 application.yml 文件中配置 Redis

spring:
  redis:
    port: 6379
    database: 0
    host: 127.0.0.1
    password:
    jedis:
      pool:
        max-active: 8
        max-wait: -1ms
        max-idle: 8
        min-idle: 0
    timeout: 5000ms

然后寫個 RedisConfig.java 配置類

package com.solo.coderiver.user.config;

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;

import java.net.UnknownHostException;


@Configuration
public class RedisConfig {

    @Bean
    @ConditionalOnMissingBean(name = "redisTemplate")
    public RedisTemplate redisTemplate(
            RedisConnectionFactory redisConnectionFactory)
            throws UnknownHostException {

        Jackson2JsonRedisSerializer