sczx_group/sczx_gateway
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'main' of http://115.190.8.52:3000/sczx_group/sczx_gateway

Browse Source
This commit is contained in:
zhangli
2025-09-03 00:59:12 +08:00
parent ad54c0e1b5 ca60cd46a5
commit ee7556f706
5 changed files with 69 additions and 54 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/sczx/gateway/component/DynamicRouteScheduler.java
View File

@ -19,7 +19,7 @@ public class DynamicRouteScheduler {
private DiscoveryClient discoveryClient;
// 延迟5秒后开始执行，避免与启动时的自动刷新冲突，每30秒刷新一次路由（可按需调整）
@Scheduled(fixedRate = 30_000, initialDelay = 5_000)
// @Scheduled(fixedRate = 60_000, initialDelay = 10_000)
public void refreshRoutes() {
log.info("refreshRoutes");
publisher.publishEvent(new RefreshRoutesEvent(this));

96
src/main/java/com/sczx/gateway/config/DynamicRouteConfig.java
View File

@ -39,52 +39,60 @@ public class DynamicRouteConfig implements RouteDefinitionLocator {
private final AtomicReference<Long> lastRefreshTime = new AtomicReference<>(0L);
// 最小刷新间隔（毫秒）
private static final long MIN_REFRESH_INTERVAL = 3000;
private static final long MIN_REFRESH_INTERVAL = 120000;
private static final URI DEFAULT_URI = URI.create("http://localhost");
@Override
public Flux<RouteDefinition> getRouteDefinitions() {
long currentTime = System.currentTimeMillis();
long lastTime = lastRefreshTime.get();
try{
long lastTime = lastRefreshTime.get();
// 防抖处理：如果距离上次刷新时间太短，则不处理
if (currentTime - lastTime < MIN_REFRESH_INTERVAL && refreshCount.get() > 0) {
log.info("刷新过于频繁，跳过本次刷新");
return Flux.empty();
}
lastRefreshTime.set(currentTime);
log.info("开始加载路由定义，第{}次调用", refreshCount.incrementAndGet());
List<RouteDefinition> routeDefinitions = new ArrayList<>();
// 定义需要路由的服务列表
String[] serviceNames = {"sczx-user", "sczx-store", "sczx-car", "sczx-order", "sczx-sync", "sczx-singlepay"};
// 为每个服务添加路由规则（如果服务存在）
for (String serviceName : serviceNames) {
if (hasServiceInstances(serviceName)) {
RouteDefinition routeDefinition = new RouteDefinition();
routeDefinition.setId(serviceName);
// 设置路径断言
routeDefinition.setPredicates(Collections.singletonList(
new PredicateDefinition("Path=/zc/" + serviceName.split("-")[1] + "/**")
));
// 设置过滤器
routeDefinition.setFilters(Collections.singletonList(
new org.springframework.cloud.gateway.filter.FilterDefinition(
"RewritePath=/zc/" + serviceName.split("-")[1] + "/(?<segment>.*), /$\\{segment}")
));
// 设置URI
routeDefinition.setUri(getServiceUri(serviceName));
routeDefinitions.add(routeDefinition);
} else {
log.warn("服务 {} 不存在实例，跳过路由配置", serviceName);
// 防抖处理：如果距离上次刷新时间太短，则不处理
if (currentTime - lastTime < MIN_REFRESH_INTERVAL && refreshCount.get() > 0) {
log.info("刷新过于频繁，跳过本次刷新");
return Flux.empty();
}
lastRefreshTime.set(currentTime);
log.info("开始加载路由定义，第{}次调用", refreshCount.incrementAndGet());
List<RouteDefinition> routeDefinitions = new ArrayList<>();
// 定义需要路由的服务列表
String[] serviceNames = {"sczx-user", "sczx-store", "sczx-car", "sczx-order", "sczx-sync", "sczx-singlepay"};
// 为每个服务添加路由规则（如果服务存在）
for (String serviceName : serviceNames) {
if (hasServiceInstances(serviceName)) {
RouteDefinition routeDefinition = new RouteDefinition();
routeDefinition.setId(serviceName);
// 设置路径断言
routeDefinition.setPredicates(Collections.singletonList(
new PredicateDefinition("Path=/zc/" + serviceName.split("-")[1] + "/**")
));
// 设置过滤器
routeDefinition.setFilters(Collections.singletonList(
new org.springframework.cloud.gateway.filter.FilterDefinition(
"RewritePath=/zc/" + serviceName.split("-")[1] + "/(?<segment>.*), /$\\{segment}")
));
// 设置URI
routeDefinition.setUri(getServiceUri(serviceName));
routeDefinitions.add(routeDefinition);
} else {
log.warn("服务 {} 不存在实例，跳过路由配置", serviceName);
}
}
log.info("路由加载完成，共加载 {} 个路由定义", routeDefinitions.size());
return Flux.fromIterable(routeDefinitions);
}catch (Exception e){
log.error("路由加载失败", e);
}
log.info("路由加载完成，共加载 {} 个路由定义", routeDefinitions.size());
return Flux.fromIterable(routeDefinitions);
return null;
}
/**
@ -93,7 +101,9 @@ public class DynamicRouteConfig implements RouteDefinitionLocator {
@EventListener
public void onRefreshRoutes(RefreshRoutesEvent event) {
long count = refreshCount.get();
log.info("接收到路由刷新事件，当前为第{}次刷新", count);
log.info("接收到路由刷新事件，当前为第{}次刷新, JVM内存使用: {}/{}", count,
Runtime.getRuntime().freeMemory(),
Runtime.getRuntime().totalMemory());
}
/**
@ -112,10 +122,10 @@ public class DynamicRouteConfig implements RouteDefinitionLocator {
List<ServiceInstance> instances = discoveryClient.getInstances(serviceName);
if (instances == null || instances.isEmpty()) {
log.warn("No available instances for service: {}, returning default URI", serviceName);
return URI.create("http://localhost");
return DEFAULT_URI;
}
ServiceInstance selected = instances.get(Math.abs(index.getAndIncrement()) % instances.size());
int idx = index.getAndIncrement() & Integer.MAX_VALUE;
ServiceInstance selected = instances.get(idx % instances.size());
log.info("Selected instance: {}", selected);
return URI.create("http://" + selected.getHost() + ":" + selected.getPort());
}