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服务网关 的相关文章

  • 分布式限流之 - Spring Cloud Gateway层限流实现

    写在前面的话 高并发的三驾马车 缓存 降级 限流 这里仅仅说限流 常用的限流算法有 计数器算法 固定窗口算法 滑动窗口算法 漏桶算法 令牌桶算法 每种算法的特点和优缺点这里不展开 比较适用的限流算法基本都会选择令牌桶 并且这里基于Sprin
  • 搭建spring-cloud-alibaba微服务项目:springBoot服务+nacos注册中心+nacos配置中心+feign服务交互+gateway网关

    项目说明 从0 1 搭建cloud alibaba微服务项目 包括各个springBoot服务 nacos注册中心 nacos配置中心 feign服务交互 gateway网关 首先统一微服务种alibaba相关组件的依赖版本问题 官方参考文
  • UWB自组网定位方案_基于UWB技术的消防应急救援定位解决方案

    目前国内应急救援市场都是基于被动定位应用 在特殊情况下救援也大多处于单兵作战的情况 并不能及时知道自己和自己组员的位置信息和状态 且没有场景感知和室内外一体位置信息结合 使相关救援人员处于更加危险境地 本篇就带大家详细了解一下微能信息针对消
  • Gateway网关

    搭建网关服务 1 创建新的moddule 引入SpringCloudGateway的依赖和nacos的服务发现依赖
  • Gateway网关-网关的cors跨域配置

    什么是跨域问题 跨域 域名不一致就是跨域 主要包括 域名不同 www taobao com 和 www taobao org 和 www jd com 和 miaosha jd com 域名相同 端口不同 localhost 8080和lo
  • API 网关基础

    目录 一 网关概述 二 网关提供的功能 三 常见网关系统 3 1 Netflix Zuul 3 2 Spring Cloud Gateway 3 3 Kong 3 4 APISIX 3 5 Shenyu 一 网关概述 API网关是一个服务器
  • 微服务内部服务调用@Inner

    1 外部从Gateway访问 需要鉴权 eg CURD操作 这种是最常使 的 户登录后正常访问接 不需要我们做什么处理 可能有的接 需要加权限字段 2 外部从Gateway访问 不需要鉴权 eg 短信验证码 需要我们将uri加 到secur
  • Nginx配置参数解释

    目录 worker processes work cpu affinity worker rlimit nofile events模块 1 use method 2 worker connections 3 multi accept htt
  • Gateway网关提示Flipping property: system-server.ribbon.ActiveConnectionsLimit to use NEXT property: niws

    一 问题描述 自己有一个微服务项目 使用了GateWay进行限流处理 但是最近发现 无论如何 系统都登陆不上去了 出现了问题 控制台总是提示Flipping property system server ribbon ActiveConne
  • SpringCloud Gateway整合Spring Security Webflux的关键点(痛点解析),及示例项目

    最近公司项目需要用到后端的认证 授权 且公司项目目前是基于SpringCloud Gateway的 所以想到都是一家的产品就决定使用Spring Security了 但是在整合过程中 经历了种种磨难 所以把最终的整合关键点列出来 让需要的读
  • Spring Cloud Gateway网关工作原理、网关谓词和GatewayFilter工厂

    Spring Cloud Gateway 官方文档地址 https docs spring io spring cloud gateway docs current reference html Spring Cloud Gateway项目
  • 微服务:gateway的使用,和解决跨域问题,用户认证与网关整合

    1 网关介绍 API网关出现的原因是微服务架构的出现 不同的微服务一般会有不同的网络地址 而外部客户端可能需要调用多个服务的接口才能完成一个业务需求 如果让客户端直接与各个微服务通信 会有以下的问题 1 客户端会多次请求不同的微服务 增加了
  • SpringCloud——网关Gateway

    文章目录 六 统一网关 Gateway 6 1 网关介绍 6 2 快速搭建网关 6 3 断言工厂 6 4 过滤器工厂 6 5 全局过滤器 GlobalFIlter 6 6 过滤器的执行顺序 6 7 跨域问题 六 统一网关 Gateway 6
  • Sentinel + Gateway网关动态限流

    Sentinel 控制台 0 概述 Sentinel 控制台是流量控制 熔断降级规则统一配置和管理的入口 它为用户提供了机器自发现 簇点链路自发现 监控 规则配置等功能 在 Sentinel 控制台上 我们可以配置规则并实时查看流量控制效果
  • activiti学习之服务任务

    写在前面 对于工作流 我们使用最多的是用户任务节点 用户任务节点就是给用户来生成任务的 需要人来手动的处理 而与之对应的还有服务任务节点 这种类型的节点需要人手动的参与而是程序来执行 即执行某个类的某个方法 这个类一般是org activi
  • 微服务网关 —— SpringCloud Gateway

    Gateway 简介 Spring Cloud Gateway 基于 Spring 5 Spring Boot 2 和 Project Reactor 等技术 是在 Spring 生态系统之上构建的 API 网关服务 Gateway 旨在提
  • SpringCloud——GateWay网关(详解+案例)

    目录 一 相关概念 1 网关概念 2 网关作用 3 网关架构图 4 网关三大核心 二 案例 1 案例说明 2 搭建GateWay网关9527服务 1 创建maven工程 2 导入依赖 3 配置application yml文件 4 创建主启
  • 系列十、Spring Cloud Gateway

    一 Spring Cloud Gateway 1 1 概述 Spring Cloud全家桶中有个很重要的组件就是网关 在1 x版本中采用的是Zuul网关 但是在2 x版本中 由于Zuul的升级一直跳票 Spring Cloud最后自己研发了
  • 使用 ECS 时保护来自 EC2 实例的出站流量规则

    即使我在私有子网中创建 EC2 实例 如果我想将它们注册到 ECS 集群 它们也必须能够将流量发送到 Internet 我正在使用 NAT 网关来执行此操作 但我仍然感到不安全 因为实例可以在被接管时将私人信息发送到任何地方 我可以用于实例
  • 关于加拿大短信网关提供商的建议[关闭]

    Closed 这个问题是无关 help closed questions 目前不接受答案 我很好奇 如果我能够接受传入的短信到某个号码 然后将其传递给 PHP 中的服务器端应用程序 会带来多少麻烦 金钱 我最终会通过电子邮件地址发回短信 有

随机推荐

  • 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 网关路由的流程图 断言工厂 过滤器工厂 路由过