本站首页 收藏本站
广告位联系

APP正在开发中...
返回顶部
您的位置： 主页 > 数据库 > Redis >

收藏
分享到

Redis之RedisTemplate配置方式(序列和反序列化)

Redis 来源：互联网 作者：秩名 发布时间：2022-03-09 20:07:25 人浏览
摘要

RedisTemplate配置序列和反序列化 对于redis操作，springboot进行了很好的封装，那就是spring data redis。提供了一个高度封装的RedisTemplate类来进行一系列redis操作，连接池自动管理；同时将事务

RedisTemplate配置序列和反序列化

对于redis操作，springboot进行了很好的封装，那就是spring data redis。提供了一个高度封装的RedisTemplate类来进行一系列redis操作，连接池自动管理；同时将事务封装操作，交由容器进行处理。

针对数据的“序列化和反序列化”，提供了多种策略(RedisSerializer)

默认为使用JdkSerializationRedisSerializer，同时还有StringRedisSerializer，JacksonJsonRedisSerializer，OxmSerializer，GenericFastJsonRedisSerializer。

简介一下

  • JdkSerializationRedisSerializer：POJO对象的存取场景，使用JDK本身序列化机制，将pojo类通过ObjectInputStream/ObjectOutputStream进行序列化操作，最终redis-server中将存储字节序列。是目前默认的序列化策略。
  • StringRedisSerializer：Key或者value为字符串的场景，根据指定的charset对数据的字节序列编码成string，是“new String(bytes, charset)”和“string.getBytes(charset)”的直接封装。是最轻量级和高效的策略。
  • JacksonJsonRedisSerializer：jackson-json工具提供了javabean与json之间的转换能力，可以将pojo实例序列化成json格式存储在redis中，也可以将json格式的数据转换成pojo实例。因为jackson工具在序列化和反序列化时，需要明确指定Class类型，因此此策略封装起来稍微复杂。【需要jackson-mapper-asl工具支持】
  • GenericFastJsonRedisSerializer：另一种javabean与json之间的转换，同时也需要指定Class类型。
  • OxmSerializer：提供了将javabean与xml之间的转换能力，目前可用的三方支持包括jaxb，apache-xmlbeans；redis存储的数据将是xml工具。不过使用此策略，编程将会有些难度，而且效率最低；不建议使用。【需要spring-oxm模块的支持】

实践

1）依赖（版本继承了SpringBoot版本）

1

2

3

4

<dependency>

   <groupId>org.springframework.boot</groupId>

   <artifactId>spring-boot-starter-data-redis</artifactId>

</dependency>

2）RedisConfig类

添加bean，指定key/value以及HashKey和HashValue的序列化和反序列化为FastJson的。

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

package com.sleb.springcloud.common.config;

import com.alibaba.fastjson.support.spring.GenericFastJsonRedisSerializer;

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.GenericToStringSerializer;

/**

 * redis配置

 * @author 追到乌云的尽头找太阳（Jacob）

 **/

@Configuration

public class RedisConfig {

    @Bean

    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {

        RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();

        redisTemplate.setConnectionFactory(redisConnectionFactory);

        // 使用 GenericFastJsonRedisSerializer 替换默认序列化

        GenericFastJsonRedisSerializer genericFastJsonRedisSerializer = new GenericFastJsonRedisSerializer();

        // 设置key和value的序列化规则

        redisTemplate.setKeySerializer(new GenericToStringSerializer<>(Object.class));

        redisTemplate.setValueSerializer(genericFastJsonRedisSerializer);

        // 设置hashKey和hashValue的序列化规则

        redisTemplate.setHashKeySerializer(new GenericToStringSerializer<>(Object.class));

        redisTemplate.setHashValueSerializer(genericFastJsonRedisSerializer);

        // 设置支持事物

        redisTemplate.setEnableTransactionSupport(true);

        redisTemplate.afterPropertiesSet();

        return redisTemplate;

    }

}

RedisTemplate序列化问题

序列化与反序列化规则不一致，导致报错

1、配置redisTemplate

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

<!-- redis数据源 -->

    <bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">

        <!-- 最大空闲数 -->

        <property name="maxIdle" value="${redis.maxIdle}"/>

        <!-- 最大空连接数 -->

        <property name="maxTotal" value="${redis.maxTotal}"/>

        <!-- 最大等待时间 -->

        <property name="maxWaitMillis" value="${redis.maxWaitMillis}"/>

        <!-- 返回连接时，检测连接是否成功 -->

        <property name="testOnBorrow" value="${redis.testOnBorrow}"/>

    </bean>

<!-- Spring-data-redis连接池管理工厂 -->

    <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">

        <!-- IP地址 -->

        <property name="hostName" value="${redis.host}"/>

        <!-- 端口号 -->

        <property name="port" value="${redis.port}"/>

        <!-- 密码 -->

<!--        <property name="password" value="${redis.password}"/>-->

        <!-- 超时时间 默认2000 -->

        <property name="timeout" value="${redis.timeout}"/>

        <!-- 连接池配置引用 -->

        <property name="poolConfig" ref="poolConfig"/>

        <!-- 是否使用连接池 -->

        <property name="usePool" value="true"/>

        <!-- 指定使用的数据库 -->

        <property name="database" value="0"/>

    </bean>

<!-- redis template definition -->

    <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">

        <property name="connectionFactory" ref="jedisConnectionFactory"/>

        <property name="keySerializer">

            <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>

        </property>

        <property name="valueSerializer">

            <bean class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/>

        </property>

        <property name="hashKeySerializer">

            <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>

        </property>

        <property name="hashValueSerializer">

            <bean class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/>

        </property>

    </bean>

2、存值

此次存值，使用redisTemplate的回调函数，是按照字符串序列化方式存redisValue

1

2

3

4

5

6

7

8

9

10

11

12

13

14

    public void testRedisListPush() {

        String redisKey = "testGoodsKey";

        List<String> redisValues = Arrays.asList("10002001", "10002002");

        // 使用管道向redis list结构中批量插入元素

        redisTemplate.executePipelined((RedisConnection redisConnection) -> {

            // 打开管道

            redisConnection.openPipeline();

            // 给本次管道内添加，一次性执行的多条命令

            for (String redisValue : redisValues) {

                redisConnection.rPush(redisKey.getBytes(), redisValue.getBytes());

            }

            return null;

        });

    }

redis客户端：value是字符串

3、取值

此次取值，返回结果默认是按照 1、配置redisTemplate中配置的JdkSerializationRedisSerializer序列化方式，由于存和取的序列化方式不统一，会产生报错情况。

1

2

3

4

5

6

7

8

9

10

11

12

13

public void testRedisListPop() {

    String redisKey = "testGoodsKey";

    // 使用管道从redis list结构中批量获取元素

    List<Object> objects = redisTemplate.executePipelined((RedisConnection redisConnection) -> {

        // 打开管道

        redisConnection.openPipeline();

        for (int i = 0; i < 2; i++) {

            redisConnection.rPop(redisKey.getBytes());

        }

        return null;

    });

    System.out.println(objects);

}

报错详情：反序列化失败


org.springframework.data.redis.serializer.SerializationException: Cannot deserialize; nested exception is org.springframework.core.serializer.support.SerializationFailedException: Failed to deserialize payload. Is the byte array a result of corresponding serialization for DefaultDeserializer?; nested exception is java.io.StreamCorruptedException: invalid stream header: 31303030
...
Caused by: org.springframework.core.serializer.support.SerializationFailedException: Failed to deserialize payload. Is the byte array a result of corresponding serialization for DefaultDeserializer?; nested exception is java.io.StreamCorruptedException: invalid stream header: 31303030
    at org.springframework.core.serializer.support.DeserializingConverter.convert(DeserializingConverter.java:78)
    at org.springframework.core.serializer.support.DeserializingConverter.convert(DeserializingConverter.java:36)
    at org.springframework.data.redis.serializer.JdkSerializationRedisSerializer.deserialize(JdkSerializationRedisSerializer.java:80)
    ... 39 more
Caused by: java.io.StreamCorruptedException: invalid stream header: 31303030
    at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:899)
    at java.io.ObjectInputStream.<init>(ObjectInputStream.java:357)
    at org.springframework.core.ConfigurableObjectInputStream.<init>(ConfigurableObjectInputStream.java:63)
    at org.springframework.core.ConfigurableObjectInputStream.<init>(ConfigurableObjectInputStream.java:49)
    at org.springframework.core.serializer.DefaultDeserializer.deserialize(DefaultDeserializer.java:68)
    at org.springframework.core.serializer.support.DeserializingConverter.convert(DeserializingConverter.java:73)
    ... 41 more

解决办法

1、取值

需要在redisTemplate.executePipelined入参中再加一个参数：redisTemplate.getStringSerializer()，取值成功，解决问题！！

1

2

3

4

5

6

7

8

9

10

11

12

13

    public void testRedisListPop() {

        String redisKey = "testGoodsKey";

        // 使用管道从redis list结构中批量获取元素

        List<Object> objects = redisTemplate.executePipelined((RedisConnection redisConnection) -> {

            // 打开管道

            redisConnection.openPipeline();

            for (int i = 0; i < 2; i++) {

                redisConnection.rPop(redisKey.getBytes());

            }

            return null;

        }, redisTemplate.getStringSerializer());

        System.out.println(objects);

    }

总结

1、使用原生redisTemplate操作数据和redisTemplate回调函数操作数据注意点：

a.原生redisTemplate操作数据

代码

1

2

3

4

5

    public void testRedisListPush() {

        String redisKey = "testGoodsKey";

        List<String> redisValues = Arrays.asList("10002001", "10002002");

        redisValues.forEach(redisValue -> redisTemplate.opsForList().rightPush(redisKey, redisValue));

    }

redis客户端数据展示

b.redisTemplate回调函数操作数据

代码

1

2

3

4

5

6

7

8

9

10

11

12

13

14

    public void testRedisListPush() {

        String redisKey = "testGoodsKey";

        List<String> redisValues = Arrays.asList("10002001", "10002002");

        // 使用管道向redis list结构中批量插入元素

        redisTemplate.executePipelined((RedisConnection redisConnection) -> {

            // 打开管道

            redisConnection.openPipeline();

            // 给本次管道内添加，一次性执行的多条命令

            for (String redisValue : redisValues) {

                redisConnection.rPush(redisKey.getBytes(), redisValue.getBytes());

            }

            return null;

        });

    }

redis客户端数据展示

c.不同点：

原生redisTemplate操作数据序列化方式是和redis配置统一的，redisTemplate回调函数操作数据序列化方式是自定义的。存值取值是需要注意。
版权声明 : 本文内容来源于互联网或用户自行发布贡献，该文观点仅代表原作者本人。本站仅提供信息存储空间服务和不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权， 违法违规的内容， 请发送邮件至2530232025#qq.cn(#换@)举报，一经查实，本站将立刻删除。

您可能感兴趣的文章 :

原文链接 : https://blog.csdn.net/chen15369337607/article/details/104058934
相关文章
  • spring boot集成redis基础入门实例介绍
    redis 支持持久化数据，不仅支持key-value类型的数据，还拥有list，set，zset，hash等数据结构的存储。 可以进行master-slave模式的数据备份 更多

  • redis批量操作pipeline管道操作方法

    redis批量操作pipeline管道操作方法
    redis | pipeline（管道） 背景 Redis是一种基于客户端-服务端模型以及请求/响应的TCP服务。这意味着通常情况下一个请求会遵循以下步骤： 客户

  • springboot整合使用云服务器上的Redis方法

    springboot整合使用云服务器上的Redis方法
    一、前提条件 修改redis.conf配置文件 1、protected-mode yes（默认的） 修改成 protected-mode no，解除保护模式 2、注释掉绑定ip ，绑定ip的话，使得

  • 阿里云服务器部署Redis并整合Spring Boot的介绍

    阿里云服务器部署Redis并整合Spring Boot的介绍
    一、什么是Redis redis是一个key-value存储系统。和Memcached类似，它支持存储的value类型相对更多，包括string(字符串)、list(链表)、set(集合)、zs

  • 生产redisson延时队列不消费问题排查解决

    生产redisson延时队列不消费问题排查解决
    问题描述 项目使用redisson延时队列功能，实现直播的开播提醒，突然有一天业务爆出问题，未触发开播提醒。 初步排查 首先通过查询生产日

  • Redis主从复制分步讲解使用

    Redis主从复制分步讲解使用
    主服务器（master）启用二进制日志 选择一个唯一的server-id 创建具有复制权限的用户 从服务器（slave）启用中继日志， 选择一个唯一的serv
  • Redis中HyperLogLog的使用介绍
    HyperLogLog，基数统计； 那什么是基数？ 比如有两个数组 数组A = [1,2,3,4,5]; 数组B = [3,4,5,6,7]; 这时候基数就是[1,2,3,4,5,6,7]，总共有7个数； 就是

  • Redis中的持久化介绍

    Redis中的持久化介绍
    1. 前言 为什么要进行持久化？：持久化功能有效地避免因进程退出造成的数据丢失问题，当下次重启时利用之前持久化的文件即可实现数据

  • Redis源码设计剖析之事件处理示例介绍

    Redis源码设计剖析之事件处理示例介绍
    1. Redis事件介绍 Redis服务器是一个 事件驱动程序 ，所谓事件驱动就是输入一条命令并且按下回车，然后消息被组装成 Redis 协议的格式发送给

  • Mysql应用安装后找不到my.ini文件的解决过程

    Mysql应用安装后找不到my.ini文件的解决过程
    一、背景 我在两台电脑上安装了MySQL Server 8.0，准备继续做主从配置，这时候就需要用到my.ini文件进行配置，但是我找不到my.ini文件。 我的
推荐阅读
最新更新
友情链接
  • 本站所有内容来源于互联网或用户自行发布，本站仅提供信息存储空间服务，不拥有版权，不承担法律责任。如有侵犯您的权益，请您联系站长处理！
  • Copyright © 2017-2022 F11.CN All Rights Reserved. F11站长开发者网 版权所有 | 苏ICP备2022031554号-1 | 51LA统计