angelo
/
java-base-app
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

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

This commit is contained in:
cabbage 2025-04-28 16:16:37 +08:00
parent ed7cf86412
commit 321c56547f
8 changed files with 263 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -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 失败的时候记录日志
}
}

43
bd-business/bd-business-bonus/src/main/java/com/hzs/listener/NacosInstancesChangeEventListener.java Normal file
View File

@ -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;
}
}

43
bd-business/bd-business-member/src/main/java/com/hzs/listener/NacosInstancesChangeEventListener.java Normal file
View File

@ -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;
}
}

43
bd-business/bd-business-report/src/main/java/com/hzs/listener/NacosInstancesChangeEventListener.java Normal file
View File

@ -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;
}
}

43
bd-business/bd-business-sale/src/main/java/com/hzs/listener/NacosInstancesChangeEventListener.java Normal file
View File

@ -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;
}
}

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

@ -16,17 +16,13 @@ import java.util.Date;
import java.util.List;
/**
* @Description: 配置controller
* @Author: sui q
* @Time: 2023/3/10 15:45
* @Classname: ConfigBaseController
* @PackageName: com.hzs.config.pub.controller
* 配置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
* @author: zhang jing
* @date: 2024/5/20 16:01
* @param: [field, object]
* 校验object的属性值是Long类型还是Integer
**/
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;
}
}
}

43
bd-business/bd-business-system/src/main/java/com/hzs/listener/NacosInstancesChangeEventListener.java Normal file
View File

@ -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;
}
}

43
bd-third/src/main/java/com/hzs/listener/NacosInstancesChangeEventListener.java Normal file
View File

@ -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;
}
}