springboot中操作redis

1.maven引入相关依赖

1. <dependencies>
2.        
3.         <dependency>
4.             <groupId>org.springframework.boot</groupId>
5.             <artifactId>spring-boot-starter-data-redis</artifactId>
6.         </dependency>
7.         
8.         <dependency>
9.             <groupId>org.apache.commons</groupId>
10.             <artifactId>commons-pool2</artifactId>
11.             <version>2.11.1</version>
12.         </dependency>
13.         
14.         <dependency>
15.             <groupId>com.fasterxml.jackson.core</groupId>
16.             <artifactId>jackson-databind</artifactId>
17.         </dependency>
18.         
19.         <dependency>
20.             <groupId>org.projectlombok</groupId>
21.             <artifactId>lombok</artifactId>
22.             <optional>true</optional>
23.         </dependency>
24.         
25.         <dependency>
26.             <groupId>org.springframework.boot</groupId>
27.             <artifactId>spring-boot-starter-test</artifactId>
28.             <scope>test</scope>
29.         </dependency>
30. </dependencies>

复制代码

2.配置redis

application.yml

1. spring:
2.   # 配置redis
3.   redis:
4.     host: 192.168.***.***
5.     port: 6379
6.     password: ******
7.     lettuce:
8.       pool:
9.         max-active: 8 # 连接池最大连接数（使用负值表示没有限制）
10.         max-idle: 8 # 连接池中的最大空闲连接
11.         max-wait: 100 # 连接池最大阻塞等待时间（使用负值表示没有限制）
12.         min-idle: 0 # 连接池中的最小空闲连接
13.     database: 0 # redis数据库索引（默认为0）

复制代码

3.配置序列化

1. package com.example.config;
3. import org.springframework.context.annotation.Bean;
4. import org.springframework.context.annotation.Configuration;
5. import org.springframework.data.redis.connection.RedisConnectionFactory;
6. import org.springframework.data.redis.core.RedisTemplate;
7. import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
8. import org.springframework.data.redis.serializer.RedisSerializer;
10. /**
11. * Redis  序列化方式配置
12. *
13. */
14. @Configuration
15. public class RedisConfig {
17.     @Bean
18.     public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
19.         // 创建RedisTemplate<String, Object>对象
20.         RedisTemplate<String, Object> template = new RedisTemplate<>();
21.         // 配置连接工厂
22.         template.setConnectionFactory(factory);
23.         // json方式序列化对象
24.         GenericJackson2JsonRedisSerializer jsonRedisSerializer =
25.                 new GenericJackson2JsonRedisSerializer();
26.         // key采用String的序列化方式
27.         template.setKeySerializer(RedisSerializer.string());
28.         // hash的key也采用String的序列化方式
29.         template.setHashKeySerializer(RedisSerializer.string());
30.         // value序列化方式采用jackson
31.         template.setValueSerializer(jsonRedisSerializer);
32.         // hash的value序列化方式采用jackson
33.         template.setHashValueSerializer(jsonRedisSerializer);
34.         return template;
35.     }
37. }

复制代码

4.测试类中进行测试

1. package com.example;
3. import com.example.entity.User;
4. import com.fasterxml.jackson.core.JsonProcessingException;
5. import com.fasterxml.jackson.databind.ObjectMapper;
6. import org.junit.jupiter.api.Test;
7. import org.springframework.beans.factory.annotation.Autowired;
8. import org.springframework.boot.test.context.SpringBootTest;
9. import org.springframework.data.redis.core.RedisTemplate;
10. import org.springframework.data.redis.core.StringRedisTemplate;
12. @SpringBootTest
13. class SpringDataRedisTestApplicationTests {
15.     @Autowired
16.     private RedisTemplate<String,Object> redisTemplate;
17.     @Autowired
18.     private StringRedisTemplate stringRedisTemplate;
20.     private static final ObjectMapper objectMapper = new ObjectMapper();
22.     /**
23.      * 测试redis的String类型
24.      */
25.     @Test
26.     void testString() {
27.         redisTemplate.opsForValue().set("name", "minqiliang");
28.         System.out.println(redisTemplate.opsForValue().get("name"));
29.     }
31.     /**
32.      * 使用StringRedisTemplate操作redis（需要手动进行序列化和反序列化）
33.      * @throws JsonProcessingException
34.      */
35.     @Test
36.     void testString2() throws JsonProcessingException {
37.         // 创建一个对象
38.         User user = new User("001", "minqiliang", 18);
39.         // 由于StringRedisTemplate默认使用的是String的序列化器，所以这里需要将对象转换成json字符串
40.         String json = objectMapper.writeValueAsString(user);
41.         // 存入redis
42.         stringRedisTemplate.opsForValue().set("user:001", json);
43.         // 从redis中取出数据
44.         String s = stringRedisTemplate.opsForValue().get("user:001");
45.         // 将json字符串转换成对象
46.         User u = objectMapper.readValue(s, User.class);
47.         System.out.println(u);
48.     }
50.     @Test
51.     void testHash() {
52.         // 存入redis
53.         redisTemplate.opsForHash().put("user:002", "id", "002");
54.         redisTemplate.opsForHash().put("user:002", "name", "张三");
55.         redisTemplate.opsForHash().put("user:002", "age", 18);
56.         // 获取对应的key的所有值
57.         System.out.println(redisTemplate.opsForHash().entries("user:002"));
58.         System.out.println("====================================");
59.         // 获取对应的key的某个值
60.         System.out.println(redisTemplate.opsForHash().get("user:002", "id"));
61.         System.out.println(redisTemplate.opsForHash().get("user:002", "name"));
62.         System.out.println(redisTemplate.opsForHash().get("user:002", "age"));
63.     }
64. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！