快捷導(dǎo)航

Spring Cloud zuul自定義統(tǒng)一異常處理實(shí)現(xiàn)方法

更新時(shí)間：2018年02月02日 16:46:45 投稿：mrr

這篇文章主要介紹了Spring Cloud zuul自定義統(tǒng)一異常處理實(shí)現(xiàn),需要的朋友可以參考下

Zuul在springcloud微服務(wù)體系中提供filer和router功能，是微服務(wù)不可或缺的部分。filer處理默認(rèn)實(shí)現(xiàn)的外還可以自定義進(jìn)行授權(quán)、限流、安全校驗(yàn)等，router完全可以替代Nginx反向代理。Zuul異常處理就是由SendErrorFilter完成。

在我們應(yīng)用過程我們發(fā)現(xiàn)使用默認(rèn)的異常filter有兩個(gè)問題不是很友好：

1.無法快速識(shí)別出是否是請(qǐng)求路由的服務(wù)超時(shí)還是沒有任何可用節(jié)點(diǎn)，發(fā)生錯(cuò)誤只能查看日志通過堆棧去定位；

2.無法兼容自定義的譬如{code:500,msg:”xx error”}格式的響應(yīng)包格式。

接下來我們討論的是如何自定義異常處理、自定義異常提示信息等。

首先，我們必須禁用默認(rèn)的SendErrorFilter，官方已經(jīng)提供了開關(guān)配置，直接配置即可

zuul.SendErrorFilter.post.disable=true

自定義ErrorFilter，這里就不多說，直接貼代碼

public class ErrorFilter extends ZuulFilter {
  private static final String ERROR_STATUS_CODE_KEY = "error.status_code";
  private Logger log = LoggerFactory.getLogger(ErrorFilter.class);
  public static final String DEFAULT_ERR_MSG = "系統(tǒng)繁忙,請(qǐng)稍后再試";
  @Override
  public String filterType() {
    return "post";
  }
  @Override
  public int filterOrder() {
    return 0;
  }
  @Override
  public boolean shouldFilter() {
    RequestContext ctx = RequestContext.getCurrentContext();
    return ctx.containsKey(ERROR_STATUS_CODE_KEY);
  }
  @Override
  public Object run() {    
    RequestContext ctx = RequestContext.getCurrentContext();
    try {
      HttpServletRequest request = ctx.getRequest();
      int statusCode = (Integer) ctx.get(ERROR_STATUS_CODE_KEY);
      String message = (String) ctx.get("error.message");
      if (ctx.containsKey("error.exception")) {
        Throwable e = (Exception) ctx.get("error.exception");
        Throwable re = getOriginException(e);
        if(re instanceof java.net.ConnectException){
          message = "Real Service Connection refused";
          log.warn("uri:{},error:{}" ,request.getRequestURI(),re.getMessage());
        }else if(re instanceof java.net.SocketTimeoutException){
          message = "Real Service Timeout";
          log.warn("uri:{},error:{}" ,request.getRequestURI(),re.getMessage());
        }else if(re instanceof com.netflix.client.ClientException){
          message = re.getMessage();
          log.warn("uri:{},error:{}" ,request.getRequestURI(),re.getMessage());
        }else{
          log.warn("Error during filtering",e);
        }
      }
      if(StringUtils.isBlank(message))message = DEFAULT_ERR_MSG;
      request.setAttribute("javax.servlet.error.status_code", statusCode);
      request.setAttribute("javax.servlet.error.message", message);
      WebUtils.responseOutJson(ctx.getResponse(), JsonUtils.toJson(new WrapperResponse<>(statusCode, message)));
    } catch (Exception e) {
      String error = "Error during filtering[ErrorFilter]";
      log.error(error,e);
      WebUtils.responseOutJson(ctx.getResponse(), JsonUtils.toJson(new WrapperResponse<>(500, error)));
    }
    return null;
  }
  private Throwable getOriginException(Throwable e){
    e = e.getCause();
    while(e.getCause() != null){
      e = e.getCause();
    }
    return e;
  }
}

最后注冊(cè)我們自定義的ErrorFilter

@Bean 
public ErrorFilter errorFilter(){
  return new ErrorFilter();
}

總結(jié)

以上所述是小編給大家介紹的Spring Cloud zuul自定義統(tǒng)一異常處理實(shí)現(xiàn)方法，希望對(duì)大家有所幫助，如果大家有任何疑問請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持！

您可能感興趣的文章: