Redis中RedisTemplate怎么配置序列和反序列化
导读:本文共6166.5字符,通常情况下阅读需要21分钟。同时您也可以点击右侧朗读,来听本文内容。按键盘←(左) →(右) 方向键可以翻页。
摘要: RedisTemplate配置序列和反序列化对于redis操作,springboot进行了很好的封装,那就是spring data redis。提供了一个高度封装的RedisTemplate类来进行一系列redis操作,连接池自动管理;同时将事务封装操作,交由容器进行处理。针对数据的“序列化和反序列化”,提供了多种策略(RedisSerializer)默认为使用... ...
目录
(为您整理了一些要点),点击可以直达。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版本)
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency>
2)RedisConfig类
添加bean,指定key/value以及HashKey和HashValue的序列化和反序列化为FastJson的。
packagecom.sleb.springcloud.common.config;importcom.alibaba.fastjson.support.spring.GenericFastJsonRedisSerializer;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;importorg.springframework.data.redis.connection.RedisConnectionFactory;importorg.springframework.data.redis.core.RedisTemplate;importorg.springframework.data.redis.serializer.GenericToStringSerializer;/***redis配置*@author追到乌云的尽头找太阳(Jacob)**/@ConfigurationpublicclassRedisConfig{@BeanpublicRedisTemplate<Object,Object>redisTemplate(RedisConnectionFactoryredisConnectionFactory){RedisTemplate<Object,Object>redisTemplate=newRedisTemplate<>();redisTemplate.setConnectionFactory(redisConnectionFactory);//使用GenericFastJsonRedisSerializer替换默认序列化GenericFastJsonRedisSerializergenericFastJsonRedisSerializer=newGenericFastJsonRedisSerializer();//设置key和value的序列化规则redisTemplate.setKeySerializer(newGenericToStringSerializer<>(Object.class));redisTemplate.setValueSerializer(genericFastJsonRedisSerializer);//设置hashKey和hashValue的序列化规则redisTemplate.setHashKeySerializer(newGenericToStringSerializer<>(Object.class));redisTemplate.setHashValueSerializer(genericFastJsonRedisSerializer);//设置支持事物redisTemplate.setEnableTransactionSupport(true);redisTemplate.afterPropertiesSet();returnredisTemplate;}}
RedisTemplate序列化问题
序列化与反序列化规则不一致,导致报错问题
1、配置redisTemplate
<!--redis数据源--><beanid="poolConfig"class="redis.clients.jedis.JedisPoolConfig"><!--最大空闲数--><propertyname="maxIdle"value="${redis.maxIdle}"/><!--最大空连接数--><propertyname="maxTotal"value="${redis.maxTotal}"/><!--最大等待时间--><propertyname="maxWaitMillis"value="${redis.maxWaitMillis}"/><!--返回连接时,检测连接是否成功--><propertyname="testOnBorrow"value="${redis.testOnBorrow}"/></bean><!--Spring-data-redis连接池管理工厂--><beanid="jedisConnectionFactory"class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"><!--IP地址--><propertyname="hostName"value="${redis.host}"/><!--端口号--><propertyname="port"value="${redis.port}"/><!--密码--><!--<propertyname="password"value="${redis.password}"/>--><!--超时时间默认2000--><propertyname="timeout"value="${redis.timeout}"/><!--连接池配置引用--><propertyname="poolConfig"ref="poolConfig"/><!--是否使用连接池--><propertyname="usePool"value="true"/><!--指定使用的数据库--><propertyname="database"value="0"/></bean><!--redistemplatedefinition--><beanid="redisTemplate"class="org.springframework.data.redis.core.RedisTemplate"><propertyname="connectionFactory"ref="jedisConnectionFactory"/><propertyname="keySerializer"><beanclass="org.springframework.data.redis.serializer.StringRedisSerializer"/></property><propertyname="valueSerializer"><beanclass="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/></property><propertyname="hashKeySerializer"><beanclass="org.springframework.data.redis.serializer.StringRedisSerializer"/></property><propertyname="hashValueSerializer"><beanclass="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/></property></bean>
2、存值
此次存值,使用redisTemplate的回调函数,是按照字符串序列化方式存redisValue
publicvoidtestRedisListPush(){StringredisKey="testGoodsKey";List<String>redisValues=Arrays.asList("10002001","10002002");//使用管道向redislist结构中批量插入元素redisTemplate.executePipelined((RedisConnectionredisConnection)->{//打开管道redisConnection.openPipeline();//给本次管道内添加,一次性执行的多条命令for(StringredisValue:redisValues){redisConnection.rPush(redisKey.getBytes(),redisValue.getBytes());}returnnull;});}
redis客户端:value是字符串
3、取值
此次取值,返回结果默认是按照 1、配置redisTemplate中配置的JdkSerializationRedisSerializer序列化方式,由于存和取的序列化方式不统一,会产生报错情况。
publicvoidtestRedisListPop(){StringredisKey="testGoodsKey";//使用管道从redislist结构中批量获取元素List<Object>objects=redisTemplate.executePipelined((RedisConnectionredisConnection)->{//打开管道redisConnection.openPipeline();for(inti=0;i<2;i++){redisConnection.rPop(redisKey.getBytes());}returnnull;});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(),取值成功,解决问题!!
publicvoidtestRedisListPop(){StringredisKey="testGoodsKey";//使用管道从redislist结构中批量获取元素List<Object>objects=redisTemplate.executePipelined((RedisConnectionredisConnection)->{//打开管道redisConnection.openPipeline();for(inti=0;i<2;i++){redisConnection.rPop(redisKey.getBytes());}returnnull;},redisTemplate.getStringSerializer());System.out.println(objects);}
总结
1、使用原生redisTemplate操作数据和redisTemplate回调函数操作数据注意点:
a.原生redisTemplate操作数据
代码
publicvoidtestRedisListPush(){StringredisKey="testGoodsKey";List<String>redisValues=Arrays.asList("10002001","10002002");redisValues.forEach(redisValue->redisTemplate.opsForList().rightPush(redisKey,redisValue));}
redis客户端数据展示
b.redisTemplate回调函数操作数据
代码
publicvoidtestRedisListPush(){StringredisKey="testGoodsKey";List<String>redisValues=Arrays.asList("10002001","10002002");//使用管道向redislist结构中批量插入元素redisTemplate.executePipelined((RedisConnectionredisConnection)->{//打开管道redisConnection.openPipeline();//给本次管道内添加,一次性执行的多条命令for(StringredisValue:redisValues){redisConnection.rPush(redisKey.getBytes(),redisValue.getBytes());}returnnull;});}
redis客户端数据展示
c.不同点:
原生redisTemplate操作数据序列化方式是和redis配置统一的,redisTemplate回调函数操作数据序列化方式是自定义的。存值取值是需要注意。
</div> <div class="zixun-tj-product adv-bottom"></div> </div> </div> <div class="prve-next-news">
Redis中RedisTemplate怎么配置序列和反序列化的详细内容,希望对您有所帮助,信息来源于网络。