## 添加微服务注册成功刷新nacos缓存；

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/listener/SaOrderSecondListener.java

@@ -12,11 +12,7 @@ import org.springframework.messaging.Message;
 import org.springframework.stereotype.Component;
 
 /**
- * @Description: 订单秒接
+ * 订单秒接
- * @Author: sui q
- * @Time: 2023/3/1 16:30
- * @Classname: SaOrderSecondListener
- * @PackageName: com.hzs.third.mqcall.listener
  */
 @Slf4j
 @Component
@@ -42,6 +38,5 @@ public class SaOrderSecondListener {
         } catch (Exception e) {
             e.printStackTrace();
         }
-        // todo 失败的时候记录日志
     }
 }

bd-business/bd-business-bonus/src/main/java/com/hzs/listener/NacosInstancesChangeEventListener.java

@@ -0,0 +1,43 @@
+package com.hzs.listener;
+
+import com.alibaba.nacos.client.naming.event.InstancesChangeEvent;
+import com.alibaba.nacos.common.notify.NotifyCenter;
+import com.alibaba.nacos.common.notify.listener.Subscriber;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.cache.Cache;
+import org.springframework.cache.CacheManager;
+import org.springframework.cloud.loadbalancer.core.CachingServiceInstanceListSupplier;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
+
+@Component
+@Slf4j
+public class NacosInstancesChangeEventListener extends Subscriber<InstancesChangeEvent> {
+
+    @Resource
+    private CacheManager defaultLoadBalancerCacheManager;
+
+    @PostConstruct
+    public void registerToNotifyCenter(){
+        NotifyCenter.registerSubscriber(this);
+    }
+
+    @Override
+    public void onEvent(InstancesChangeEvent event) {
+        log.info("bonus 接收微服务刷新事件：{}, 开始刷新本地存储的微服务缓存", event.getServiceName());
+        Cache cache = defaultLoadBalancerCacheManager.getCache(CachingServiceInstanceListSupplier.SERVICE_INSTANCE_CACHE_NAME);
+        if (cache != null) {
+            cache.evict(event.getServiceName());
+            log.info("{} 微服务刷新", event.getServiceName());
+        }
+        log.info("bonus 微服务缓存刷新完成");
+    }
+
+    @Override
+    public Class<? extends com.alibaba.nacos.common.notify.Event> subscribeType() {
+        return InstancesChangeEvent.class;
+    }
+
+}

bd-business/bd-business-member/src/main/java/com/hzs/listener/NacosInstancesChangeEventListener.java

@@ -0,0 +1,43 @@
+package com.hzs.listener;
+
+import com.alibaba.nacos.client.naming.event.InstancesChangeEvent;
+import com.alibaba.nacos.common.notify.NotifyCenter;
+import com.alibaba.nacos.common.notify.listener.Subscriber;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.cache.Cache;
+import org.springframework.cache.CacheManager;
+import org.springframework.cloud.loadbalancer.core.CachingServiceInstanceListSupplier;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
+
+@Component
+@Slf4j
+public class NacosInstancesChangeEventListener extends Subscriber<InstancesChangeEvent> {
+
+    @Resource
+    private CacheManager defaultLoadBalancerCacheManager;
+
+    @PostConstruct
+    public void registerToNotifyCenter(){
+        NotifyCenter.registerSubscriber(this);
+    }
+
+    @Override
+    public void onEvent(InstancesChangeEvent event) {
+        log.info("member 接收微服务刷新事件：{}, 开始刷新本地存储的微服务缓存", event.getServiceName());
+        Cache cache = defaultLoadBalancerCacheManager.getCache(CachingServiceInstanceListSupplier.SERVICE_INSTANCE_CACHE_NAME);
+        if (cache != null) {
+            cache.evict(event.getServiceName());
+            log.info("{} 微服务刷新", event.getServiceName());
+        }
+        log.info("member 微服务缓存刷新完成");
+    }
+
+    @Override
+    public Class<? extends com.alibaba.nacos.common.notify.Event> subscribeType() {
+        return InstancesChangeEvent.class;
+    }
+
+}

bd-business/bd-business-report/src/main/java/com/hzs/listener/NacosInstancesChangeEventListener.java

@@ -0,0 +1,43 @@
+package com.hzs.listener;
+
+import com.alibaba.nacos.client.naming.event.InstancesChangeEvent;
+import com.alibaba.nacos.common.notify.NotifyCenter;
+import com.alibaba.nacos.common.notify.listener.Subscriber;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.cache.Cache;
+import org.springframework.cache.CacheManager;
+import org.springframework.cloud.loadbalancer.core.CachingServiceInstanceListSupplier;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
+
+@Component
+@Slf4j
+public class NacosInstancesChangeEventListener extends Subscriber<InstancesChangeEvent> {
+
+    @Resource
+    private CacheManager defaultLoadBalancerCacheManager;
+
+    @PostConstruct
+    public void registerToNotifyCenter(){
+        NotifyCenter.registerSubscriber(this);
+    }
+
+    @Override
+    public void onEvent(InstancesChangeEvent event) {
+        log.info("report 接收微服务刷新事件：{}, 开始刷新本地存储的微服务缓存", event.getServiceName());
+        Cache cache = defaultLoadBalancerCacheManager.getCache(CachingServiceInstanceListSupplier.SERVICE_INSTANCE_CACHE_NAME);
+        if (cache != null) {
+            cache.evict(event.getServiceName());
+            log.info("{} 微服务刷新", event.getServiceName());
+        }
+        log.info("report 微服务缓存刷新完成");
+    }
+
+    @Override
+    public Class<? extends com.alibaba.nacos.common.notify.Event> subscribeType() {
+        return InstancesChangeEvent.class;
+    }
+
+}

bd-business/bd-business-sale/src/main/java/com/hzs/listener/NacosInstancesChangeEventListener.java

@@ -0,0 +1,43 @@
+package com.hzs.listener;
+
+import com.alibaba.nacos.client.naming.event.InstancesChangeEvent;
+import com.alibaba.nacos.common.notify.NotifyCenter;
+import com.alibaba.nacos.common.notify.listener.Subscriber;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.cache.Cache;
+import org.springframework.cache.CacheManager;
+import org.springframework.cloud.loadbalancer.core.CachingServiceInstanceListSupplier;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
+
+@Component
+@Slf4j
+public class NacosInstancesChangeEventListener extends Subscriber<InstancesChangeEvent> {
+
+    @Resource
+    private CacheManager defaultLoadBalancerCacheManager;
+
+    @PostConstruct
+    public void registerToNotifyCenter(){
+        NotifyCenter.registerSubscriber(this);
+    }
+
+    @Override
+    public void onEvent(InstancesChangeEvent event) {
+        log.info("sale 接收微服务刷新事件：{}, 开始刷新本地存储的微服务缓存", event.getServiceName());
+        Cache cache = defaultLoadBalancerCacheManager.getCache(CachingServiceInstanceListSupplier.SERVICE_INSTANCE_CACHE_NAME);
+        if (cache != null) {
+            cache.evict(event.getServiceName());
+            log.info("{} 微服务刷新", event.getServiceName());
+        }
+        log.info("sale 微服务缓存刷新完成");
+    }
+
+    @Override
+    public Class<? extends com.alibaba.nacos.common.notify.Event> subscribeType() {
+        return InstancesChangeEvent.class;
+    }
+
+}

bd-business/bd-business-system/src/main/java/com/hzs/config/pub/controller/ConfigBaseController.java

@@ -16,17 +16,13 @@ import java.util.Date;
 import java.util.List;
 
 /**
- * @Description: 配置controller
+ * 配置controller
- * @Author: sui q
- * @Time: 2023/3/10 15:45
- * @Classname: ConfigBaseController
- * @PackageName: com.hzs.config.pub.controller
  */
 @Slf4j
 public abstract class ConfigBaseController extends BaseController {
 
     @DubboReference
-    private IDelayedMessageApi delayedMessageApi;
+    IDelayedMessageApi delayedMessageApi;
 
     protected boolean sendDelayedMessage(Object config, Integer delayBusType, String key, String... otherKey) {
         Integer pkId = null;
@@ -63,18 +59,13 @@ public abstract class ConfigBaseController extends BaseController {
     }
 
     /**
-     * @description: 校验object的属性值是Long类型还是Integer
+     * 校验object的属性值是Long类型还是Integer
-     * @author: zhang jing
-     * @date: 2024/5/20 16:01
-     * @param: [field, object]
      **/
     public static boolean isLong(Object object) {
         if (object instanceof Long) {
             return false;
-        } else if (object instanceof Integer) {
-            return true;
         } else {
-            return false;
+            return object instanceof Integer;
         }
     }
 }

bd-business/bd-business-system/src/main/java/com/hzs/listener/NacosInstancesChangeEventListener.java

@@ -0,0 +1,43 @@
+package com.hzs.listener;
+
+import com.alibaba.nacos.client.naming.event.InstancesChangeEvent;
+import com.alibaba.nacos.common.notify.NotifyCenter;
+import com.alibaba.nacos.common.notify.listener.Subscriber;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.cache.Cache;
+import org.springframework.cache.CacheManager;
+import org.springframework.cloud.loadbalancer.core.CachingServiceInstanceListSupplier;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
+
+@Component
+@Slf4j
+public class NacosInstancesChangeEventListener extends Subscriber<InstancesChangeEvent> {
+
+    @Resource
+    private CacheManager defaultLoadBalancerCacheManager;
+
+    @PostConstruct
+    public void registerToNotifyCenter(){
+        NotifyCenter.registerSubscriber(this);
+    }
+
+    @Override
+    public void onEvent(InstancesChangeEvent event) {
+        log.info("system 接收微服务刷新事件：{}, 开始刷新本地存储的微服务缓存", event.getServiceName());
+        Cache cache = defaultLoadBalancerCacheManager.getCache(CachingServiceInstanceListSupplier.SERVICE_INSTANCE_CACHE_NAME);
+        if (cache != null) {
+            cache.evict(event.getServiceName());
+            log.info("{} 微服务刷新", event.getServiceName());
+        }
+        log.info("system 微服务缓存刷新完成");
+    }
+
+    @Override
+    public Class<? extends com.alibaba.nacos.common.notify.Event> subscribeType() {
+        return InstancesChangeEvent.class;
+    }
+
+}

bd-third/src/main/java/com/hzs/listener/NacosInstancesChangeEventListener.java

@@ -0,0 +1,43 @@
+package com.hzs.listener;
+
+import com.alibaba.nacos.client.naming.event.InstancesChangeEvent;
+import com.alibaba.nacos.common.notify.NotifyCenter;
+import com.alibaba.nacos.common.notify.listener.Subscriber;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.cache.Cache;
+import org.springframework.cache.CacheManager;
+import org.springframework.cloud.loadbalancer.core.CachingServiceInstanceListSupplier;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
+
+@Component
+@Slf4j
+public class NacosInstancesChangeEventListener extends Subscriber<InstancesChangeEvent> {
+
+    @Resource
+    private CacheManager defaultLoadBalancerCacheManager;
+
+    @PostConstruct
+    public void registerToNotifyCenter(){
+        NotifyCenter.registerSubscriber(this);
+    }
+
+    @Override
+    public void onEvent(InstancesChangeEvent event) {
+        log.info("third 接收微服务刷新事件：{}, 开始刷新本地存储的微服务缓存", event.getServiceName());
+        Cache cache = defaultLoadBalancerCacheManager.getCache(CachingServiceInstanceListSupplier.SERVICE_INSTANCE_CACHE_NAME);
+        if (cache != null) {
+            cache.evict(event.getServiceName());
+            log.info("{} 微服务刷新", event.getServiceName());
+        }
+        log.info("third 微服务缓存刷新完成");
+    }
+
+    @Override
+    public Class<? extends com.alibaba.nacos.common.notify.Event> subscribeType() {
+        return InstancesChangeEvent.class;
+    }
+
+}