From 34519ee280f63c6e2d1457e2b7ed829e597623fa Mon Sep 17 00:00:00 2001 From: tanghc Date: Thu, 20 Aug 2020 14:28:51 +0800 Subject: [PATCH] 4.0.3 --- .../gateway/route/GatewayRouteCache.java | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/sop-common/sop-gateway-common/src/main/java/com/gitee/sop/gatewaycommon/gateway/route/GatewayRouteCache.java b/sop-common/sop-gateway-common/src/main/java/com/gitee/sop/gatewaycommon/gateway/route/GatewayRouteCache.java index 068de786..02b4d491 100644 --- a/sop-common/sop-gateway-common/src/main/java/com/gitee/sop/gatewaycommon/gateway/route/GatewayRouteCache.java +++ b/sop-common/sop-gateway-common/src/main/java/com/gitee/sop/gatewaycommon/gateway/route/GatewayRouteCache.java @@ -52,18 +52,28 @@ public class GatewayRouteCache implements RouteLoader { log.debug("新增路由:{}", JSON.toJSONString(routeDefinition)); } } - this.routeRepository.refresh(); + this.refresh(); callback.accept(null); } catch (Exception e) { log.error("加载路由信息失败,serviceRouteInfo:{}", serviceRouteInfo, e); } } + /** + * 添加路由信息到本地缓存,这里添加后Spring Cloud Gateway并不会识别路由,需要调用refresh()方法 + * + * @see #refresh() + * @param serviceId 服务id + * @param routeDefinition 路由信息 + */ public void add(String serviceId, RouteDefinition routeDefinition) { GatewayTargetRoute targetRoute = new GatewayTargetRoute(new ServiceDefinition(serviceId), routeDefinition); routeRepository.add(targetRoute); } + /** + * 刷新路由到Spring Cloud Gateway路由管理器当中 + */ public void refresh() { this.routeRepository.refresh(); }