Gateway服务网关

2023-05-16

目录

为什么需要网关

1)创建gateway服务,引入依赖

2)编写启动类

3)编写基础配置和路由规则

4)重启测试

5)网关路由的流程图

断言工厂  

过滤器工厂

路由过滤器的种类

请求头过滤器

默认过滤器

全局过滤器

自定义全局过滤器

过滤器执行顺序

跨域问题

什么是跨域问题

解决跨域问题


        Spring Cloud Gateway 是 Spring Cloud 的一个全新项目,该项目是基于 Spring 5.0,Spring Boot 2.0 和 Project Reactor 等响应式编程和事件流技术开发的网关,它旨在为微服务架构提供一种简单有效的统一的 API 路由管理方式。

为什么需要网关

Gateway网关是我们服务的守门神,所有微服务的统一入口。

网关的核心功能特性

  • 请求路由

  • 权限控制

  • 限流

架构图:

权限控制:网关作为微服务入口,需要校验用户是是否有请求资格,如果没有则进行拦截。

路由和负载均衡:一切请求都必须先经过gateway,但网关不处理业务,而是根据某种规则,把请求转发到某个微服务,这个过程叫做路由。当然路由的目标服务有多个时,还需要做负载均衡。

限流:当请求流量过高时,在网关中按照下流的微服务能够接受的速度来放行请求,避免服务压力过大。

在SpringCloud中网关的实现包括两种:

  • gateway

  • zuul

Zuul是基于Servlet的实现,属于阻塞式编程。而SpringCloudGateway则是基于Spring5中提供的WebFlux,属于响应式编程的实现,具备更好的性能。

1)创建gateway服务,引入依赖

创建服务:

 引入依赖:

<!--网关-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>
<!--nacos服务发现依赖-->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>

2)编写启动类

package cn.itcast.gateway;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class GatewayApplication {

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

 

3)编写基础配置和路由规则

server:
  port: 10010 # 网关端口
spring:
  application:
    name: gateway # 服务名称
  cloud:
    nacos:
      server-addr: localhost:8848 # nacos地址
    gateway:
      routes: # 网关路由配置
        - id: user-service # 路由id,自定义,只要唯一即可
          # uri: http://127.0.0.1:8081 # 路由的目标地址 http就是固定地址
          uri: lb://userservice # 路由的目标地址 lb就是负载均衡,后面跟服务名称
          predicates: # 路由断言,也就是判断请求是否符合路由规则的条件
            - Path=/user/** # 这个是按照路径匹配,只要以/user/开头就符合要求

        我们将符合Path 规则的一切请求,都代理到 uri参数指定的地址。

        本例中,我们将 /user/**开头的请求,代理到lb://userservice,lb是负载均衡,根据服务名拉取服务列表,实现负载均衡。

4)重启测试

重启网关,访问http://localhost:10010/user/1时,符合/user/**规则,请求转发到uri:http://userservice/user/1,得到了结果:

 

5)网关路由的流程图

 

总结:

网关搭建步骤:

  1. 创建项目,引入nacos服务发现和gateway依赖

  2. 配置application.yml,包括服务基本信息、nacos地址、路由

路由配置包括:

  1. 路由id:路由的唯一标示

  2. 路由目标(uri):路由的目标地址,http代表固定地址,lb代表根据服务名负载均衡

  3. 路由断言(predicates):判断路由的规则,

  4. 路由过滤器(filters):对请求或响应做处理

断言工厂  

我们在配置文件中写的断言规则只是字符串,这些字符串会被Predicate Factory读取并处理,转变为路由判断的条件

例如Path=/user/**是按照路径匹配,这个规则是由

org.springframework.cloud.gateway.handler.predicate.PathRoutePredicateFactory类来

处理的,像这样的断言工厂在SpringCloudGateway还有十几个:

名称说明示例
After是某个时间点后的请求- After=2037-01-20T17:42:47.789-07:00[America/Denver]
Before是某个时间点之前的请求- Before=2031-04-13T15:14:47.433+08:00[Asia/Shanghai]
Between是某两个时间点之前的请求- Between=2037-01-20T17:42:47.789-07:00[America/Denver], 2037-01-21T17:42:47.789-07:00[America/Denver]
Cookie请求必须包含某些cookie- Cookie=chocolate, ch.p
Header请求必须包含某些header- Header=X-Request-Id, \d+
Host请求必须是访问某个host(域名)- Host=.somehost.org,.anotherhost.org
Method请求方式必须是指定方式- Method=GET,POST
Path请求路径必须符合指定规则- Path=/red/{segment},/blue/**
Query请求参数必须包含指定参数- Query=name, Jack或者- Query=name
RemoteAddr请求者的ip必须是指定范围- RemoteAddr=192.168.1.1/24
Weight权重处理

过滤器工厂

GatewayFilter是网关中提供的一种过滤器,可以对进入网关的请求和微服务返回的响应做处理:

 

 

路由过滤器的种类

Spring提供了31种不同的路由过滤器工厂。例如:

名称说明
AddRequestHeader给当前请求添加一个请求头
RemoveRequestHeader移除请求中的一个请求头
AddResponseHeader给响应结果中添加一个响应头
RemoveResponseHeader从响应结果中移除有一个响应头
RequestRateLimiter

限制请求的流量

请求头过滤器

 

 需求:给所有进入userservice的请求添加一个请求头:Truth=itcast is freaking awesome!

 只需要修改gateway服务的application.yml文件,添加路由过滤即可:

spring:
  cloud:
    gateway:
      routes:
      - id: user-service 
        uri: lb://userservice 
        predicates: 
        - Path=/user/** 
        filters: # 过滤器
        - AddRequestHeader=Truth, Itcast is freaking awesome! # 添加请求头

当前过滤器写在userservice路由下,因此仅仅对访问userservice的请求有效。

默认过滤器

如果要对所有的路由都生效,则可以将过滤器工厂写到default下。格式如下:

spring:
  cloud:
    gateway:
      routes:
      - id: user-service 
        uri: lb://userservice 
        predicates: 
        - Path=/user/**
      default-filters: # 默认过滤项
      - AddRequestHeader=Truth, Itcast is freaking awesome! 

过滤器的作用是什么?

        ① 对路由的请求或响应做加工处理,比如添加请求头

        ② 配置在路由下的过滤器只对当前路由的请求生效

defaultFilters的作用是什么?

        ① 对所有路由都生效的过滤器

全局过滤器

public interface GlobalFilter {
    /**
     *  处理当前请求,有必要的话通过{@link GatewayFilterChain}将请求交给下一个过滤器处理
     *
     * @param exchange 请求上下文,里面可以获取Request、Response等信息
     * @param chain 用来把请求委托给下一个过滤器 
     * @return {@code Mono<Void>} 返回标示当前过滤器业务结束
     */
    Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain);
}

在filter中编写自定义逻辑,可以实现下列功能:

  • 登录状态判断

  • 权限校验

  • 请求限流等

自定义全局过滤器

需求:定义全局过滤器,拦截请求,判断请求的参数是否满足下面条件:

  • 参数中是否有authorization,

  • authorization参数值是否为admin

  • 如果同时满足则放行,否则拦截

在gateway中定义一个过滤器:

package com.example.gateway;

import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.http.HttpStatus;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.stereotype.Component;
import org.springframework.util.MultiValueMap;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;

// @Order(-1)
@Component
public class AuthorizeFilter implements GlobalFilter, Ordered {
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        // 1.获取请求参数
        ServerHttpRequest request = exchange.getRequest();
        MultiValueMap<String, String> params = request.getQueryParams();
        // 2.获取参数中的 authorization 参数
        String auth = params.getFirst("authorization");
        // 3.判断参数值是否等于 admin
        if ("admin".equals(auth)) {
            // 4.是,放行
            return chain.filter(exchange);
        }
        // 5.否,拦截
        // 5.1.设置状态码
        exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);
        // 5.2.拦截请求
        return exchange.getResponse().setComplete();
    }

    @Override
    public int getOrder() {
        return -1;
    }
}

 

 

过滤器执行顺序

        请求进入网关会碰到三类过滤器:当前路由的过滤器、DefaultFilter、GlobalFilter

        请求路由后,会将当前路由过滤器和DefaultFilter、GlobalFilter,合并到一个过滤器链(集合)中,排序后依次执行每个过滤器:

 

排序的规则是什么呢?

  • 每一个过滤器都必须指定一个int类型的order值,order值越小,优先级越高,执行顺序越靠前

  • GlobalFilter通过实现Ordered接口,或者添加@Order注解来指定order值,由我们自己指定

  • 路由过滤器和defaultFilter的order由Spring指定,默认是按照声明顺序从1递增。

  • 当过滤器的order值一样时,会按照 defaultFilter > 路由过滤器 > GlobalFilter的顺序执行

详细内容,可以查看源码:

org.springframework.cloud.gateway.route.RouteDefinitionRouteLocator#getFilters()方法是先加载defaultFilters,然后再加载某个route的filters,然后合并。

org.springframework.cloud.gateway.handler.FilteringWebHandler#handle()方法会加载全局过滤器,与前面的过滤器合并后根据order排序,组织过滤器链

跨域问题

什么是跨域问题

跨域:域名不一致就是跨域,主要包括:

  • 域名不同: www.taobao.com 和 www.taobao.org 和 www.jd.com 和 miaosha.jd.com

  • 域名相同,端口不同:localhost:8080和localhost8081

跨域问题:浏览器禁止请求的发起者与服务端发生跨域ajax请求,请求被浏览器拦截的问题

解决方案:CORS,这个以前应该学习过,这里不再赘述了。不知道的小伙伴可以查看跨域资源共享 CORS 详解 - 阮一峰的网络日志

解决跨域问题

spring:
  cloud:
    gateway:
      # 。。。
      globalcors: # 全局的跨域处理
        add-to-simple-url-handler-mapping: true # 解决options请求被拦截问题
        corsConfigurations:
          '[/**]':
            allowedOrigins: # 允许哪些网站的跨域请求 
              - "http://localhost:8090"
            allowedMethods: # 允许的跨域ajax的请求方式
              - "GET"
              - "POST"
              - "DELETE"
              - "PUT"
              - "OPTIONS"
            allowedHeaders: "*" # 允许在请求中携带的头信息
            allowCredentials: true # 是否允许携带cookie
            maxAge: 360000 # 这次跨域检测的有效期

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

Gateway服务网关 的相关文章

  • 网关(gateway)简介与作用

    网关的英文名称 gateway 又叫做网间连接器 协议转换器 网关是在采用不同体系结构或协议的网络之间进行互通时 用于提供协议转换 路由选择 数据交换等网络兼容功能的设施 网关在传输层上以实现网络互连 是最复杂的网络互连设备 仅用于两个高层
  • Jenkins + NACOS + GATEWAY 实现微服务不停机部署

    Nacos 版本
  • 微服务网关鉴权:gateway使用、网关限流使用、用户密码加密、JWT鉴权

    点击关注 芋道源码 2022 09 05 10 32 发表于上海 收录于合集 芋道源码1000个 点击上方 芋道源码 选择 设为星标 管她前浪 还是后浪 能浪的浪 才是好浪 每天 10 33 更新文章 每天掉亿点点头发 源码精品专栏 原创
  • 使用Spring Gateway为对象存储系统MinIo和kkFileView文档预览增加登录验证

    文章目录 1 kkfileview下载部署 1 1 安装包部署运行 1 1 1 物理机或虚拟机上运行 1 1 2 Docker容器环境环境运行 1 2 接入说明 2 使用Spring Gateway增加登录认证 2 1 网关实现代码 2 2
  • 跨域问题以及在springcloud的gateway中解决跨域问题

    一 什么是跨域问题 跨域问题 当两个页面的域名不一致时 浏览器禁止请求的发起者与服务端发生跨域ajax请求 请求被浏览器拦截的问题 发生跨域问题需要满足的点有 1 两个页面的域名不一致 2 两个页面发生的是ajax请求 这里不允许跨域是浏览
  • GateWay 服务网关

    介绍 Cloud全家桶中有个很重要的组件就是网关 在1 x版本中都是采用的Zuul网关 但在2 x版本中 zuul的升级一直跳票 SpringCloud最后自己研发了一个网关替代Zuul 那就是SpringCloud Gateway Gat
  • Spring Cloud Gateway网关工作原理、网关谓词和GatewayFilter工厂

    Spring Cloud Gateway 官方文档地址 https docs spring io spring cloud gateway docs current reference html Spring Cloud Gateway项目
  • 四. Gateway 限流

    目录 一 限流中的基础问题 1 为什么限流及常见限流方案 2 常见限流算法 计数器限流算法 令牌桶算法 漏桶算法 3 几种基础版限流实现方案 基于redis实现限流 基于 Guava RateLimiter 实现令牌算法 二 Gateway
  • spring gateway 的搭建与配置

    步骤 建项目 给主启动类添加Eureka的注解 EnableEurekaClient 添加并配置application yml 第一步 新建gateway的项目 gateway 8205 需要用到的组件
  • 理解gateway网关,及与前端联调过程

    1 一些概念 客户端向Spring Cloud Gateway发出请求 然后在Gateway Handler Mapping中找到请求相匹配的路由 将其发送到Gateway Web Handler Handler再通过制定的过滤器链来将请求
  • SpringCloud Gateway:status: 503 error: Service Unavailable

    使用SpringCloud Gateway路由请求时 出现如下错误 yml配置如下 可能的一种原因是 yml配置了gateway discovery locator enabled true 此时gateway会使用负载均衡模式路由请求 但
  • 第五章 Gateway--服务网关

    接上一篇文章开始网关之旅 首先告诉大家网关是什么 Gateway简介 怎么配置 怎么入门 执行流程等等相关介绍 第一章 微服务的架构介绍发展第二章 微服务环境搭建第三章 Nacos Discovery 服务治理第四章 Sentinel 服务
  • java中获取默认网关

    我想使用 java 获取本地计算机的默认网关 我知道如何通过执行dos或shell命令来获取它 但是还有其他方法来获取吗 还需要获取主要和辅助 dns ip My way is try DatagramSocket s new Datagr
  • 当应用程序发送 401 时,Azure 应用程序网关抛出 502

    Azure 应用程序网关显示502 bad gateway error 当应用程序返回时401 or 500 errors 它应该发送应用程序发送的任何内容 但默认情况下它发送502 知道发生了什么以及有任何配置或代码更改建议吗 EDIT
  • go-zero开发入门之gateway深入研究1

    创建一个 gateway 示例 main go package main import flag fmt gateway middleware github com zeromicro go zero core conf github co
  • 系列十、Spring Cloud Gateway

    一 Spring Cloud Gateway 1 1 概述 Spring Cloud全家桶中有个很重要的组件就是网关 在1 x版本中采用的是Zuul网关 但是在2 x版本中 由于Zuul的升级一直跳票 Spring Cloud最后自己研发了
  • 从 IP 块计算网络掩码/网关

    我们的数据中心为我们提供了所有机器的 JSON 转储 以便导入到我们自己的库存管理系统中 这提供了 IP 块 例如 192 168 1 1 26 但当我导入数百个块时 我还想计算网络掩码和网关 我查看了 PHP Doxygen 上的网络功能
  • HTTP代理、隧道、网关有什么区别? [关闭]

    Closed 这个问题是无关 help closed questions 目前不接受答案 全部 我看到 RFC 2616 中的条款 http www w3 org Protocols rfc2616 rfc2616 sec1 html se
  • CoAP数据包的大小是多少?

    我是这项技术的新手 有人可以帮助我了解一些疑问吗 Q 1 CoAP数据包的大小是多少 我知道有 4 字节固定标头 但是包括标头 选项和负载在内的最大大小限制是多少 Q 2 有像MQTT那样的Keep Alive的概念吗 它在UDP上工作 它
  • 如何在linux中使用iptables将http和https流量转发到透明代理[关闭]

    Closed 这个问题不符合堆栈溢出指南 help closed questions 目前不接受答案 这个问题似乎不是关于主要由程序员使用的特定编程问题 软件算法或软件工具 help on topic 如果您认为该问题与主题相关另一个 St

随机推荐

  • Linux系统编程之--文件操作

    前言 xff1a Linux系统之下皆文件 1 缓冲区文件操作 普通文件 xff08 TXT MP3 MP4 xff09 缓冲区 xff1a 文件的读写并不是直接操作文件的 xff0c 而是操作缓冲区的 xff08 RAM xff09 例如
  • Linux interfaces配置静态ip(开机自启动)

    编辑 xff1a vim etc network interfaces 基本配置如下 xff1a eth0会在系统启动时被自动配置 auto eth0 eth0接口具有一个静态 xff08 static xff09 IP配置 iface e
  • 超详细Windows10 Tomcat 9安装与配置

    文章目录 附Eclipse配置Tomcat教程一 Tomcat下载二 配置环境变量三 启动Tomcat四 测试Tomcat是否启动成功 附Eclipse配置Tomcat教程 超详细Ecilpse配置Tomcat教程 一 Tomcat下载 首
  • VS2019左侧 黄、绿线条 以及 错误波浪线 隐藏

    VS2019左侧黄线 绿线 选项 gt 文本编译器 gt 常规 gt 跟踪更改 xff08 T xff09 选中后在代码左侧会出现黄绿线条 错误波浪线 选项 gt 文本编译器 gt 常规 gt 显示错误波形曲线 xff08 E xff09
  • Zemax光学设计(十)——变焦镜头设计

    变焦镜头原理 在基础光学理论中像面大小 视场和焦距三者有 如下关系 xff1a 变焦镜头的变焦倍数为长焦距和短焦距比值 xff0c 也称为倍率 在变焦过程中镜头的相对孔径保持不变 xff0c 但对于实际的高变倍比系统 xff0c 由于外形尺
  • Spring Boot注解的运行原理

    Spring Boot 是一个基于 Spring Framework 的开源框架 xff0c 通过简化配置和开发过程 xff0c 使 Spring 应用程序的开发变得更加快速和便捷 在 Spring Boot 中 xff0c 注解是非常重要
  • 在Ubuntu 18.04上安装Git

    步骤1 首先 xff0c 通过运行以下命令确保您的系统和apt包列表完全更新 xff1a apt get update y apt get upgrade y 第2步 在Ubuntu 18 04上安装Git 现在让我们安装git xff1a
  • python中‘‘‘ ‘‘‘ 的作用

    在python中 39 有下面两个作用 xff1a 1 保留原样输出 代码块就是 email message span class token operator 61 span span class token triple quoted
  • 1.4 配置通过FTP进行文件操作

  • Python编程——列表输入字典再转为DataFrame

    导入依赖库 import pandas as pd 设置两个列表 alpha list 61 1 2 3 4 5 beta list 61 2 3 4 5 6 some dict 61 设置空字典 some dict 39 a 39 61
  • 【毕设】基于SpringBoot的医院管理系统的设计和实现

    毕设 基于SpringBoot的医院管理系统的设计和实现 xff1a 本次毕设是基于SpringBoot的前后端分离医院管理系统 xff0c 毕设中包括开题任务书 开题报告 项目系统 毕设论文 相应的答辩PPT 项目演示基本业务操作流程 毕
  • Android S GTS 常见的 fail 项

    此文章只是一篇总结 xff0c 针对 MTK 平台近期的 GTS 做个简单的整理回顾 xff0c 后期不断扩展 GTS GtsJniUncompressHostTestCases com google android gts jniunco
  • 正则表达式底层实现 matcher.find

    matcher find 完成的任务 xff08 考虑分组 xff09 什么是分组 xff0c 比如 d d d d 正则表达式中有 表示分组 第1个 表示第1组 第2个 表示第2组 1 根据指定的规则 定位满足规则的子字符串 比如 19
  • MyBatisPlus配置与实现

    目录 基于SpringBoot使用MyBatisPlus 标准数据层开发 Lombok 分页功能 DQL编程控制 构建条件查询 null判定 查询投影 聚合查询 分组查询 查询条件 模糊查询 排序查询 映射匹配兼容性 DML编程控制 id生
  • 深入理解SpringApplication.run(PeaApplication.class,args)(1)

    运行流程 xff1a 前言 本篇将对SpringApplication run xff09 方法进行源码溯源 xff0c 深入理解该方法 在进入该方法后 xff0c 把第一个class参数转化为数组类型 xff0c 调用同名方法 这里有2个
  • Nacos注册中心

    国内公司一般都推崇阿里巴巴的技术 xff0c 比如注册中心 xff0c SpringCloudAlibaba也推出了一个名为Nacos的注册中心 认识和安装Nacos Nacos是阿里巴巴的产品 xff0c 现在是SpringCloud中的
  • Activity的启动和结束

    onCreate xff1a 创建活动 此时会把页面布局加载进内存 xff0c 进入了初始状态 onStart xff1a 开启活动 此时会把活动页面显示在屏幕上 xff0c 进入了就绪状态 onResume xff1a 恢复活动 此时活动
  • Nacos集群搭建

    官方给出的Nacos集群图 xff1a 其中包含3个nacos节点 xff0c 然后一个负载均衡器代理3个Nacos 这里负载均衡器可以使用nginx 我们计划的集群结构 xff1a 2 搭建集群 搭建集群的基本步骤 xff1a 搭建数据库
  • Feign远程调用

    目录 Feign替代RestTemplate 1 xff09 引入依赖 2 xff09 添加注解 3 xff09 编写Feign的客户端 Load balancer does not have available server for cl
  • Gateway服务网关

    目录 为什么需要网关 1 xff09 创建gateway服务 xff0c 引入依赖 2 xff09 编写启动类 3 xff09 编写基础配置和路由规则 4 xff09 重启测试 5 xff09 网关路由的流程图 断言工厂 过滤器工厂 路由过