摘要：洞察和監(jiān)控在邊緣跟蹤有意義的數(shù)據(jù)和統(tǒng)計(jì)數(shù)據(jù)，以便為我們提供準(zhǔn)確的生產(chǎn)視圖。壓力測(cè)試逐步增加集群的流量，以評(píng)估性能。減少負(fù)載為每種類型的請(qǐng)求分配容量，并刪除超過(guò)限制的請(qǐng)求。在路由到源之前執(zhí)行，可以用于身份驗(yàn)證路由和裝飾請(qǐng)求。

Zuul是所有從設(shè)備和web站點(diǎn)到Netflix流媒體應(yīng)用程序后端的請(qǐng)求的前門。作為一個(gè)邊緣服務(wù)應(yīng)用程序，Zuul的構(gòu)建是為了支持動(dòng)態(tài)路由、監(jiān)視、彈性和安全性。它還可以根據(jù)需要將請(qǐng)求路由到多個(gè)Amazon自動(dòng)伸縮組。

Zuul使用了一系列不同類型的過(guò)濾器，使我們能夠快速靈活地將功能應(yīng)用到edge服務(wù)中。這些過(guò)濾器幫助我們執(zhí)行以下功能:

身份驗(yàn)證和安全性——識(shí)別每個(gè)資源的身份驗(yàn)證需求并拒絕不滿足這些需求的請(qǐng)求。
洞察和監(jiān)控——在邊緣跟蹤有意義的數(shù)據(jù)和統(tǒng)計(jì)數(shù)據(jù)，以便為我們提供準(zhǔn)確的生產(chǎn)視圖。
動(dòng)態(tài)路由——根據(jù)需要?jiǎng)討B(tài)地將請(qǐng)求路由到不同的后端集群。
壓力測(cè)試——逐步增加集群的流量，以評(píng)估性能。
減少負(fù)載——為每種類型的請(qǐng)求分配容量，并刪除超過(guò)限制的請(qǐng)求。
靜態(tài)響應(yīng)處理——直接在邊緣構(gòu)建一些響應(yīng)，而不是將它們轉(zhuǎn)發(fā)到內(nèi)部集群
多區(qū)域彈性——跨AWS區(qū)域路由請(qǐng)求，以使我們的ELB使用多樣化，并使我們的優(yōu)勢(shì)更接近我們的成員

在高級(jí)視圖中，Zuul 2.0是一個(gè)Netty服務(wù)器，它運(yùn)行預(yù)過(guò)濾器(入站過(guò)濾器)，然后使用Netty客戶機(jī)代理請(qǐng)求，然后在運(yùn)行后過(guò)濾器(出站過(guò)濾器)后返回響應(yīng)。

過(guò)濾器是Zuul業(yè)務(wù)邏輯的核心所在。它們能夠執(zhí)行非常大范圍的操作，并且可以在請(qǐng)求-響應(yīng)生命周期的不同部分運(yùn)行，如上圖所示。

Inbound Filters在路由到源之前執(zhí)行，可以用于身份驗(yàn)證、路由和裝飾請(qǐng)求。

Endpoint Filters 可用于返回靜態(tài)響應(yīng)，否則內(nèi)置的ProxyEndpoint過(guò)濾器將把請(qǐng)求路由到源。

Outbound Filters 在從源獲取響應(yīng)后執(zhí)行，可用于度量、裝飾用戶響應(yīng)或添加自定義頭。

還有兩種類型的過(guò)濾器:同步和異步。因?yàn)槲覀兪窃谝粋€(gè)事件循環(huán)上運(yùn)行的，所以千萬(wàn)不要阻塞過(guò)濾器。如果要阻塞，可以在一個(gè)異步過(guò)濾器中阻塞，在一個(gè)多帶帶的threadpool上阻塞——否則可以使用同步過(guò)濾器。

實(shí)用過(guò)濾器

DebugRequest——查找一個(gè)查詢參數(shù)來(lái)為請(qǐng)求添加額外的調(diào)試日志

Healthcheck -簡(jiǎn)單的靜態(tài)端點(diǎn)過(guò)濾器，返回200，如果一切引導(dǎo)正確

ZuulResponseFilter -添加信息頭部提供額外的細(xì)節(jié)路由，請(qǐng)求執(zhí)行，狀態(tài)和錯(cuò)誤原因

GZipResponseFilter -可以啟用gzip出站響應(yīng)

SurgicalDebugFilter ——可以將特定的請(qǐng)求路由到不同的主機(jī)進(jìn)行調(diào)試

依賴：

    
            org.springframework.cloud
            spring-cloud-starter-netflix-zuul
        

MyFilter 過(guò)濾器

@Component
public class MyFilter extends ZuulFilter {

    private static Logger log = LoggerFactory.getLogger(MyFilter.class);

    /**
     * pre：路由之前
     * routing：路由之時(shí)
     * post： 路由之后
     * error：發(fā)送錯(cuò)誤調(diào)用
     * @return
     */
    @Override
    public String filterType() {
        return "pre";
    }

    /**
     * 過(guò)濾的順序
     * @return
     */
    @Override
    public int filterOrder() {
        return 0;
    }

    /**
     * 這里可以寫邏輯判斷，是否要過(guò)濾，本文true,永遠(yuǎn)過(guò)濾
     * @return
     */
    @Override
    public boolean shouldFilter() {
        return true;
    }


    /**
     * 過(guò)濾器的具體邏輯。
     * 可用很復(fù)雜，包括查sql，nosql去判斷該請(qǐng)求到底有沒(méi)有權(quán)限訪問(wèn)。
     * @return
     * @throws ZuulException
     */
    @Override
    public Object run() throws ZuulException {
        RequestContext ctx = RequestContext.getCurrentContext();
        HttpServletRequest request = ctx.getRequest();
        log.info(String.format("%s >>> %s", request.getMethod(), request.getRequestURL().toString()));
        Object accessToken = request.getParameter("token");
        if(accessToken == null) {
            log.warn("token is empty");
            ctx.setSendZuulResponse(false);
            ctx.setResponseStatusCode(401);
            try {
                ctx.getResponse().getWriter().write("token is empty");
            }catch (Exception e){}

            return null;
        }
        log.info("ok");
        return null;
    }

}

application.yml配置路由轉(zhuǎn)發(fā)

eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/
server:
  port: 8769
spring:
  application:
    name: cloud-service-zuul
zuul:
  routes:
    api-a:
      path: /api-a/**
      serviceId: cloud-service-ribbon
    api-b:
      path: /api-b/**
      serviceId: cloud-service-feign

啟用zuul

@SpringBootApplication
@EnableZuulProxy
@EnableEurekaClient
@EnableDiscoveryClient
public class CloudServiceZuulApplication {

    public static void main(String[] args) {
        SpringApplication.run(CloudServiceZuulApplication.class, args);
    }

}

路由熔斷

/**
 * 路由熔斷
 */
@Component
public class ProducerFallback implements FallbackProvider {
    private final Logger logger = LoggerFactory.getLogger(FallbackProvider.class);

    //指定要處理的 service。
    @Override
    public String getRoute() {
        return "spring-cloud-producer";
    }

    @Override
    public ClientHttpResponse fallbackResponse(String route, Throwable cause) {
        if (cause != null && cause.getCause() != null) {
            String reason = cause.getCause().getMessage();
            logger.info("Excption {}",reason);
        }
        return fallbackResponse();
    }

    public ClientHttpResponse fallbackResponse() {
        return new ClientHttpResponse() {
            @Override
            public HttpStatus getStatusCode() throws IOException {
                return HttpStatus.OK;
            }

            @Override
            public int getRawStatusCode() throws IOException {
                return 200;
            }

            @Override
            public String getStatusText() throws IOException {
                return "OK";
            }

            @Override
            public void close() {

            }

            @Override
            public InputStream getBody() throws IOException {
                return new ByteArrayInputStream("The service is unavailable.".getBytes());
            }

            @Override
            public HttpHeaders getHeaders() {
                HttpHeaders headers = new HttpHeaders();
                headers.setContentType(MediaType.APPLICATION_JSON);
                return headers;
            }
        };
    }


}

Zuul網(wǎng)關(guān)有自動(dòng)轉(zhuǎn)發(fā)機(jī)制，但其實(shí)Zuul還有更多的應(yīng)用場(chǎng)景，比如：鑒權(quán)、流量轉(zhuǎn)發(fā)、請(qǐng)求統(tǒng)計(jì)等等，這些功能都可以使用Zuul來(lái)實(shí)現(xiàn)。
’
更多資源：zuul重試

參考博文：
http://www.ityouknow.com/spri...

如果對(duì) Java、大數(shù)據(jù)感興趣請(qǐng)長(zhǎng)按二維碼關(guān)注一波，我會(huì)努力帶給你們價(jià)值。覺得對(duì)你哪怕有一丁點(diǎn)幫助的請(qǐng)幫忙點(diǎn)個(gè)贊或者轉(zhuǎn)發(fā)哦。