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

4.2.0

Browse Source
This commit is contained in:
tanghc
2020-11-13 14:37:15 +08:00
parent b3aa515d01
commit 3247f4528a
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
sop-common/sop-service-common/src/main/java/com/gitee/sop/servercommon/configuration/GlobalExceptionHandler.java
View File

@@ -22,6 +22,7 @@ import java.nio.charset.StandardCharsets;
@Slf4j @Slf4j
public class GlobalExceptionHandler { public class GlobalExceptionHandler {
/** /**
* 与网关约定好的状态码，表示业务出错 * 与网关约定好的状态码，表示业务出错
*/ */
@@ -33,10 +34,15 @@ public class GlobalExceptionHandler {
private static final int SYSTEM_ERROR_CODE = 5050; private static final int SYSTEM_ERROR_CODE = 5050;
/** /**
* 返回错误信息headerName * header中的错误code
*/ */
private static final String X_SERVICE_ERROR_HEADER_NAME = "x-service-error-code"; private static final String X_SERVICE_ERROR_HEADER_NAME = "x-service-error-code";
/**
* header中的错误信息
*/
private static final String X_SERVICE_ERROR_MESSAGE = "x-service-error-message";
/** /**
* 捕获手动抛出的异常 * 捕获手动抛出的异常
* *
@@ -63,7 +69,6 @@ public class GlobalExceptionHandler {
@ExceptionHandler(Exception.class) @ExceptionHandler(Exception.class)
@ResponseBody @ResponseBody
public Object exceptionHandler(HttpServletRequest request, HttpServletResponse response, Exception exception) { public Object exceptionHandler(HttpServletRequest request, HttpServletResponse response, Exception exception) {
response.addHeader(X_SERVICE_ERROR_HEADER_NAME, String.valueOf(SYSTEM_ERROR_CODE));
log.error("系统错误", exception); log.error("系统错误", exception);
StringBuilder msg = new StringBuilder(); StringBuilder msg = new StringBuilder();
msg.append(exception.getMessage()); msg.append(exception.getMessage());
@@ -74,7 +79,10 @@ public class GlobalExceptionHandler {
StackTraceElement stackTraceElement = stackTrace[i]; StackTraceElement stackTraceElement = stackTrace[i];
msg.append("\n at ").append(stackTraceElement.toString()); msg.append("\n at ").append(stackTraceElement.toString());
} }
response.setHeader("x-service-error-message", UriUtils.encode(msg.toString(), StandardCharsets.UTF_8)); // 需要设置两个值，这样网关会收到错误信息
// 并且会统计到监控当中
response.setHeader(X_SERVICE_ERROR_HEADER_NAME, String.valueOf(SYSTEM_ERROR_CODE));
response.setHeader(X_SERVICE_ERROR_MESSAGE, UriUtils.encode(msg.toString(), StandardCharsets.UTF_8));
return this.processError(request, response, new ServiceException("系统繁忙")); return this.processError(request, response, new ServiceException("系统繁忙"));
} }