1.maven引入相关依赖
1 | org.springframework.bootspring-boot-starter-data-redisorg.apache.commonscommons-pool22.11.1com.fasterxml.jackson.corejackson-databindorg.projectlomboklomboktrueorg.springframework.bootspring-boot-starter-testtest |
2.配置redis
application.yml
1 2 3 4 5 6 7 8 9 10 11 12 13 | spring: # 配置redis redis: host: 192.168.***.*** port: 6379 password: ****** lettuce: pool: max-active: 8 # 连接池最大连接数（使用负值表示没有限制） max-idle: 8 # 连接池中的最大空闲连接 max-wait: 100 # 连接池最大阻塞等待时间（使用负值表示没有限制） min-idle: 0 # 连接池中的最小空闲连接 database: 0 # redis数据库索引（默认为0） |
3.配置序列化
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 | package com.example.config;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.GenericJackson2JsonRedisSerializer;import org.springframework.data.redis.serializer.RedisSerializer;/** * Redis 序列化方式配置 * */@Configurationpublic class RedisConfig { @Bean public RedisTemplate redisTemplate(RedisConnectionFactory factory) { // 创建RedisTemplate对象 RedisTemplate template = new RedisTemplate(); // 配置连接工厂 template.setConnectionFactory(factory); // json方式序列化对象 GenericJackson2JsonRedisSerializer jsonRedisSerializer = new GenericJackson2JsonRedisSerializer(); // key采用String的序列化方式 template.setKeySerializer(RedisSerializer.string()); // hash的key也采用String的序列化方式 template.setHashKeySerializer(RedisSerializer.string()); // value序列化方式采用jackson template.setValueSerializer(jsonRedisSerializer); // hash的value序列化方式采用jackson template.setHashValueSerializer(jsonRedisSerializer); return template; }} |
4.测试类中进行测试
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 | package com.example;import com.example.entity.User;import com.fasterxml.jackson.core.JsonProcessingException;import com.fasterxml.jackson.databind.ObjectMapper;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.RedisTemplate;import org.springframework.data.redis.core.StringRedisTemplate;@SpringBootTestclass SpringDataRedisTestApplicationTests { @Autowired private RedisTemplate redisTemplate; @Autowired private StringRedisTemplate stringRedisTemplate; private static final ObjectMapper objectMapper = new ObjectMapper(); /** * 测试redis的String类型 */ @Test void testString() { redisTemplate.opsForValue().set("name", "minqiliang"); System.out.println(redisTemplate.opsForValue().get("name")); } /** * 使用StringRedisTemplate操作redis（需要手动进行序列化和反序列化） * @throws JsonProcessingException */ @Test void testString2() throws JsonProcessingException { // 创建一个对象 User user = new User("001", "minqiliang", 18); // 由于StringRedisTemplate默认使用的是String的序列化器，所以这里需要将对象转换成json字符串 String json = objectMapper.writeValueAsString(user); // 存入redis stringRedisTemplate.opsForValue().set("user:001", json); // 从redis中取出数据 String s = stringRedisTemplate.opsForValue().get("user:001"); // 将json字符串转换成对象 User u = objectMapper.readValue(s, User.class); System.out.println(u); } @Test void testHash() { // 存入redis redisTemplate.opsForHash().put("user:002", "id", "002"); redisTemplate.opsForHash().put("user:002", "name", "张三"); redisTemplate.opsForHash().put("user:002", "age", 18); // 获取对应的key的所有值 System.out.println(redisTemplate.opsForHash().entries("user:002")); System.out.println("===================================="); // 获取对应的key的某个值 System.out.println(redisTemplate.opsForHash().get("user:002", "id")); System.out.println(redisTemplate.opsForHash().get("user:002", "name")); System.out.println(redisTemplate.opsForHash().get("user:002", "age")); }} |
到此这篇关于springboot中操作redis实例分享的文章就介绍到这了,更多相关springboot中操作redis内容请搜索IT俱乐部以前的文章或继续浏览下面的相关文章希望大家以后多多支持IT俱乐部！
