app开发者平台在数字化时代的重要性与发展趋势解析
2282
2023-03-08
解决RedisTemplate调用increment报错问题
使用spring redis的increment方法时,报错:
nested exception is redis.clients.jedishttp://.exceptions.JedisDataException: ERR value is not an integer or out of range
一、INCRBY key increment
INCRBY key increment介绍如下:
http://
将 key 所储存的值加上增量 increment 。如果 key 不存在,那么 key 的值会先被初始化为 0 ,然后再执行 INCRBY 命令。如果值包含错误的类型,或字符串类型的值不能表示为数字,那么返回一个错误。本操作的值限制在 64 位(bit)有符号数字表示之内。
# key 存在且是数字值
redis> SET rank 50
OK
redis> INCRBY rank 20
(integer) 70
redis> GET rank
"70"
# key 不存在时
redis> EXISTS counter
(integer) 0
redis> INCRBY counter 30
(integer) 30
redis> GET counter
"30"
# key 不是数字值时
redis> SET book "long long ago..."
OK
redis> INCRBY book 200
(error) ERR value is not an integer or out of range
二、错误分析
报错的初始使用方法为
public Long incr(String key, long delta){
return commonRedisTemplate.opsForValue().increment(key, delta);
}
通过上面分析可以发现,错误原因是key对应的值不为数字,不能进行递增操作。通过查看RedisTemplate源码发现,其默认的序列化器为JdkSerializationRedisSerializer,猜想是否是序列化器进行序列化的时候,将key对应的value序列化为了字符串。
下面是RedisTemplate类部分源码
boolean defaultUsed = false;
if (defaultSerializer == null) {
defaultSerializer = new JdkSerializationRedisSerializer(
classLoader != null ? classLoader : this.getClass().getClassLoader());
}
if (enableDefaultSerializer) {
if (keySerializer == null) {
keySerializer = defaultSerializer;
defaultUsed = true;
}
if (valueSerializer == null) {
valueSerializer = defaultSerializer;
defaultUsed = true;
}
if (hashKeySerializer == null) {
hashKeySerializer = defaultSerializer;
defaultUsed = true;
}
if (hashValueSerializer == null) {
hashValueSerializer = defaultSerializer;
defaultUsed = true;
}
通过查看源码可以发现,
1.GenericJackson2jsonRedisSerializer、Jackson2JsonRedisSerializer是先将对象转为json,然后再保存到redis,所以,1在redis中是字符串1,所以无法进行加1。
2.JdkSerializationRedisSerializer使用的jdk对象序列化,序列化后的值有类信息、版本号等,所以是一个包含很多字母的字符串,所以根本无法加1。
3.GenericToStringSerializer、StringRedisSerializer将字符串的值直接转为字节数组,所以保存到redis中是数字,所以可以进行加1
修正后使用方法为
public Long incr(String key, long delta){
ValueOperations
commonRedisTemplate.setKeySerializer(new StringRedisSehttp://rializer());
commonRedisTemplate.setValueSerializer(new StringRedisSerializer());
return operations.increment(key, delta);
}
补充知识:生成履行行行号及RedisTemplate使用碰坑
title: 生成履行行行号及RedisTemplate使用碰坑
date: 2020-10-24 13:40
updated: 2020-10-24 13:30
categories:
搬砖笔记
java
tags:
java
redis
大致实现逻辑
后台写一个通用方法,参数为履行合同业务类型和公司代码,返回值为16位的履行行行号。
生成规则:履行合同业务类型1位+公司代码4位+年份2位+流水号9位(每个公司每年的流水号都从1开始)。例如:1 0021 20 000000001。
用子项目编码+公司代码+年份做Redis键,值为流水号。
流水号:由于直接用java代码生成在集群环境会有问题,故采用redisTemplate的increment(key,delta)方法生成,初次调用该方法会返回1。
格式化:redis返回的是自增的数字,需要格式化为9位流水号。java代码如下:
String.format("%09d",serialNumber);
RedisTemplate使用碰坑
redisTemplate. opsForValue(). set(key,value)这种方式存入Redis后会把数字型的值转为字符串,以后调用increment(key,delta)方法报错。
原因是底层采用了JdkSerializationRedisSerializer序列化机制。
解决方法有如下两种:
采用序列化方式
redishttp://Template.setKeySerializer(new StringRedisSerializer());
redisTemplate.setValueSerializer(new StringRedisSerializer());
赋值方法也要改(值为字符串),例如:
redisTemplate. opsForValue().set(key,"0")
使用StringRedisTemplate
Long serialNumber = stringRedisTemplate. opsForValue().increment(key,1);
版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。
发表评论
暂时没有评论,来抢沙发吧~