SpringBoot整合Redis

時間 2019-12-07

原文原文鏈接

最近學習了一下redis，並與SpringBoot進行了整合，在此與你們分享。html

1、Redis

關於Redis的解釋網上有不少，我在這裏不作出多餘解釋，你們能夠自行搜索，我在這裏要提到的是，Redis與SpringBoot整合有兩種方式，第一種是使用Jedis，它是Redis官方推薦的面向Java的操做Redis的客戶端，第二種是使用RedisTemplate，它是SpringDataRedis中對JedisApi的高度封裝。我這次使用的是RedisTemplate，並整理了redis工具類方便你們使用，GitHub地址文末給出。java

2、項目結構

我在此貼出項目目錄結構，方便你們觀察：mysql

config中是對Redis的相關配置，controller中是測試接口，dao中是對數據庫操做的相關接口，entity中數據表實體，service中是具體實現，util中含有Redis工具類。

3、項目開發

一、準備pom文件

此項目使用SpringBoot版本爲2.1.3.RELEASE，下面引入依賴：git

 <!-- mysql依賴 -->
         <dependency>
             <groupId>mysql</groupId>
             <artifactId>mysql-connector-java</artifactId>
             <version>5.1.34</version>
         </dependency>

<!-- mybatis依賴 -->
       <dependency>
             <groupId>org.mybatis.spring.boot</groupId>
             <artifactId>mybatis-spring-boot-starter</artifactId>
             <version>1.1.1</version>
       </dependency>

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

<!-- 日誌 -->
<!-- https://mvnrepository.com/artifact/org.projectlombok/lombok -->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>

使用JDK1.8github

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

至此，pom文件已經準備好。redis

二、項目相關配置

application.properties文件以下：spring

1 server.port=8088
2 mybatis.type-aliases-package=com.neo.entity
3 spring.datasource.driverClassName = com.mysql.jdbc.Driver
4 spring.datasource.url= jdbc:mysql://localhost:3306/test1?useUnicode=true&characterEncoding=utf-8&useSSL=false
5 spring.datasource.username = root
6 spring.datasource.password = yingziairen
7 logging.level.root=info

application.yml文件以下，其中配置了Mybatis：sql

1 mybatis:
2     typeAliasesPackage: com.cone.redis.entity
3     mapperLocations: classpath:mapper/*.xml

三、配置Redis

當添加Redis依賴後，SpringBoot會自動幫咱們在容器中生成一個RedisTemplate和一個StringRedisTemplate，可是，這個RedisTemplate的泛型是<Object,Object>，在代碼中會不可避免的須要類型轉換，這樣不夠安全，也過於麻煩，並且RedisTemplate沒有設置序列化方式，因此，咱們須要配置Redis：數據庫

 1     @Bean
 2     @SuppressWarnings("all")
 3     public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
 4         
 5         RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
 6         template.setConnectionFactory(factory);
 7         Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
 8         ObjectMapper om = new ObjectMapper();
 9         om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
10         om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
11         jackson2JsonRedisSerializer.setObjectMapper(om);
12         StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
13         //key採用String的序列化方式
14         template.setKeySerializer(stringRedisSerializer);
15         //hash的key也採用String的序列化方式
16         template.setHashKeySerializer(stringRedisSerializer);
17         //value序列化方式採用jackson
18         template.setValueSerializer(jackson2JsonRedisSerializer);
19         //hash的value序列化方式採用jackson
20         template.setHashValueSerializer(jackson2JsonRedisSerializer);
21         template.afterPropertiesSet();
22         return template;
23     }

四、編寫Entity

這張表是我其它項目的，這裏用來舉例：（項目中有sql語句文件，可本身在本地測試）apache

 1 package com.cone.redis.entity;
 2 
 3 /**
 4  * 圖書信息實體
 5  * @author Cone
 6  */
 7 public class Product {
 8 
 9     private Integer productId;
10     private String productCategories;
11     
12     public Integer getProductId() {
13         return productId;
14     }
15     public void setProductId(Integer productId) {
16         this.productId = productId;
17     }
18     public String getProductCategories() {
19         return productCategories;
20     }
21     public void setProductCategories(String productCategories) {
22         this.productCategories = productCategories;
23     }
24     
25 }

五、編寫Dao

項目使用Mybatis操做數據庫：

 1 package com.cone.redis.dao;
 2 
 3 import java.util.List;
 4 import org.apache.ibatis.annotations.Mapper;
 5 import com.cone.redis.entity.Product;
 6 
 7 @Mapper
 8 public interface ProductDao {
 9     /**
10      * 查詢圖書列表
11      * @return
12      */
13     public List<Product> searchProduct();
14 }

xml文件以下：

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 3 <mapper namespace="com.cone.redis.dao.ProductDao">
 4      <!-- 查詢圖書類別 -->
 5      <select id="searchProduct" resultType="com.cone.redis.entity.Product">
 6              
 7           select * from product
 8 
 9      </select>
10      
11          
12 </mapper>

六、編寫Service

 1 package com.cone.redis.service;
 2 
 3 import java.util.List;
 4 import com.cone.redis.entity.Product;
 5 
 6 
 7 public interface RedisService {
 8     
 9     public List<Product> searchProduct();
10 
11 }

實現類以下：

①首先注入相關Bean

1     @Autowired
2     private RedisUtil.redisList redisList;
3     
4     @Autowired
5     private RedisUtil redisUtil;
6     
7     @Autowired
8     private ProductDao productDao;

RedisUtil是個人工具類，這裏你們只須要知道這個便可。

②實現

 1     @Override
 2     public List searchProduct() {
 3         
 4         List list = new ArrayList<>();
 5         if (redisUtil.hasKey("productList")) {
 6             log.info("從redis中獲取數據.");
 7             list = redisList.get("productList", 0, -1);
 8         
 9         }
10         else {
11             list = productDao.searchProduct();
12             log.info("從數據庫中獲取數據.");
13             log.info("將數據存入redis...");
14             redisList.set("productList", list);
15             log.info("成功存入redis.");
16         }
17         return list;
18     }

首先判斷redis中有沒有相關數據，如有，則從redis中查詢並返回數據，若沒有則從數據庫中查詢，並將查詢到的數據存入redis中。

七、編寫Controller

 1 @Controller
 2 @RequestMapping(value="/redis")
 3 
 4 public class RedisController {
 5 
 6     @Autowired
 7     private RedisServiceImpl redisServiceImpl;
 8     
 9     @SuppressWarnings("unchecked")
10     @PostMapping(value = "/test")
11     @ResponseBody
12     public List<Product> testRedis() {
13         
14         return redisServiceImpl.searchProduct();
15 
16     }
17 
18 }