ChenTaiSen
/
cloud-common-nacos-remote
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix():修复了nacosService

master
chentaisen 2024-08-09 10:06:16 +08:00
parent 37dd78b777
commit 7d596c3c6b
1 changed files with 12 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/main/java/com/muyu/common/nacos/remote/interceptor/NacosNamespaceInterceptor.java
View File

@ -19,18 +19,22 @@ public class NacosNamespaceInterceptor<T> implements Interceptor<T> {
*/ */
@Override @Override
public boolean beforeExecute(ForestRequest req) { public boolean beforeExecute(ForestRequest req) {
if (StringUtils.isNotEmpty(namespaceId)) { if(StringUtils.isNotEmpty(namespaceId)){
String reqNamespaceId = Convert.str(req.getQuery("namespaceId"), ""); // 执行在发送请求之前处理的代码
if (reqNamespaceId == null) { Object reqNamespaceId =Convert.utf8Str( req.getQuery("namespaceId"));
log.warn("本次请求nacos的namespace未携带，已添加：[{}]", namespaceId); if(reqNamespaceId==null){
log.warn("本次请求nacos的namespaceId未携带，已添加[{}]",namespaceId);
req.addQuery("namespaceId", namespaceId); // 添加URL的Query参数 req.addQuery("namespaceId", namespaceId); // 添加URL的Query参数
} else { }else {
if (StringUtils.equals(reqNamespaceId, namespaceId)) { if(StringUtils.equals(Convert.str(reqNamespaceId,""),namespaceId)){
log.warn("本次请求nacos的namespace和项目ID不相符，现已更改：[{}->{}]", reqNamespaceId, namespaceId); log.warn("本次请求nacos的namespaceId和项目ID不符合,现已更改:[{}->{}]",reqNamespaceId,namespaceId);
req.addQuery("namespaceId", namespaceId); req.addQuery("namespaceId", namespaceId); // 添加URL的Query参数
} }
} }
} }
return true; // 继续执行请求返回true return true; // 继续执行请求返回true
} }