<!-- spring cloud Eureka Client 啟動器 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-zuul</artifactId>
</dependency>
<!-- zuul網(wǎng)關的重試機制，不是使用ribbon內(nèi)置的重試機制
   是借助spring-retry組件實現(xiàn)的重試
   開啟zuul網(wǎng)關重試機制需要增加下述依賴
 -->
<dependency>
   <groupId>org.springframework.retry</groupId>
   <artifactId>spring-retry</artifactId>
</dependency>

/**
 * @EnableZuulProxy - 開啟Zuul網(wǎng)關。
 *  當前應用是一個Zuul微服務網(wǎng)關。會在Eureka注冊中心中注冊當前服務。并發(fā)現(xiàn)其他的服務。
 *  Zuul需要的必要依賴是spring-cloud-starter-zuul。
 */
@SpringBootApplication
@EnableZuulProxy
public class ZuulApplication {
    public static void main(String[] args) {
        SpringApplication.run(ZuulApplication.class, args);
    }
}

# URL pattern
# 使用路徑方式匹配路由規(guī)則。
# 參數(shù)key結(jié)構(gòu)： zuul.routes.customName.path=xxx
# 用于配置路徑匹配規(guī)則。
# 其中customName自定義。通常使用要調(diào)用的服務名稱，方便后期管理
# 可使用的通配符有： * ** ?
# ? 單個字符
# * 任意多個字符，不包含多級路徑
# ** 任意多個字符，包含多級路徑
zuul.routes.eureka-application-service.path=/api/**
# 參數(shù)key結(jié)構(gòu)： zuul.routes.customName.url=xxx
# url用于配置符合path的請求路徑路由到的服務地址。
zuul.routes.eureka-application-service.url=http://127.0.0.1:8080/

# service id pattern 通過服務名稱路由
# key結(jié)構(gòu) ： zuul.routes.customName.path=xxx
# 路徑匹配規(guī)則
zuul.routes.eureka-application-service.path=/api/**
# key結(jié)構(gòu) ： zuul.routes.customName.serviceId=xxx
# serviceId用于配置符合path的請求路徑路由到的服務名稱。
zuul.routes.eureka-application-service.serviceId=eureka-application-service

# simple service id pattern 簡化配置方案
# 如果只配置path，不配置serviceId。則customName相當于服務名稱。
# 符合path的請求路徑直接路由到customName對應的服務上。
zuul.routes.eureka-application-service.path=/api/**

# ignored service id pattern
# 配置不被zuul管理的服務列表。多個服務名稱使用逗號','分隔。
# 配置的服務將不被zuul代理。
zuul.ignored-services=eureka-application-service
# 此方式相當于給所有新發(fā)現(xiàn)的服務默認排除zuul網(wǎng)關訪問方式，只有配置了路由網(wǎng)關的服務才可以通過zuul網(wǎng)關訪問
# 通配方式配置排除列表。
zuul.ignored-services=*
# 使用服務名稱匹配規(guī)則配置路由列表，相當于只對已配置的服務提供網(wǎng)關代理。
zuul.routes.eureka-application-service.path=/api/**
# 通配方式配置排除網(wǎng)關代理路徑。所有符合ignored-patterns的請求路徑都不被zuul網(wǎng)關代理。
zuul.ignored-patterns=/**/test/**
zuul.routes.eureka-application-service.path=/api/**

# prefix URL pattern 前綴路由匹配
# 配置請求路徑前綴，所有基于此前綴的請求都由zuul網(wǎng)關提供代理。
zuul.prefix=/api
# 使用服務名稱匹配方式配置請求路徑規(guī)則。
# 這里的配置將為：http://ip:port/api/appservice/**的請求提供zuul網(wǎng)關代理，可以將要訪問服務進行前綴分類。
# 并將請求路由到服務eureka-application-service中。
zuul.routes.eureka-application-service.path=/appservice/**

/**
 * Zuul過濾器，必須繼承ZuulFilter父類。
 * 當前類型的對象必須交由Spring容器管理。使用@Component注解描述。
 * 繼承父類后，必須實現(xiàn)父類中定義的4個抽象方法。
 * shouldFilter、 run、 filterType、 filterOrder
 */
@Component
public class LoggerFilter extends ZuulFilter {
    private static final Logger logger = LoggerFactory.getLogger(LoggerFilter.class);
    
    /**
     * 返回boolean類型。代表當前filter是否生效。
     * 默認值為false。
     * 返回true代表開啟filter。
     */
    @Override
    public boolean shouldFilter() {
        return true;
    }
    /**
     * run方法就是過濾器的具體邏輯。
     * return 可以返回任意的對象，當前實現(xiàn)忽略。（spring-cloud-zuul官方解釋）
     * 直接返回null即可。
     */
    @Override
    public Object run() throws ZuulException {
        // 通過zuul，獲取請求上下文
        RequestContext rc = RequestContext.getCurrentContext();
        HttpServletRequest request = rc.getRequest();
        logger.info("LogFilter1.....method={},url={}",
                request.getMethod(),request.getRequestURL().toString());
        // 可以記錄日志、鑒權(quán)，給維護人員記錄提供定位協(xié)助、統(tǒng)計性能
        return null;
    }
    /**
     * 過濾器的類型?？蛇x值有：
     * pre - 前置過濾
     * route - 路由后過濾
     * error - 異常過濾
     * post - 遠程服務調(diào)用后過濾
     */
    @Override
    public String filterType() {
        return "pre";
    }
    /**
     * 同種類的過濾器的執(zhí)行順序。
     * 按照返回值的自然升序執(zhí)行。
     */
    @Override
    public int filterOrder() {
        return 0;
    }
}

/**
 * 如果需要在Zuul網(wǎng)關服務中增加容錯處理fallback，需要實現(xiàn)接口ZuulFallbackProvider
 * spring-cloud框架，在Edgware版本(包括)之后，聲明接口ZuulFallbackProvider過期失效，
 * 提供了新的ZuulFallbackProvider的子接口 - FallbackProvider
 * 在老版本中提供的ZuulFallbackProvider中，定義了兩個方法。
 *  - String getRoute()
 *    當前的fallback容錯處理邏輯處理的是哪一個服務?？梢允褂猛ㄅ浞?'代表為全部的服務提供容錯處理。
 *    如果只為某一個服務提供容錯，返回對應服務的spring.application.name值。
 *  - ClientHttpResponse fallbackResponse()
 *    當服務發(fā)生錯誤的時候，如何容錯。
 * 新版本中提供的FallbackProvider提供了新的方法。
 *  - ClientHttpResponse fallbackResponse(Throwable cause)
 *    如果使用新版本中定義的接口來做容錯處理，容錯處理邏輯，只運行子接口中定義的新方法。也就是有參方法。
 *    是為遠程服務發(fā)生異常的時候，通過異常的類型來運行不同的容錯邏輯。
 */
@Component
public class TestFallBbackProvider implements FallbackProvider {
    /**
     * return - 返回fallback處理哪一個服務。返回的是服務的名稱
     * 推薦 - 為指定的服務定義特性化的fallback邏輯。
     * 推薦 - 提供一個處理所有服務的fallback邏輯。
     * 好處 - 服務某個服務發(fā)生超時，那么指定的fallback邏輯執(zhí)行。如果有新服務上線，未提供fallback邏輯，有一個通用的。
     */
    @Override
    public String getRoute() {
        return "eureka-application-service";
    }
    /**
     * fallback邏輯。在早期版本中使用。
     * Edgware版本之后，ZuulFallbackProvider接口過期，提供了新的子接口FallbackProvider
     * 子接口中提供了方法ClientHttpResponse fallbackResponse(Throwable cause)。
     * 優(yōu)先調(diào)用子接口新定義的fallback處理邏輯。
     */
    @Override
    public ClientHttpResponse fallbackResponse() {
        System.out.println("ClientHttpResponse fallbackResponse()");
        
        List<Map<String, Object>> result = new ArrayList<>();
        Map<String, Object> data = new HashMap<>();
        data.put("message", "服務正忙，請稍后重試");
        result.add(data);
        
        ObjectMapper mapper = new ObjectMapper();
        
        String msg = "";
        try {
            msg = mapper.writeValueAsString(result);
        } catch (JsonProcessingException e) {
            msg = "";
        }
        
        return this.executeFallback(HttpStatus.OK, msg, 
                "application", "json", "utf-8");
    }
    /**
     * fallback邏輯。優(yōu)先調(diào)用?？梢愿鶕?jù)異常類型動態(tài)決定處理方式。
     */
    @Override
    public ClientHttpResponse fallbackResponse(Throwable cause) {
        System.out.println("ClientHttpResponse fallbackResponse(Throwable cause)");
        if(cause instanceof NullPointerException){
            
            List<Map<String, Object>> result = new ArrayList<>();
            Map<String, Object> data = new HashMap<>();
            data.put("message", "網(wǎng)關超時，請稍后重試");
            result.add(data);
            
            ObjectMapper mapper = new ObjectMapper();
            
            String msg = "";
            try {
                msg = mapper.writeValueAsString(result);
            } catch (JsonProcessingException e) {
                msg = "";
            }
            
            return this.executeFallback(HttpStatus.GATEWAY_TIMEOUT, 
                    msg, "application", "json", "utf-8");
        }else{
            return this.fallbackResponse();
        }
    }
    
    /**
     * 具體處理過程。
     * @param status 容錯處理后的返回狀態(tài)，如200正常GET請求結(jié)果，201正常POST請求結(jié)果，404資源找不到錯誤等。
     *  使用spring提供的枚舉類型對象實現(xiàn)。HttpStatus
     * @param contentMsg 自定義的響應內(nèi)容。就是反饋給客戶端的數(shù)據(jù)。
     * @param mediaType 響應類型，是響應的主類型， 如： application、text、media。
     * @param subMediaType 響應類型，是響應的子類型， 如： json、stream、html、plain、jpeg、png等。
     * @param charsetName 響應結(jié)果的字符集。這里只傳遞字符集名稱，如： utf-8、gbk、big5等。
     * @return ClientHttpResponse 就是響應的具體內(nèi)容。
     *  相當于一個HttpServletResponse。
     */
    private final ClientHttpResponse executeFallback(final HttpStatus status, 
            String contentMsg, String mediaType, String subMediaType, String charsetName) {
        return new ClientHttpResponse() {
            /**
             * 設置響應的頭信息
             */
            @Override
            public HttpHeaders getHeaders() {
                HttpHeaders header = new HttpHeaders();
                MediaType mt = new MediaType(mediaType, subMediaType, Charset.forName(charsetName));
                header.setContentType(mt);
                return header;
            }
            /**
             * 設置響應體
             * zuul會將本方法返回的輸入流數(shù)據(jù)讀取，并通過HttpServletResponse的輸出流輸出到客戶端。
             */
            @Override
            public InputStream getBody() throws IOException {
                String content = contentMsg;
                return new ByteArrayInputStream(content.getBytes());
            }
            /**
             * ClientHttpResponse的fallback的狀態(tài)碼 返回String
             */
            @Override
            public String getStatusText() throws IOException {
                return this.getStatusCode().getReasonPhrase();
            }
            /**
             * ClientHttpResponse的fallback的狀態(tài)碼 返回HttpStatus
             */
            @Override
            public HttpStatus getStatusCode() throws IOException {
                return status;
            }
            /**
             * ClientHttpResponse的fallback的狀態(tài)碼 返回int
             */
            @Override
            public int getRawStatusCode() throws IOException {
                return this.getStatusCode().value();
            }
            /**
             * 回收資源方法
             * 用于回收當前fallback邏輯開啟的資源對象的。
             * 不要關閉getBody方法返回的那個輸入流對象。
             */
            @Override
            public void close() {
            }
        };
    }
}

<dependency>
    <groupId>com.marcosbarbero.cloud</groupId>
    <artifactId>spring-cloud-zuul-ratelimit</artifactId>
    <version>1.3.4.RELEASE</version>
</dependency>

# 開啟限流保護
zuul.ratelimit.enabled=true
# 60s內(nèi)請求超過3次，服務端就拋出異常，60s后可以恢復正常請求
zuul.ratelimit.default-policy.limit=3
zuul.ratelimit.default-policy.refresh-interval=60
# 針對IP進行限流，不影響其他IP
zuul.ratelimit.default-policy.type=origin

# 開啟限流保護
zuul.ratelimit.enabled=true
# hystrix-application-client服務60s內(nèi)請求超過3次，服務拋出異常。
zuul.ratelimit.policies.hystrix-application-client.limit=3
zuul.ratelimit.policies.hystrix-application-client.refresh-interval=60
# 針對IP限流。
zuul.ratelimit.policies.hystrix-application-client.type=origin

# 開啟zuul網(wǎng)關重試
zuul.retryable=true
# hystrix超時時間設置
# 線程池隔離，默認超時時間1000ms
hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=8000
# ribbon超時時間設置：建議設置比Hystrix小
# 請求連接的超時時間: 默認5000ms
ribbon.ConnectTimeout=5000
# 請求處理的超時時間: 默認5000ms
ribbon.ReadTimeout=5000
# 重試次數(shù)：MaxAutoRetries表示訪問服務集群下原節(jié)點（同路徑訪問）；MaxAutoRetriesNextServer表示訪問服務集群下其余節(jié)點（換臺服務器）
ribbon.MaxAutoRetries=1
ribbon.MaxAutoRetriesNextServer=1
# 開啟重試
ribbon.OkToRetryOnAllOperations=true

<dependency>
　　<groupId>org.springframework.retry</groupId>
　　<artifactId>spring-retry</artifactId>
</dependency>