溫馨提示×

您好，登錄后才能下訂單哦！

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

spring-boot-2.0.3之redis緩存實(shí)現(xiàn)，不是你想的那樣哦

發(fā)布時(shí)間：2020-07-31 21:26:24 來(lái)源：網(wǎng)絡(luò) 閱讀：5237 作者：小楊Java 欄目：大數(shù)據(jù)

前言
　　開(kāi)心一刻

　　　　小白問(wèn)小明：“你前面有一個(gè)5米深的坑，里面沒(méi)有水，如果你跳進(jìn)去后該怎樣出來(lái)了？”小明：“躺著出來(lái)唄，還能怎么出來(lái)？”小白：“為什么躺著出來(lái)？”小明：“5米深的坑，還沒(méi)有水，跳下去不死就很幸運(yùn)了，殘是肯定會(huì)殘的，不躺著出來(lái)，那能怎么出來(lái)？”小白：“假設(shè)沒(méi)死也沒(méi)殘呢？”小明：“你當(dāng)我超人了？ 那也簡(jiǎn)單，把腦子里的水放出來(lái)就可以漂出來(lái)了。”小白：“你腦子里有這么多水嗎？”小明：“我腦子里沒(méi)那么多水我跳下去干嘛？”　

　　路漫漫其修遠(yuǎn)兮，吾將上下而求索！

　　springboot 1.x到2.x變動(dòng)的內(nèi)容還是挺多的，而2.x之間也存在細(xì)微的差別，本文不講這些差別（具體差別我也不知道，汗......），只講1.5.9與2.0.3的redis緩存配置的區(qū)別

回到頂部
springboot1.5.9緩存配置
　　工程實(shí)現(xiàn)
　　　　1.x系列配置應(yīng)該都差不多，下面我們看看1.5.9中，springboot集成redis的緩存實(shí)現(xiàn)

　　　　pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>

<groupId>com.lee</groupId>
<artifactId>spring-boot159.cache</artifactId>
<version>1.0-SNAPSHOT</version>

<properties>
    <java.version>1.8</java.version>
</properties>

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.5.9.RELEASE</version>
</parent>

<dependencies>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-redis</artifactId>
    </dependency>

</dependencies>

</project>
application.yml

　　server:
port: 8888
spring:
#redis配置
redis:
database: 0
host: 127.0.0.1
port: 6379
password:

連接超時(shí)時(shí)間（毫秒）

timeout: 2000
pool:

連接池最大連接數(shù)（使用負(fù)值表示沒(méi)有限制）

max-active: 8

連接池最大阻塞等待時(shí)間（使用負(fù)值表示沒(méi)有限制）

max-wait: -1

連接池中的最大空閑連接

max-idle: 8

連接池中的最小空閑連接

min-idle: 0
cache:
type: redis
cache:
expire-time: 180　　

　　　　RedisCacheConfig.java

package com.lee.cache.config;

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cache.CacheManager;
import org.springframework.cache.annotation.CachingConfigurerSupport;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.cache.interceptor.KeyGenerator;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.cache.RedisCacheManager;
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;

/**

  • 必須繼承CachingConfigurerSupport，不然此類中生成的Bean不會(huì)生效（沒(méi)有替換掉默認(rèn)生成的，只是一個(gè)普通的bean）
  • springboot默認(rèn)生成的緩存管理器和redisTemplate支持的類型很有限，根本不滿足我們的需求，會(huì)拋出如下異常：

  • org.springframework.cache.interceptor.SimpleKey cannot be cast to java.lang.String*/
    @Configuration
    br/>*/
    @Configuration
    public class RedisCacheConfig extends CachingConfigurerSupport {

    @Value("${cache.expire-time:180}")
    private int expireTime;

    // 配置key生成器，作用于緩存管理器管理的所有緩存
    // 如果緩存注解（@Cacheable、@CacheEvict等）中指定key屬性，那么會(huì)覆蓋此key生成器@Bean
    br/>@Bean
    return (target, method, params) -> {
    StringBuilder sb = new StringBuilder();
    sb.append(target.getClass().getName());
    sb.append(method.getName());
    for (Object obj : params) {
    sb.append(obj.toString());
    }
    return sb.toString();
    };
    }

    // 緩存管理器管理的緩存都需要有對(duì)應(yīng)的緩存空間，否則拋異常：No cache could be resolved for 'Builder...@Bean
    br/>@Bean
    RedisCacheManager rcm = new RedisCacheManager(redisTemplate);
    rcm.setDefaultExpiration(expireTime); //設(shè)置緩存管理器管理的緩存的過(guò)期時(shí)間, 單位：秒
    return rcm;
    }

    @Bean
    public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory) {
    StringRedisTemplate template = new StringRedisTemplate(factory);
    Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
    ObjectMapper om = new ObjectMapper();
    om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
    om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
    jackson2JsonRedisSerializer.setObjectMapper(om);
    template.setValueSerializer(jackson2JsonRedisSerializer);
    template.afterPropertiesSet();
    return template;
    }
    }
    　　　　CacheServiceImpl.java

package com.lee.cache.service.impl;

import com.lee.cache.model.User;
import com.lee.cache.service.ICacheService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;

import java.util.ArrayList;
import java.util.List;

/**

  • 若未配置@CacheConfig(cacheNames = "hello"), 則@Cacheable一定要配置value，相當(dāng)于指定緩存空間
  • 否則會(huì)拋異常：No cache could be resolved for 'Builder...
  • 若@CacheConfig(cacheNames = "hello") 與 @Cacheable(value = "123")都配置了， 則@Cacheable(value = "123")生效

  • 當(dāng)然@CacheConfig還有一些其他的配置項(xiàng)，Cacheable也有一些其他的配置項(xiàng)*/
    @Service
    br/>*/
    @Service

    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    @Override
    @Cacheable(value = "test") // key用的自定義的KeyGenerator
    public String getName() {
    System.out.println("getName, no cache now...");
    return "brucelee";
    }

    @Override
    @Cacheable(value = "user", key = "methodName + '_' + #p0", unless = "#result.size() <= 0") // key會(huì)覆蓋掉KeyGenerator
    public List<User> listUser(int pageNum, int pageSize) {
    System.out.println("listUser no cache now...");
    List<User> users = new ArrayList<>();
    users.add(new User("zhengsan", 22));
    users.add(new User("lisi", 20));
    System.out.println("===========");
    return users;
    }

    /**

    • 緩存不是緩存管理器管理，那么不受緩存管理器的約束
    • 緩存管理器中的配置不適用與此
    • 這里相當(dāng)于我們平時(shí)直接通過(guò)redis-cli操作redis

    • @return*/
      @Override
      br/>*/
      @Override

      String userName = redisTemplate.opsForValue().get("userName");
      if (!StringUtils.isEmpty(userName)) {
      return userName;
      }

      System.out.println("getUserName, no cache now...");
      redisTemplate.opsForValue().set("userName", "userName");
      return "userName";
      }

}
　　　　上述只講了幾個(gè)主要的文件，更多詳情請(qǐng)點(diǎn)springboot159-cache

　　redis 怎樣保存cache
　　　　大家一定要把工程仔細(xì)看一遍，不然下面出現(xiàn)的一些名稱會(huì)讓我們感覺(jué)不知從哪來(lái)的；

spring-boot-2.0.3之redis緩存實(shí)現(xiàn)，不是你想的那樣哦
　　　　工程中的緩存分兩種：緩存管理器管理的緩存（也就是一些列注解實(shí)現(xiàn)的緩存）、redisTemplate操作的緩存

　　　　　　緩存管理器管理的緩存

　　　　　　　　會(huì)在redis中增加2條數(shù)據(jù)，一個(gè)是類型為 zset 的 緩存名~keys , 里面存放了該緩存所有的key， 另一個(gè)是對(duì)應(yīng)的key，值為序列化后的json；緩存名~keys可以理解成緩存空間，與我們平時(shí)所說(shuō)的具體的緩存是不一樣的。另外對(duì)緩存管理器的一些設(shè)置（全局過(guò)期時(shí)間等）都會(huì)反映到緩存管理器管理的所有緩存上；上圖中的http://localhost:8888/getName和http://localhost:8888/listUser?pageNum=1&pageSize=3對(duì)應(yīng)的是緩存管理器管理的緩存。

　　　　　　redisTemplate操作的緩存

　　　　　　　　會(huì)在redis中增加1條記錄，key - value鍵值對(duì)，與我們通過(guò)redis-cli操作緩存一樣；上圖中的http://localhost:8888/getUserName對(duì)應(yīng)的是redisTemplate操作的緩存。

回到頂部
spring2.0.3緩存配置
　　工程實(shí)現(xiàn)
　　　　pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>

<groupId>com.lee</groupId>
<artifactId>spring-boot-cache</artifactId>
<version>1.0-SNAPSHOT</version>

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.0.3.RELEASE</version>
</parent>

<dependencies>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-redis</artifactId>
    </dependency>
    <dependency>
        <groupId>org.apache.commons</groupId>
        <artifactId>commons-pool2</artifactId>
    </dependency>
    <dependency>
        <groupId>org.apache.commons</groupId>
        <artifactId>commons-lang3</artifactId>
    </dependency>

</dependencies>

</project>
　　　　application.yml

server:
port: 8889
spring:
#redis配置
redis:
database: 0
host: 127.0.0.1
port: 6379
password:
lettuce:
pool:

接池最大連接數(shù)（使用負(fù)值表示沒(méi)有限制）

    max-active: 8
    # 連接池最大阻塞等待時(shí)間（使用負(fù)值表示沒(méi)有限制）
    max-wait: -1ms
    # 連接池中的最小空閑連接
    max-idle: 8
    # 連接池中的最大空閑連接
    min-idle: 0
# 連接超時(shí)時(shí)間
timeout: 2000ms

cache:
type: redis
cache:
test:
expire-time: 180
name: test
default:
expire-time: 200
　　　　緩存定制：RedisCacheManagerConfig.java

package com.lee.cache.config;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.cache.CacheManager;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.cache.RedisCacheConfiguration;
import org.springframework.data.redis.cache.RedisCacheManager;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializationContext;
import org.springframework.data.redis.serializer.StringRedisSerializer;

import java.time.Duration;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import java.util.Set;

/**

  • 進(jìn)行緩存管理的定制

  • 可以不配置，采用springboot默認(rèn)的也行*/
    @Configuration
    br/>*/
    @Configuration

    @Value("${cache.default.expire-time:1800}")
    private int defaultExpireTime;@Value("${cache.test.expire-time:180}")
    br/>@Value("${cache.test.expire-time:180}")
    br/>@Value("${cache.test.name:test}")

    //緩存管理器@Bean
    br/>@Bean
    RedisCacheConfiguration defaultCacheConfig = RedisCacheConfiguration.defaultCacheConfig();
    // 設(shè)置緩存管理器管理的緩存的默認(rèn)過(guò)期時(shí)間
    defaultCacheConfig = defaultCacheConfig.entryTtl(Duration.ofSeconds(defaultExpireTime))
    // 設(shè)置 key為string序列化
    .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer()))
    // 設(shè)置value為json序列化
    .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(new GenericJackson2JsonRedisSerializer()))
    // 不緩存空值
    .disableCachingNullValues();

    Set<String> cacheNames = new HashSet<>();
cacheNames.add(testCacheName);

// 對(duì)每個(gè)緩存空間應(yīng)用不同的配置
Map<String, RedisCacheConfiguration> configMap = new HashMap<>();
configMap.put(testCacheName, defaultCacheConfig.entryTtl(Duration.ofSeconds(testExpireTime)));

RedisCacheManager cacheManager = RedisCacheManager.builder(lettuceConnectionFactory)
        .cacheDefaults(defaultCacheConfig)
        .initialCacheNames(cacheNames)
        .withInitialCacheConfigurations(configMap)
        .build();
return cacheManager;

    }
    }
    　　　　　　此類可不用配置，就用spring-boot自動(dòng)配置的緩存管理器也行，只是在緩存的可閱讀性上會(huì)差一些。有興趣的朋友可以刪除此類試試。

　　　　CacheServiceImpl.java
package com.lee.cache.service.impl;

import com.lee.cache.model.User;
import com.lee.cache.service.ICacheService;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.annotation.CacheConfig;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.List;

/**

  • 若未配置@CacheConfig(cacheNames = "hello"), 則@Cacheable一定要配置value
  • 若@CacheConfig(cacheNames = "hello") 與 @Cacheable(value = "123")都配置了， 則@Cacheable(value = "123") 生效

  • 當(dāng)然@CacheConfig還有一些其他的配置項(xiàng)，Cacheable也有一些其他的配置項(xiàng)*/
    @Service
    br/>*/
    @Service

    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    @Override
    @Cacheable(value = "test", key = "targetClass + '_' + methodName")
    public String getName() {
    System.out.println("getName, no cache now...");
    return "brucelee";
    }

    @Override
    @Cacheable(value = "user", key = "targetClass + ':' + methodName + '_' + #p0", unless = "#result.size() <= 0")
    public List<User> listUser(int pageNum, int pageSize) {
    System.out.println("listUser no cache now...");
    List<User> users = new ArrayList<>();
    users.add(new User("zhengsan", 22));
    users.add(new User("lisi", 20));
    return users;
    }

    /**

    • 緩存不是緩存管理器管理，那么不受緩存管理器的約束
    • 緩存管理器中的配置不適用與此
    • 這里相當(dāng)于我們平時(shí)直接通過(guò)redis-cli操作redis

    • @return*/
      @Override
      br/>*/
      @Override

      String userName = redisTemplate.opsForValue().get("userName");
      if (StringUtils.isNotEmpty(userName)) {
      return userName;
      }

      System.out.println("getUserName, no cache now...");
      redisTemplate.opsForValue().set("userName", "userName");
      return "userName";
      }

}
　　　　更多詳情請(qǐng)點(diǎn)spring-boot-cache

　　redis 怎樣保存cache
　　　　我們來(lái)看圖說(shuō)話，看看緩存在redis中是如何保存的

spring-boot-2.0.3之redis緩存實(shí)現(xiàn)，不是你想的那樣哦
　　　　工程中的緩存分兩種：緩存管理器管理的緩存（也就是一些列注解實(shí)現(xiàn)的緩存）、redisTemplate操作的緩存

　　　　　　緩存管理器管理的緩存

　　　　　　　　會(huì)在redis中增加1條數(shù)據(jù)，key是以緩存空間開(kāi)頭的字符串（緩存空間名::緩存key），值為序列化后的json；上圖中的http://localhost:8889/getName和http://localhost:8889/listUser?pageNum=1&pageSize=3對(duì)應(yīng)的是緩存管理器管理的緩存。

　　　　　　redisTemplate操作的緩存

　　　　　　　　會(huì)在redis中增加1條記錄，key - value鍵值對(duì)，與我們通過(guò)redis-cli操作緩存一樣；上圖中的http://localhost:8889/getUserName對(duì)應(yīng)的是redisTemplate操作的緩存。

回到頂部
總結(jié)
　　1、有時(shí)候我們引入spring-boot-starter-cache這個(gè)starter只是為了快速添加緩存依賴，目的是引入spring-context-support；如果我們的應(yīng)用中中已經(jīng)有了spring-context-support，那么我們無(wú)需再引入spring-boot-starter-cache，例如我們的應(yīng)用中依賴了spring-boot-starter-web，而spring-boot-starter-web中又有spring-context-support依賴，所以我們無(wú)需再引入spring-boot-starter-cache。

　　2、Supported Cache Providers，講了支持的緩存類型以及默認(rèn)情況下的緩存加載方式，可以通讀下。

　　3、只要我們引入了redis依賴，并將redis的連接信息配置正確，springboot（2.0.3）根據(jù)我們的配置會(huì)給我們生成默認(rèn)的緩存管理器和redisTemplate；我們也可以自定義我們自己的緩存管理器來(lái)替換掉默認(rèn)的，只要我們自定義了緩存管理器和redisTemplate，那么springboot的默認(rèn)生成的會(huì)替換成我們自定義的。

　　4、緩存管理器對(duì)緩存的操作也是通過(guò)redisTemplate實(shí)現(xiàn)的，只是進(jìn)行了統(tǒng)一的管理，并且能夠減少我么的代碼量，我們可以將更多的精力放到業(yè)務(wù)處理上。

　　5、redis-cli -h 127.0.0.1 -p 6379 -a 123456與redis-cli -a 123456兩種方式訪問(wèn)到的數(shù)據(jù)完全不一致，好像操作不同的庫(kù)一樣！ 這個(gè)需要注意，有空我回頭看看這兩者到底有啥區(qū)別，有知道的朋友可以留個(gè)言。

向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱：is@yisu.com進(jìn)行舉報(bào)，并提供相關(guān)證據(jù)，一經(jīng)查實(shí)，將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI
助
手