SpringCloud之zuul的原理及使用方法介紹

這篇文章帶給大家的內容是關於SpringCloud之zuul的原理及使用方法介紹，有一定的參考價值，有需要的朋友可以參考一下，希望對你有所幫助。

簡介

Zuul是所有從裝置和web網站到Netflix串流應用程式後端的請求的前門。作為一個邊緣服務應用程序，Zuul的建置是為了支援動態路由、監視、彈性和安全性。它還可以根據需要將請求路由到多個Amazon自動伸縮群組。

Zuul使用了一系列不同類型的篩選器，讓我們能夠快速且靈活地將功能應用到edge服務中。這些過濾器幫助我們執行以下功能:

• 身份驗證和安全性—識別每個資源的身份驗證需求並拒絕不滿足這些需求的請求。
• 洞察和監控——在邊緣追蹤有意義的數據和統計數據，以便為我們提供準確的生產視圖。
• 動態路由－根據需要動態地將請求路由到不同的後端叢集。
• 壓力測試－逐步增加群集的流量，以評估效能。
• 減少負載－為每種類型的請求分配容量，並刪除超過限制的請求。
• 靜態回應處理－直接在邊緣建立一些回應，而不是將它們轉送到內部群集
• 多區域彈性－跨AWS區域路由請求，以使我們的ELB使用多樣化，並使我們的優勢更接近我們的成員

工作原理

#在高級視圖中，Zuul 2.0是一個Netty伺服器，它運行預過濾器(入站過濾器)，然後使用Netty客戶機代理請求，然後在運行後過濾器(出站過濾器)後返回回應。

篩選器是Zuul業務邏輯的核心所在。它們能夠執行非常大範圍的操作，並且可以在請求-回應生命週期的不同部分運行，如上圖所示。

• Inbound Filters在路由到來源之前執行，可以用於驗證、路由和裝飾請求。
• Endpoint Filters 可用於傳回靜態回應，否則內建的ProxyEndpoint過濾器將把請求路由到來源。
• Outbound Filters 在從來源取得回應後執行，可用於度量、裝飾使用者回應或新增自訂頭。

還有兩種類型的篩選器:同步和非同步。因為我們是在一個事件循環上運行的，所以千萬不要阻塞過濾器。如果要阻塞，可以在一個非同步過濾器中阻塞，在一個單獨的threadpool上阻塞－否則可以使用同步過濾器。

實用過濾器

• DebugRequest－尋找一個查詢參數來為請求新增額外的偵錯日誌
• Healthcheck -簡單的靜態端點過濾器，返回200，如果一切引導正確
• ZuulResponseFilter -新增訊息頭部提供額外的細節路由，請求執行，狀態和錯誤原因
• GZipResponseFilter -可以啟用gzip出站回應
• SurgicalDebugFilter －可以將特定的請求路由到不同的主機進行偵錯

##使用技巧

##依賴：

    <dependency>
            <groupid>org.springframework.cloud</groupid>
            <artifactid>spring-cloud-starter-netflix-zuul</artifactid>
        </dependency>

MyFilter 過濾器

@Component
public class MyFilter extends ZuulFilter {

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

    /**
     * pre：路由之前
     * routing：路由之时
     * post： 路由之后
     * error：发送错误调用
     * @return
     */
    @Override
    public String filterType() {
        return "pre";
    }

    /**
     * 过滤的顺序
     * @return
     */
    @Override
    public int filterOrder() {
        return 0;
    }

    /**
     * 这里可以写逻辑判断，是否要过滤，本文true,永远过滤
     * @return
     */
    @Override
    public boolean shouldFilter() {
        return true;
    }


    /**
     * 过滤器的具体逻辑。
     * 可用很复杂，包括查sql，nosql去判断该请求到底有没有权限访问。
     * @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設定路由轉送

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閘道有自動轉送機制，但其實Zuul還有更多的應用場景，例如：鑑權、流量轉送、請求統計等等，這些功能都可以使用Zuul來實現。

#

以上是SpringCloud之zuul的原理及使用方法介紹的詳細內容。更多資訊請關注PHP中文網其他相關文章！