|  |  |  | 
|---|
|  |  |  | import org.springframework.data.redis.connection.RedisConnection; | 
|---|
|  |  |  | import org.springframework.data.redis.listener.KeyExpirationEventMessageListener; | 
|---|
|  |  |  | import org.springframework.data.redis.listener.RedisMessageListenerContainer; | 
|---|
|  |  |  | import org.springframework.util.StringUtils; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import java.util.Properties; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public class RedisKeyExpirationEventMessageListener extends KeyExpirationEventMessageListener { | 
|---|
|  |  |  |  | 
|---|
|  |  |  | private UserSetup userSetup; | 
|---|
|  |  |  | private UserSetting userSetting; | 
|---|
|  |  |  | private RedisMessageListenerContainer listenerContainer; | 
|---|
|  |  |  | private String keyspaceNotificationsConfigParameter = "EA"; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public RedisKeyExpirationEventMessageListener(RedisMessageListenerContainer listenerContainer, UserSetup userSetup) { | 
|---|
|  |  |  | public RedisKeyExpirationEventMessageListener(RedisMessageListenerContainer listenerContainer, UserSetting userSetting) { | 
|---|
|  |  |  | super(listenerContainer); | 
|---|
|  |  |  | this.listenerContainer = listenerContainer; | 
|---|
|  |  |  | this.userSetup = userSetup; | 
|---|
|  |  |  | this.userSetting = userSetting; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public void init() { | 
|---|
|  |  |  | if (!userSetup.getRedisConfig()) { | 
|---|
|  |  |  | if (!userSetting.getRedisConfig()) { | 
|---|
|  |  |  | // 配置springboot默认Config为空,即不让应用去修改redis的默认配置,因为Redis服务出于安全会禁用CONFIG命令给远程用户使用 | 
|---|
|  |  |  | setKeyspaceNotificationsConfigParameter(""); | 
|---|
|  |  |  | }else { | 
|---|