• Spring Boot中RedisTemplate的使用

    当前Spring Boot的版本为2.7.6，在使用RedisTemplate之前我们需要在pom.xml中引入下述依赖：

    1. <dependency>
    2. 	<groupId>org.springframework.bootgroupId>
    3. 	<artifactId>spring-boot-starter-data-redisartifactId>
    4. 	<version>3.1.4version>
    5. dependency>

    同时在application.yml文件中添加下述配置：

    1. spring
    2.   redis:
    3.     host: 127.0.0.1
    4.     port: 6379

    一、opsForHash 

    RedisTemplate.opsForHash()是RedisTemplate类提供的用于操作Hash类型的方法，它可以用于对Redis中的Hash数据结构进行各种操作，如设置字段值、获取字段值、删除字段值等。

    1.1 设置哈希字段的值

    1. import org.junit.jupiter.api.Test;
    2. import org.springframework.beans.factory.annotation.Autowired;
    3. import org.springframework.boot.test.context.SpringBootTest;
    4. import org.springframework.data.redis.core.RedisTemplate;
    5.  
    6. @SpringBootTest
    7. public class DemoApplicationTests {
    8.  
    9.     @Autowired
    10.     private RedisTemplate redisTemplate;
    11.  
    12.     @Test
    13.     void test(){
    14.         redisTemplate.opsForHash().put("fruit:list", "1", "苹果");
    15.     }
    16. }

    在上述代码能正常运行的情况下，我们在终端中执行 redis-cli 命令进入到redis的控制台中，然后执行 keys * 命令查看所有的key，结果发现存储在redis中的key不是设置的string值，前面还多出了许多类似 \xac\xed\x00\x05t\x00 这种字符串，如下图所示：

    这是因为Spring-Data-Redis的RedisTemplate模板类在操作redis时默认使用JdkSerializationRedisSerializer来进行序列化，因此我们要更改其序列化方式：

    1. import org.springframework.context.annotation.Bean;
    2. import org.springframework.context.annotation.Configuration;
    3. import org.springframework.data.redis.connection.RedisConnectionFactory;
    4. import org.springframework.data.redis.core.RedisTemplate;
    5. import org.springframework.data.redis.serializer.RedisSerializer;
    6. import org.springframework.data.redis.serializer.StringRedisSerializer;
    7.  
    8. @Configuration
    9. public class RedisTemplateConfig {
    10.  
    11.     @Bean
    12.     public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory) {
    13.         RedisTemplate redisTemplate = new RedisTemplate<>();
    14.         redisTemplate.setConnectionFactory(redisConnectionFactory);
    15.         RedisSerializer stringRedisSerializer = new StringRedisSerializer();
    16.         redisTemplate.setKeySerializer(stringRedisSerializer);
    17.         redisTemplate.setValueSerializer(stringRedisSerializer);
    18.         redisTemplate.setHashKeySerializer(stringRedisSerializer);
    19.         redisTemplate.setHashValueSerializer(stringRedisSerializer);
    20.         return redisTemplate;
    21.     }
    22. }

    需要说明的是这种配置只是针对所有的数据都是String类型，如果是其它类型，则根据需求修改一下序列化方式。 

    使用 flushdb 命令清除完所有的数据以后，再次执行上述测试案例，接着我们再次去查看所有的key，这个看到数据已经正常：

    接着使用 hget fruit:list 1 命令去查询刚刚存储的数据，这时又发现对应字段的值中文显示乱码：

    \xe8\x8b\xb9\xe6\x9e\x9c

    这个时候需要我们在进入redis控制台前，添加 --raw 参数：

    redis-cli --raw

    1.2 设置多个哈希字段的值

    设置多个哈希字段的值一种很简单的粗暴的方法是多次执行opsForHash().put()方法，另外一种更优雅的方式如下：

    1. import org.junit.jupiter.api.Test;
    2. import org.springframework.beans.factory.annotation.Autowired;
    3. import org.springframework.boot.test.context.SpringBootTest;
    4. import org.springframework.data.redis.core.RedisTemplate;
    5.  
    6. import java.util.HashMap;
    7. import java.util.Map;
    8.  
    9. @SpringBootTest
    10. public class DemoApplicationTests {
    11.  
    12.     @Autowired
    13.     private RedisTemplate redisTemplate;
    14.  
    15.     @Test
    16.     void test(){
    17.         Map map = new HashMap<>();
    18.         map.put("1","苹果");
    19.         map.put("2","橘子");
    20.         map.put("3","香蕉");
    21.         redisTemplate.opsForHash().putAll("fruit:list",map);
    22.     }
    23. }

    1.3 获取哈希字段的值

    1. import org.junit.jupiter.api.Test;
    2. import org.springframework.beans.factory.annotation.Autowired;
    3. import org.springframework.boot.test.context.SpringBootTest;
    4. import org.springframework.data.redis.core.RedisTemplate;
    5.  
    6. @SpringBootTest
    7. public class DemoApplicationTests {
    8.  
    9.     @Autowired
    10.     private RedisTemplate redisTemplate;
    11.  
    12.     @Test
    13.     void test(){
    14.         String value = (String) redisTemplate.opsForHash().get("fruit:list","1");
    15.         System.out.println(value);
    16.     }
    17. }

    1.4 获取多个哈希字段的值

    1. import org.junit.jupiter.api.Test;
    2. import org.springframework.beans.factory.annotation.Autowired;
    3. import org.springframework.boot.test.context.SpringBootTest;
    4. import org.springframework.data.redis.core.RedisTemplate;
    5.  
    6. import java.util.Arrays;
    7. import java.util.List;
    8.  
    9. @SpringBootTest
    10. public class DemoApplicationTests {
    11.  
    12.     @Autowired
    13.     private RedisTemplate redisTemplate;
    14.  
    15.     @Test
    16.     void test(){
    17.         List values = redisTemplate.opsForHash().multiGet("fruit:list", Arrays.asList("1", "2","3"));
    18.         System.out.println(values);
    19.     }
    20. }

    1.5 判断哈希中是否存在指定的字段

    1. import org.junit.jupiter.api.Test;
    2. import org.springframework.beans.factory.annotation.Autowired;
    3. import org.springframework.boot.test.context.SpringBootTest;
    4. import org.springframework.data.redis.core.RedisTemplate;
    5.  
    6. @SpringBootTest
    7. public class DemoApplicationTests {
    8.  
    9.     @Autowired
    10.     private RedisTemplate redisTemplate;
    11.  
    12.     @Test
    13.     void test(){
    14.         Boolean hasKey = redisTemplate.opsForHash().hasKey("fruit:list", "1");
    15.         System.out.println(hasKey);
    16.     }
    17. }

    1.6 获取哈希的所有字段

    1. import org.junit.jupiter.api.Test;
    2. import org.springframework.beans.factory.annotation.Autowired;
    3. import org.springframework.boot.test.context.SpringBootTest;
    4. import org.springframework.data.redis.core.RedisTemplate;
    5.  
    6. import java.util.Set;
    7.  
    8. @SpringBootTest
    9. public class DemoApplicationTests {
    10.  
    11.     @Autowired
    12.     private RedisTemplate redisTemplate;
    13.  
    14.     @Test
    15.     void test(){
    16.         Set keys = redisTemplate.opsForHash().keys("fruit:list");
    17.         System.out.println(keys);
    18.     }
    19. }

    1.7 获取哈希的所有字段的值

    1. import org.junit.jupiter.api.Test;
    2. import org.springframework.beans.factory.annotation.Autowired;
    3. import org.springframework.boot.test.context.SpringBootTest;
    4. import org.springframework.data.redis.core.RedisTemplate;
    5.  
    6. import java.util.List;
    7.  
    8. @SpringBootTest
    9. public class DemoApplicationTests {
    10.  
    11.     @Autowired
    12.     private RedisTemplate redisTemplate;
    13.  
    14.     @Test
    15.     void test(){
    16.         List values = redisTemplate.opsForHash().values("fruit:list");
    17.         System.out.println(values);
    18.     }
    19. }

    1.8 获取哈希的所有字段和对应的值

    1. import org.junit.jupiter.api.Test;
    2. import org.springframework.beans.factory.annotation.Autowired;
    3. import org.springframework.boot.test.context.SpringBootTest;
    4. import org.springframework.data.redis.core.RedisTemplate;
    5.  
    6. import java.util.Map;
    7.  
    8. @SpringBootTest
    9. public class DemoApplicationTests {
    10.  
    11.     @Autowired
    12.     private RedisTemplate redisTemplate;
    13.  
    14.     @Test
    15.     void test(){
    16.         Map entries = redisTemplate.opsForHash().entries("fruit:list");
    17.         System.out.println(entries);
    18.     }
    19. }

    1.9 删除指定的字段 

    返回值返回的是删除成功的字段的数量，如果字段不存在的话，则返回的是0。 

    1. import org.junit.jupiter.api.Test;
    2. import org.springframework.beans.factory.annotation.Autowired;
    3. import org.springframework.boot.test.context.SpringBootTest;
    4. import org.springframework.data.redis.core.RedisTemplate;
    5.  
    6. @SpringBootTest
    7. public class DemoApplicationTests {
    8.  
    9.     @Autowired
    10.     private RedisTemplate redisTemplate;
    11.  
    12.     @Test
    13.     void test(){
    14.         Long deletedFields = redisTemplate.opsForHash().delete("fruit:list", "4");
    15.         System.out.println(deletedFields);
    16.     }
    17. }

    1.10 如果哈希的字段存在则不会添加，不存在则添加 

    1. import org.junit.jupiter.api.Test;
    2. import org.springframework.beans.factory.annotation.Autowired;
    3. import org.springframework.boot.test.context.SpringBootTest;
    4. import org.springframework.data.redis.core.RedisTemplate;
    5.  
    6. @SpringBootTest
    7. public class DemoApplicationTests {
    8.  
    9.     @Autowired
    10.     private RedisTemplate redisTemplate;
    11.  
    12.     @Test
    13.     void test(){
    14.         Boolean success =  redisTemplate.opsForHash().putIfAbsent("fruit:list","4","西瓜");
    15.         System.out.println(success);
    16.     }
    17. }

    1.11 将指定字段的值增加指定步长

    1. import org.junit.jupiter.api.Test;
    2. import org.springframework.beans.factory.annotation.Autowired;
    3. import org.springframework.boot.test.context.SpringBootTest;
    4. import org.springframework.data.redis.core.RedisTemplate;
    5.  
    6. @SpringBootTest
    7. public class DemoApplicationTests {
    8.  
    9.     @Autowired
    10.     private RedisTemplate redisTemplate;
    11.  
    12.     @Test
    13.     void test(){
    14.         Long incrementedValue = redisTemplate.opsForHash().increment("salary:list", "1", 5);
    15.         System.out.println(incrementedValue);
    16.     }
    17. }

    如果字段不存在，则将该字段的值设置为指定步长，并且返回该字段当前的值；如果字段存在，则在该字段原有值的基础上增加指定步长，返回该字段当前的最新值。 该方法只适用于字段值为int类型的数据，因此关于哈希数据结构的value值的序列化方式要有所改变：

    1. import org.springframework.context.annotation.Bean;
    2. import org.springframework.context.annotation.Configuration;
    3. import org.springframework.data.redis.connection.RedisConnectionFactory;
    4. import org.springframework.data.redis.core.RedisTemplate;
    5. import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
    6. import org.springframework.data.redis.serializer.RedisSerializer;
    7. import org.springframework.data.redis.serializer.StringRedisSerializer;
    8.  
    9. @Configuration
    10. public class RedisTemplateConfig {
    11.  
    12.     @Bean
    13.     public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory) {
    14.         RedisTemplate redisTemplate = new RedisTemplate<>();
    15.         redisTemplate.setConnectionFactory(redisConnectionFactory);
    16.         RedisSerializer stringRedisSerializer = new StringRedisSerializer();
    17.         redisTemplate.setKeySerializer(stringRedisSerializer);
    18.         redisTemplate.setValueSerializer(stringRedisSerializer);
    19.         redisTemplate.setHashKeySerializer(stringRedisSerializer);
    20.         Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
    21.         redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
    22.         return redisTemplate;
    23.     }
    24. }

    StringRedisTemplate的好处就是在RedisTemplate基础上封装了一层，指定了所有数据的序列化方式都是采用StringRedisSerializer（即字符串），使用语法上面完全一致。 

    1. public class StringRedisTemplate extends RedisTemplate {
    2.     public StringRedisTemplate() {
    3.         this.setKeySerializer(RedisSerializer.string());
    4.         this.setValueSerializer(RedisSerializer.string());
    5.         this.setHashKeySerializer(RedisSerializer.string());
    6.         this.setHashValueSerializer(RedisSerializer.string());
    7.     }
    8. }

    二、opsForValue

    RedisTemplate.opsForValue()是RedisTemplate类提供的用于操作字符串值类型的方法。它可以用于对Redis中的字符串值进行各种操作，如设置值、获取值、删除值等。

    2.1 设置一个键值对

    1. import org.junit.jupiter.api.Test;
    2. import org.springframework.beans.factory.annotation.Autowired;
    3. import org.springframework.boot.test.context.SpringBootTest;
    4. import org.springframework.data.redis.core.RedisTemplate;
    5.  
    6. import java.util.concurrent.TimeUnit;
    7.  
    8. @SpringBootTest
    9. public class DemoApplicationTests {
    10.  
    11.     @Autowired
    12.     private RedisTemplate redisTemplate;
    13.  
    14.     @Test
    15.     void test(){
    16.         String key = "fruit";
    17.         String value = "apple";
    18.         redisTemplate.opsForValue().set(key,value,30,TimeUnit.SECONDS);
    19.     }
    20. }

    2.2 根据键获取对应的值 

    1. import org.junit.jupiter.api.Test;
    2. import org.springframework.beans.factory.annotation.Autowired;
    3. import org.springframework.boot.test.context.SpringBootTest;
    4. import org.springframework.data.redis.core.RedisTemplate;
    5.  
    6. @SpringBootTest
    7. public class DemoApplicationTests {
    8.  
    9.     @Autowired
    10.     private RedisTemplate redisTemplate;
    11.  
    12.     @Test
    13.     void test(){
    14.         String value = (String) redisTemplate.opsForValue().get("fruit");
    15.         System.out.println(value);
    16.     }
    17. }

    2.3 删除单个key值

    1. import org.junit.jupiter.api.Test;
    2. import org.springframework.beans.factory.annotation.Autowired;
    3. import org.springframework.boot.test.context.SpringBootTest;
    4. import org.springframework.data.redis.core.RedisTemplate;
    5.  
    6. @SpringBootTest
    7. public class DemoApplicationTests {
    8.  
    9.     @Autowired
    10.     private RedisTemplate redisTemplate;
    11.  
    12.     @Test
    13.     void test(){
    14.         redisTemplate.delete("fruit");
    15.     }
    16. }

     

  • 相关阅读:
    『力扣每日一题10』：字符串中的单词数
    ubuntu 20.04 安装软件踩坑
    RabbitMQ的六种工作模式
    计算机专业毕业论文安卓毕业设计源码基于Uniapp+SSM实现的Android的健康食谱交流app[包运行成功]
    【数据结构】栈和队列
    【Java设计模式】第6讲--代理模式
    kali安装volatility及插件mimikatz
    nano的CAN通信
    2022-08-20 网易秋招笔试
    Qt跨平台（统信UOS）各种坑解决办法
  • 原文地址：https://blog.csdn.net/y_bccl27/article/details/133987340