本节探讨Zuul的高级特性。spring
TIPS:json
笔者已经写过不少Zuul相关的文章,对于已经写过的内容,就再也不啰嗦一遍了,直接贴地址吧。后端
过滤器是Zuul的核心,Zuul大多功能都是基于过滤器实现的。详见:Spring Cloud Zuul过滤器详解,文章着重探讨了Zuul过滤器的生命周期、如何自定义过滤器、如何禁用指定过滤器等。app
Zuul内置了不少过滤器,这些过滤器帮助咱们实现各类能力,来分析一下内置过滤器有哪些,分别是干吗的。ide
详见:Spring Cloud内置的Zuul过滤器详解微服务
跟我学Spring Cloud(Finchley版)-16-Zuul 讲过,Zuul整合了Hystrix,而Hystrix提供fallback的能力。this
前文已详细讲过通用方式提供fallback、Feign提供fallback。若是不记得如何提供Fallback,可前往以下文章复习。线程
/** * @author itmuch.com */ @Component public class MyFallbackProvider implements FallbackProvider { @Override public String getRoute() { // 代表是为哪一个微服务提供回退,*表示为全部微服务提供回退 return "*"; } @Override public ClientHttpResponse fallbackResponse(String route, Throwable cause) { if (cause instanceof HystrixTimeoutException) { return response(HttpStatus.GATEWAY_TIMEOUT); } else { return this.fallbackResponse(); } } public ClientHttpResponse fallbackResponse() { return this.response(HttpStatus.INTERNAL_SERVER_ERROR); } private ClientHttpResponse response(final HttpStatus status) { return new ClientHttpResponse() { @Override public HttpStatus getStatusCode() throws IOException { return status; } @Override public int getRawStatusCode() throws IOException { return status.value(); } @Override public String getStatusText() throws IOException { return status.getReasonPhrase(); } @Override public void close() { } @Override public InputStream getBody() throws IOException { return new ByteArrayInputStream("服务不可用,请稍后再试。".getBytes()); } @Override public HttpHeaders getHeaders() { // headers设定 HttpHeaders headers = new HttpHeaders(); MediaType mt = new MediaType("application", "json", Charset.forName("UTF-8")); headers.setContentType(mt); return headers; } }; } }
这样,当Zuul后端服务发生异常时,就会进到该Fallback类,并返回服务不可用,请稍后再试。
。code
详见:Zuul的高可用生命周期
虽然是基于Edgware写的,但Finchley版本依然适用。
http://www.itmuch.com/spring-cloud/finchley-18/