解決RedisTemplate呼叫increment報錯問題
使用spring redis的increment方法時,報錯:
nested exception is redis.clients.jedis.exceptions.JedisDataException: ERR value is not an integer or out of range
一、INCRBY key increment
INCRBY key increment介紹如下:
將 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<String,String> operations = commonRedisTemplate.opsForValue(); commonRedisTemplate.setKeySerializer(new StringRedisSerializer()); 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序列化機制。
解決方法有如下兩種:
採用序列化方式
redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setValueSerializer(new StringRedisSerializer());
賦值方法也要改(值為字串),例如:
redisTemplate. opsForValue().set(key,"0")
使用StringRedisTemplate
Long serialNumber = stringRedisTemplate. opsForValue().increment(key,1);
以上這篇解決RedisTemplate呼叫increment報錯問題就是小編分享給大家的全部內容了,希望能給大家一個參考,也希望大家多多支援我們。