zuulGateway是spring cloud中很不错的组件,使用频率很高。使用过程中偶尔可能遇到服务路由异常的情况,如果没有异常熔断,可能会造成应用无响应,严重甚至造成系统雪崩。所以一般需要加上熔断机制。直接看代码,很简单:
/* * 文件名:ServerFallback.java 版权:Copyright by www.poly.com 描述: 修改人:gogym 修改时间:2018年1月31日 跟踪单号: 修改单号: * 修改内容: */ package com.poly.zuul.fallback; import java.io.ByteArrayInputStream; import java.io.IOException; import java.io.InputStream; import org.springframework.cloud.netflix.zuul.filters.route.ZuulFallbackProvider; import org.springframework.http.HttpHeaders; import org.springframework.http.HttpStatus; import org.springframework.http.MediaType; import org.springframework.http.client.ClientHttpResponse; import org.springframework.stereotype.Component; /** * 〈异常熔断〉 * * @author gogym * @version 2018年1月31日 * @see ServerFallback * @since */ @Component public class ServerFallback implements ZuulFallbackProvider { @Override public String getRoute() { // api服务id,如果需要所有调用都支持回退,则return "*"或return null return "*"; } @Override public ClientHttpResponse fallbackResponse() { // ----------------返回前端----------------------- return new ClientHttpResponse() { String responseStr = "{\"code\":10006,\"msg\":\"服务路由异常\"}"; @Override public InputStream getBody() throws IOException { return new ByteArrayInputStream(responseStr.getBytes("UTF-8")); } @Override public HttpHeaders getHeaders() { HttpHeaders headers = new HttpHeaders(); // 和body中的内容编码一致,否则容易乱码 headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED); return headers; } @Override public int getRawStatusCode() throws IOException { return HttpStatus.OK.value(); } @Override public HttpStatus getStatusCode() throws IOException { /** * 网关向api服务请求是失败了,但是消费者客户端向网关发起的请求是OK的, 不应该把api的404,500等问题抛给客户端 * 网关和api服务集群对于客户端来说是黑盒子 */ return HttpStatus.OK; } @Override public String getStatusText() throws IOException { return HttpStatus.OK.getReasonPhrase(); } @Override public void close() { } }; } }