fix():修复了nacosService

master
chentaisen 2024-08-09 10:08:18 +08:00
parent 7d596c3c6b
commit 907b130031
1 changed files with 8 additions and 12 deletions

View File

@ -19,22 +19,18 @@ 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"), "");
Object reqNamespaceId =Convert.utf8Str( req.getQuery("namespaceId")); if (reqNamespaceId == null) {
if(reqNamespaceId==null){ log.warn("本次请求nacos的namespace未携带已添加[{}]", namespaceId);
log.warn("本次请求nacos的namespaceId未携带已添加[{}]",namespaceId);
req.addQuery("namespaceId", namespaceId); // 添加URL的Query参数 req.addQuery("namespaceId", namespaceId); // 添加URL的Query参数
}else { } else {
if(StringUtils.equals(Convert.str(reqNamespaceId,""),namespaceId)){ if (StringUtils.equals(reqNamespaceId, namespaceId)) {
log.warn("本次请求nacos的namespaceId和项目ID不符合,现已更改:[{}->{}]",reqNamespaceId,namespaceId); log.warn("本次请求nacos的namespace和项目ID不相符现已更改[{}->{}]", reqNamespaceId, namespaceId);
req.addQuery("namespaceId", namespaceId); // 添加URL的Query参数 req.addQuery("namespaceId", namespaceId);
} }
} }
} }
return true; // 继续执行请求返回true return true; // 继续执行请求返回true
} }