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

场景：

项目有两种角色需要不同的登录权限，将redis做为用户登录信息缓存数据库。码一个方法，希望能够根据传入不用用户实体类型来获取相应的数据。用户实体为：SessionEntity、SessionEntity。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() {
   public SessionEntity doInRedis(RedisConnection connection)
     throws DataAccessException {
    RedisSerializer 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() {
   public SessionEntity doInRedis(RedisConnection connection)
     throws DataAccessException {
    RedisSerializer 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>(){});
   }
  });

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

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

SessionEntity result = redisTemplate.execute(new RedisCallback>() {
   public SessionEntity doInRedis(RedisConnection connection)
     throws DataAccessException {
    RedisSerializer 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>(){});
   }
  });

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

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

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

替换后的代码：

SessionEntity result = redisTemplate.execute(new RedisCallback>() {
   public SessionEntity doInRedis(RedisConnection connection)
     throws DataAccessException {
    RedisSerializer 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>(){});
   }
  });

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

提供的抽象方法为：

public SessionEntity get(final String s, Class 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 ? this.classLoader : this.getClass().getClassLoader());
 }

 if (this.enableDefaultSerializer) {
  if (this.keySerializer == null) {
   this.keySerializer = this.defaultSerializer;
   defaultUsed = true;
  }

  if (this.valueSerializer == null) {
   this.valueSerializer = this.defaultSerializer;
   defaultUsed = true;
  }

  if (this.hashKeySerializer == null) {
   this.hashKeySerializer = this.defaultSerializer;
   defaultUsed = true;
  }

  if (this.hashValueSerializer == null) {
   this.hashValueSerializer = this.defaultSerializer;
   defaultUsed = true;
  }
 }

 if (this.enableDefaultSerializer && defaultUsed) {
  Assert.notNull(this.defaultSerializer, "default serializer null and not all serializers initialized");
 }

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

 this.initialized = true;
}

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

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

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

 @Bean
 public RedisTemplate objectRedisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {
  RedisTemplate template = new RedisTemplate();
  Jackson2JsonRedisSerializer