SpringBoot集成Redis來實現緩存技術方案

在咱們的平常項目開發過程當中緩存是無處不在的，由於它能夠極大的提升系統的訪問速度，關於緩存的框架也種類繁多，今天主要介紹的是使用如今很是流行的NoSQL數據庫（Redis）來實現咱們的緩存需求。

 

Redis簡介

Redis 是一個開源（BSD許可）的，內存中的數據結構存儲系統，它能夠用做數據庫、緩存和消息中間件，Redis 的優點包括它的速度、支持豐富的數據類型、操做原子性，以及它的通用性。

 

案例整合

本案例是在以前一篇SpringBoot + Mybatis + RESTful的基礎上來集成Redis的，因此你們若有什麼不明白的地方能夠前往https://my.oschina.net/feinik/blog/879266，因爲篇幅緣由這裏不一一貼出全部的代碼，具體完整案例代碼能夠看這裏：https://github.com/AIFEINIK/SpringBoot-Learn/tree/master/spring-boot-redis2，關於Redis如何安裝可自行google。

 

一、在Maven pom.xml文件中加入Redis包

<!--redis-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-redis</artifactId>
    <version>${boot.version}</version>
</dependency>

 

二、SpringBoot配置文件中配置Redis鏈接（YAML方式配置）

spring:
    application:
        name: spring-boot-redis
    redis:
        host: 192.168.145.132
        port: 6379
        timeout: 20000
        cluster:
            nodes: 192.168.211.134:7000,192.168.211.134:7001,192.168.211.134:7002
            maxRedirects: 6
        pool:
            max-active: 8
            min-idle: 0
            max-idle: 8
            max-wait: -1

解釋：本配置採用Redis一主三從的的配置方式來提升緩存的吞吐量

 

三、Redis配置類

@Configuration
public class RedisConfig {

   @Bean
   public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
      RedisTemplate<Object, Object> template = new RedisTemplate<>();
      template.setConnectionFactory(connectionFactory);

      //使用Jackson2JsonRedisSerializer來序列化和反序列化redis的value值
      Jackson2JsonRedisSerializer serializer = new Jackson2JsonRedisSerializer(Object.class);

      ObjectMapper mapper = new ObjectMapper();
      mapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
      mapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
      serializer.setObjectMapper(mapper);

      template.setValueSerializer(serializer);
      //使用StringRedisSerializer來序列化和反序列化redis的key值
      template.setKeySerializer(new StringRedisSerializer());
      template.afterPropertiesSet();
      return template;
   }
}

解釋：SpringBoot提供了對Redis的自動配置功能，在RedisAutoConfiguration中默認爲咱們配置了JedisConnectionFactory（客戶端鏈接）、RedisTemplate以及StringRedisTemplate（數據操做模板），其中StringRedisTemplate模板只針對鍵值對都是字符型的數據進行操做，本示例採用RedisTemplate做爲數據操做模板，該模板默認採用JdkSerializationRedisSerializer的二進制數據序列化方式，爲了方便演示本示例採用Jackson2JsonRedisSerializer來序列化和反序列化redis的value值，使用StringRedisSerializer來序列化和反序列化redis的key值。

 

四、Service層應用緩存（註解方式）

@Service
public class PersonService {

    @Autowired
    private PersonRepo personRepo;

   /**
     * @Cacheable 應用到讀取數據的方法上，先從緩存中讀取，若是沒有再從DB獲取數據，而後把數據添加到緩存中
    * unless 表示條件表達式成立的話不放入緩存
     * @param username
     * @return
     */
    @Cacheable(value = "user", key = "#root.targetClass + #username", unless = "#result eq null")
    public Person getPersonByName(String username) {
        Person person = personRepo.getPersonByName(username);
        return person;
    }

   /**
    * @CachePut 應用到寫數據的方法上，如新增/修改方法，調用方法時會自動把相應的數據放入緩存
     * @param person
     * @return
     */
    @CachePut(value = "user", key = "#root.targetClass + #result.username", unless = "#person eq null")
    public Person savePerson(Person person) {
        return personRepo.savePerson(person);
    }

   /**
    * @CacheEvict 應用到刪除數據的方法上，調用方法時會從緩存中刪除對應key的數據
     * @param username
     * @return
     */
    @CacheEvict(value = "user", key = "#root.targetClass + #username", condition = "#result eq true")
    public boolean removePersonByName(String username) {
        return personRepo.removePersonByName(username) > 0;
    }

    public boolean isExistPersonName(Person person) {
        return personRepo.existPersonName(person) > 0;
    }
}

解釋：

 

一、這裏的緩存key爲簡單的字符串組合，也可根據具體須要實現自定義的Key生成器，而後在註解中使用keyGenerator來引用。

 

二、Spring Cache提供了一些供咱們使用的SpEL上下文數據，經過#來引用，具體可查看Spring官網：http://docs.spring.io/spring/docs/current/spring-framework-reference/htmlsingle/#cache-spel-context。

 

五、數據訪問資源類

@Component
@Path("personMgr")
public class PersonMgrResource {

    @Autowired
    private PersonService personService;

    @GET
    @Path("getPersonByName")
    @Produces(MediaType.APPLICATION_JSON)
    public JsonResp getPersonByName(@QueryParam("username") String username) {
        Person person = personService.getPersonByName(username);
        return JsonResp.success(person);
    }

    @POST
    @Path("removePersonByName")
    @Produces(MediaType.APPLICATION_JSON)
    public JsonResp removePersonByName(@QueryParam("username") String username) {
        if (personService.removePersonByName(username)) {
            return JsonResp.success();
        }
        return JsonResp.fail("系統錯誤！");
    }

    @POST
    @Path("savePerson")
    @Produces(MediaType.APPLICATION_JSON)
    public JsonResp savePerson(Person person) {
        if (personService.isExistPersonName(person)) {
            return JsonResp.fail("用戶名已存在！");
        }
        if (personService.savePerson(person).getId() > 0) {
            return JsonResp.success();
        }
        return JsonResp.fail("系統錯誤！");
    }
}

 

六、經過postman工具來測試緩存是否生效

 

第一次訪問查找用戶：

 

第一次經過用戶名稱來查找用戶能夠看到是從庫中查詢的數據，咱們能夠經過RedisClient工具來查看數據已放入了緩存

第二次查找用戶：發現服務端並未打印任何數據庫查詢日誌，能夠知道第二次查詢是從緩存中查詢獲得的數據。

 

總結

本文介紹如何經過SpringBoot來一步步集成Redis緩存，關於Redis的使用它不只能夠用做緩存，還能夠用來構建隊列系統，Pub/Sub實時消息系統，分佈式系統的的計數器應用，關於Redis更多的介紹，請前往查閱官方文檔。