Spring Cloud 入门之 Zuul（五）附源码

红太狼 2021-10-19 01:14 373阅读 0赞

## 一、前言 ##

随着业务的扩展，微服务会不对增加，相应的其对外开放的 API 接口也势必增多，这不利于前端的调用以及不同场景下数据的返回，因此，我们通常都需要设计一个 API 网关作为一个统一的 API 入口，来组合一个或多个内部 API。

## 二、简单介绍 ##

### 2.1 API 网关使用场景 ###

黑白名单： 实现通过 IP 地址控制请求的访问
    
    日志：实现访问日志的记录，进而实现日志分析，处理性能指标等
    
    协议适配：实现通信协议的校验、适配转换的功能
    
    身份认证：对请求进行身份认证
    
    计流限流：可以设计限流规则，记录访问流量
    
    路由：将请求进行内部（服务）转发

###  2.2 API 网关的实现 ###

业界常用的 API 网关有很多方式，如：Spring Cloud Zuul、 Nginx、Tyk、Kong。本篇介绍的对象正是 **Spring Cloud Zuul**。

Zuul 是 Netflix 公司开源的一个 API 网关组件，提供了认证、鉴权、限流、动态路由、监控、弹性、安全、负载均衡、协助单点压测等边缘服务的框架。

Spring Cloud Zuul 是基于 Netflix Zuul 的微服务路由和过滤器的解决方案，也用于实现 API 网关。其中，路由功能负责将外部请求转发到具体的微服务实例上，是实现外部访问统一入门的基础。而过滤功能是负责对请求的处理过程进行干预，是实现请求校验、服务聚合等功能的基础。

Spring Cloud Zuul 和 Eureka 进行整合时，Zuul 将自身注册到 Eureka 服务中，同时从 Eureka 中获取其他微服务信息，以便请求可以准确的通过 Zuul 转发到具体微服务上。

## 三、实战演练 ##

**本次测试案例基于之前发表的文章中介绍的案例进行演示，不清楚的读者请先转移至[Spring Cloud 入门之 Hystrix][Spring Cloud _ Hystrix] 进行浏览。**

<table> 
 <thead> 
  <tr> 
   <th>服务实例</th> 
   <th>端口</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>common</td> 
   <td>-</td> 
   <td>公用的，如：实体类</td> 
  </tr> 
  <tr> 
   <td>eureka-server</td> 
   <td>9000</td> 
   <td>注册中心（Eureka 服务端）</td> 
  </tr> 
  <tr> 
   <td>provider01-server</td> 
   <td>8081</td> 
   <td>用户服务（Eureka 客户端）</td> 
  </tr> 
  <tr> 
   <td>provider02-server</td> 
   <td>8082</td> 
   <td>用户服务（Eureka 客户端）</td> 
  </tr> 
  <tr> 
   <td>api</td> 
   <td>80</td> 
   <td>消费服务（Eureka 客户端）</td> 
  </tr> 
 </tbody> 
</table>

创建一个为名 gateway-server 的 Spring Boot 项目。

### 3.1添加依赖 ###

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
                <version>2.1.0.RELEASE</version>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-zuul</artifactId>
                <version>2.1.0.RELEASE</version>
            </dependency>

### 3.2配置文件 ###

server:
      port: 5555
    
    spring:
      application:
        name: gateway
    
    eureka:
      instance:
        instance-id: gateway-5555
        prefer-ip-address: true
      client:
        service-url:
          defaultZone: http://localhost:9000/eureka/  # 注册中心访问地址

### 3.3 启动 Zuul ###

在启动类上添加 **@EnableZuulProxy 注解.**

@EnableZuulProxy
    @SpringBootApplication
    public class GatewayApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(GatewayApplication.class, args);
        }
    
    }

**依次启动上面项目**

![20190814094043838.gif][]

**首先我们先调用api服务项目的地址：[http://127.0.0.1/user/get/1][http_127.0.0.1_user_get_1]**

**之后再修改成访问 gateway-server 项目的请求地址：[http://127.0.0.1:5555/api/user/get/1][http_127.0.0.1_user_get_1]**

**最终的相应结果都一样。**

**[http://127.0.0.1:5555/api/user/get/1][http_127.0.0.1_user_get_1]中的api是在Eureka 上注册的消费服务**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMzY5OTQ0_size_16_color_FFFFFF_t_70][]

### 3.4 zuul 常用配置 ###

**修改路由：**

zuul:
      sensitive-headers: # 全局忽略敏感头，即允许接收 cookie 等请求头信息   
      routes:
        javaj: # 任意名字，保证唯一即可
          path: /javaj/** # 自定义，真正用到的请求地址
          service-id: api # 路由到的目标服务名称

将消费服务的路由名称改成 javaj。

使用 Postman 请求下单接口，运行结果：

![20190814094905913.gif][]

**请求成功**

禁用路由：

zuul:
      ignored-patterns:
      - /api/user/**

[http://127.0.0.1:5555/api/user/get/1][http_127.0.0.1_user_get_1] 无法正常路由到消费服务，返回404错误

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMzY5OTQ0_size_16_color_FFFFFF_t_70 1][]

**路由加前缀：**

zuul:
    prefix: /open

所有请求中的path需要添加前缀/open；

如[http://127.0.0.1:5555/javaj/user/get/1][http_127.0.0.1_5555_javaj_user_get_1] 要改为 [http://127.0.0.1:5555/open/javaj/user/get/1][http_127.0.0.1_5555_javaj_user_get_1]

**设置敏感头：**

zuul:
        sensitive-headers: # 设置全局敏感头，如果为空，表示接收所有敏感头信息
    或
    zuul:
        routes:
            javaj: # 任意名字，保证唯一即可
                path: /javaj/** # 自定义，真正用到的请求地址
                service-id: api# 路由到的目标服务名称
                sensitive-headers: # 针对 /javaj/ 的请求设置敏感头信息

## 四、Zuul 自定义过滤器 ##

Zuul 的核心技术就是过滤器，该框架提供了 ZuulFilter 接口让开发者可以自定义过滤规则。

我们以身份检验为例，自定义 ZuulFilter 过滤器实现该功能。

### 4.1 创建用户服务 ###

新建名为 user-server 的项目。

添加依赖：

<dependency>
                <groupId>com.common</groupId>
                <artifactId>common</artifactId>
                <version>0.0.1-SNAPSHOT</version>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
                <version>2.1.0.RELEASE</version>
            </dependency>

application.yml：

server:
      port: 8100
    
    spring:
      application:
        name: USER
    
    eureka:
      instance:
        instance-id: user-api-8100
        prefer-ip-address: true # 访问路径可以显示 IP
      client:
        service-url:
          defaultZone: http://localhost:9000/eureka/  # 注册中心访问地址

登录接口：

@RestController
    @RequestMapping("/user")
    public class LoginController {
    
        @PostMapping("/login")
        public AjaxResult login(String username, String password, HttpServletResponse response) {
    
    
            if ("admin".equals(username) && "admin".equals(password)) {
                // 模拟生成 token，实际开发中 token 应存放在数据库或缓存中
                String token = "123456";
                Cookie cookie = new Cookie("token", token);
                cookie.setPath("/");
                cookie.setMaxAge(60 * 10);
                response.addCookie(cookie);
    
                return AjaxResult.success();
            }
    
            return AjaxResult.error(401, "账号或密码错误");
        }
    }

user-server 启动类：

@EnableEurekaClient
    @SpringBootApplication
    public class UserApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(UserApplication.class, args);
        }
    
    }

### 4.2 创建 ZuulFilter 过滤器 ###

在 gateway-server 项目中，新建一个过滤器，需要继承 **ZuulFilter 类**：

@Component
    public class AuthenticationFilter extends ZuulFilter {
    
        /**
         * 是否开启过滤
         */
        @Override
        public boolean shouldFilter() {
            RequestContext context = RequestContext.getCurrentContext();
            HttpServletRequest request = context.getRequest();
    
            boolean flag = request.getRequestURI().contains("/login");
            // 如果是登录请求不进行过滤
            if (flag) {
                System.out.println("========不执行 zuul 过滤方法=======");
            } else {
                System.out.println("========执行 zuul 过滤方法=======");
            }
            return !flag;
        }
    
        /**
         * 过滤器执行内容
         */
        @Override
        public Object run() throws ZuulException {
    
            RequestContext context = RequestContext.getCurrentContext();
            HttpServletRequest request = context.getRequest();
            String token = request.getParameter("token");
            // 此处模拟获取数据库或缓存中的 token
            String dbToken = "123456";
            // 此处简单检验 token
            if (token == null || "".equals(token) || !dbToken.equals(token)) {
                context.setSendZuulResponse(false);
                context.setResponseStatusCode(HttpStatus.UNAUTHORIZED.value());
            }
    
            return null;
        }
    
        /**
         * 过滤器类型
         */
        @Override
        public String filterType() {
            return "pre";
        }
    
        /**
         * 过滤器执行顺序
         */
        @Override
        public int filterOrder() {
            return 0;
        }
    
    }

其中，filterType 有 4 种类型：

pre： 这种过滤器在请求被路由之前调用。我们可利用这种过滤器实现身份验证、在集群中选择请求的微服务、记录调试信息等。
    
    routing：这种过滤器将请求路由到微服务。这种过滤器用于构建发送给微服务的请求，并使用 Apache HttpClient 或 Netfilx Ribbon 请求微服务。
    
    post：这种过滤器在路由到微服务以后执行。这种过滤器可用来为响应添加标准的 HTTP Header、收集统计信息和指标、将响应从微服务发送给客户端等。
    
    error：在其他阶段发生错误时执行该过滤器。

其过滤顺序如下图：

[![aHR0cDovL2ltYWdlcy5leHRsaWdodC5jb20venV1bC0wNC5qcGc][]][aHR0cDovL2ltYWdlcy5leHRsaWdodC5jb20venV1bC0wNC5qcGc 1]

### 4.3 测试过滤器 ###

运行所有项目，测试操作步骤如下：

请求用户服务的登录接口(http://127.0.0.1:5555/open/user/user/login?username=admin&password=admin)，请求不执行 zuul 过滤方法，并且请求响应返回的 cookie 包含 token
    
    请求消费服务的接口(http://127.0.0.1:5555/open/javaj/user/get/1)，但不携带 token，请求需要执行 zuul 过滤方法，请求响应 401 权限不足
    
    请求消费服务的接口(http://127.0.0.1:5555/open/javaj/user/get/1)，携带之前登录接口返回的 token，请求需要执行 zuul 过滤方法，校验通过后路由到消费服务执行之后的操作

![20190814102511138.gif][]

![20190814103331236.gif][]

## 五、案例源码 ##

[源码][Link 1]

[Spring Cloud _ Hystrix]: https://blog.csdn.net/qq_40369944/article/details/98970421
[20190814094043838.gif]: /images/20211018/db9d52642ea046ad8fe8e069ab74b92e.png
[http_127.0.0.1_user_get_1]: http://127.0.0.1:5555/api/user/get/1
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMzY5OTQ0_size_16_color_FFFFFF_t_70]: /images/20211018/eda0f8c9e4694436aab8e1d25f97a260.png
[20190814094905913.gif]: /images/20211018/143b0fa4ea404d2f98d21f87d236e326.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMzY5OTQ0_size_16_color_FFFFFF_t_70 1]: /images/20211018/1d400c94811b457b801924b97d0b5f3a.png
[http_127.0.0.1_5555_javaj_user_get_1]: http://127.0.0.1:5555/open/javaj/user/get/1
[aHR0cDovL2ltYWdlcy5leHRsaWdodC5jb20venV1bC0wNC5qcGc]: /images/20211018/a2c5ed89b74345c0a03a1a8684c1787a.png
[aHR0cDovL2ltYWdlcy5leHRsaWdodC5jb20venV1bC0wNC5qcGc 1]: http://images.extlight.com/zuul-04.jpg
[20190814102511138.gif]: /images/20211018/91e184d0efdc4eed821c4ca4946413ca.png
[20190814103331236.gif]: /images/20211018/bec367725c9e4944a9f7081c1e80402f.png
[Link 1]: https://github.com/Uncle-LiuY/spring-cloud-test