From 0bb75324254c20a986dd70142798cf888f168a0b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=B8=80=E4=B8=AA=E4=B8=8D=E7=9F=A5=E5=90=8D=E7=9A=84Java?= =?UTF-8?q?=E9=9D=93=E4=BB=94?= <42876375+icodening@users.noreply.github.com> Date: Mon, 21 Mar 2022 10:42:09 +0800 Subject: [PATCH] Use unified entrance context name by default in Spring WebFlux adapter (#2610) --- .../adapter/spring/webflux/SentinelWebFluxFilter.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/sentinel-adapter/sentinel-spring-webflux-adapter/src/main/java/com/alibaba/csp/sentinel/adapter/spring/webflux/SentinelWebFluxFilter.java b/sentinel-adapter/sentinel-spring-webflux-adapter/src/main/java/com/alibaba/csp/sentinel/adapter/spring/webflux/SentinelWebFluxFilter.java index 7d9cbf28..f704f78b 100644 --- a/sentinel-adapter/sentinel-spring-webflux-adapter/src/main/java/com/alibaba/csp/sentinel/adapter/spring/webflux/SentinelWebFluxFilter.java +++ b/sentinel-adapter/sentinel-spring-webflux-adapter/src/main/java/com/alibaba/csp/sentinel/adapter/spring/webflux/SentinelWebFluxFilter.java @@ -36,6 +36,8 @@ import reactor.core.publisher.Mono; */ public class SentinelWebFluxFilter implements WebFilter { + public static final String SENTINEL_SPRING_WEBFLUX_CONTEXT_NAME = "sentinel_spring_webflux_context"; + @Override public Mono filter(ServerWebExchange exchange, WebFilterChain chain) { // Maybe we can get the URL pattern elsewhere via: @@ -56,7 +58,11 @@ public class SentinelWebFluxFilter implements WebFilter { .orElse(EMPTY_ORIGIN); return new SentinelReactorTransformer<>(new EntryConfig(finalPath, ResourceTypeConstants.COMMON_WEB, - EntryType.IN, new ContextConfig(finalPath, origin))); + EntryType.IN, new ContextConfig(getContextName(exchange), origin))); + } + + protected String getContextName(ServerWebExchange exchange){ + return SENTINEL_SPRING_WEBFLUX_CONTEXT_NAME; } private static final String EMPTY_ORIGIN = "";