From 7d596c3c6b650570c67c882d4700b09eba77efa6 Mon Sep 17 00:00:00 2001 From: chentaisen <14615430+chentaisen@user.noreply.gitee.com> Date: Fri, 9 Aug 2024 10:06:16 +0800 Subject: [PATCH] =?UTF-8?q?fix():=E4=BF=AE=E5=A4=8D=E4=BA=86nacosService?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../NacosNamespaceInterceptor.java | 20 +++++++++++-------- 1 file changed, 12 insertions(+), 8 deletions(-) diff --git a/src/main/java/com/muyu/common/nacos/remote/interceptor/NacosNamespaceInterceptor.java b/src/main/java/com/muyu/common/nacos/remote/interceptor/NacosNamespaceInterceptor.java index b59a4a9..e67250d 100644 --- a/src/main/java/com/muyu/common/nacos/remote/interceptor/NacosNamespaceInterceptor.java +++ b/src/main/java/com/muyu/common/nacos/remote/interceptor/NacosNamespaceInterceptor.java @@ -19,18 +19,22 @@ public class NacosNamespaceInterceptor implements Interceptor { */ @Override public boolean beforeExecute(ForestRequest req) { - if (StringUtils.isNotEmpty(namespaceId)) { - String reqNamespaceId = Convert.str(req.getQuery("namespaceId"), ""); - if (reqNamespaceId == null) { - log.warn("本次请求nacos的namespace未携带，已添加：[{}]", namespaceId); + if(StringUtils.isNotEmpty(namespaceId)){ + // 执行在发送请求之前处理的代码 + Object reqNamespaceId =Convert.utf8Str( req.getQuery("namespaceId")); + if(reqNamespaceId==null){ + log.warn("本次请求nacos的namespaceId未携带，已添加[{}]",namespaceId); req.addQuery("namespaceId", namespaceId); // 添加URL的Query参数 - } else { - if (StringUtils.equals(reqNamespaceId, namespaceId)) { - log.warn("本次请求nacos的namespace和项目ID不相符，现已更改：[{}->{}]", reqNamespaceId, namespaceId); - req.addQuery("namespaceId", namespaceId); + }else { + if(StringUtils.equals(Convert.str(reqNamespaceId,""),namespaceId)){ + log.warn("本次请求nacos的namespaceId和项目ID不符合,现已更改:[{}->{}]",reqNamespaceId,namespaceId); + req.addQuery("namespaceId", namespaceId); // 添加URL的Query参数 } } } + + + return true; // 继续执行请求返回true }