我在Redis里面踩的那些坑

2018-12-27  本文已影响0人  momo_vivi

最近刚刚上手使用redis,实际操作中遇到了许多大大小小的问题。在这篇文章中我会记录下这些问题,并尽量列出解决方法,希望能够帮助同样遇到这些问题的程序员们。

问题1:用RedisTemplate的opsForValue等方法插入数据以后,key和value都变成了乱码

乱码1 乱码2

RedisTemplate默认使用JdkSerializationRedisSerializer来进行序列化操作,而使用这种原始的序列化器进行序列化,会带入类型信息,就出现了乱码1的那种情况,因此我们需要手动配置RedisTemplate的序列化器。

代码如下:

代码1

在这里我把序列化器改为了Jackson2JsonRedisSerializer,出现了乱码2的问题。但是具体原因我也不知道是为什么,待查。

代码2

后来我把序列化器换成了StringRedisSerializer,乱码问题成功解决。但是如果在插入数据时,value的类型不是String类型的话,会抛出类型转换异常。

 问题2:WRONGTYPE Operation against a key holding the wrong kind of value

这个问题比较简单,纯粹是细不细心的问题。我往redis中插入了一条数据,key为map1,我以为数据的类型是Hash类型,但实际上的类型是Set类型。在使用opsForHash()的操作去获取value的时候,后台返回了WRONGTYPE Operation against a key holding the wrong kind of value的错误。

问题3:关于StringRedisTemplate.keys()方法

这个方法的作用是查找所有符合给定模式 pattern 的 key 。老大说不要使用这个方法,这个方法会影响redis集群的性能,甚至会导致丢key。

问题4:关于"Only localhost can do this command!"问题

为了获知指定的key有没有过期,我写了一个监听器,代码如下:

redis Key过期监听

这段代码在本地跑的时候没有问题,能够及时的监听到指定key的过期消息,并获取key,进行后续的业务处理。但是我把服务部署到domeos上以后,项目就起不来了,提示"Only localhost can do this command!"。后来发现是我本地项目连的是我自己的redis服务,domeos上用的是公司的redis集群。我把本地服务配置更改,连接到redis集群后,错误复现。

既然问题可以复现,那就相对好办一些了,我们来看看源码。我写的ActivityOnlineListener继承了KeyExpirationEventMessageListener,这个KeyExpirationEventMessageListener是用于监听redisKey过期事件的,附上源码:

KeyExpirationEventMessageListener

代码里面都是一些添加监听器和处理消息的方法,和异常没有关系,但是不着急,KeyExpirationEventMessageListener还继承了KeyspaceEventMessageListener,并实现了ApplicationEventPublisherAware。我们先去KeyspaceEventMessageListener里面看看。这部分代码比较长,我暂且只放重要的那部分。

KeyspaceEventMessageListener1 KeyspaceEventMessageListener2

问题来了,KeyspaceEventMessageListener中的init()方法负责监听器的初始化,在这个方法里面它去配置文件中取notify-keyspace-events(notify-keyspace-events 作用)这一个配置的值,如果该值为空,则修改为"EA"。由于我使用的是公司的redis集群,而集群中可能是没有配置notify-keyspace-events这一项的。而出于安全性的考虑,redis集群肯定是不允许服务去修改集群配置的,于是出现了上面的那个错误。后联系运维修改了相关配置,问题解决。

问题5:"No ongoing transaction. Did you forget to call multi?"

最近在写一些redis的demo,偶尔会遇到几个小问题,比如这个:在实现redis事务的时候遇到的小问题。先放上源码和异常,

demoCode 异常

我们来看看这个异常是怎么产生的,去异常的源头,也就是JedisConnection.exec()这个方法里面看一下。

方法源码

很明显,transaction为空,然后抛出了这个异常。所以,你要么在开启multi()之前,手动setEnableTransactionSupport(true)或者是在executePipelined(new SessionCallback(){})这个方法里面开启multi()。

上一篇下一篇

猜你喜欢

热点阅读