7x31/SOP
1
0
Fork 0
mirror of https://gitee.com/durcframework/SOP.git synced 2025-08-11 12:56:28 +08:00
Code Issues Packages Projects Releases Wiki Activity

优化dubbo filter

Browse Source
This commit is contained in:
六如
2025-03-12 09:55:12 +08:00
parent 30c7245cbb
commit d82dd73099
3 changed files with 0 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
sop-gateway/src/main/java/com/gitee/sop/gateway/request/ApiRequestContext.java
View File

@@ -36,11 +36,6 @@ public class ApiRequestContext {
*/ */
private UploadContext uploadContext; private UploadContext uploadContext;
/**
* 标签
*/
private String tag;
/** /**
* 是否需要签名校验 * 是否需要签名校验
*/ */

5
sop-gateway/src/main/java/com/gitee/sop/gateway/service/impl/ParamExecutorImpl.java
View File

@@ -93,7 +93,6 @@ public class ParamExecutorImpl implements ParamExecutor<HttpServletRequest, Http
.apiRequest(apiRequest) .apiRequest(apiRequest)
.locale(request.getLocale()) .locale(request.getLocale())
.ip(ip) .ip(ip)
.tag(getTag(request))
.uploadContext(uploadContext) .uploadContext(uploadContext)
.traceId(UUID.randomUUID().toString().replace("-", "")) .traceId(UUID.randomUUID().toString().replace("-", ""))
.rawParams(params) .rawParams(params)
@@ -124,10 +123,6 @@ public class ParamExecutorImpl implements ParamExecutor<HttpServletRequest, Http
} }
protected String getTag(HttpServletRequest request) {
return request.getHeader(apiConfig.getHeaderKeyTag());
}
protected ApiRequest convertApiRequest(HttpServletRequest request, JSONObject jsonObject) { protected ApiRequest convertApiRequest(HttpServletRequest request, JSONObject jsonObject) {
ApiRequest apiRequest = new ApiRequest(); ApiRequest apiRequest = new ApiRequest();
apiRequest.setAppId(jsonObject.getString(apiConfig.getAppIdName())); apiRequest.setAppId(jsonObject.getString(apiConfig.getAppIdName()));

6
sop-gateway/src/main/java/com/gitee/sop/gateway/service/impl/RouteServiceImpl.java
View File

@@ -36,7 +36,6 @@ import org.springframework.context.ApplicationContext;
import org.springframework.core.env.Environment; import org.springframework.core.env.Environment;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils; import org.springframework.util.ObjectUtils;
import org.springframework.util.StringUtils;
import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartFile;
import javax.annotation.PostConstruct; import javax.annotation.PostConstruct;
@@ -116,12 +115,7 @@ public class RouteServiceImpl implements RouteService {
protected Object doRoute(RouteContext routeContext) { protected Object doRoute(RouteContext routeContext) {
ApiRequestContext apiRequestContext = routeContext.getApiRequestContext(); ApiRequestContext apiRequestContext = routeContext.getApiRequestContext();
ApiInfoDTO apiInfo = routeContext.getApiInfo(); ApiInfoDTO apiInfo = routeContext.getApiInfo();
String tag = apiRequestContext.getTag();
// 设置隔离环境
RpcContextAttachment clientAttachment = RpcContext.getClientAttachment(); RpcContextAttachment clientAttachment = RpcContext.getClientAttachment();
if (StringUtils.hasText(tag)) {
clientAttachment.setAttachment(SopConstants.DUBBO_TAG, tag);
}
String paramInfo = apiInfo.getParamInfo(); String paramInfo = apiInfo.getParamInfo();
List<ParamInfoDTO> paramInfoList = JSON.parseArray(paramInfo, ParamInfoDTO.class); List<ParamInfoDTO> paramInfoList = JSON.parseArray(paramInfo, ParamInfoDTO.class);
OpenContext openRequest = buildOpenContext(apiRequestContext); OpenContext openRequest = buildOpenContext(apiRequestContext);