java

关注公众号 jb51net

关闭
首页 > 软件编程 > java > Java对象存入Redis

Java对象以Hash结构存入Redis详解

作者:Abstracted

这篇文章主要介绍了Java对象以Hash结构存入Redis详解,和Java中的对象非常相似,却不能按照Java对象的结构直接存储进Redis的hash中,因为Java对象中的field是可以嵌套的,而Redis的Hash结构不支持嵌套结构,需要的朋友可以参考下

Java对象以Hash结构存入Redis

Redis中Hash存储结构:

Key:{
	filed: value,
	filed: value,
	filed: value,
	....
}

和Java中的对象非常相似,却不能按照Java对象的结构直接存储进Redis的hash中。因为Java对象中的field是可以嵌套的,而Redis的Hash结构不支持嵌套结构。(不允许套娃~)。

有的同学要问了,那我就是头铁,就要把带嵌套属性的对象存储redis的hash中,应该怎么办?

Spring对所有的RedisClient进行了封装,提供了一个RedisTemplate。那我们看看RedisTemplate中对hash结构的存储都接受什么参数?

在这里插入图片描述

从图中可以看出:

一次只存一个KV就不用说了。重点是第二个putAll方法。既然是Map,那我们不就是可以将带有嵌套属性的对象转成Map就可以存进Redis了吗?

但经过实践最终抛出了异常。正如上面已经说过的,Redis的Hash结构不允许套娃。而不带有嵌套属性的对象转成Map后可以正常存入。

对象转Map可以使用commons的BeanUtils中的toMap方法。

难道真的就没有解决办法了吗?其实Spring已经为我们提供了嵌套属性转Map的3中实现方案,也就是 HashMapper 接口

在这里插入图片描述

可以看出 ObjectHashMapper 和 Jackson2HashMapper 的效果相同,用那个都可以。

注意:Jackson2HashMapper在为对象生成Map时,内部对ObjectMapper配置了对Date类型的序列化规则,会将其换成时间戳Long类型。 在执行putAll时,内部会报ClassCastException Long cast to String,Long无法直接转换为String。此时可以使用DecoratingStringHashMapper对Jackson2HashMapper进行增强。

下面是一部分的示例代码和截图

@Autowired
    private RedisTemplate redisTemplate;
    /**
     * 测试Redis存Hash结构数据
     */
    @Test
    void testSaveRedisHash() throws JsonProcessingException {
        User user = new User();user.setUserId(111);user.setPassword("psw");user.setName("张三");user.setCreateTime(new Date());
        ObjectMapper objectMapper = new ObjectMapper();
        redisTemplate.setHashKeySerializer(RedisSerializer.string());
        redisTemplate.setHashValueSerializer(RedisSerializer.string());
        // key, filed, value
        redisTemplate.opsForHash().put("testHash", "hashKey", "hashValue");
        // 直接写JSON,并没有什么卵用
        redisTemplate.opsForHash().put("testHash", "user", objectMapper.writeValueAsString(user));
        TestRedisHashObject testObj = new TestRedisHashObject(1, "测试时", new Date(), user);
        // 依赖第三方commons.beanUtils包
        redisTemplate.opsForHash().putAll("BeanUtilsHashMapper实现对象转hash",new BeanUtilsHashMapper<>(TestRedisHashObject.class).toHash(testObj));
        // flatmap为true,才开启json属性path扁平化。
        // jackson2HashMapper中默认的ObjectMapper对时间序列化成了long,而putAll方法中对long无法直接强转成string。会发生ClassCastException
        // decoratingStringHashMapper:将map中的所有kv都使用StringValueOf进行了增强
        redisTemplate.opsForHash().putAll("Jackson2HashMapper实现对象转hash",new DecoratingStringHashMapper<>(new Jackson2HashMapper(true)).toHash(testObj));
        // ObjectHashMapper返回的Map的泛型是Map<byte[], byte[]> 需要自己手动转换。不推荐使用
        // decoratingStringHashMapper:String.valueOf方法无法对byte[]进行转成字符串
        // redisTemplate.opsForHash().putAll("ObjectHashMapper实现对象转hash",new ObjectHashMapper().toHash(testObj));
    }
    /**
     * 测试Redis取Hash结构数据
     */
    @Test
    void testGetRedisHash(){
        redisTemplate.setHashKeySerializer(RedisSerializer.string());
        redisTemplate.setHashValueSerializer(RedisSerializer.string());
        String key = "Jackson2HashMapper实现对象转hash";
        Object o = new Jackson2HashMapper(true).fromHash(redisTemplate.opsForHash().entries(key));
        TestRedisHashObject testObj = (TestRedisHashObject) o;
        System.out.println(testObj);
        Long newCount = redisTemplate.opsForHash().increment(key, "count", 10L);
        System.out.println("newCount = " + newCount);
        o = new Jackson2HashMapper(true).fromHash(redisTemplate.opsForHash().entries(key));
        testObj = (TestRedisHashObject) o;
        System.out.println(testObj);
		Object c = redisTemplate.opsForHash().get(key, "count");
        Long count = (Long) c;
        System.out.println("getCount = " + count);
    }

在这里插入图片描述

在这里插入图片描述

到此这篇关于Java对象以Hash结构存入Redis详解的文章就介绍到这了,更多相关Java对象存入Redis内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

您可能感兴趣的文章:
阅读全文