javascript
cloub spring 拦截器_Spring Cloud Gateway之全局异常拦截器
/**
* @version 2019/8/14
* @description: 異常攔截器
* @modified:
*/
@Slf4j
public class JsonExceptionHandler implements ErrorWebExceptionHandler {
/**
* MessageReader
*/
private List> messageReaders = Collections.emptyList();
/**
* MessageWriter
*/
private List> messageWriters = Collections.emptyList();
/**
* ViewResolvers
*/
private List viewResolvers = Collections.emptyList();
/**
* 存儲處理異常后的信息
*/
private ThreadLocal exceptionHandlerResult = new ThreadLocal<>();
/**
* 參考AbstractErrorWebExceptionHandler
*/
public void setMessageReaders(List> messageReaders) {
Assert.notNull(messageReaders, "'messageReaders' must not be null");
this.messageReaders = messageReaders;
}
/**
* 參考AbstractErrorWebExceptionHandler
*/
public void setViewResolvers(List viewResolvers) {
this.viewResolvers = viewResolvers;
}
/**
* 參考AbstractErrorWebExceptionHandler
*/
public void setMessageWriters(List> messageWriters) {
Assert.notNull(messageWriters, "'messageWriters' must not be null");
this.messageWriters = messageWriters;
}
@Override
public Mono handle(ServerWebExchange exchange, Throwable ex) {
// 按照異常類型進(jìn)行處理 默認(rèn)500
int httpStatus = HttpStatus.INTERNAL_SERVER_ERROR.value();
String body = "系統(tǒng)異常，請聯(lián)系管理員";
if (ex instanceof NotFoundException) {
httpStatus = HttpStatus.NOT_FOUND.value();
body = ex.getMessage();
}else if(ex instanceof ResponseStatusException){
ResponseStatusException responseStatusException = (ResponseStatusException) ex;
httpStatus = responseStatusException.getStatus().value();
body = responseStatusException.getMessage();
} else if (ex instanceof BusinessException) {
body = ex.getMessage();
httpStatus = ((BusinessException) ex).toResEntity().getHttpStatus();
} else if (ex instanceof RuntimeException) {
Throwable cause = ex.getCause();
body = ex.getMessage();
if(null != cause && cause.getMessage().contains("Load balancer does not have available server for client")){
body = "服務(wù)不存在";
}
}
//錯誤記錄
ServerHttpRequest request = exchange.getRequest();
log.error("[全局異常處理]異常請求路徑:{}", request.getPath());
log.error("異常詳細(xì)信息：{}",ex);
//封裝響應(yīng)體
ResEntity res = new ResEntity();
res.setHttpStatus(httpStatus);
res.setMsg(body);
//參考AbstractErrorWebExceptionHandler
if (exchange.getResponse().isCommitted()) {
return Mono.error(ex);
}
exceptionHandlerResult.set(res);
ServerRequest newRequest = ServerRequest.create(exchange, this.messageReaders);
return RouterFunctions.route(RequestPredicates.all(), this::renderErrorResponse).route(newRequest)
.switchIfEmpty(Mono.error(ex))
.flatMap((handler) -> handler.handle(newRequest))
.flatMap((response) -> write(exchange, response));
}
/**
* 參考DefaultErrorWebExceptionHandler
*/
protected Mono renderErrorResponse(ServerRequest request) {
ResEntity result = exceptionHandlerResult.get();
//404 因前端框架問題，不轉(zhuǎn)換處理 ，因此目前只有系統(tǒng)報500才轉(zhuǎn)換為自定義的狀態(tài)碼
if(HttpStatus.INTERNAL_SERVER_ERROR.value() == result.getHttpStatus()){
return ServerResponse.status(HttpStatus.OK.value())
.contentType(MediaType.APPLICATION_JSON_UTF8)
.body(BodyInserters.fromObject(result));
}
return ServerResponse.status(result.getHttpStatus())
.contentType(MediaType.APPLICATION_JSON_UTF8)
.body(BodyInserters.fromObject(result));
}
/**
* 參考AbstractErrorWebExceptionHandler
*/
private Mono extends Void> write(ServerWebExchange exchange,
ServerResponse response) {
exchange.getResponse().getHeaders()
.setContentType(response.headers().getContentType());
return response.writeTo(exchange, new ResponseContext());
}
/**
* 參考AbstractErrorWebExceptionHandler
*/
private class ResponseContext implements ServerResponse.Context {
@Override
public List> messageWriters() {
return JsonExceptionHandler.this.messageWriters;
}
@Override
public List viewResolvers() {
return JsonExceptionHandler.this.viewResolvers;
}
}
}
總結(jié)
以上是生活随笔為你收集整理的cloub spring 拦截器_Spring Cloud Gateway之全局异常拦截器的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： redis 安装测试
- 下一篇： Spring AOP进行日志记录，管理