package com.thhy.general.exception; import com.alibaba.fastjson.JSONObject; import com.github.pagehelper.util.StringUtil; import com.thhy.general.common.BasicMessage; import com.thhy.general.utils.UUIDUtils; import com.thhy.general.common.BasicResult; import com.thhy.general.common.BasicStatus; import feign.FeignException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.http.HttpStatus; import org.springframework.web.bind.MethodArgumentNotValidException; import org.springframework.web.bind.annotation.ExceptionHandler; import org.springframework.web.bind.annotation.RestControllerAdvice; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.PrintWriter; import java.io.StringWriter; /** * @Author: zhang_xiao_bo * @Date: 2022/3/22 16:43 * @description: controller 监听异常配置 */ @RestControllerAdvice public class ExceptionController { private static Logger log = LoggerFactory.getLogger(ExceptionController.class); @ExceptionHandler(Exception.class) public BasicResult handleException(HttpServletRequest request, HttpServletResponse response, Exception exception) { //如果有框架把自定义异常又封装成了系统异常，则需要重新指向自定义处理流程 if(exception instanceof BasicException){ return handleBusinessException(request,response,(BasicException)exception); } if(exception instanceof FeignException){ return handleFeignException(request,response,(FeignException) exception); } if(exception instanceof MethodArgumentNotValidException){ System.out.println("ssss"); } //异常日志ID String errorLogId= UUIDUtils.create(); //日志堆栈 String stackTrace=getInfo(exception); //装配异常消息，异步发送 ExceptionMessage exceptionMessage=new ExceptionMessage(); //exceptionMessage.setAddress(serverConfig.getUrl()); exceptionMessage.setRequestUri(request.getRequestURI()); exceptionMessage.setErrorLogId(errorLogId); exceptionMessage.setStatusCode(BasicStatus.ERROR.statusCode()); exceptionMessage.setStatusMsg(BasicStatus.ERROR.statusMsg()); exceptionMessage.setStackTraceMsg(stackTrace); log.error("请求: " + request.getRequestURI() + " 引起异常："); log.error("日志编码："+exceptionMessage.getErrorLogId()); log.error("状态码："+exceptionMessage.getStatusCode()); log.error("状态说明："+exceptionMessage.getStatusMsg()); log.error(stackTrace); response.setStatus(HttpStatus.OK.value()); return new BasicResult(false,BasicStatus.ERROR,new JSONObject()); } /** * 自定义业务异常处理 * @param request * @param response * @param exception * @return */ @ExceptionHandler(BasicException.class) public BasicResult handleBusinessException(HttpServletRequest request, HttpServletResponse response, BasicException exception) { //日志堆栈,方法体中主动抛出的，还是catch中抛出的，二者不同 String stackTrace= StringUtil.isEmpty(exception.getStackTraceMsg())?getInfo(exception):exception.getStackTraceMsg(); //装配异常消息，异步发送 ExceptionMessage exceptionMessage=new ExceptionMessage(); //exceptionMessage.setAddress(serverConfig.getUrl()); exceptionMessage.setRequestUri(request.getRequestURI()); exceptionMessage.setErrorLogId(exception.getErrorLogId()); exceptionMessage.setStatusCode(exception.getBasicStatus().statusCode()); exceptionMessage.setStatusMsg(exception.getBasicStatus().statusMsg()); exceptionMessage.setStackTraceMsg(stackTrace); log.error("请求: " + request.getRequestURI() + " 引起异常："); log.error("日志编码："+exception.getErrorLogId()); log.error("状态码："+exception.getBasicStatus().statusCode()); log.error("状态说明："+exception.getBasicStatus().statusMsg()); log.error(stackTrace); response.setStatus(HttpStatus.OK.value()); return new BasicResult(false,exception.getBasicStatus(),new JSONObject()); } /** * 自定义业务异常处理 * @param request * @param response * @param exception * @return */ @ExceptionHandler(FeignException.class) public BasicResult handleFeignException(HttpServletRequest request, HttpServletResponse response, FeignException exception) { //日志堆栈,方法体中主动抛出的，还是catch中抛出的，二者不同 /*String stackTrace= StringUtils.isBlank(exception.getStackTraceMsg())?getInfo(exception):exception.getStackTraceMsg(); //装配异常消息，异步发送 ExceptionMessage exceptionMessage=new ExceptionMessage(); exceptionMessage.setAddress(serverConfig.getUrl()); exceptionMessage.setRequestUri(request.getRequestURI()); exceptionMessage.setErrorLogId(exception.getErrorLogId()); exceptionMessage.setStatusCode(exception.getBasicStatus().statusCode()); exceptionMessage.setStatusMsg(exception.getBasicStatus().statusMsg()); exceptionMessage.setStackTraceMsg(stackTrace); log.error("请求: " + request.getRequestURI() + " 引起异常："); log.error("日志编码："+exception.get()); log.error("状态码："+exception.getBasicStatus().statusCode()); log.error("状态说明："+exception.getBasicStatus().statusMsg()); log.error(stackTrace);*/ String feignUrl = exception.request().url(); String suff = feignUrl.split("//")[1]; String serviceName = suff.substring(0,suff.indexOf("/")); String statusMsg = "feign调用"+serviceName+"出现异常"; if(exception.status()==503){ statusMsg=serviceName+"服务可能下线"; } response.setStatus(HttpStatus.OK.value()); return new BasicResult(false,new BasicMessage("00900",statusMsg),exception.getMessage()); } @ExceptionHandler(MethodArgumentNotValidException.class) public BasicResult handleValidException(HttpServletRequest request, HttpServletResponse response, BasicException exception) { //日志堆栈,方法体中主动抛出的，还是catch中抛出的，二者不同 String stackTrace= StringUtil.isEmpty(exception.getStackTraceMsg())?getInfo(exception):exception.getStackTraceMsg(); //装配异常消息，异步发送 ExceptionMessage exceptionMessage=new ExceptionMessage(); //exceptionMessage.setAddress(serverConfig.getUrl()); exceptionMessage.setRequestUri(request.getRequestURI()); exceptionMessage.setErrorLogId(exception.getErrorLogId()); exceptionMessage.setStatusCode(exception.getBasicStatus().statusCode()); exceptionMessage.setStatusMsg(exception.getBasicStatus().statusMsg()); exceptionMessage.setStackTraceMsg(stackTrace); log.error("请求: " + request.getRequestURI() + " 引起异常："); log.error("日志编码："+exception.getErrorLogId()); log.error("状态码："+exception.getBasicStatus().statusCode()); log.error("状态说明："+exception.getBasicStatus().statusMsg()); log.error(stackTrace); response.setStatus(HttpStatus.OK.value()); return new BasicResult(false,exception.getBasicStatus(),new JSONObject()); } /** * 获取异常的堆栈信息 * * @param t * @return */ public String getInfo(Throwable t) { StringWriter sw = new StringWriter(); PrintWriter pw = new PrintWriter(sw); try { t.printStackTrace(pw); return sw.toString(); } finally { pw.close(); } } }