SpringBoot整合redis

2019 年 11 月 7 日
筆記

redis是最常用的快取資料庫，常用於存儲用戶登錄token、臨時數據、定時相關數據等。

redis是單執行緒的，所以redis的操作是原子性的，這樣可以保證不會出現並發問題。

redis基於記憶體，速度非常快，據測試，redis讀的速度是110000次/s,寫的速度是81000次/s

本節介紹SpringBoot引入redis，以及使用RedisTemplate來操作redis數據。

採用SpringBoot 2.1.9.RELEASE，對應示例程式碼在：https://github.com/laolunsi/spring-boot-examples/tree/master/07-spring-boot-redis-demo

一、A Simple Demo-使用SpringBoot連接redis

maven:

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

yml:

server:    port: 8867  spring:    redis:      host: localhost      port: 6379      #password: ''      database: 6

測試類：

@SpringBootTest  @RunWith(SpringRunner.class)  public class RedisTest {        @Autowired      private RedisTemplate redisTemplate;        @Test      public void testRedis() {          String key = "hello";          redisTemplate.opsForValue().set("hello", "你好");            String res = (String) redisTemplate.opsForValue().get(key);          System.out.println(res);      }  }

執行結果：

看一下redis：

這裡存在一個問題：默認的存儲方式導致key在redis-manager裡面顯示出來是亂碼的，並且存儲結果是二進位了。這樣不利用我們查看redis裡面的數據。

我們需要自定義redis存儲的序列化規則。

二、解決RedisTemplate默認序列化的問題

完善一下maven:

<dependency>      <groupId>org.springframework.boot</groupId>      <artifactId>spring-boot-starter</artifactId>  </dependency>    <dependency>      <groupId>org.springframework.boot</groupId>      <artifactId>spring-boot-starter-test</artifactId>      <scope>test</scope>  </dependency>    <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>

定義RedisConfig類：

/**   * redis配置   * 主要是配置Redis的序列化規則，替換默認的jdkSerializer   * key的序列化規則用StringRedisSerializer   * value的序列化規則用Jackson2JsonRedisSerializer   */  @Configuration  public class RedisConfig {        @Bean      public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory connectionFactory) {          RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();          redisTemplate.setConnectionFactory(connectionFactory);            // 使用Jackson2JsonRedisSerialize替換默認序列化          Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);            ObjectMapper objectMapper = new ObjectMapper();          objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);          objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);            jackson2JsonRedisSerializer.setObjectMapper(objectMapper);            // 設置key和value的序列化規則          redisTemplate.setKeySerializer(new StringRedisSerializer());          redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);            redisTemplate.setHashKeySerializer(new StringRedisSerializer());          redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);            redisTemplate.afterPropertiesSet();          return redisTemplate;      }  }

刪除之前的key，重新執行一下test方法：

下面來演示一下SpringBoot使用RedisTemplate進行redis數據的操作

三、基於SpringBoot的redis操作——key/list/hash

RedisTemplate內置redis操作如下：

這裡主要展示value/hash/list三種用法：

3.1 RedisTemplate.opsForValue

  @Test      public void testKeyOps() {          // 測試redis操作key-value形式          Set<String> keySet = new HashSet<>();            String key1 = "name";          keySet.add(key1);          // 存儲簡單的key-value，並設置過期時間          redisTemplate.opsForValue().set(key1, "eknown", 1, TimeUnit.MINUTES);            String key2 = "token:user1";          String key3 = "token:user2";          keySet.add(key2);          keySet.add(key3);          //          redisTemplate.opsForValue().set(key2, "{"name":"eknown"}, "role":"admin"");          redisTemplate.opsForValue().set(key3, "{"name":"test"}, "role":"test"");            // 根據key的集合獲取多個value          List<String> valueList = redisTemplate.opsForValue().multiGet(keySet);          for (String value : valueList) {              System.out.println(value);          }      }

執行結果：

redis中的數據：

redis中的key顯示出了一個層級關係，這個小技巧對於實際項目有個非常好的作用：通過prefix:suffix這樣的形式，可以將redis中存儲的數據分出層級。

3.2 RedisTemplate.opsForHash

清空該database下的數據，測試redisTemplate.opsForHash：

    @Test      public void testHashOps() {          String key = "hash";          // 單次往hash中存放一個數據          redisTemplate.opsForHash().put(key, "1", "你好");            Map<String, Object> map = new HashMap<>();          map.put("2", "hello");          map.put("3a", "china1=2");            // 一次性向hash中存放一個map          redisTemplate.opsForHash().putAll(key, map);            // 獲取hash下的所有key和value          Map<String, Object> resultMap = redisTemplate.opsForHash().entries(key);          for (String hashKey : resultMap.keySet()) {              System.out.println(hashKey + ": " + resultMap.get(hashKey));          }      }

執行結果：

redis:

3.3 RedisTemplate.opsForList

    @Test      public void testListOps() {          String listKey = "list";          redisTemplate.opsForList().leftPush(listKey, "first value"); // 從list最左邊插入數據          redisTemplate.opsForList().leftPush(listKey, "second value but left");          redisTemplate.opsForList().rightPush(listKey, 3); // 從list最右邊插入數據            List<Object> list = new ArrayList<>();          list.add("hello");          list.add("http://www.eknown.cn");          list.add(23344);          list.add(false);          redisTemplate.opsForList().rightPushAll(listKey, list); // 從list右邊批量插入數據            long size = redisTemplate.opsForList().size(listKey);          if (size > 0) {              for (int i = 0; i < size -1 ; i++) {                  // 從list最左邊開始讀取list中的數據，注意pop會導致出棧，也就是數據被取出來了（redis中就沒有這個值了）                  // 此處我們讀取size-1條數據，僅留下最後一條數據                  System.out.println(i + ":" + redisTemplate.opsForList().leftPop(listKey).toString());              }          }      }

執行上面的腳本，注意在最後的讀取list數據程式碼前面加一個斷點，此時redis中是這樣的：

放開斷點，程式繼續執行，控制台如下：

注意，此時redis中僅剩餘最後一條數據，這是由於pop的問題，list中的數據被讀取並刪除了：

好了，這一節主要講了SpringBoot引入redis，以及使用redis的一些基本操作和相關技巧，在此基礎上，我們可以讓我們的項目變得更加快速、靈活！

Tags: