修改redis 过期事件通知

device-manager/src/main/java/com/mortals/xhx/base/framework/config/RedisConfig.java

+package com.mortals.xhx.base.framework.config;
+
+import com.mortals.xhx.base.framework.listener.CustomerKeyExpirationListener;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.listener.PatternTopic;
+import org.springframework.data.redis.listener.RedisMessageListenerContainer;
+
+/**
+ * 监听所有expire事件
+ * @author: zxfei
+ * @date: 2022/6/22 16:51
+ * @description:
+ **/
+@Configuration
+public class RedisConfig {
+    @Bean
+    public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory
+            , CustomerKeyExpirationListener customerKeyExpirationListener) {
+        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
+        container.setConnectionFactory(connectionFactory);
+        container.addMessageListener(customerKeyExpirationListener,new PatternTopic("__keyevent@*__:expired"));
+        return container;
+    }
+
+}
\ No newline at end of file

device-manager/src/main/java/com/mortals/xhx/base/framework/listener/CustomerKeyExpirationListener.java

+package com.mortals.xhx.base.framework.listener;
+
+import org.springframework.data.redis.connection.Message;
+import org.springframework.data.redis.connection.MessageListener;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author: zxfei
+ * @date: 2022/6/22 16:40
+ * @description:
+ **/
+@Component
+public class CustomerKeyExpirationListener implements MessageListener {
+    @Override
+    public void onMessage(Message message, byte[] bytes) {
+        String key = message.toString();
+        System.out.println("监听到key:" + key + "过期");
+    }
+}
\ No newline at end of file

device-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/DemoStartService.java

 package com.mortals.xhx.daemon.applicationservice;
 
+import com.mortals.framework.service.ICacheService;
 import com.mortals.xhx.common.utils.SendTaskThreadPool;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.logging.Log;
@@ -10,17 +11,24 @@ import org.springframework.stereotype.Component;
 
 import com.mortals.framework.springcloud.service.IApplicationService;
 
+import java.time.Duration;
+
 @Component
 @Slf4j
 public class DemoStartService implements IApplicationService {
 
     @Autowired
     private SendTaskThreadPool sendTaskThreadPool;
+    @Autowired
+    private ICacheService cacheService;
 
     @Override
     public void start() {
         log.info("初始化发送线程数量");
         sendTaskThreadPool.init(20);
+
+        cacheService.setnx("test-expire","111", Duration.ofMinutes(1).toMillis());
+
         log.info("开始服务..[配置已加载完成，但部分框架还未初始化，比如：Kafka]");
     }
 

device-manager/src/main/java/com/mortals/xhx/module/device/service/impl/DeviceServiceImpl.java

@@ -3,6 +3,7 @@ package com.mortals.xhx.module.device.service.impl;
 import cn.hutool.core.lang.PatternPool;
 import com.mortals.framework.exception.AppException;
 import com.mortals.framework.model.Context;
+import com.mortals.framework.service.ICacheService;
 import com.mortals.framework.service.impl.AbstractCRUDCacheServiceImpl;
 import com.mortals.xhx.base.system.message.MessageService;
 import com.mortals.xhx.busiz.req.DeviceReq;
@@ -52,6 +53,8 @@ public class DeviceServiceImpl extends AbstractCRUDCacheServiceImpl<DeviceDao, D
 
     @Autowired
     private MessageService messageService;
+    @Autowired
+    private ICacheService cacheService;
 
 
     @Override