这篇文章主要介绍了Redis之RedisTemplate配置方式(序列和反序列化)，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
RedisTemplate配置序列和反序列化
对于redis操作，springboot封装的很好，就是spring数据redis。提供了一个高度封装的redisTemplate类来执行一系列Redis操作，连接池是自动管理的。同时，将事务封装操作交给容器进行处理。
Ldquo为数据；序列化和反序列化rdquo，提供了多种策略(再序列化)
默认使用JDKSerialization Redisserializer，另外还有StringRedisSerializer、JacksonJsonRedisSerializer、OxmSerializer、GenericFastJsonRedisSerializer。
简介一下JdkSerializationRedisSerializer：POJO对象的存取场景，使用JDK本身序列化机制，将pojo类通过ObjectInputStream/ObjectOutputStream进行序列化操作，最终redis-server中将存储字节序列。是目前默认的序列化策略。StringRedisSerializer：Key或者value为字符串的场景，根据指定的charset对数据的字节序列编码成string，是ldquo;new String(bytes, charset)rdquo;和ldquo;string.getBytes(charset)rdquo;的直接封装。是最轻量级和高效的策略。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版本)
lt;dependencygt; lt;groupIdgt;org.springframework.bootlt;/groupIdgt; lt;artifactIdgt;spring-boot-starter-data-redislt;/artifactIdgt;lt;/dependencygt;
2)RedisConfig类
添加bean，指定key/value、HashKey和HashValue的序列化和反序列化为FastJson。
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）**/@Configurationpublic class RedisConfig { @Bean public RedisTemplatelt;Object, Objectgt; redisTemplate(RedisConnectionFactory redisConnectionFactory) { RedisTemplatelt;Object, Objectgt; redisTemplate = new RedisTemplatelt;gt;(); redisTemplate.setConnectionFactory(redisConnectionFactory); // 使用 GenericFastJsonRedisSerializer 替换默认序列化 GenericFastJsonRedisSerializer genericFastJsonRedisSerializer = new GenericFastJsonRedisSerializer(); // 设置key和value的序列化规则 redisTemplate.setKeySerializer(new GenericToStringSerializerlt;gt;(Object.class)); redisTemplate.setValueSerializer(genericFastJsonRedisSerializer); // 设置hashKey和hashValue的序列化规则 redisTemplate.setHashKeySerializer(new GenericToStringSerializerlt;gt;(Object.class)); redisTemplate.setHashValueSerializer(genericFastJsonRedisSerializer); // 设置支持事物 redisTemplate.setEnableTransactionSupport(true); redisTemplate.afterPropertiesSet(); return redisTemplate; }}
RedisTemplate序列化问题
序列化与反序列化规则不一致，导致报错
1.配置redisTemplate
lt;!-- redis数据源 --gt; lt;bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig"gt; lt;!-- 最大空闲数 --gt; lt;property name="maxIdle" value="${redis.maxIdle}"/gt; lt;!-- 最大空连接数 --gt; lt;property name="maxTotal" value="${redis.maxTotal}"/gt; lt;!-- 最大等待时间 --gt; lt;property name="maxWaitMillis" value="${redis.maxWaitMillis}"/gt; lt;!-- 返回连接时，检测连接是否成功 --gt; lt;property name="testOnBorrow" value="${redis.testOnBorrow}"/gt; lt;/beangt;lt;!-- Spring-data-redis连接池管理工厂 --gt; lt;bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"gt; lt;!-- IP地址 --gt; lt;property name="hostName" value="${redis.host}"/gt; lt;!-- 端口号 --gt; lt;property name="port" value="${redis.port}"/gt; lt;!-- 密码 --gt;lt;!-- lt;property name="password" value="${redis.password}"/gt;--gt; lt;!-- 超时时间 默认2000 --gt; lt;property name="timeout" value="${redis.timeout}"/gt; lt;!-- 连接池配置引用 --gt; lt;property name="poolConfig" ref="poolConfig"/gt; lt;!-- 是否使用连接池 --gt; lt;property name="usePool" value="true"/gt; lt;!-- 指定使用的数据库 --gt; lt;property name="database" value="0"/gt; lt;/beangt;lt;!-- redis template definition --gt; lt;bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate"gt; lt;property name="connectionFactory" ref="jedisConnectionFactory"/gt; lt;property name="keySerializer"gt; lt;bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/gt; lt;/propertygt; lt;property name="valueSerializer"gt; lt;bean class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/gt; lt;/propertygt; lt;property name="hashKeySerializer"gt; lt;bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/gt; lt;/propertygt; lt;property name="hashValueSerializer"gt; lt;bean class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/gt; lt;/propertygt; lt;/beangt;
2.存入值
这次使用redisTemplate的回调函数，按照字符串序列化存储redisValue。
public void testRedisListPush() { String redisKey = "testGoodsKey"; Listlt;Stringgt; redisValues = Arrays.asList("10002001", "10002002"); // 使用管道向redis list结构中批量插入元素 redisTemplate.executePipelined((RedisConnection redisConnection) -gt; { // 打开管道 redisConnection.openPipeline(); // 给本次管道内添加，一次性执行的多条命令 for (String redisValue : redisValues) { redisConnection.rPush(redisKey.getBytes(), redisValue.getBytes()); } return null; }); }
Redis客户端:值是一个字符串
3.价值选择
对于这个值检索，默认情况下返回的结果是根据1。配置redisTemplate中配置的JDKSerialization Redisserializer序列化方法。因为存储和检索的序列化方法不统一，所以会报错。
public void testRedisListPop() { String redisKey = "testGoodsKey"; // 使用管道从redis list结构中批量获取元素 Listlt;Objectgt; objects = redisTemplate.executePipelined((RedisConnection redisConnection) -gt; { // 打开管道 redisConnection.openPipeline(); for (int i = 0; i lt; 2; i++) { redisConnection.rPop(redisKey.getBytes()); } return null; }); System.out.println(objects); }
错误详细信息:反序列化失败。
org . spring framework . data . redis . serializer . serialization exception:无法反序列化；嵌套异常为org . spring framework . core . serializer . support . serializationfailedexception:未能反序列化负载。该字节数组是DefaultDeserializer的相应序列化的结果；嵌套异常是Java . io . streamcorruptedexception:无效的流头:31303030
...
原因:org . spring framework . core . serializer . support . serializationfailedexception:未能反序列化负载。该字节数组是DefaultDeserializer的相应序列化的结果；嵌套异常为Java . io . streamcorruptedexception:无效流头:31303030
at org . spring framework . core . serializer . support . deserializing converter . convert(deserializing converter . Java:78)
at org . spring framework . core . serializer . support . deserializing converter . convert(description:36)
at org . spring framework . data . redis . serializer . jdkserializationredisserializer . deserialize...39 more
由:Java . io . streamcorruptedexception:无效的流头:31303030
at Java . io . objectinputstream . read stream header(objectinputstream . Java:899)
at Java . io . objectinputstream . lt；initgt(objectinputstream . Java:357)
at org . spring framework . core . configurableobjectinputstream . lt；initgt(configurableobjectinputstream . Java:63)
at org . spring framework . core . configurableobjectinputstream . lt；initgt(configurableobjectinputstream . Java:49)
at org . spring framework . core . serializer . default deserializer . deserialize(default deserializer . Java:68)
at org . spring framework . core . serializer . support . deserialing converter . convert(deserializing converter . Java:73)
...41更
解决办法
1.价值选择
您需要向redisTemplate.executePipelined参数添加另一个参数:redis template . getstring serializer()。值成功了，问题解决了！！
public void testRedisListPop() { String redisKey = "testGoodsKey"; // 使用管道从redis list结构中批量获取元素 Listlt;Objectgt; objects = redisTemplate.executePipelined((RedisConnection redisConnection) -gt; { // 打开管道 redisConnection.openPipeline(); for (int i = 0; i lt; 2; i++) { redisConnection.rPop(redisKey.getBytes()); } return null; }, redisTemplate.getStringSerializer()); System.out.println(objects); }
总结
1.使用原生redisTemplate操作数据和redisTemplate回调函数操作数据。注意:
A.本机redist模板操作数据
密码
public void testRedisListPush() { String redisKey = "testGoodsKey"; Listlt;Stringgt; redisValues = Arrays.asList("10002001", "10002002"); redisValues.forEach(redisValue -gt; redisTemplate.opsForList().rightPush(redisKey, redisValue)); }
Redis客户数据展示
B.b.redisTemplate回调函数的操作数据
密码
public void testRedisListPush() { String redisKey = "testGoodsKey"; Listlt;Stringgt; redisValues = Arrays.asList("10002001", "10002002"); // 使用管道向redis list结构中批量插入元素 redisTemplate.executePipelined((RedisConnection redisConnection) -gt; { // 打开管道 redisConnection.openPipeline(); // 给本次管道内添加，一次性执行的多条命令 for (String redisValue : redisValues) { redisConnection.rPush(redisKey.getBytes(), redisValue.getBytes()); } return null; }); }
Redis客户数据展示
C.差异:
原生redisTemplate操作数据的序列化方式与redis配置一致，redisTemplate回调函数操作数据的序列化方式是自定义的。注意存储和取值是很重要的。
以上个人经验，希望能给你一个参考
加载中,请稍侯......
精彩评论