这篇文章将为大家详细讲解有关怎么在Redis集群中监听过期key，文章内容质量较高，因此小编分享给大家做个参考，希望大家阅读完这篇文章后对相关知识有一定的了解。

redis.host1:10.113.56.68redis.port1:7030redis.host2:10.113.56.68redis.port2:7031redis.host3:10.113.56.68redis.port3:7032redis.host4:10.113.56.68redis.port4:7033redis.host5:10.113.56.68redis.port5:7034redis.host6:10.113.56.68redis.port6:7035

importorg.springframework.beans.factory.annotation.Value;importorg.springframework.cache.CacheManager;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;importorg.springframework.data.redis.cache.RedisCacheManager;importorg.springframework.data.redis.connection.RedisClusterConfiguration;importorg.springframework.data.redis.connection.jedis.JedisConnectionFactory;importorg.springframework.data.redis.core.RedisTemplate;importorg.springframework.data.redis.listener.RedisMessageListenerContainer;importorg.springframework.data.redis.serializer.StringRedisSerializer;importredis.clients.jedis.Jedis;importredis.clients.jedis.JedisPoolConfig;importjava.util.Arrays;/***@Authorxiabing5*@Create2019/8/614:46*@Desc监听redis中Key过期事件**/@ConfigurationpublicclassRedisListenerConfig{@Value("${redis.host1}")privateStringhost1;@Value("${redis.host2}")privateStringhost2;@Value("${redis.host3}")privateStringhost3;@Value("${redis.host4}")privateStringhost4;@Value("${redis.host5}")privateStringhost5;@Value("${redis.host6}")privateStringhost6;@Value("${redis.port1}")privateintport1;@Value("${redis.port2}")privateintport2;@Value("${redis.port3}")privateintport3;@Value("${redis.port4}")privateintport4;@Value("${redis.port5}")privateintport5;@Value("${redis.port6}")privateintport6;@BeanJedisPoolConfigjedisPoolConfig(){JedisPoolConfigjedisPoolConfig=newJedisPoolConfig();jedisPoolConfig.setMaxIdle(100);jedisPoolConfig.setMaxWaitMillis(1000);returnjedisPoolConfig;}//redis-cluster不支持key过期监听，建立多个连接，对每个redis节点进行监听@BeanRedisMessageListenerContainerredisContainer1(){finalRedisMessageListenerContainercontainer=newRedisMessageListenerContainer();JedisConnectionFactoryjedisConnectionFactory=newJedisConnectionFactory();jedisConnectionFactory.setHostName(host1);jedisConnectionFactory.setPort(port1);jedisConnectionFactory.setPoolConfig(jedisPoolConfig());jedisConnectionFactory.afterPropertiesSet();container.setConnectionFactory(jedisConnectionFactory);returncontainer;}@BeanRedisMessageListenerContainerredisContainer2(){finalRedisMessageListenerContainercontainer=newRedisMessageListenerContainer();JedisConnectionFactoryjedisConnectionFactory=newJedisConnectionFactory();jedisConnectionFactory.setHostName(host2);jedisConnectionFactory.setPort(port2);jedisConnectionFactory.setPoolConfig(jedisPoolConfig());jedisConnectionFactory.afterPropertiesSet();container.setConnectionFactory(jedisConnectionFactory);returncontainer;}@BeanRedisMessageListenerContainerredisContainer3(){finalRedisMessageListenerContainercontainer=newRedisMessageListenerContainer();JedisConnectionFactoryjedisConnectionFactory=newJedisConnectionFactory();jedisConnectionFactory.setHostName(host3);jedisConnectionFactory.setPort(port3);jedisConnectionFactory.setPoolConfig(jedisPoolConfig());jedisConnectionFactory.afterPropertiesSet();container.setConnectionFactory(jedisConnectionFactory);returncontainer;}@BeanRedisMessageListenerContainerredisContainer4(){finalRedisMessageListenerContainercontainer=newRedisMessageListenerContainer();JedisConnectionFactoryjedisConnectionFactory=newJedisConnectionFactory();jedisConnectionFactory.setHostName(host4);jedisConnectionFactory.setPort(port4);jedisConnectionFactory.setPoolConfig(jedisPoolConfig());jedisConnectionFactory.afterPropertiesSet();container.setConnectionFactory(jedisConnectionFactory);returncontainer;}@BeanRedisMessageListenerContainerredisContainer5(){finalRedisMessageListenerContainercontainer=newRedisMessageListenerContainer();JedisConnectionFactoryjedisConnectionFactory=newJedisConnectionFactory();jedisConnectionFactory.setHostName(host5);jedisConnectionFactory.setPort(port5);jedisConnectionFactory.setPoolConfig(jedisPoolConfig());jedisConnectionFactory.afterPropertiesSet();container.setConnectionFactory(jedisConnectionFactory);returncontainer;}@BeanRedisMessageListenerContainerredisContainer6(){finalRedisMessageListenerContainercontainer=newRedisMessageListenerContainer();JedisConnectionFactoryjedisConnectionFactory=newJedisConnectionFactory();jedisConnectionFactory.setHostName(host6);jedisConnectionFactory.setPort(port6);jedisConnectionFactory.setPoolConfig(jedisPoolConfig());jedisConnectionFactory.afterPropertiesSet();container.setConnectionFactory(jedisConnectionFactory);returncontainer;}@BeanRedisKeyExpirationListenerredisKeyExpirationListener1(){returnnewRedisKeyExpirationListener(redisContainer1());}@BeanRedisKeyExpirationListenerredisKeyExpirationListener2(){returnnewRedisKeyExpirationListener(redisContainer2());}@BeanRedisKeyExpirationListenerredisKeyExpirationListener3(){returnnewRedisKeyExpirationListener(redisContainer3());}@BeanRedisKeyExpirationListenerredisKeyExpirationListener4(){returnnewRedisKeyExpirationListener(redisContainer4());}@BeanRedisKeyExpirationListenerredisKeyExpirationListener5(){returnnewRedisKeyExpirationListener(redisContainer5());}@BeanRedisKeyExpirationListenerredisKeyExpirationListener6(){returnnewRedisKeyExpirationListener(redisContainer6());}}

importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.data.redis.connection.Message;importorg.springframework.data.redis.listener.KeyExpirationEventMessageListener;importorg.springframework.data.redis.listener.RedisMessageListenerContainer;importjava.util.Date;/***@Authorxiabing5*@Create2019/9/49:47*@Descredis过期监听**/publicclassRedisKeyExpirationListenerextendsKeyExpirationEventMessageListener{@AutowiredRedisUtilredisUtil;@AutowiredLoginUserStatisticsMapperloginUserStatisticsMapper;publicRedisKeyExpirationListener(RedisMessageListenerContainerlistenerContainer){super(listenerContainer);}@OverridepublicvoidonMessage(Messagemessage,byte[]pattern){//用户做自己的业务处理即可,message.toString()可以获取失效的keyStringmesg=message.toString();}}

3.　Redis防止过期key重复监听

对于项目集群情况下，部署多个服务后，容易出现redis过期被多个服务同时监听到，从而执行相同的业务逻辑，这不是我们期望的。单机部署下方法的同步可以采用synchronize关键字。但集群下，就得采用分布式锁。在需要加锁的地方，只要加锁和解锁即可。此处正好写到Redis，那就贴一个自己用的redis分布式锁。

importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.stereotype.Component;importredis.clients.jedis.Jedis;importjava.util.Collections;importjava.util.UUID;/***@Authorxiabing5*@Create2019/9/615:54*@Descredis分布式锁**/@ComponentpublicclassRedisLock{@AutowiredJedisjedis;privatestaticfinalStringSET_IF_NOT_EXIST="NX";//NX表示如果不存在key就设置valueprivatestaticfinalStringSET_WITH_EXPIRE_TIME="PX";//PX表示毫秒//加锁publicStringtryLock(Stringkey,LongacquireTimeout){//生成随机valueStringidentifierValue=UUID.randomUUID().toString();//设置超时时间LongendTime=System.currentTimeMillis()+acquireTimeout;//循环获取锁while(System.currentTimeMillis()<endTime){Stringresult=jedis.set(key,identifierValue,SET_IF_NOT_EXIST,SET_WITH_EXPIRE_TIME,acquireTimeout);if("OK".equals(result)){returnidentifierValue;}}returnnull;}//解锁//publicvoiddelLock(Stringkey,StringidentifierValue){////判断是否是同一把锁//try{//if(jedis.get(key).equals(identifierValue)){////此处操作非原子性，容易造成释放非自己的锁//jedis.del(key);//}//}catch(Exceptione){//e.printStackTrace();//}//}//使用Lua代码解锁publicvoiddelLock(Stringkey,StringidentifierValue){try{Stringscript="ifredis.call('get',KEYS[1])==ARGV[1]thenreturnredis.call('del',KEYS[1])elsereturn0end";Longresult=(Long)jedis.eval(script,Collections.singletonList(key),Collections.singletonList(identifierValue));if(1==result){System.out.println(result+"释放锁成功");}if(0==result){System.out.println(result+"释放锁失败");}}catch(Exceptione){e.printStackTrace();}}}

关于怎么在Redis集群中监听过期key就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。