Spring中RedisTemplate的基本使用淺析

Posted on by

spring-data-redis項目

  spring-data-redis提供瞭在Spring應用中通過簡單的配置訪問redis服務，封裝瞭 RedisTemplate 對象來對Redis進行各種操作、異常處理及序列化，支持發佈訂閱。RedisTemplate對應於Redis五大數據類型的api：

Api 返回值類型 說明
redisTemplate.opsForValue() ValueOperations 操作 String 類型數據
redisTemplate.opsForHash() HashOperations 操作 Hash 類型數據
redisTemplate.opsForList() ListOperations 操作 List 類型數據
redisTemplate.opsForSet() SetOperations 操作 Set 類型數據
redisTemplate.opsForZSet() ZSetOperations 操作 SortedSet 類型數據

使用步驟

  前提條件：運行著的Redis(有windows版本)

  引入依賴：

<dependency>
  <groupId>org.springframework.data</groupId>
  <artifactId>spring-data-redis</artifactId>
  <version>2.7.3</version>
</dependency>
<!--SpringBoot項目，可以引入這個依賴，這個依賴也是會依賴spring-data-redis的-->
<!--<dependency>-->
<!--    <groupId>org.springframework.boot</groupId>-->
<!--    <artifactId>spring-boot-starter-data-redis</artifactId>-->
<!--    <version>2.7.4</version>-->
<!--</dependency>-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <version>2.7.4</version>
</dependency>

  application.yml配置Redis的信息：

spring:
  redis:
    host: 127.0.0.1
    port: 6379
    # 沒有密碼可以註釋掉
    password: 123456
    database: 0
    lettuce:
      pool:
        # 最大連接
        max-active: 8
        # 最大空閑連接
        max-idle: 8
        # 最小空閑連接
        min-idle: 0
        # 連接等待時間
        max-wait: 100ms

  demo使用：

import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.DefaultTypedTuple;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ZSetOperations;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
@SpringBootTest
public class RedisDemoApplicationTest {
    // 註入RedisTemplate
    @Autowired
    private RedisTemplate redisTemplate;
    // String類型
    @Test
    void testString () {
        redisTemplate.opsForValue().set("name", "javaCoder");
        Object name = redisTemplate.opsForValue().get("name");
        System.out.println(name);
    }
    // Hash類型
    @Test
    public void testHash () {
        redisTemplate.opsForHash().put("hash", "name", "abc");
        redisTemplate.opsForHash().put("hash", "age", 18);
        Map map = redisTemplate.opsForHash().entries("hash");
        System.out.println(map);
    }
    // List類型
    @Test
    public void testList () {
        redisTemplate.opsForList().leftPushAll("list", "zhangsan", "li", 
        "wanger");
        List<String> names = redisTemplate.opsForList().range("list", 0, 
        -1);
        System.out.println(names);
    }
    // Set類型
    @Test
    public void testSet () {
        redisTemplate.opsForSet().add("set", "cat", "dog", "wolf", "pig", 
        "sheep");
        Set<String> set = redisTemplate.opsForSet().members("set");
        System.out.println(set);
    }
    // SortedSet類型
    @Test
    public void testSortedSet () {
        redisTemplate.opsForZSet().add("zset", "cat", 30);
        redisTemplate.opsForZSet().add("zset", "dog", 20);
        redisTemplate.opsForZSet().add("zset", "wolf", 80);
        redisTemplate.opsForZSet().add("zset", "pig", 40);
        Set<String> aClass = redisTemplate.opsForZSet().range("zset", 
        0, -1);
        System.out.println(aClass);
        //使用下面這套寫法，也行
        //Set<ZSetOperations.TypedTuple<String>> set = new HashSet<>();
        //set.add(new DefaultTypedTuple<>("cat", 30.0));
        //set.add(new DefaultTypedTuple<>("dog", 20.0));
        //set.add(new DefaultTypedTuple<>("wolf", 80.0));
        //set.add(new DefaultTypedTuple<>("pig", 40.0));
        //redisTemplate.opsForZSet().add("zset", set);
        //Set<String> aClass1 = redisTemplate.opsForZSet().range("zset", 
        //0, -1);
        //System.out.println(aClass1);
    }
}

  此時代碼運行起來沒問題，但用redis-cli客戶端，用相關命令去查看時，發現數據不存在(get name、hgetall hash、lrange list 0 -1、smembers set、zrange zset 0 -1)，用如下解決方法：

  a.設置RedisTemplate對象的key的序列化方式

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.serializer.RedisSerializer;
@Configuration
public class RedisConfig {
    @Bean
    public RedisTemplate<String, Object> redisTemplate(
    RedisConnectionFactory connectionFactory) {
        // 創建 RedisTemplate 對象
        RedisTemplate<String, Object> redisTemplate = 
        new RedisTemplate<>();
        // 設置連接工廠
        redisTemplate.setConnectionFactory(connectionFactory);
        // 設置Key的序列化 - String 序列化 RedisSerializer.string() => 
        // StringRedisSerializer.UTF_8
        redisTemplate.setKeySerializer(RedisSerializer.string());
        redisTemplate.setHashKeySerializer(RedisSerializer.string());
        // 返回
        return redisTemplate;
    }
}

  b.註入的RestTemplate對象，指定泛型類型

@Autowired
private RedisTemplate<String, String> redisTemplate;

  不過方法a又有問題啦，去看String類型的key：name的值，

  長長的一串，占用空間大，可讀性差。這是因為value的序列化方式默認是JdkSerializationRedisSerializer，把它改成json。在上方的RedisConfig類中，添加代碼：

redisTemplate.setValueSerializer(RedisSerializer.json());
// 針對於hash類型的value
redisTemplate.setHashValueSerializer(RedisSerializer.json());

  如果你的redisTemplate類型確定就是RedisTemplate<String, String>，那也可以用StringRedisTemplate，兩者效果一樣。

到此這篇關於Spring中RedisTemplate的基本使用淺析的文章就介紹到這瞭,更多相關Spring RedisTemplate內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：