搜索

SpringCloud系列之API网关(Gateway)服务Zuul

JAVA烂猪皮

共 12155字，需浏览 25分钟

 · 2021-06-10

走过路过不要错过

点击蓝字关注我们


1、什么是API网关

API网关是所有请求的入口，承载了所有的流量，API Gateway是一个门户一样，也可以说是进入系统的唯一节点。这跟面向对象设计模式中的Facet模式很像。API Gateway封装内部系统的架构，并且提供API给各个客户端。它还可能有其他功能，如授权、监控、负载均衡、缓存、请求分片和管理、静态响应处理等

API Gateway负责请求转发、合成和协议转换。所有来自客户端的请求都要先经过API Gateway，然后路由这些请求到对应的微服务。API Gateway将经常通过调用多个微服务来处理一个请求以及聚合多个服务的结果。它可以在web协议与内部使用的非Web友好型协议间进行转换，如 HTTP协议、WebSocket协议。

画图表示，没有网关的情况，客户端的请求会直接落到后端的各个服务中，无法集中统一管理。

画图表示，有网关的情况，所有的请求都先经过网关，然后进行分发到对应服务

2、API网关的重要性

API网关在微服务项目中是很重要的，网关提供一个统一的管理，服务间的调度变得有序

引用nginx官方的一篇优质博客，https://www.nginx.com/blog/building-microservices-using-an-api-gateway/，例子介绍了一个庞杂的电商系统，按照微服务理论进行设计，有如下各种服务：

  • 购物车服务：购物车中的物品数量

  • 订单服务：订单历史记录

  • 目录服务：基本产品信息，例如其名称，图像和价格

  • 审核服务：客户审核

  • 库存服务：库存不足警告

  • 运送服务：运送选项，期限和费用与运送提供商的API分开提取

  • 推荐服务：建议项目

在不使用网关的情况，客户端直接调用各服务：

理想情况，各服务调用是可以正常使用的，但是随着业务拓展，服务之间的调用越来越复杂，到时候系统就会变成如图：

如果没有一个统一的管理，肯定是不合理的，所以可以引入网关，作为一个统一的门户，如图：

3、API Gateway的作用

ok，简单介绍网关之后，要说说网关的作用，在Spring cloud官网也有过归纳：

当然，我们可以自己挑几个重要的介绍

  • 动态路由
    网关可以做路由转发，假如服务信息变了，只要改网关配置既可，所以说网关有动态路由(Dynamic Routing)的作用，如图：

  • 请求监控
    请求监控可以对整个系统的请求进行监控，详细地记录请求响应日志，如图，可以将日志丢到消息队列，如果没有使用网关的话，记录请求信息需要在各个服务中去做

  • 认证鉴权
    认证鉴权可以对每一个访问请求做认证，拒绝非法请求，保护后端的服务，不需要每个服务都做鉴权，在项目中经常有加上OAuth2.0、JWT，Spring Security进行权限校验

  • 压力测试
    有网关的系统，如果要要对某个服务进行压力测试，可以如图所示，改下网关配置既可，测试请求路由到测试服务，测试服务会有单独的测试数据库，这样测试的请求就不会影响到正式的服务和数据库

4、什么是Netflix Zuul？

Netflix Zuul是Netflix公司的产品，是一款API网关中间件。Zuul是一个基于 JVM 路由和服务端的负载均衡器。提供了路由、监控、弹性、安全等服务。Zuul 能够与 Eureka、Ribbon、Hystrix 等组件配合使用，提供统一的API网关处理

5、Netflix Zuul工作原理

参考Zuul官网wiki，Zuul的核心如图其实就是过滤器，zuul基于Servlet实现。当一个请求进来时，会先进入 pre 过滤器，在 pre 过滤器执行完后，接着就到了 routing 过滤器中，开始路由到具体的服务中，错误的情况会被错误过滤器拦截

  • 过滤器类型：

    • 前置过滤器(PRE FILTER)：在路由过滤器之前执行。功能可以包括请求身份验证，选择原始服务器以及记录调试信息。

    • 路由过滤器(ROUTE FILTER)：处理将请求路由到源的过程。这是使用Apache HttpClient或Netflix Ribbon构建和发送原始HTTP请求的地方。

    • 后置过滤器(POST FILTER)：在将请求路由过滤器之后执行。功能可以包括向响应中添加标准HTTP标头，收集统计信息和指标以及将响应从源流传输到客户端。

    • 错误过滤器(ERR FILTER)：在其他阶段之一发生错误时就会调用到错误过滤器

6、Zuul实验环境准备

环境准备：

  • JDK 1.8

  • SpringBoot2.2.3

  • SpringCloud(Hoxton.SR6)

  • Maven 3.2+

  • 开发工具

    • IntelliJ IDEA

    • smartGit

创建一个SpringBoot Initialize项目，详情可以参考我之前博客：SpringBoot系列之快速创建项目教程


maven配置：

<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-netflix-zuul</artifactId>        </dependency>

本博客的是基于spring-cloud-starter-netflix-eureka-client进行试验，试验前要运行eureka服务端，eureka服务提供者，代码请参考上一章博客

项目创建成功后，先在启动类加上@EnableZuulProxy：

import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.netflix.zuul.EnableZuulProxy;
@SpringBootApplication@EnableZuulProxypublic class SpringcloudZuulApplication {
    public static void main(String[] args) {        SpringApplication.run(SpringcloudZuulApplication.class, args);    }}

7、eureka、zuul配置

eureka客户端配置：

server:  port: 8082# 指定application name，这个是微服务注册的serviceIdspring:  application:    name: zuul-api-gateway
eureka:  client:    # 服务注册中心url    service-url:      defaultZone: http://localhost:8761/eureka/     # 网关服务注册、发现都开放，所以 register-with-eureka、fetch-registry都是true    register-with-eureka: true    fetch-registry: true  instance:    status-page-url-path: http://localhost:8761/actuator/info    health-check-url-path: http://localhost:8761/actuator/health    prefer-ip-address: true    instance-id: zuul-api-gateway8082

Zuul 配置路由规则：

zuul:  routes:    provider: # 路由标识，可以自己定义      service-id: eureka-service-provider # 服务id(必须配置)      path: /provider/** # 映射的路径，一般和routes.provider一致      url: http://localhost:8083 # 路由到的url，可以不配置

Zuul配置访问前缀：访问时候需要加上前缀，eg：http://localhost:8082/api-gateway/provider/api/users/mojombo

zuul:  # 配置前缀  prefix: /api-gateway

Zuul配置Header过滤：

zuul: # 配置过滤敏感的请求头信息，设置为空就不会过滤  sensitive-headers: Cookie,Set-Cookie,Authorization

Zuul配置重定向添加Host：

zuul:# 重定向会添加host请求头  add-proxy-headers: true

Zuul超时设置：

zuul:  host:    # 配置连接超时时间    connect-timeout-millis: 15000    # socker发送超时时间    socket-timeout-millis: 60000

zuul所有配置参考，详情参考官网：

zuul:  # 配置前缀  prefix: /api-gateway  routes:    provider: # 路由标识，可以自己定义      service-id: eureka-service-provider # 服务id      path: /provider/** # 映射的路径，一般和routes.provider一致      url: http://localhost:8083 # 路由到的url  host:    # 配置连接超时时间    connect-timeout-millis: 15000    # socker发送超时时间    socket-timeout-millis: 60000  # 请求url编码  decode-url: true  # 查询字符串编码  force-original-query-string-encoding: false  # 配置过滤敏感的请求头信息，设置为空就不会过滤  sensitive-headers: Cookie,Set-Cookie,Authorization  # 重定向会添加host请求头  add-proxy-headers: true

访问：http://localhost:8082/api-gateway/provider/api/users/mojombo，要加上前缀，配置的path

可能遇到的错误，504错误：


经过排查，需要加上超时设置，因为调用服务超时，导致504错误

zuul:  host:    connect-timeout-millis: 15000    socket-timeout-millis: 60000

加上配置，调用服务成功

8、Zuul自定义过滤器

在前面的介绍中，已经介绍了几种过滤器，现在自定义实现这四种过滤器

ps：spring cloud官网也提供了zuul过滤器的例子，详情可以去github查看：https://github.com/spring-cloud-samples/sample-zuul-filters

项目结构：


过滤器类型参考org.springframework.cloud.netflix.zuul.filters.supportFilterConstants.java：

实现一个前置过滤器：拦截请求，必须带token过来，不然抛出提示信息等等

package com.example.springcloud.zuul.web.filter;
import com.netflix.zuul.ZuulFilter;import com.netflix.zuul.context.RequestContext;import com.netflix.zuul.exception.ZuulException;import lombok.extern.slf4j.Slf4j;import org.apache.http.HttpHeaders;import org.springframework.stereotype.Component;import org.springframework.util.StringUtils;
import javax.servlet.http.HttpServletRequest;
import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.FORWARD_TO_KEY;import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.PRE_TYPE;import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.SERVICE_ID_KEY;
/** * <pre> *  API网关预过滤器 * </pre> * * <pre> * @author mazq * 修改记录 *    修改后版本:     修改人：修改日期: 2020/08/05 18:08  修改内容: * </pre> */@Slf4j//@Componentpublic class ZuulApiGatewayPreFilter extends ZuulFilter {
    @Override    public String filterType() {        return PRE_TYPE;    }
    @Override    public int filterOrder() {        return 0;    }
    @Override    public boolean shouldFilter() {        return true;    }
    @Override    public Object run() throws ZuulException {        RequestContext ctx = RequestContext.getCurrentContext();        HttpServletRequest request = ctx.getRequest();        String accessToken = request.getParameter("token");        if (StringUtils.isEmpty(accessToken)) {            // zuul过滤该请求，不进行路由            ctx.setSendZuulResponse(false);            // 设置返回的错误码            ctx.setResponseStatusCode(403);            ctx.setResponseBody("AccessToken is Invalid ");            return null;        }        log.info("accessToken: {}",accessToken);        // 否则业务继续执行        return null;    }}

后置过滤器，经常被用于打印日志等等操作，代码参考：https://www.baeldung.com/zuul-filter-modifying-response-body，实现效果时，路由过滤器执行之后，执行后置过滤器打印日志：

package com.example.springcloud.zuul.web.filter;
import com.google.common.io.CharStreams;import com.netflix.zuul.ZuulFilter;import com.netflix.zuul.context.RequestContext;import com.netflix.zuul.exception.ZuulException;import lombok.extern.slf4j.Slf4j;import org.apache.http.protocol.RequestContent;import org.springframework.stereotype.Component;
import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;
import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.POST_TYPE;import static org.springframework.http.HttpStatus.INTERNAL_SERVER_ERROR;
/** * <pre> *      API Gateway后置过滤器 * </pre> * * <pre> * @author mazq * 修改记录 *    修改后版本:     修改人：修改日期: 2020/08/06 10:05  修改内容: * </pre> */@Slf4j//@Componentpublic class ZuulApiGatewayPostFilter extends ZuulFilter {    @Override    public String filterType() {        return POST_TYPE;    }
    @Override    public int filterOrder() {        return 0;    }
    @Override    public boolean shouldFilter() {        return true;    }
    @Override    public Object run() throws ZuulException {        RequestContext context = RequestContext.getCurrentContext();        try (final InputStream responseDataStream = context.getResponseDataStream()) {            if(responseDataStream == null) {                log.warn("RESPONSE BODY: {}", "");                return null;            }            String responseData = CharStreams.toString(new InputStreamReader(responseDataStream, "UTF-8"));            log.info("RESPONSE BODY: {}", responseData);            context.setResponseBody(responseData);        }        catch (Exception e) {            throw new ZuulException(e, INTERNAL_SERVER_ERROR.value(), e.getMessage());        }        return null;    }}

注册过滤器，将过滤器加载到Spring容器，也可以在过滤器类加上@Component

package com.example.springcloud.zuul;
import com.example.springcloud.zuul.web.filter.ZuulApiGatewayErrFilter;import com.example.springcloud.zuul.web.filter.ZuulApiGatewayPostFilter;import com.example.springcloud.zuul.web.filter.ZuulApiGatewayPreFilter;import com.example.springcloud.zuul.web.filter.ZuulApiGatewayRouteFilter;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.netflix.zuul.EnableZuulProxy;import org.springframework.context.annotation.Bean;
@SpringBootApplication@EnableZuulProxypublic class SpringcloudZuulApplication {
    public static void main(String[] args) {        SpringApplication.run(SpringcloudZuulApplication.class, args);    }
    @Bean    public ZuulApiGatewayPreFilter zuulApiGatewayPreFilter(){        return new ZuulApiGatewayPreFilter();    }    @Bean    public ZuulApiGatewayPostFilter zuulApiGatewayPostFilter(){        return new ZuulApiGatewayPostFilter();    }    @Bean    public ZuulApiGatewayRouteFilter zuulApiGatewayRouteFilter(){        return new ZuulApiGatewayRouteFilter();    }    @Bean    public ZuulApiGatewayErrFilter zuulApiGatewayErrFilter(){        return new ZuulApiGatewayErrFilter();    }}

访问网关：http://localhost:8082/api-gateway/provider/api/users/mojombo，不带token的情况


http://localhost:8082/api-gateway/provider/api/users/mojombo?token=?，带上token调用成功

9、查看Zuul路由信息

加上spring-boot-starter-actuator，进行路由信息监控：

<dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-actuator</artifactId>        </dependency>

spring-boot-starter-actuator配置：

management:  endpoints:    web:      exposure:        # 默认只支持info,health，开启对routes的监控        include: info,health,routes  # 开启健康检查详细信息  endpoint:    health:      show-details: always

查看路由详细，访问http://localhost:8082/actuator/routes，SpringBoot2.2.3版本要加上actuator前缀，调用成功，返回json数据：

{    "/api-gateway/provider/**":"eureka-service-provider",    "/api-gateway/eureka-service-provider/**":"eureka-service-provider"}

查看路由详细信息，访问链接：http://localhost:8082/actuator/routes/details

{    "/api-gateway/provider/**":{        "id":"provider",        "fullPath":"/api-gateway/provider/**",        "location":"eureka-service-provider",        "path":"/**",        "prefix":"/api-gateway/provider",        "retryable":false,        "customSensitiveHeaders":false,        "prefixStripped":true    },    "/api-gateway/eureka-service-provider/**":{        "id":"eureka-service-provider",        "fullPath":"/api-gateway/eureka-service-provider/**",        "location":"eureka-service-provider",        "path":"/**",        "prefix":"/api-gateway/eureka-service-provider",        "retryable":false,        "customSensitiveHeaders":false,        "prefixStripped":true    }}

本博客代码例子下载：code download

Zuul官网手册：
spring Cloud官网zuul资料：https://docs.spring.io/spring-cloud-netflix/docs/2.2.x-SNAPSHOT/reference/html/#router-and-filter-zuul

zuul github wiki：https://github.com/Netflix/zuul/wiki/How-it-Works

github zuul过滤器例子：https://github.com/spring-cloud-samples/sample-zuul-filters


往期精彩推荐



腾讯、阿里、滴滴后台面试题汇总总结 — （含答案）

面试：史上最全多线程面试题 ！

最新阿里内推Java后端面试题

JVM难学？那是因为你没认真看完这篇文章


—END—


关注作者微信公众号 —《JAVA烂猪皮》


了解更多java后端架构知识以及最新面试宝典


你点的每个好看，我都认真当成了


看完本文记得给作者点赞+在看哦~~~大家的支持，是作者源源不断出文的动力


作者：SmileNicky

出处：https://www.cnblogs.com/mzq123/p/13447769.html

浏览 8
点赞
评论
收藏
分享

手机扫一扫分享

举报
评论
图片
表情
推荐
Go 1.22 的新增功能系列之二：reflect.TypeFor
Go 1.22 的第一个候选版本已经发布，这意味着最终版本即将发布，现在是我在博客中介绍我在这个周期中所做工作的时候了。像往常一样，我的贡献很小，但它们是我的，所以我将从幕后的角度来谈谈它们。首先是reflect.TypeFor。这是整个函数：// TypeFor returns the [Type
GoCN
0
springboot第70集：字节跳动后端三面经，一文让你走出微服务迷雾架构周刊
创建一个使用Kubernetes (K8s) 和 Jenkins 来自动化 GitLab 前端项目打包的CI/CD流水线，需要配置多个组件。下面，我将概述一个基本的设置步骤和示例脚本，以帮助你理解如何使用这些工具整合一个自动化流程。前提条件确保你已经有：Kubernetes 集群：用于部署 Jenk
程序源代码
0
牛逼啊，几乎涵盖了SpringCloud所有操作
前言Spring Cloud Alibaba为分布式应用开发提供了一站式解决方案。它包含开发分布式应用程序所需的所有组件，可以轻松地使用Spring Cloud开发应用程序。使用Spring Cloud Alibaba，只需添加一些注解和少量配置，即可将Spring Cloud应用连接到Alibab
java团长
0
一站式解决方案：基于 Arthas 实现服务发现和权限控制
来源：juejin.cn/post/7281849496983994383👉 欢迎加入小哈的星球 ，你将获得: 专属的项目实战 / Java 学习路线 / 一对一提问 / 学习打卡 /  赠书福利全栈前后端分离博客项目 2.0 版本完结啦， 演示链接
小哈学Java
0
Go 1.22 的新增功能系列之一：cmp.Or
截至撰写本文时，Go 1.22 已经发布几个月了。早就该结束我为 1.22 所做的工作的系列了。抱歉耽搁了这么久，我最近忙于生活事务。如果您错过了我关于reflect.TypeFor(https://blog.carlana.net/post/2024/golang-reflect-type-for
GoCN
1
微服务与领域驱动设计，架构实践总结
来源：知了一笑👉 欢迎加入小哈的星球 ，你将获得: 专属的项目实战 / Java 学习路线 / 一对一提问 / 学习打卡 /  赠书福利全栈前后端分离博客项目 2.0 版本完结啦， 演示链接：http://116.62.199.48/ ，新
小哈学Java
0
Stability AI开放Stable Diffusion 3 API，在线免费使用
「Stability AI」宣布开放其最新文本到图像生成模型「Stable Diffusion 3」的API接口，供开发者和企业使用。该模型采用创新的多模态扩散转换器架构，在字体、细节还原、提示理解等方面表现优异，评测结果超越了业内其他顶尖系统。与DALL-E 3和Midjourney v6等最先进
IQ前端
0
Higress 或许是目前最好的云原生网关？
Higress 是基于阿里内部的 Envoy Gateway 实践沉淀、以开源 Istio + Envoy 为核心构建的云原生 API 网关，实现了流量网关 + 微服务网关 + 安全网关三合一的高集成能力，深度集成 Dubbo、Nacos、Sentinel 等微服务技术栈，能够帮助用户极大的降低网关
k8s技术圈
18
【第124期】Vue 3 组合式 API 的瑞士军刀（VueUse）
概述 今天，我们要深入探索一个强大的工具集——VueUse。它为 Vue 3 的组合式 API（Composition API）提供了超过 200 个实用函数，让你的开发工作更加得心应手。官方网站：https://vueuse.org/VueUse 是什么？VueUse 的官方网站是 https:
前端微服务
0
全新 SOTA backbone | 2024年了，再见ViT系列Backbone，实数难得，不知道效果如何？
点击上方“小白学视觉”，选择加"星标"或“置顶”重磅干货，第一时间送达在构建用于精确匹配的深度固定长度表示时，确定指纹上的密集特征点，特别是在像素 Level 上，具有重大意义。为了探索指纹匹配的可解释性，作者提出了一种多阶段可解释的指纹匹配网络，名为通过视觉 Transformer 进行指纹匹配的
小白学视觉
10
点赞
评论
收藏
分享

手机扫一扫分享

举报