当前位置:   article > 正文

【springboot进阶】springboot集成fastjson(三)配置redis使用fastJson进行序列化_spring boot 3.0 集成redis fastjson

spring boot 3.0 集成redis fastjson

目录

一、引入依赖

二、添加redis连接配置

三、新建RedisConfig类配置

四、测试

 五、踩过的坑

数字型的保存

对象的保存 


上一章节,我们说到fastjson的自定义序列化和反序列化,这章节,我们看看如何配置redis使用fastjson进行序列化。

一、引入依赖

默认使用的redis连接为方式为lettuce

  1. <dependency>
  2. <groupId>org.springframework.boot</groupId>
  3. <artifactId>spring-boot-starter-data-redis</artifactId>
  4. </dependency>
  5. <dependency>
  6. <groupId>org.apache.commons</groupId>
  7. <artifactId>commons-pool2</artifactId>
  8. </dependency>

二、添加redis连接配置

在application.yml文件中,添加redis配置

  1. #redis配置
  2. spring:
  3. redis:
  4. host: 127.0.0.1
  5. password:
  6. port: 6379
  7. database: 3
  8. # 连接超时时间(毫秒)
  9. timeout: 10s
  10. client-type: lettuce
  11. lettuce:
  12. pool:
  13. # 连接池最大连接数(使用负值表示没有限制) 默认 8
  14. max-active: 1000
  15. # 连接池中的最大空闲连接 默认 8
  16. max-idle: 300
  17. # 连接池中的最小空闲连接 默认 0
  18. min-idle: 3
  19. # 连接池最大阻塞等待时间(使用负值表示没有限制) 默认 -1
  20. max-wait: 1s

三、新建RedisConfig类配置

  1. @Configuration
  2. public class FastjsonRedisConfig {
  3. /**
  4. * 自定义redisTemplate配置
  5. *
  6. * 使用的序列化方式
  7. *
  8. * @param redisConnectionFactory
  9. * @return
  10. */
  11. @Bean
  12. public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
  13. RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
  14. redisTemplate.setConnectionFactory(redisConnectionFactory);
  15. //key值使用spring默认的StringRedisSerializer
  16. redisTemplate.setKeySerializer(new StringRedisSerializer());
  17. //value值使用fastjson的GenericFastJsonRedisSerializer
  18. GenericFastJsonRedisSerializer fastJsonRedisSerializer = new GenericFastJsonRedisSerializer();
  19. redisTemplate.setValueSerializer(fastJsonRedisSerializer);
  20. //以下是hash序列化的配置
  21. redisTemplate.setHashKeySerializer(new StringRedisSerializer());
  22. redisTemplate.setHashValueSerializer(fastJsonRedisSerializer);
  23. return redisTemplate;
  24. }
  25. }

四、测试

编写测试demo

  1. @SpringBootTest
  2. class SpringbootFastjsonApplicationTests {
  3. @Resource
  4. RedisTemplate<String, Object> redisTemplate;
  5. @Test
  6. void contextLoads() {
  7. redisTemplate.opsForValue().set("fastjson_key", "a1b2c3", Duration.ofMinutes(5));
  8. Object object = redisTemplate.opsForValue().get("fastjson_key");
  9. System.out.println(object);
  10. }
  11. }

从调试窗口可以看到,redis连接池和redis连接配置信息,都是我们上面设置的。

 运行后,我们看一下redis保存的信息是否存在。

 可以看到在3库里面,保存着我们刚才设置的值。

这里看出,使用fastjson保存的字符串,会多出两个引号,这是区分字符和数字的标志。

 五、踩过的坑

使用fastJson进行序列化时,有一些坑是需要注意的。

数字型的保存

如果我们使用的是字符串来保存一个数字,那么我们就不能够在获取值的时候强制转化为数字型,否则会报错。

  1. redisTemplate.opsForValue().set("fastjson_key", "123", Duration.ofMinutes(5));
  2. Integer object = (Integer)redisTemplate.opsForValue().get("fastjson_key");
  3. System.out.println(object);

如下图报错信息

这里有个坑点就是,保存的时候用了字符串,但是取的时候印象中记得是一个数字,所以就理想当然的用数字型来强制转换,就会报错。redis中也是用的双引号标志,这是一个字符串,所以fastjson取值的时候也当作是一个字符串来处理。

 我们在看看,如果我们存的是一个数字型,是怎么样的。

可以看到,外层没有了双引号,fastjson也能识别出一个数字型,所以这次强转是没有报错了。

对象的保存 

建议保存对象的时候,能够先序列化为json字符串再保存,然后在获取的时候,再从字符串转为对应的对象。

如果我们直接保存对象到redis,代码如下。

  1. FastjsonDemoRequest fastjsonDemoRequest = new FastjsonDemoRequest();
  2. fastjsonDemoRequest.setUserName("张三");
  3. fastjsonDemoRequest.setAge(18);
  4. fastjsonDemoRequest.setMoney("1.8");
  5. redisTemplate.opsForValue().set("fastjson_key", fastjsonDemoRequest, Duration.ofMinutes(5));
  6. FastjsonDemoRequest object = (FastjsonDemoRequest)redisTemplate.opsForValue().get("fastjson_key");
  7. System.out.println(object);

此时的redis保存的值,如下图,这里多了一个"@type",值为这个类的class包路径。

这里会有什么问题呢?如果在其他的业务系统中,也要读取这个值,因为不同的系统间,包路径命名等不同,就会导致取值的时候会报错,如下图。

  1. FastjsonDemoRequest fastjsonDemoRequest = new FastjsonDemoRequest();
  2. fastjsonDemoRequest.setUserName("张三");
  3. fastjsonDemoRequest.setAge(18);
  4. fastjsonDemoRequest.setMoney("1.8");
  5. redisTemplate.opsForValue().set("fastjson_key", fastjsonDemoRequest, Duration.ofMinutes(5));
  6. org.liurb.springboot.fastjson.redis.FastjsonDemoRequest object = (org.liurb.springboot.fastjson.redis.FastjsonDemoRequest)redisTemplate.opsForValue().get("fastjson_key");
  7. System.out.println(object);

报错信息,如下图

如果我们先序列化为一个json字符串,代码如下

  1. FastjsonDemoRequest fastjsonDemoRequest = new FastjsonDemoRequest();
  2. fastjsonDemoRequest.setUserName("张三");
  3. fastjsonDemoRequest.setAge(18);
  4. fastjsonDemoRequest.setMoney("1.8");
  5. redisTemplate.opsForValue().set("fastjson_key", JSON.toJSONString(fastjsonDemoRequest), Duration.ofMinutes(5));
  6. String str = (String)redisTemplate.opsForValue().get("fastjson_key");
  7. org.liurb.springboot.fastjson.redis.FastjsonDemoRequest object = JSON.parseObject(str, org.liurb.springboot.fastjson.redis.FastjsonDemoRequest.class);
  8. System.out.println(object);

这样,我们就不需要担心因为跨业务系统导致包路径不相同,或者我们重命名为另外一个类的名字,都可以正常获取到redis的值,只要字段名字相同就行了。

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/酷酷是懒虫/article/detail/871336
推荐阅读
相关标签
  

闽ICP备14008679号