Spring Cloud入門教程 - Zuul實現API網關和請求過濾

簡介

Zuul是Spring Cloud提供的api網關和過濾組件，它提供以下功能：

• 認證
• 過濾
• 壓力測試
• Canary測試
• 動態路由
• 服務遷移
• 負載均衡
• 安全
• 靜態請求處理
• 動態流量管理

在本教程中，咱們將用zuul，把web端的請求/product轉發到對應的產品服務上，而且定義一個pre過濾器來驗證是否通過了zuul的轉發。

基礎環境

• JDK 1.8
• Maven 3.3.9
• IntelliJ 2018.1
• Git

項目源碼

Gitee碼雲

建立Zuul服務

在IntelliJ中建立一個maven項目：

• cn.zxuqian
• apiGateway

而後在pom.xml中添加以下代碼：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>cn.zxuqian</groupId>
    <artifactId>apiGateway</artifactId>
    <version>1.0-SNAPSHOT</version>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.1.RELEASE</version>
    </parent>

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <!-- name has changed, before: spring-cloud-starter-zuul -->
            <artifactId>spring-cloud-starter-netflix-zuul</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-config</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Finchley.M9</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <properties>
        <java.version>1.8</java.version>
    </properties>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

    <repositories>
        <repository>
            <id>spring-milestones</id>
            <name>Spring Milestones</name>
            <url>https://repo.spring.io/libs-milestone</url>
            <snapshots>
                <enabled>false</enabled>
            </snapshots>
        </repository>
    </repositories>

</project>

須要注意的是，Spring官網的教程給的zuul的artifactId爲spring-cloud-starter-zuul，這個是舊版zuul的名字，在咱們的Finchley.M9版本中已經改名爲spring-cloud-starter-netflix-zuul。

添加src/main/resources/bootstrap.yml文件，指定spring.application.name：

spring:
  application:
    name: zuul-server

建立cn.zxuqian.Application類：

package cn.zxuqian;

import cn.zxuqian.filters.PreFilter;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.zuul.EnableZuulProxy;
import org.springframework.context.annotation.Bean;

@EnableZuulProxy
@EnableDiscoveryClient
@SpringBootApplication
public class Application {

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

    @Bean
    public PreFilter preFilter() {
        return new PreFilter();
    }
}

這裏使用了@EnableZuulProxy來指定使用zuul的反向代理，把咱們的請求轉發到對應的服務器上。而後啓用了eureka的服務發現。Zuul默認也會使用Ribbon作負載均衡，因此能夠經過eureka發現已註冊的服務。PreFilter是一個預過濾器，用來在request請求被處理以前進行一些操做，它的代碼以下：

package cn.zxuqian.filters;

import com.netflix.zuul.ZuulFilter;
import com.netflix.zuul.context.RequestContext;
import com.netflix.zuul.exception.ZuulException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javax.servlet.http.HttpServletRequest;

public class PreFilter extends ZuulFilter {

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

    @Override
    public String filterType() {
        return "pre";
    }

    @Override
    public int filterOrder() {
        return 1;
    }

    @Override
    public boolean shouldFilter() {
        return true;
    }

    @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()));

        return null;
    }
}

filterType - Zuul內置的filter類型有四種，pre, route，post，error，分別表明請求處理前，處理時，處理後和出錯後。
filterOrder - 指定了該過濾器執行的順序。
shouldFilter - 是否開啓此過濾器。
run - 過濾器的業務邏輯。這裏只是簡單的log了一下reqeust的請求方式和請求的路徑。

接下來，在咱們的配置中心的git倉庫中建立zuul-server.yml文件，並添加以下配置：

server:
  port: 8083
zuul:
  routes:
    products:
      path: /product/**
      serviceId: product-service

這裏配置了zuul的端口爲8083，而後映射全部/product/的請求到咱們的product-service服務上。若是不配置serviceId，那麼products這個Key就會默認做爲ServiceId，而咱們的例子中，ServiceId包括了-，因此在下邊顯示指定了ServiceId。配置完成後提交到git。

更新productService

productService的uri作了一點改動，使其更符合rest風格：

@RequestMapping("/list")
public String productList() {
    log.info("Access to /products endpoint");
    return "外套，夾克，毛衣，T恤";
}

這裏@RequestMapping匹配的路徑改成了/list，以前是/products。

更新web客戶端

在咱們的web客戶端的ProductService中添加一個新的方法：

public String productListZuul() {
    return this.restTemplate.getForObject("http://zuul-server/product/list", String.class);
}

此次咱們直接請求zuul-server服務，而後由它把咱們的請求反射代理到product-service服務。最後在ProductController中添加一個請求處理方法：

@RequestMapping("/product/list")
public String productListZuul() {
    return productService.productListZuul();
}

用來處理/product/list請求，而後調用ProductService類中的方法。

測試

使用mvn spring-boot:run啓動configServer，registry, zuulServer, productService，web這幾個工程，而後啓動第二個productService，使用SERVER_PORT=8082 spring-boot:run。
訪問幾回http://localhost:8080/product/list，而後除了會在瀏覽器看到返回的結果，咱們還會在zuulServer的命令行窗口中看到以下字樣：

GET 方式請求 http://xuqians-imac:8083/product/list

而後在兩個productService的命令行窗口中，咱們還會看到隨機出現的

Access to /products endpoint

說明zuulServer也會自動進行負載均衡。

歡迎訪問個人博客張旭乾的博客

你們有什麼想法歡迎來討論。