使用Redis获取数据转json,解决动态泛型传参的问题

站长资源 2024/4/27 佚名

2 0 1

兴国资源网 Design By www.nnzcdc.com

场景：

项目有两种角色需要不同的登录权限，将redis做为用户登录信息缓存数据库。码一个方法，希望能够根据传入不用用户实体类型来获取相应的数据。用户实体为：SessionEntity<User1>、SessionEntity<User2>。json使用FastJson。

先阐述遇到的几个问题：

1、redis获取到的数据序列化后，转json，经常提示转换异常（并不是每次，只是时常）。

2、不想每种用户都书写一个redis操作方法（显得tai low）。

解决：

1、redis获取到的数据序列化后，转json，经常提示转换异常：

先说redis有两种获取方式。

1）

redisTemplate.opsForValue().get(key);

2）

SessionEntity result = redisTemplate.execute(new RedisCallback<SessionEntity>() {
   public SessionEntity doInRedis(RedisConnection connection)
     throws DataAccessException {
    RedisSerializer<String> serializer = getRedisSerializer();
    byte[] key = serializer.serialize(s);
    byte[] value = connection.get(key);
    if (value == null) {
     return null;
    }
    String json = serializer.deserialize(value);
    return JSONObject.parseObject(json,SessionEntity.class);
   }
  });

显然第一种的方式比较简单。查看源码，发现第一种方式底层调用的也是redisTemplate.execute方法，所以应该算是一种封装吧。我们一直采用的是第二种方式。（第一种方式试过，也一样会出现json强转异常）。这里出现过json异常，怀疑是跟泛型有关。这里手动指定泛型反序列化类型。

修改后：

SessionEntity result = redisTemplate.execute(new RedisCallback<SessionEntity>() {
   public SessionEntity doInRedis(RedisConnection connection)
     throws DataAccessException {
    RedisSerializer<String> serializer = getRedisSerializer();
    byte[] key = serializer.serialize(s);
    byte[] value = connection.get(key);
    if (value == null) {
     return null;
    }
    String json = serializer.deserialize(value);
    return JSONObject.parseObject(json, new TypeReference<SessionEntity<User(){});
   }
  });

完美~，确实解决了json强转异常。

那么问题来了，这里的TypeReference需要手动指定明确的的实体类型，尝试添加泛型：

SessionEntity<T> result = redisTemplate.execute(new RedisCallback<SessionEntity<T() {
   public SessionEntity<T> doInRedis(RedisConnection connection)
     throws DataAccessException {
    RedisSerializer<String> serializer = getRedisSerializer();
    byte[] key = serializer.serialize(s);
    byte[] value = connection.get(key);
    if (value == null) {
     return null;
    }
    String json = serializer.deserialize(value);
    return JSONObject.parseObject(json, new TypeReference<SessionEntity<T(){});
   }
  });

看样子是没什么问题，而且泛型也被识别到了。但是依旧无法通过。

2、不想每种用户都书写一个redis操作方法：

上面说到就算加了泛型也依旧无法通过，尝试了多种方式依旧如此。百度了一圈，都是说使用TypeReference这个来解决，但是并没有提及动态泛型的问题。偶然间看到文章说Fastjson不支持，所以尝试替换成jackson。

替换后的代码：

SessionEntity<T> result = redisTemplate.execute(new RedisCallback<SessionEntity<T() {
   public SessionEntity<T> doInRedis(RedisConnection connection)
     throws DataAccessException {
    RedisSerializer<String> serializer = getRedisSerializer();
    byte[] key = serializer.serialize(s);
    byte[] value = connection.get(key);
    if (value == null) {
     return null;
    }
    String json = serializer.deserialize(value);
    ObjectMapper om = new ObjectMapper();
    JavaType javatype = om.getTypeFactory().constructParametricType(SessionEntity.class, clazz);
    try {
     return om.readValue(json, javatype);
    } catch (IOException e) {
     e.printStackTrace();
    }
    return null;
//    return JSONObject.parseObject(json, new TypeReference<SessionEntity<T(){});
   }
  });

这里使用到了jackson的ObjectMapper。ObjectMapper类是Jackson库的主要类。它提供一些功能将转换成Java对象匹配JSON结构，反之亦然。它使用JsonParser和JsonGenerator的实例实现JSON实际的读/写。（复制来的）发现问题解决。

提供的抽象方法为：

public <T> SessionEntity<T> get(final String s, Class<T> clazz);

调用方式为：

sessionEntityDao.get(key, User1.class); 跟 sessionEntityDao.get(key, User2.class);

由于这里使用到的是jackson-databind-2.6.0的库，这个版本种constructParametricType这个方法已经快要过时，更高版本使用

constructParametrizedType

替换。这里我还没尝试过，等有空再玩。

这里问题已经解决，纯粹做个笔记以供自己以后方便查阅。这里只提供自己项目中遇到的解决方式之一，相信应该还有其他方式可以解决。如果有说明错误的地方，请指出并见谅。

补充知识：Redis爬坑——Redis实现通用序列化器 & 解决Redis反序列化失败

Redis默认序列化是 JdkSerializationRedisSerializer,由此可见

public void afterPropertiesSet() {
 super.afterPropertiesSet();
 boolean defaultUsed = false;
 if (this.defaultSerializer == null) {
  this.defaultSerializer = new JdkSerializationRedisSerializer(this.classLoader != null "default serializer null and not all serializers initialized");
 }

 if (this.scriptExecutor == null) {
  this.scriptExecutor = new DefaultScriptExecutor(this);
 }

 this.initialized = true;
}

这里因为我们的项目需要更改默认序列策略为Jackson2JsonRedisSerializer让它序列化为可视化的***json***语句

我们首先定义自己的RedisTemplate，这里我们不要为了每一个类定义一个序列化器，我们定义一个统一的序列化器所以这里泛型是 <String,Object>,key我们使用StringRedisSerializer,value使用Jackson2JsonRedisSerializer

注释代码为修复反序列化bug的代码

 @Bean
 public RedisTemplate<String, Object> objectRedisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {
  RedisTemplate<String, Object> template = new RedisTemplate();
  Jackson2JsonRedisSerializer<Object> jsonSerial = new 		 Jackson2JsonRedisSerializer(Object.class);
//  //修复反序列化bug
//  ObjectMapper om = new ObjectMapper();
//  om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
//  om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
//  jsonSerial.setObjectMapper(om);
  template.setDefaultSerializer(jsonSerial);
  template.setKeySerializer(RedisSerializer.string());
  template.setConnectionFactory(redisConnectionFactory);
  template.afterPropertiesSet();
  return template;
 }

测试代码为

@Test
public void redisSaveObject(){

 UserDO ob = new UserDO();
 ob.setName("name");
 ob.setCity("city");
 objectRedisTemplate.opsForValue().set("ob1",ob);
 Object ob2 = objectRedisTemplate.opsForValue().get("ob1");
 UserDO ob1 = (UserDO)ob2;
 System.out.println(ob1);

}

运行结果为

java.lang.ClassCastException: java.util.LinkedHashMap cannot be cast to com.hcy.core.model.UserDO
at com.hcy.core.redistest.RedisTest.redisSaveObject(RedisTest.java:42)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at

很明显是对象强制转换错误

这是因为泛型的原因，redis在序列化时候把他当成Object序列化的，所以这里反序列化为Object是可以的，但是因为这个Object没有类型定义所以无法强转。

解决办法

在RedisTemplate中对序列化器Jackson2JsonRedisSerializer进行修改添加如下代码，上文注释了

  //修复反序列化bug
  ObjectMapper om = new ObjectMapper();
  om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
  om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
  jsonSerial.setObjectMapper(om);

通过 objectMapper.enableDefaultTyping() 方法设置

即使使用 Object.class 作为 jcom.fasterxml.jackson.databind.JavaType 也可以实现相应类型的序列化和反序列化

好处：只定义一个序列化器就可以了（通用）

这里我们也做个测试，分别用不修改ObjectMapper的和修改了ObjectMapper的看看生成的value有啥子不一样

运行结果：

ob1: [“com.hcy.core.model.UserDO”,{“userid”:null,“openid”:null,“name”:“name”,“city”:“city”}]

ob2: {“userid”:null,“openid”:null,“name”:“name”,“city”:“city”}

这里结果很明显啦！！！

希望对大家有帮助！！！

以上这篇使用Redis获取数据转json,解决动态泛型传参的问题就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持。

Redis,数据,json,泛型传参

兴国资源网 Design By www.nnzcdc.com

广告合作：本站广告合作请联系QQ：858582 申请时备注：广告合作（否则不回）
免责声明：本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除！

兴国资源网 Design By www.nnzcdc.com

评论“使用Redis获取数据转json,解决动态泛型传参的问题”

暂无评论...

www.nnzcdc.com 兴国资源网

39,976影音资源

44,792技术资源

21,817软件资源

651,128站长资源

使用Redis获取数据转json,解决动态泛型传参的问题

redis 解决key的乱码问题,并清理详解

redis操作学习记录

评论“使用Redis获取数据转json,解决动态泛型传参的问题”

RTX 5090要首发性能要翻倍！三星展示GDDR7显存

更新日志

友情链接

使用Redis获取数据转json,解决动态泛型传参的问题

redis 解决key的乱码问题,并清理详解

redis操作学习记录

评论“使用Redis获取数据转json,解决动态泛型传参的问题”

RTX 5090要首发 性能要翻倍！三星展示GDDR7显存

更新日志

友情链接

RTX 5090要首发性能要翻倍！三星展示GDDR7显存