redis.clients.jedis.exceptions.JedisDataException: ERR hash value is not an integer

78 阅读 0 评论 52 点赞

我是靠谱客的博主着急悟空，这篇文章主要介绍redis.clients.jedis.exceptions.JedisDataException: ERR hash value is not an integer，现在分享给大家，希望可以做个参考。

业务场景

https://blog.csdn.net/qq_31071543/article/details/84752778

推测抛出异常的原因
第一次访问接口时通过void setEntryInHash(String key,String field,String vlaue)方法在redis中存放用户访问当前接口的次数为1，此时不会抛出异常，通过redis命令查看存放的数据为
field为： “��” value为："��。第二次访问接口时通过void incrementValue(String key,String field,int increment)方法改变用户访问接口的次数，此时就会抛出异常。由此可以看出抛出异常的原因可能是因为第一次存放的数据已经发生乱码，第二次通过传入一个int去改变内存中用户访问的接口次数就会发生乱码。

分析抛出异常的原因
在项目中采用 Spring Data Redis操作数据库缓存，通过RedisTemplate模版来操作redis数据库。RedisTemplate的bean配置为：

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
@Bean
	RedisTemplate<String, Object> template(RedisConnectionFactory connectionFactory) {
		RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
		template.setConnectionFactory(connectionFactory);
		// 定义value的序列化方式
		Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<Object>(Object.class);
		ObjectMapper om = new ObjectMapper();
		om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
		om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
		jackson2JsonRedisSerializer.setObjectMapper(om);
		template.setValueSerializer(jackson2JsonRedisSerializer);
		template.setKeySerializer(new StringRedisSerializer(Charset.forName("UTF-8")));
		template.afterPropertiesSet();
		return template;
	}

发现没有配置hashkey,hashValue的序列化方式，因此当我们采用RedisTemplate操作hash数据结构，就会采用默认的序列化方式JdkSerializationRedisSerializer(这种序列化方式主要用来操作对象，操作字符串就会发生乱码的情况)。

解决方案
方案一：
在使用注解@Bean返回RedisTemplate的时候，同时配置hashKey与hashValue的序列化方式。

复制代码

@Bean
	RedisTemplate<String, Object> template(RedisConnectionFactory connectionFactory) {
		RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
		template.setConnectionFactory(connectionFactory);
		// 定义value的序列化方式
		Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<Object>(Object.class);
		ObjectMapper om = new ObjectMapper();
		om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
		om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
		jackson2JsonRedisSerializer.setObjectMapper(om);
		template.setValueSerializer(jackson2JsonRedisSerializer);
		template.setKeySerializer(new StringRedisSerializer(Charset.forName("UTF-8")));
		//save hash use StringRedisSerializer as serial method
		template.setHashKeySerializer(new StringRedisSerializer(Charset.forName("UTF-8")));
		template.setHashValueSerializer(new StringRedisSerializer(Charset.forName("UTF-8")));
		template.afterPropertiesSet();
		return template;
	}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
@Bean
	RedisTemplate<String, Object> template(RedisConnectionFactory connectionFactory) {
		RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
		template.setConnectionFactory(connectionFactory);
		// 定义value的序列化方式
		Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<Object>(Object.class);
		ObjectMapper om = new ObjectMapper();
		om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
		om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
		jackson2JsonRedisSerializer.setObjectMapper(om);
		template.setValueSerializer(jackson2JsonRedisSerializer);
		template.setKeySerializer(new StringRedisSerializer(Charset.forName("UTF-8")));
		//save hash use StringRedisSerializer as serial method
		template.setHashKeySerializer(new StringRedisSerializer(Charset.forName("UTF-8")));
		template.setHashValueSerializer(new StringRedisSerializer(Charset.forName("UTF-8")));
		template.afterPropertiesSet();
		return template;
	}

方案二：
采用Spring Data Redis的StringRedisTemplate这个模版来操作数据。

复制代码

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
@Slf4j
@Service("redisHashService")
public class RedisHashServiceImpl implements RedisHashService {
	
	
	@Autowired
	StringRedisTemplate redisTemplate;
	
	@Resource(name="redisTemplate")
	HashOperations<String, Object, Object>  opsForHash;

	@Override
	public Object getValueByKeyAndField(String key, String field) {
		return opsForHash.get(key, field);
	}

	@Override
	public boolean hasKey(String key) {
		return redisTemplate.hasKey(key);
	}

	@Override
	public void setExpire(String key, long during, TimeUnit timeUnit) {
		redisTemplate.expire(key, during, timeUnit);
	}

	@Override
	public boolean hasKeyAndField(String key, String field) {
		return opsForHash.hasKey(key, field);
	}

	@Override
	public void setEntryInHash(String key, String field, String value) {
		 opsForHash.put(key, field, value);
	}

	@Override
	public void incrementValue(String key, String field,long incredment) {
		opsForHash.increment(key, field, incredment);
	}

}