（转）SpringCloud之服务网关Gateway

zoukankan html css js c++ java

（转）SpringCloud之服务网关Gateway
原文网址 https://blog.csdn.net/qq_41402200/article/details/94333830

前言

SpringCloud 是微服务中的翘楚，最佳的落地方案。

Spring Cloud Gateway 是 Spring Cloud 新推出的网关框架，之前是 Netflix Zuul。网关通常在项目中为了简化

前端的调用逻辑，同时也简化内部服务之间互相调用的复杂度；具体作用就是转发服务，接收并转发所有内外

部的客户端调用；其他常见的功能还有权限认证，限流控制等等。

本博客会提到网关的基本转发功能，熔断功能，限流功能以及功能的综合使用。

源码

GitHub地址：https://github.com/intomylife/SpringCloud

环境
- JDK 1.8.0 +
- Maven 3.0 +
- SpringBoot 2.0.3
- SpringCloud Finchley.RELEASE
- Redis 3.0 +
开发工具
- IntelliJ IDEA
正文

 commons 工程

 commons 工程 - POM 文件
<?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>com.zwc</groupId> <artifactId>springcloud-gateway-commons</artifactId> <version>1.0</version>  <name>springcloud-gateway-commons</name> <description>公用工程</description>  <packaging>jar</packaging>  <properties>  <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>  <java.version>1.8</java.version>  <platform-bom.version>Cairo-SR3</platform-bom.version>  <spring-cloud-dependencies.version>Finchley.RELEASE</spring-cloud-dependencies.version> </properties>  <dependencies> </dependencies>     <dependencyManagement> <dependencies>  <dependency> <groupId>io.spring.platform</groupId> <artifactId>platform-bom</artifactId> <version>${platform-bom.version}</version> <type>pom</type> <scope>import</scope> </dependency>  <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>${spring-cloud-dependencies.version}</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement>  <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
- 配置一些共用依赖
commons 工程 - 项目结构

service 工程

① 此工程下有四个模块：一个注册中心，一个网关以及两个提供者

② 两个提供者除端口不一致以外，其他代码基本一致

 registry-service（注册中心）

registry-service - POM 文件
<?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>  <parent> <groupId>com.zwc</groupId> <artifactId>springcloud-gateway-service</artifactId> <version>1.0</version> </parent>  <groupId>com.zwc</groupId> <artifactId>springcloud-gateway-registry-service</artifactId> <version>1.0</version>  <name>springcloud-gateway-registry-service</name> <description>注册中心</description>  <packaging>jar</packaging>  <properties> </properties>  <dependencies>  <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId> </dependency> </dependencies>  <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
- 主要加入 spring-cloud-starter-netflix-eureka-server 依赖
registry-service - application.yml 配置文件
# 端口 server: port: 8761 # 应用名称 spring: application: name: eureka-server eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: # 是否向注册中心注册自己 registerWithEureka: false # 是否向注册中心获取注册信息 fetchRegistry: false serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
- 这里使用了默认的 8761 端口，当然也可以更改，不过在发现调用服务端的注册中心地址端口要与它一致
registry-service - 启动类
package com.zwc; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer; @SpringBootApplication @EnableEurekaServer public class SpringcloudGatewayRegistryServiceApplication { public static void main(String[] args) { SpringApplication.run(SpringcloudGatewayRegistryServiceApplication.class, args); } }
在启动类中添加 @EnableEurekaServer 注解表示此工程是注册中心

registry-service - 启动项目

1. 项目启动成功后访问 http://localhost:8761/ 即可看到 eureka-server 主页面

注：由于服务工程 A 和服务工程 B 除端口不一致以外，其他代码基本一致，所以服务工程 B 不再赘述

a-service（服务工程 A）

a-service - POM 文件
<?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>  <parent> <groupId>com.zwc</groupId> <artifactId>springcloud-gateway-a-service</artifactId> <version>1.0</version> </parent>  <groupId>com.zwc</groupId> <artifactId>springcloud-gateway-a-service-core</artifactId> <version>1.0</version>  <name>springcloud-gateway-a-service-core</name> <description>服务工程 - A 核心</description>  <packaging>jar</packaging>  <properties> </properties>  <dependencies>  <dependency> <groupId>com.zwc</groupId> <artifactId>springcloud-gateway-commons</artifactId> <version>1.0</version> </dependency>  <dependency> <groupId>com.zwc</groupId> <artifactId>springcloud-gateway-a-service-api</artifactId> <version>1.0</version> </dependency>  <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency>  <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency> </dependencies>  <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
- 加入 spring-cloud-starter-netflix-eureka-client 依赖
a-service - application.yml 配置文件
# 端口 server: port: 9000 # 应用名称 spring: application: name: gateway-service eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/
- 注意此处配置注册中心地址的端口为 8761 也就是上面注册中心工程配置的端口
a-service - controller 前端控制器（提供服务）
package com.zwc.a.controller; import org.springframework.beans.factory.annotation.Value; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; /* * @ClassName ASayHelloController * @Desc TODO Say Hello * @Date 2019/5/20 23:24 * @Version 1.0 */ @RestController public class ASayHelloController { /* * @ClassName ASayHelloController * @Desc TODO 读取配置文件中的端口 * @Date 2019/5/20 23:24 * @Version 1.0 */ @Value("${server.port}") private String port; /* * @ClassName ASayHelloController * @Desc TODO Say Hello * @Date 2019/5/20 23:24 * @Version 1.0 */ @RequestMapping("/hello") public String hello(){ return "Hello！I'm a. port：" + port; } /* * @ClassName ASayHelloController * @Desc TODO 接收从网关传入的参数 * @Date 2019/6/23 16:28 * @Version 1.0 */ @RequestMapping("/name") public String name(String name){ return "My name is " + name + ". aaa"; } /* * @ClassName ASayHelloController * @Desc TODO 接收从网关传入的参数 * @Date 2019/6/23 16:52 * @Version 1.0 */ @RequestMapping("/age") public String age(String age){ return "I am " + age + " years old this year. aaa"; } /* * @ClassName ASayHelloController * @Desc TODO 接收从网关传入的参数 * @Date 2019/6/29 22:00 * @Version 1.0 */ @RequestMapping("/routeAll") public String routeAll(String pass) { return "Can I pass? " + pass + "! port：" + port; } }
- 提供输出字符串服务，供网关调用
a-service - 启动类
package com.zwc; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.EnableEurekaClient; @SpringBootApplication @EnableEurekaClient public class SpringcloudGatewayAServiceCoreApplication { public static void main(String[] args) { SpringApplication.run(SpringcloudGatewayAServiceCoreApplication.class, args); } }
添加 @EnableEurekaClient 注解表示此工程可以向注册中心提供服务

a-service - 启动项目

1. 刷新 http://localhost:8761/（注册中心）可以看到服务已经被注册进来了

2. 项目启动成功后访问：http://localhost:9000/hello

3. 输出内容：'Hello！I'm a. port：9000'

4. 同样启动服务工程 B后，刷新 http://localhost:8761/（注册中心）

5. 项目启动成功后访问：http://localhost:9001/hello

6. 输出内容：'Hello！I'm b. port：9001'

7. 其他接口是下面网关服务启动后转发调用的，也是本博客的重头戏

master-service（网关）

master-service - POM 文件
<?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>  <parent> <groupId>com.zwc</groupId> <artifactId>springcloud-gateway-service</artifactId> <version>1.0</version> </parent>  <groupId>com.zwc</groupId> <artifactId>springcloud-gateway-master-service</artifactId> <version>1.0</version>  <name>springcloud-gateway-master-service</name> <description>Spring Cloud Gateway 服务网关</description>  <packaging>jar</packaging>  <properties>  <fastjson.version>1.2.47</fastjson.version> </properties>  <dependencies>  <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-gateway</artifactId> </dependency>  <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis-reactive</artifactId> </dependency>  <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-hystrix</artifactId> </dependency>  <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>${fastjson.version}</version> </dependency> </dependencies>  <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
- 加入 spring-cloud-starter-netflix-eureka-client 依赖：提供和注册服务
- 加入 spring-cloud-starter-gateway 依赖：gateway
- 加入 spring-boot-starter-data-redis-reactive 依赖：结合 Redis 限流
- 加入 spring-cloud-starter-netflix-hystrix 依赖：熔断器
master-service - application.yml 配置文件
# 端口 server: port: 8000 spring: profiles: # 指定配置 # route_simple：简单尝试 # route_stripPrefix：截取请求 # route_uri：转发指定地址并传入参数 # route_addRequestParameter：转发指定服务并传入参数 # route_hystrix：熔断 # route_requestRateLimiter：限流 # route_all：综合 active: route_simple --- spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 简单尝试 profiles: route_simple application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）简单尝试 - id: route_simple # 目标服务地址（uri：地址，请求转发后的地址） uri: https://www.zouwencong.com # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 转发地址格式为 uri/archive - Path=/archive eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug --- spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 截取请求 profiles: route_stripPrefix application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）截取请求 - id: route_simple # 目标服务地址（uri：地址，请求转发后的地址） uri: https://www.zouwencong.com # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 转发地址格式为 uri/archive，/str 部分会被下面的过滤器给截取掉 - Path=/str/archive filters: ## 截取路径位数 - StripPrefix=1 eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug --- spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 转发指定地址并传入参数 profiles: route_uri application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）转发指定地址并传入参数 - id: route_uri # 目标服务地址（uri：地址，请求转发后的地址） uri: http://localhost:9000 # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 匹配 GET 请求 - Method=GET # 过滤器（filters：过滤器，过滤规则） filters: ## 添加指定参数 - AddRequestParameter=name, zwc eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug --- spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 转发指定服务并传入参数 profiles: route_addRequestParameter application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）转发指定服务并传入参数 - id: route_addRequestParameter # 目标服务地址（uri：地址，请求转发后的地址） uri: lb://gateway-service # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 匹配 GET 请求 - Method=GET # 过滤器（filters：过滤器，过滤规则） filters: ## 添加指定参数 - AddRequestParameter=age, three eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug --- spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 熔断 profiles: route_hystrix application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）熔断 - id: route_hystrix # 目标服务地址（uri：地址，请求转发后的地址） uri: lb://gateway-service # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 匹配 GET 请求 - Method=GET # 过滤器（filters：过滤器，过滤规则） filters: ## 添加指定参数 - AddRequestParameter=age, three ## 熔断 - name: Hystrix args: name: fallbackcmd ### fallback 时调用的方法 http://localhost:8000/fallback fallbackUri: forward:/fallback eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug --- spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 限流 profiles: route_requestRateLimiter redis: host: localhost port: 6379 database: 0 application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）限流 - id: route_requestRateLimiter # 目标服务地址（uri：地址，请求转发后的地址） uri: lb://gateway-service # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 匹配 GET 请求 - Method=GET # 过滤器（filters：过滤器，过滤规则） filters: ## 添加指定参数 - AddRequestParameter=age, three ## 限流 - name: RequestRateLimiter args: ### 限流过滤器的 Bean 名称 key-resolver: '#{@uriKeyResolver}' ### 希望允许用户每秒处理多少个请求 redis-rate-limiter.replenishRate: 1 ### 用户允许在一秒钟内完成的最大请求数 redis-rate-limiter.burstCapacity: 3 eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug --- spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 综合 profiles: route_all redis: host: localhost port: 6379 database: 0 application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）综合 - id: route_all # 目标服务地址（uri：地址，请求转发后的地址） uri: lb://gateway-service # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 转发地址格式为 uri/routeAll，/all 部分会被下面的过滤器给截取掉 - Path=/all/routeAll ## 匹配 GET 请求 - Method=GET # 过滤器（filters：过滤器，过滤规则） filters: ## 截取路径位数 - StripPrefix=1 ## 添加指定参数 - AddRequestParameter=pass, yes ## 熔断 - name: Hystrix args: name: fallbackcmd ### fallback 时调用的方法 http://localhost:8000/fallback fallbackUri: forward:/fallback ## 限流 - name: RequestRateLimiter args: ### 限流过滤器的 Bean 名称 key-resolver: '#{@uriKeyResolver}' ### 希望允许用户每秒处理多少个请求 redis-rate-limiter.replenishRate: 1 ### 用户允许在一秒钟内完成的最大请求数 redis-rate-limiter.burstCapacity: 3 eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug
- 注意配置注册中心地址的端口都为 8761 也就是上面注册中心工程配置的端口
- 每一对 '---' 符号中的配置文件都是单独的，使用 spring.profiles.active 指定
- 每一对 '---' 符号中的配置文件都只配置了一个 route（路由）
- route（路由）由四部分组成，其中 filters 不是必须参数
- 唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）
master-service - 简单尝试
spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 简单尝试 profiles: route_simple application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）简单尝试 - id: route_simple # 目标服务地址（uri：地址，请求转发后的地址） uri: https://www.zouwencong.com # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 转发地址格式为 uri/archive - Path=/archive
1. 停止注册中心工程（registry-service）、服务工程 A 和服务工程 B

2. 把 master-service - application.yml 配置文件中最上面的 spring.profiles.active 的值更改为 route_simple

3. 上面配置文件内容意思是当访问 http://localhost:8000/archive （网关地址/archive）

会被转发到 https://www.zouwencong.com/archive/ （uri/archive）

4. 启动注册中心工程（registry-service）和网关工程（master-service）

5. 项目启动成功后访问：http://localhost:8000/archive

6. 发现页面会自动被跳转到：https://www.zouwencong.com/archive/

7. 证明服务转发成功

master-service - 截取请求
spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 截取请求 profiles: route_stripPrefix application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）截取请求 - id: route_simple # 目标服务地址（uri：地址，请求转发后的地址） uri: https://www.zouwencong.com # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 转发地址格式为 uri/archive，/str 部分会被下面的过滤器给截取掉 - Path=/str/archive filters: ## 截取路径位数 - StripPrefix=1 eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug
1. 停止注册中心工程（registry-service）和网关工程（master-service）

2. 把 master-service - application.yml 配置文件中最上面的 spring.profiles.active 的值更改为 route_stripPrefix

3. 上面配置文件内容意思是访问的路径 http://localhost:8000/str/archive （网关地址/str/archive）截取 /str 部分，

截取后被转发到 https://www.zouwencong.com/archive/ （uri/archive）

4. 启动注册中心工程（registry-service）和网关工程（master-service）

5. 项目启动成功后访问：http://localhost:8000/str/archive

6. 发现页面会自动被跳转到：https://www.zouwencong.com/archive/

7. 证明路径被截取并服务转发成功

master-service - 转发指定地址并传入参数
spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 转发指定地址并传入参数 profiles: route_uri application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）转发指定地址并传入参数 - id: route_uri # 目标服务地址（uri：地址，请求转发后的地址） uri: http://localhost:9000 # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 匹配 GET 请求 - Method=GET # 过滤器（filters：过滤器，过滤规则） filters: ## 添加指定参数 - AddRequestParameter=name, zwc eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug
1. 停止注册中心工程（registry-service）和网关工程（master-service）

2. 把 master-service - application.yml 配置文件中最上面的 spring.profiles.active 的值更改为 route_uri

3. 上面配置文件内容意思是访问的路径 http://localhost:8000/name （网关地址/name）

会被转发到 http://localhost:9000/name（uri/name），并传入 'name=zwc' 参数（注意为 Get 请求）

4. 启动注册中心工程（registry-service）,网关工程（master-service）和服务工程 A（a-service）

5. 项目启动成功后访问：http://localhost:8000/name

6. 输出内容：'My name is zwc. aaa'（通过网关转发的参数有值）

7. 打开新页面访问：http://localhost:9000/name

8. 输出内容：'My name is null. aaa'（问的直接访参数没有值）

9. 证明转发指定地址并传入参数成功

master-service - 转发指定服务并传入参数
spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 转发指定服务并传入参数 profiles: route_addRequestParameter application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）转发指定服务并传入参数 - id: route_addRequestParameter # 目标服务地址（uri：地址，请求转发后的地址） uri: lb://gateway-service # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 匹配 GET 请求 - Method=GET # 过滤器（filters：过滤器，过滤规则） filters: ## 添加指定参数 - AddRequestParameter=age, three eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug
1. 停止注册中心工程（registry-service），网关工程（master-service）和服务工程 A（a-service）

2. 把 master-service - application.yml 配置文件中最上面的 spring.profiles.active 的值

更改为 route_addRequestParameter

3. 上面配置文件内容意思是访问的路径 http://localhost:8000/age （网关地址/age）

会被转发到 http://gateway-service/age（uri/age），并传入 'age=three' 参数（注意为 Get 请求）

4. 注意此处的配置 uri: lb://gateway-service 与之前都有所不同，之前都是指定了明确的转发地址，可以满足

单个服务转发的需求，但是一般情况都会有多个服务，所以这里是指定的服务名称，格式为：lb://应用注册

服务名。

5. 启动注册中心工程（registry-service）,网关工程（master-service）和服务工程 A/B（a-service、b-service）

6. 项目启动成功后访问：http://localhost:8000/age

7. 这时可能会报错 500.错误信息为 'Unable to find instance for gateway-service'

8. 这种情况不要慌张，只是服务还没有被注册到注册中心，稍等片刻再访问

9. 多次访问：http://localhost:8000/age

10. 轮流输出内容：'I am three years old this year. aaa' 和 'I am three years old this year. bbb'

11. 此时还通过网关达到了负载均衡的效果

12. 证明转发指定服务并传入参数成功

master-service - 熔断
spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 熔断 profiles: route_hystrix application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）熔断 - id: route_hystrix # 目标服务地址（uri：地址，请求转发后的地址） uri: lb://gateway-service # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 匹配 GET 请求 - Method=GET # 过滤器（filters：过滤器，过滤规则） filters: ## 添加指定参数 - AddRequestParameter=age, three ## 熔断 - name: Hystrix args: name: fallbackcmd ### fallback 时调用的方法 http://localhost:8000/fallback fallbackUri: forward:/fallback eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug
1. 停止注册中心工程（registry-service），网关工程（master-service）和服务工程 A/B（a-service、b-service）

2. 把 master-service - application.yml 配置文件中最上面的 spring.profiles.active 的值更改为 route_hystrix

3. 上面配置文件内容意思是访问的路径 http://localhost:8000/age （网关地址/age）

会被转发到 http://gateway-service/age（uri/age），并传入 'age=three' 参数（注意为 Get 请求）

4. 注意此处的配置 uri: lb://gateway-service 与之前都有所不同，之前都是指定了明确的转发地址，可以满足

单个服务转发的需求，但是一般情况都会有多个服务，所以这里是指定的服务名称，格式为：lb://应用注册

服务名。

5. 此处还多配置了一个过滤器 '- name: Hystrix'（熔断）

6. 当请求服务出错时，会调用 fallback，路径为：http://localhost:8000/fallback （网关地址/fallback）

7. 此时就需要如下前端控制器

master-service - 熔断 - controller
package com.zwc.gateway.hystrix; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; /** * @ClassName FallbackController * @Desc TODO 网关断路器 * @Date 2019/6/23 19:33 * @Version 1.0 */ @RestController public class FallbackController { /* * @ClassName FallbackController * @Desc TODO 网关断路器 * @Date 2019/6/23 19:35 * @Version 1.0 */ @RequestMapping("/fallback") public String fallback() { return "I'm Spring Cloud Gateway fallback."; } }
　　7. 启动注册中心工程（registry-service）,网关工程（master-service）和服务工程 A/B（a-service、b-service）

8. 项目启动成功后访问：http://localhost:8000/age

9. 输出内容：'I'm Spring Cloud Gateway fallback.'

10. 证明熔断成功
spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 限流 profiles: route_requestRateLimiter redis: host: localhost port: 6379 database: 0 application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）限流 - id: route_requestRateLimiter # 目标服务地址（uri：地址，请求转发后的地址） uri: lb://gateway-service # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 匹配 GET 请求 - Method=GET # 过滤器（filters：过滤器，过滤规则） filters: ## 添加指定参数 - AddRequestParameter=age, three ## 限流 - name: RequestRateLimiter args: ### 限流过滤器的 Bean 名称 key-resolver: '#{@uriKeyResolver}' ### 希望允许用户每秒处理多少个请求 redis-rate-limiter.replenishRate: 1 ### 用户允许在一秒钟内完成的最大请求数 redis-rate-limiter.burstCapacity: 3 eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug
1. 停止注册中心工程（registry-service），网关工程（master-service）和服务工程 A/B（a-service、b-service）

2. 把 master-service - application.yml 配置文件中最上面的 spring.profiles.active 的值

更改为 route_requestRateLimiter

3. 上面配置文件内容意思是访问的路径 http://localhost:8000/age （网关地址/age）

会被转发到 http://gateway-service/age（uri/age），并传入 'age=three' 参数（注意为 Get 请求）

4. 注意此处还需要配置 redis 的连接信息

5. 注意此处是结合 redis 实现的限流，所以 filter 过滤器的 name 必须为 RequestRateLimiter

6. 并且通过实现 KeyResolver 类来自定义限流策略，如下

master-service - 限流 - 策略
package com.zwc.gateway.config.filters; import org.springframework.cloud.gateway.filter.ratelimit.KeyResolver; import org.springframework.web.server.ServerWebExchange; import reactor.core.publisher.Mono; /** * @ClassName UriKeyResolver * @Desc TODO Spring Cloud Gateway 网关限流过滤器 * @Date 2019/6/23 17:59 * @Version 1.0 */ public class UriKeyResolver implements KeyResolver { /* * @ClassName UriKeyResolver * @Desc TODO 根据请求的 uri 限流 * @Date 2019/6/29 17:25 * @Version 1.0 */ @Override public Mono<String> resolve(ServerWebExchange exchange) { return Mono.just(exchange.getRequest().getURI().getPath()); } }
7. 启动本地 redis（redis-server.exe）服务

8. 启动注册中心工程（registry-service）,网关工程（master-service）和服务工程 A/B（a-service、b-service）

9. 项目启动成功后访问：http://localhost:8000/age

9. 此时限流却无论如何都不生效，原因有如下两点

① redis-server 版本过低！我 Windows 本地是 redis-2.4.2 版本的，要用 3 以上的版本！！！

② 数据在 redis 中存储的时间只有几秒，所以得使用 monitor 指令来动态的观察！！！

10. 打开 redis-cli.exe，输入命令 monitor

11. 快速刷新地址：http://localhost:8000/age

12. 页面上会出现 429，redis-cli.exe 中会出现很多数据交互（request_rate_limiter.xxx 开头的 key）

13. 证明限流成功

master-service - 综合
spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 综合 profiles: route_all redis: host: localhost port: 6379 database: 0 application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）综合 - id: route_all # 目标服务地址（uri：地址，请求转发后的地址） uri: lb://gateway-service # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 转发地址格式为 uri/routeAll，/all 部分会被下面的过滤器给截取掉 - Path=/all/routeAll ## 匹配 GET 请求 - Method=GET # 过滤器（filters：过滤器，过滤规则） filters: ## 截取路径位数 - StripPrefix=1 ## 添加指定参数 - AddRequestParameter=pass, yes ## 熔断 - name: Hystrix args: name: fallbackcmd ### fallback 时调用的方法 http://localhost:8000/fallback fallbackUri: forward:/fallback ## 限流 - name: RequestRateLimiter args: ### 限流过滤器的 Bean 名称 key-resolver: '#{@uriKeyResolver}' ### 希望允许用户每秒处理多少个请求 redis-rate-limiter.replenishRate: 1 ### 用户允许在一秒钟内完成的最大请求数 redis-rate-limiter.burstCapacity: 3 eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug
1. 停止注册中心工程（registry-service），网关工程（master-service）和服务工程 A/B（a-service、b-service）

2. 把 master-service - application.yml 配置文件中最上面的 spring.profiles.active 的值更改为 route_all

3. 上面配置文件内容意思是访问的路径 http://localhost:8000/all/routeAll （网关地址/all/routeAll）截取 /all 部分，

会被转发到 http://gateway-service/routeAll（uri/routeAll），并传入 'pass=yes' 参数（注意为 Get 请求）

4. 启动注册中心工程（registry-service）,网关工程（master-service）和服务工程 A/B（a-service、b-service）

5. 项目启动成功后访问：http://localhost:8000/all/routeAll

6. 首先会返回 'I'm Spring Cloud Gateway fallback.'，因为服务还未被注册到注册中心

7. 然后会返回 '{"msg":"缺少凭证","code":-1}'，因为配置了全局过滤器，如下
package com.zwc.gateway.config.filters; import com.alibaba.fastjson.JSONObject; 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.http.server.reactive.ServerHttpResponse; import org.springframework.web.server.ServerWebExchange; import reactor.core.publisher.Mono; import org.springframework.core.io.buffer.DataBuffer; import java.net.InetSocketAddress; import java.nio.charset.StandardCharsets; /** * @ClassName TokenFilter * @Desc TODO 请求认证过滤器 * @Date 2019/6/29 17:49 * @Version 1.0 */ public class TokenFilter implements GlobalFilter{ @Override public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) { // 请求对象 ServerHttpRequest request = exchange.getRequest(); // 响应对象 ServerHttpResponse response = exchange.getResponse(); // 只有综合路由才添加这个全局过滤器（routesId：route_all） // 如果请求路径中不存在 routeAll 字符串 if(request.getURI().toString().indexOf("routeAll") == -1){ System.out.println("filter -> return"); // 直接跳出 return chain.filter(exchange); } // 从请求中获取 token 参数 String token = exchange.getRequest().getQueryParams().getFirst("token"); // 如果为空，那么将返回 401 if (token == null || token.isEmpty()) { // 响应消息内容对象 JSONObject message = new JSONObject(); // 响应状态 message.put("code", -1); // 响应内容 message.put("msg", "缺少凭证"); // 转换响应消息内容对象为字节 byte[] bits = message.toJSONString().getBytes(StandardCharsets.UTF_8); DataBuffer buffer = response.bufferFactory().wrap(bits); // 设置响应对象状态码 401 response.setStatusCode(HttpStatus.UNAUTHORIZED); // 设置响应对象内容并且指定编码，否则在浏览器中会中文乱码 response.getHeaders().add("Content-Type", "text/plain;charset=UTF-8"); // 返回响应对象 return response.writeWith(Mono.just(buffer)); } // 获取请求地址 String beforePath = request.getPath().pathWithinApplication().value(); // 获取响应状态码 HttpStatus beforeStatusCode = response.getStatusCode(); System.out.println("响应码：" + beforeStatusCode + "，请求路径：" + beforePath); // 请求前 System.out.println("filter -> before"); // 如果不为空，就通过 return chain.filter(exchange).then(Mono.fromRunnable(() -> { // 获取请求地址 String afterPath = request.getPath().pathWithinApplication().value(); // 获取响应状态码 HttpStatus afterStatusCode = response.getStatusCode(); System.out.println("响应码：" + afterStatusCode + "，请求路径：" + afterPath); // 响应后 System.out.println("filter -> after"); })); } }
8. 全局过滤器，不需要配置在配置文件中，作用于所有路由；只是这里在处理前做了判断，只有路径中存在

routeAll 字符串才到后续处理；并且处理分为请求前的处理，和响应后的处理

9. 此时在地址：http://localhost:8000/all/routeAll 中添加 token 参数

10. 访问：http://localhost:8000/all/routeAll?token=123

11. 轮流输出内容：'Can I pass? yes! port：9000' 和 'Can I pass? yes! port：9001'

12. 观察 gateway 工程的控制台，会有如下内容输出
响应码：null，请求路径：/routeAll filter -> before 响应码：200，请求路径：/routeAll filter -> after
13. 证明全局过滤器过滤成功

service 工程 - 项目结构

把多工程项目使用 IntelliJ IDEA 打开
- 把项目从 GitHub 中下载到你的本地
- 打开 IntelliJ IDEA
- 点击 File -> Open
- 打开你下载到本地的项目目录
- springcloud-gateway -> springcloud-gateway-service（选择打开此工程）
- 打开 service 工程后
- 再次点击 File -> Project Structrue
- 选择 Modules，点击 '+' 符号
- 点击 Import Module
- 还是打开你下载到本地的项目目录
- springcloud-gateway -> springcloud-gateway-commons -> pom.xml
- 点击 OK
- 点击 Next，Finish
- 点击 Apply，OK
————————————————

版权声明：本文为CSDN博主「intomylife」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。

原文链接：https://blog.csdn.net/qq_41402200/article/details/94333830

————————————————

版权声明：本文为CSDN博主「intomylife」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。

原文链接：https://blog.csdn.net/qq_41402200/article/details/94333830

————————————————

版权声明：本文为CSDN博主「intomylife」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。

原文链接：https://blog.csdn.net/qq_41402200/article/details/94333830

————————————————

版权声明：本文为CSDN博主「intomylife」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。

原文链接：https://blog.csdn.net/qq_41402200/article/details/94333830

————————————————

版权声明：本文为CSDN博主「intomylife」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。

原文链接：https://blog.csdn.net/qq_41402200/article/details/94333830

master-service - 限流（重点，解决不生效问题）

————————————————

版权声明：本文为CSDN博主「intomylife」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。

原文链接：https://blog.csdn.net/qq_41402200/article/details/94333830

————————————————

版权声明：本文为CSDN博主「intomylife」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。

原文链接：https://blog.csdn.net/qq_41402200/article/details/94333830

————————————————

版权声明：本文为CSDN博主「intomylife」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。

原文链接：https://blog.csdn.net/qq_41402200/article/details/94333830

————————————————

版权声明：本文为CSDN博主「intomylife」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。

原文链接：https://blog.csdn.net/qq_41402200/article/details/94333830

————————————————

版权声明：本文为CSDN博主「intomylife」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。

原文链接：https://blog.csdn.net/qq_41402200/article/details/94333830

————————————————

版权声明：本文为CSDN博主「intomylife」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。

原文链接：https://blog.csdn.net/qq_41402200/article/details/94333830

————————————————

版权声明：本文为CSDN博主「intomylife」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。

原文链接：https://blog.csdn.net/qq_41402200/article/details/94333830

————————————————

版权声明：本文为CSDN博主「intomylife」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。

原文链接：https://blog.csdn.net/qq_41402200/article/details/94333830

————————————————

版权声明：本文为CSDN博主「intomylife」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。

原文链接：https://blog.csdn.net/qq_41402200/article/details/94333830

————————————————
版权声明：本文为CSDN博主「intomylife」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。
原文链接：https://blog.csdn.net/qq_41402200/article/details/94333830

开发工具IntelliJ IDEA正文commons 工程commons 工程 - POM 文件<?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>com.zwc</groupId> <artifactId>springcloud-gateway-commons</artifactId> <version>1.0</version>    <name>springcloud-gateway-commons</name> <description>公用工程</description>    <packaging>jar</packaging>    <properties>  <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>  <java.version>1.8</java.version>    <platform-bom.version>Cairo-SR3</platform-bom.version>    <spring-cloud-dependencies.version>Finchley.RELEASE</spring-cloud-dependencies.version> </properties>    <dependencies>   </dependencies>       <dependencyManagement> <dependencies>  <dependency> <groupId>io.spring.platform</groupId> <artifactId>platform-bom</artifactId> <version>${platform-bom.version}</version> <type>pom</type> <scope>import</scope> </dependency>  <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>${spring-cloud-dependencies.version}</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement>    <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>配置一些共用依赖commons 工程 - 项目结构

service 工程 ① 此工程下有四个模块：一个注册中心，一个网关以及两个提供者
② 两个提供者除端口不一致以外，其他代码基本一致

registry-service（注册中心）registry-service - POM 文件<?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>    <parent> <groupId>com.zwc</groupId> <artifactId>springcloud-gateway-service</artifactId> <version>1.0</version> </parent>    <groupId>com.zwc</groupId> <artifactId>springcloud-gateway-registry-service</artifactId> <version>1.0</version>    <name>springcloud-gateway-registry-service</name> <description>注册中心</description>    <packaging>jar</packaging>    <properties>   </properties>    <dependencies>  <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId> </dependency> </dependencies>    <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>主要加入 spring-cloud-starter-netflix-eureka-server 依赖registry-service - application.yml 配置文件# 端口server: port: 8761 # 应用名称spring: application: name: eureka-server eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: # 是否向注册中心注册自己 registerWithEureka: false # 是否向注册中心获取注册信息 fetchRegistry: false serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/这里使用了默认的 8761 端口，当然也可以更改，不过在发现调用服务端的注册中心地址端口要与它一致registry-service - 启动类package com.zwc; import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer; @SpringBootApplication@EnableEurekaServerpublic class SpringcloudGatewayRegistryServiceApplication {   public static void main(String[] args) { SpringApplication.run(SpringcloudGatewayRegistryServiceApplication.class, args); } }在启动类中添加 @EnableEurekaServer 注解表示此工程是注册中心registry-service - 启动项目 1. 项目启动成功后访问 http://localhost:8761/ 即可看到 eureka-server 主页面

注：由于服务工程 A 和服务工程 B 除端口不一致以外，其他代码基本一致，所以服务工程 B 不再赘述
a-service（服务工程 A）a-service - POM 文件<?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>    <parent> <groupId>com.zwc</groupId> <artifactId>springcloud-gateway-a-service</artifactId> <version>1.0</version> </parent>    <groupId>com.zwc</groupId> <artifactId>springcloud-gateway-a-service-core</artifactId> <version>1.0</version>    <name>springcloud-gateway-a-service-core</name> <description>服务工程 - A 核心</description>    <packaging>jar</packaging>    <properties>   </properties>    <dependencies>  <dependency> <groupId>com.zwc</groupId> <artifactId>springcloud-gateway-commons</artifactId> <version>1.0</version> </dependency>    <dependency> <groupId>com.zwc</groupId> <artifactId>springcloud-gateway-a-service-api</artifactId> <version>1.0</version> </dependency>    <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency>    <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency> </dependencies>    <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>加入 spring-cloud-starter-netflix-eureka-client 依赖a-service - application.yml 配置文件# 端口server: port: 9000 # 应用名称spring: application: name: gateway-service eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/注意此处配置注册中心地址的端口为 8761 也就是上面注册中心工程配置的端口a-service - controller 前端控制器（提供服务）package com.zwc.a.controller; import org.springframework.beans.factory.annotation.Value;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController; /* * @ClassName ASayHelloController * @Desc TODO Say Hello * @Date 2019/5/20 23:24 * @Version 1.0 */@RestControllerpublic class ASayHelloController {   /* * @ClassName ASayHelloController * @Desc TODO 读取配置文件中的端口 * @Date 2019/5/20 23:24 * @Version 1.0 */ @Value("${server.port}") private String port;   /* * @ClassName ASayHelloController * @Desc TODO Say Hello * @Date 2019/5/20 23:24 * @Version 1.0 */ @RequestMapping("/hello") public String hello(){ return "Hello！I'm a. port：" + port; }   /* * @ClassName ASayHelloController * @Desc TODO 接收从网关传入的参数 * @Date 2019/6/23 16:28 * @Version 1.0 */ @RequestMapping("/name") public String name(String name){ return "My name is " + name + ". aaa"; }   /* * @ClassName ASayHelloController * @Desc TODO 接收从网关传入的参数 * @Date 2019/6/23 16:52 * @Version 1.0 */ @RequestMapping("/age") public String age(String age){ return "I am " + age + " years old this year. aaa"; }   /* * @ClassName ASayHelloController * @Desc TODO 接收从网关传入的参数 * @Date 2019/6/29 22:00 * @Version 1.0 */ @RequestMapping("/routeAll") public String routeAll(String pass) { return "Can I pass? " + pass + "! port：" + port; } }提供输出字符串服务，供网关调用a-service - 启动类package com.zwc; import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.netflix.eureka.EnableEurekaClient; @SpringBootApplication@EnableEurekaClientpublic class SpringcloudGatewayAServiceCoreApplication {   public static void main(String[] args) { SpringApplication.run(SpringcloudGatewayAServiceCoreApplication.class, args); } }添加 @EnableEurekaClient 注解表示此工程可以向注册中心提供服务a-service - 启动项目 1. 刷新 http://localhost:8761/（注册中心）可以看到服务已经被注册进来了

2. 项目启动成功后访问：http://localhost:9000/hello
3. 输出内容：'Hello！I'm a. port：9000'
4. 同样启动服务工程 B后，刷新 http://localhost:8761/（注册中心）

5. 项目启动成功后访问：http://localhost:9001/hello
6. 输出内容：'Hello！I'm b. port：9001'
7. 其他接口是下面网关服务启动后转发调用的，也是本博客的重头戏

master-service（网关）master-service - POM 文件<?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>    <parent> <groupId>com.zwc</groupId> <artifactId>springcloud-gateway-service</artifactId> <version>1.0</version> </parent>    <groupId>com.zwc</groupId> <artifactId>springcloud-gateway-master-service</artifactId> <version>1.0</version>    <name>springcloud-gateway-master-service</name> <description>Spring Cloud Gateway 服务网关</description>    <packaging>jar</packaging>    <properties>  <fastjson.version>1.2.47</fastjson.version> </properties>    <dependencies>  <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-gateway</artifactId> </dependency>    <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis-reactive</artifactId> </dependency>    <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-hystrix</artifactId> </dependency>    <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>${fastjson.version}</version> </dependency> </dependencies>    <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>加入 spring-cloud-starter-netflix-eureka-client 依赖：提供和注册服务加入 spring-cloud-starter-gateway 依赖：gateway加入 spring-boot-starter-data-redis-reactive 依赖：结合 Redis 限流加入 spring-cloud-starter-netflix-hystrix 依赖：熔断器master-service - application.yml 配置文件# 端口server: port: 8000 spring: profiles: # 指定配置 # route_simple：简单尝试 # route_stripPrefix：截取请求 # route_uri：转发指定地址并传入参数 # route_addRequestParameter：转发指定服务并传入参数 # route_hystrix：熔断 # route_requestRateLimiter：限流 # route_all：综合 active: route_simple --- spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 简单尝试 profiles: route_simple application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）简单尝试 - id: route_simple # 目标服务地址（uri：地址，请求转发后的地址） uri: https://www.zouwencong.com # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 转发地址格式为 uri/archive - Path=/archive eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug --- spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 截取请求 profiles: route_stripPrefix application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）截取请求 - id: route_simple # 目标服务地址（uri：地址，请求转发后的地址） uri: https://www.zouwencong.com # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 转发地址格式为 uri/archive，/str 部分会被下面的过滤器给截取掉 - Path=/str/archive filters: ## 截取路径位数 - StripPrefix=1 eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug --- spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 转发指定地址并传入参数 profiles: route_uri application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）转发指定地址并传入参数 - id: route_uri # 目标服务地址（uri：地址，请求转发后的地址） uri: http://localhost:9000 # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 匹配 GET 请求 - Method=GET # 过滤器（filters：过滤器，过滤规则） filters: ## 添加指定参数 - AddRequestParameter=name, zwc eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug --- spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 转发指定服务并传入参数 profiles: route_addRequestParameter application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）转发指定服务并传入参数 - id: route_addRequestParameter # 目标服务地址（uri：地址，请求转发后的地址） uri: lb://gateway-service # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 匹配 GET 请求 - Method=GET # 过滤器（filters：过滤器，过滤规则） filters: ## 添加指定参数 - AddRequestParameter=age, three eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug --- spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 熔断 profiles: route_hystrix application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）熔断 - id: route_hystrix # 目标服务地址（uri：地址，请求转发后的地址） uri: lb://gateway-service # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 匹配 GET 请求 - Method=GET # 过滤器（filters：过滤器，过滤规则） filters: ## 添加指定参数 - AddRequestParameter=age, three ## 熔断 - name: Hystrix args: name: fallbackcmd ### fallback 时调用的方法 http://localhost:8000/fallback fallbackUri: forward:/fallback eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug --- spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 限流 profiles: route_requestRateLimiter redis: host: localhost port: 6379 database: 0 application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）限流 - id: route_requestRateLimiter # 目标服务地址（uri：地址，请求转发后的地址） uri: lb://gateway-service # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 匹配 GET 请求 - Method=GET # 过滤器（filters：过滤器，过滤规则） filters: ## 添加指定参数 - AddRequestParameter=age, three ## 限流 - name: RequestRateLimiter args: ### 限流过滤器的 Bean 名称 key-resolver: '#{@uriKeyResolver}' ### 希望允许用户每秒处理多少个请求 redis-rate-limiter.replenishRate: 1 ### 用户允许在一秒钟内完成的最大请求数 redis-rate-limiter.burstCapacity: 3 eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug --- spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 综合 profiles: route_all redis: host: localhost port: 6379 database: 0 application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）综合 - id: route_all # 目标服务地址（uri：地址，请求转发后的地址） uri: lb://gateway-service # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 转发地址格式为 uri/routeAll，/all 部分会被下面的过滤器给截取掉 - Path=/all/routeAll ## 匹配 GET 请求 - Method=GET # 过滤器（filters：过滤器，过滤规则） filters: ## 截取路径位数 - StripPrefix=1 ## 添加指定参数 - AddRequestParameter=pass, yes ## 熔断 - name: Hystrix args: name: fallbackcmd ### fallback 时调用的方法 http://localhost:8000/fallback fallbackUri: forward:/fallback ## 限流 - name: RequestRateLimiter args: ### 限流过滤器的 Bean 名称 key-resolver: '#{@uriKeyResolver}' ### 希望允许用户每秒处理多少个请求 redis-rate-limiter.replenishRate: 1 ### 用户允许在一秒钟内完成的最大请求数 redis-rate-limiter.burstCapacity: 3 eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug注意配置注册中心地址的端口都为 8761 也就是上面注册中心工程配置的端口每一对 '---' 符号中的配置文件都是单独的，使用 spring.profiles.active 指定每一对 '---' 符号中的配置文件都只配置了一个 route（路由）route（路由）由四部分组成，其中 filters 不是必须参数唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）
master-service - 简单尝试spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 简单尝试 profiles: route_simple application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）简单尝试 - id: route_simple # 目标服务地址（uri：地址，请求转发后的地址） uri: https://www.zouwencong.com # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 转发地址格式为 uri/archive - Path=/archive 1. 停止注册中心工程（registry-service）、服务工程 A 和服务工程 B
2. 把 master-service - application.yml 配置文件中最上面的 spring.profiles.active 的值更改为 route_simple
3. 上面配置文件内容意思是当访问 http://localhost:8000/archive （网关地址/archive）
会被转发到 https://www.zouwencong.com/archive/ （uri/archive）
4. 启动注册中心工程（registry-service）和网关工程（master-service）
5. 项目启动成功后访问：http://localhost:8000/archive
6. 发现页面会自动被跳转到：https://www.zouwencong.com/archive/
7. 证明服务转发成功

master-service - 截取请求spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 截取请求 profiles: route_stripPrefix application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）截取请求 - id: route_simple # 目标服务地址（uri：地址，请求转发后的地址） uri: https://www.zouwencong.com # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 转发地址格式为 uri/archive，/str 部分会被下面的过滤器给截取掉 - Path=/str/archive filters: ## 截取路径位数 - StripPrefix=1 eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug 1. 停止注册中心工程（registry-service）和网关工程（master-service）
2. 把 master-service - application.yml 配置文件中最上面的 spring.profiles.active 的值更改为 route_stripPrefix
3. 上面配置文件内容意思是访问的路径 http://localhost:8000/str/archive （网关地址/str/archive）截取 /str 部分，
截取后被转发到 https://www.zouwencong.com/archive/ （uri/archive）
4. 启动注册中心工程（registry-service）和网关工程（master-service）
5. 项目启动成功后访问：http://localhost:8000/str/archive
6. 发现页面会自动被跳转到：https://www.zouwencong.com/archive/
7. 证明路径被截取并服务转发成功

master-service - 转发指定地址并传入参数spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 转发指定地址并传入参数 profiles: route_uri application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）转发指定地址并传入参数 - id: route_uri # 目标服务地址（uri：地址，请求转发后的地址） uri: http://localhost:9000 # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 匹配 GET 请求 - Method=GET # 过滤器（filters：过滤器，过滤规则） filters: ## 添加指定参数 - AddRequestParameter=name, zwc eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug 1. 停止注册中心工程（registry-service）和网关工程（master-service）
2. 把 master-service - application.yml 配置文件中最上面的 spring.profiles.active 的值更改为 route_uri
3. 上面配置文件内容意思是访问的路径 http://localhost:8000/name （网关地址/name）
会被转发到 http://localhost:9000/name（uri/name），并传入 'name=zwc' 参数（注意为 Get 请求）
4. 启动注册中心工程（registry-service）,网关工程（master-service）和服务工程 A（a-service）
5. 项目启动成功后访问：http://localhost:8000/name
6. 输出内容：'My name is zwc. aaa'（通过网关转发的参数有值）
7. 打开新页面访问：http://localhost:9000/name
8. 输出内容：'My name is null. aaa'（问的直接访参数没有值）
9. 证明转发指定地址并传入参数成功

master-service - 转发指定服务并传入参数spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 转发指定服务并传入参数 profiles: route_addRequestParameter application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）转发指定服务并传入参数 - id: route_addRequestParameter # 目标服务地址（uri：地址，请求转发后的地址） uri: lb://gateway-service # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 匹配 GET 请求 - Method=GET # 过滤器（filters：过滤器，过滤规则） filters: ## 添加指定参数 - AddRequestParameter=age, three eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug 1. 停止注册中心工程（registry-service），网关工程（master-service）和服务工程 A（a-service）
2. 把 master-service - application.yml 配置文件中最上面的 spring.profiles.active 的值
更改为 route_addRequestParameter
3. 上面配置文件内容意思是访问的路径 http://localhost:8000/age （网关地址/age）
会被转发到 http://gateway-service/age（uri/age），并传入 'age=three' 参数（注意为 Get 请求）
4. 注意此处的配置 uri: lb://gateway-service 与之前都有所不同，之前都是指定了明确的转发地址，可以满足
单个服务转发的需求，但是一般情况都会有多个服务，所以这里是指定的服务名称，格式为：lb://应用注册
服务名。
5. 启动注册中心工程（registry-service）,网关工程（master-service）和服务工程 A/B（a-service、b-service）
6. 项目启动成功后访问：http://localhost:8000/age
7. 这时可能会报错 500.错误信息为 'Unable to find instance for gateway-service'
8. 这种情况不要慌张，只是服务还没有被注册到注册中心，稍等片刻再访问
9. 多次访问：http://localhost:8000/age
10. 轮流输出内容：'I am three years old this year. aaa' 和 'I am three years old this year. bbb'
11. 此时还通过网关达到了负载均衡的效果
12. 证明转发指定服务并传入参数成功

master-service - 熔断spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 熔断 profiles: route_hystrix application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）熔断 - id: route_hystrix # 目标服务地址（uri：地址，请求转发后的地址） uri: lb://gateway-service # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 匹配 GET 请求 - Method=GET # 过滤器（filters：过滤器，过滤规则） filters: ## 添加指定参数 - AddRequestParameter=age, three ## 熔断 - name: Hystrix args: name: fallbackcmd ### fallback 时调用的方法 http://localhost:8000/fallback fallbackUri: forward:/fallback eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug 1. 停止注册中心工程（registry-service），网关工程（master-service）和服务工程 A/B（a-service、b-service）
2. 把 master-service - application.yml 配置文件中最上面的 spring.profiles.active 的值更改为 route_hystrix
3. 上面配置文件内容意思是访问的路径 http://localhost:8000/age （网关地址/age）
会被转发到 http://gateway-service/age（uri/age），并传入 'age=three' 参数（注意为 Get 请求）
4. 注意此处的配置 uri: lb://gateway-service 与之前都有所不同，之前都是指定了明确的转发地址，可以满足
单个服务转发的需求，但是一般情况都会有多个服务，所以这里是指定的服务名称，格式为：lb://应用注册
服务名。
5. 此处还多配置了一个过滤器 '- name: Hystrix'（熔断）
6. 当请求服务出错时，会调用 fallback，路径为：http://localhost:8000/fallback （网关地址/fallback）
7. 此时就需要如下前端控制器
master-service - 熔断 - controllerpackage com.zwc.gateway.hystrix; import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController; /** * @ClassName FallbackController * @Desc TODO 网关断路器 * @Date 2019/6/23 19:33 * @Version 1.0 */@RestControllerpublic class FallbackController {   /* * @ClassName FallbackController * @Desc TODO 网关断路器 * @Date 2019/6/23 19:35 * @Version 1.0 */ @RequestMapping("/fallback") public String fallback() { return "I'm Spring Cloud Gateway fallback."; } } 7. 启动注册中心工程（registry-service）,网关工程（master-service）和服务工程 A/B（a-service、b-service）
8. 项目启动成功后访问：http://localhost:8000/age
9. 输出内容：'I'm Spring Cloud Gateway fallback.'
10. 证明熔断成功

master-service - 限流（重点，解决不生效问题）spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 限流 profiles: route_requestRateLimiter redis: host: localhost port: 6379 database: 0 application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）限流 - id: route_requestRateLimiter # 目标服务地址（uri：地址，请求转发后的地址） uri: lb://gateway-service # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 匹配 GET 请求 - Method=GET # 过滤器（filters：过滤器，过滤规则） filters: ## 添加指定参数 - AddRequestParameter=age, three ## 限流 - name: RequestRateLimiter args: ### 限流过滤器的 Bean 名称 key-resolver: '#{@uriKeyResolver}' ### 希望允许用户每秒处理多少个请求 redis-rate-limiter.replenishRate: 1 ### 用户允许在一秒钟内完成的最大请求数 redis-rate-limiter.burstCapacity: 3 eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug 1. 停止注册中心工程（registry-service），网关工程（master-service）和服务工程 A/B（a-service、b-service）
2. 把 master-service - application.yml 配置文件中最上面的 spring.profiles.active 的值
更改为 route_requestRateLimiter
3. 上面配置文件内容意思是访问的路径 http://localhost:8000/age （网关地址/age）
会被转发到 http://gateway-service/age（uri/age），并传入 'age=three' 参数（注意为 Get 请求）
4. 注意此处还需要配置 redis 的连接信息
5. 注意此处是结合 redis 实现的限流，所以 filter 过滤器的 name 必须为 RequestRateLimiter
6. 并且通过实现 KeyResolver 类来自定义限流策略，如下
master-service - 限流 - 策略package com.zwc.gateway.config.filters; import org.springframework.cloud.gateway.filter.ratelimit.KeyResolver;import org.springframework.web.server.ServerWebExchange;import reactor.core.publisher.Mono; /** * @ClassName UriKeyResolver * @Desc TODO Spring Cloud Gateway 网关限流过滤器 * @Date 2019/6/23 17:59 * @Version 1.0 */public class UriKeyResolver implements KeyResolver {   /* * @ClassName UriKeyResolver * @Desc TODO 根据请求的 uri 限流 * @Date 2019/6/29 17:25 * @Version 1.0 */ @Override public Mono<String> resolve(ServerWebExchange exchange) { return Mono.just(exchange.getRequest().getURI().getPath()); } } 7. 启动本地 redis（redis-server.exe）服务
8. 启动注册中心工程（registry-service）,网关工程（master-service）和服务工程 A/B（a-service、b-service）
9. 项目启动成功后访问：http://localhost:8000/age
9. 此时限流却无论如何都不生效，原因有如下两点
① redis-server 版本过低！我 Windows 本地是 redis-2.4.2 版本的，要用 3 以上的版本！！！
② 数据在 redis 中存储的时间只有几秒，所以得使用 monitor 指令来动态的观察！！！
10. 打开 redis-cli.exe，输入命令 monitor
11. 快速刷新地址：http://localhost:8000/age
12. 页面上会出现 429，redis-cli.exe 中会出现很多数据交互（request_rate_limiter.xxx 开头的 key）
13. 证明限流成功

master-service - 综合spring: # 配置文件名称，用来标识不同环境的配置。由 spring.profiles.active 的值来决定使用哪组配置。 ## 综合 profiles: route_all redis: host: localhost port: 6379 database: 0 application: # 应用名称 name: gateway-master cloud: gateway: discovery: locator: # 是否和服务注册与发现组件结合，设置为 true 后可以直接使用应用名称调用服务 enabled: true # 路由（routes：路由，它由唯一标识（ID）、目标服务地址（uri）、一组断言（predicates）和一组过滤器组成（filters）。filters 不是必需参数。） routes: # 路由标识（id：标识，具有唯一性）综合 - id: route_all # 目标服务地址（uri：地址，请求转发后的地址） uri: lb://gateway-service # 路由条件（predicates：断言，匹配 HTTP 请求内容） predicates: ## 转发地址格式为 uri/routeAll，/all 部分会被下面的过滤器给截取掉 - Path=/all/routeAll ## 匹配 GET 请求 - Method=GET # 过滤器（filters：过滤器，过滤规则） filters: ## 截取路径位数 - StripPrefix=1 ## 添加指定参数 - AddRequestParameter=pass, yes ## 熔断 - name: Hystrix args: name: fallbackcmd ### fallback 时调用的方法 http://localhost:8000/fallback fallbackUri: forward:/fallback ## 限流 - name: RequestRateLimiter args: ### 限流过滤器的 Bean 名称 key-resolver: '#{@uriKeyResolver}' ### 希望允许用户每秒处理多少个请求 redis-rate-limiter.replenishRate: 1 ### 用户允许在一秒钟内完成的最大请求数 redis-rate-limiter.burstCapacity: 3 eureka: instance: # 使用 ip 代替实例名 prefer-ip-address: true # 实例的主机名 hostname: ${spring.cloud.client.ip-address} # 实例的 ID 规则 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注册中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ logging: level: # log 级别 org.springframework.cloud.gateway: debug 1. 停止注册中心工程（registry-service），网关工程（master-service）和服务工程 A/B（a-service、b-service）
2. 把 master-service - application.yml 配置文件中最上面的 spring.profiles.active 的值更改为 route_all
3. 上面配置文件内容意思是访问的路径 http://localhost:8000/all/routeAll （网关地址/all/routeAll）截取 /all 部分，
会被转发到 http://gateway-service/routeAll（uri/routeAll），并传入 'pass=yes' 参数（注意为 Get 请求）
4. 启动注册中心工程（registry-service）,网关工程（master-service）和服务工程 A/B（a-service、b-service）
5. 项目启动成功后访问：http://localhost:8000/all/routeAll
6. 首先会返回 'I'm Spring Cloud Gateway fallback.'，因为服务还未被注册到注册中心
7. 然后会返回 '{"msg":"缺少凭证","code":-1}'，因为配置了全局过滤器，如下
package com.zwc.gateway.config.filters; import com.alibaba.fastjson.JSONObject;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.http.server.reactive.ServerHttpResponse;import org.springframework.web.server.ServerWebExchange;import reactor.core.publisher.Mono;import org.springframework.core.io.buffer.DataBuffer; import java.net.InetSocketAddress;import java.nio.charset.StandardCharsets; /** * @ClassName TokenFilter * @Desc TODO 请求认证过滤器 * @Date 2019/6/29 17:49 * @Version 1.0 */public class TokenFilter implements GlobalFilter{   @Override public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) { // 请求对象 ServerHttpRequest request = exchange.getRequest(); // 响应对象 ServerHttpResponse response = exchange.getResponse();   // 只有综合路由才添加这个全局过滤器（routesId：route_all） // 如果请求路径中不存在 routeAll 字符串 if(request.getURI().toString().indexOf("routeAll") == -1){ System.out.println("filter -> return"); // 直接跳出 return chain.filter(exchange); }   // 从请求中获取 token 参数 String token = exchange.getRequest().getQueryParams().getFirst("token"); // 如果为空，那么将返回 401 if (token == null || token.isEmpty()) {   // 响应消息内容对象 JSONObject message = new JSONObject(); // 响应状态 message.put("code", -1); // 响应内容 message.put("msg", "缺少凭证"); // 转换响应消息内容对象为字节 byte[] bits = message.toJSONString().getBytes(StandardCharsets.UTF_8); DataBuffer buffer = response.bufferFactory().wrap(bits); // 设置响应对象状态码 401 response.setStatusCode(HttpStatus.UNAUTHORIZED); // 设置响应对象内容并且指定编码，否则在浏览器中会中文乱码 response.getHeaders().add("Content-Type", "text/plain;charset=UTF-8"); // 返回响应对象 return response.writeWith(Mono.just(buffer)); } // 获取请求地址 String beforePath = request.getPath().pathWithinApplication().value(); // 获取响应状态码 HttpStatus beforeStatusCode = response.getStatusCode(); System.out.println("响应码：" + beforeStatusCode + "，请求路径：" + beforePath); // 请求前 System.out.println("filter -> before"); // 如果不为空，就通过 return chain.filter(exchange).then(Mono.fromRunnable(() -> { // 获取请求地址 String afterPath = request.getPath().pathWithinApplication().value(); // 获取响应状态码 HttpStatus afterStatusCode = response.getStatusCode(); System.out.println("响应码：" + afterStatusCode + "，请求路径：" + afterPath); // 响应后 System.out.println("filter -> after"); })); } } 8. 全局过滤器，不需要配置在配置文件中，作用于所有路由；只是这里在处理前做了判断，只有路径中存在
routeAll 字符串才到后续处理；并且处理分为请求前的处理，和响应后的处理
9. 此时在地址：http://localhost:8000/all/routeAll 中添加 token 参数
10. 访问：http://localhost:8000/all/routeAll?token=123
11. 轮流输出内容：'Can I pass? yes! port：9000' 和 'Can I pass? yes! port：9001'
12. 观察 gateway 工程的控制台，会有如下内容输出
响应码：null，请求路径：/routeAllfilter -> before响应码：200，请求路径：/routeAllfilter -> after 13. 证明全局过滤器过滤成功

service 工程 - 项目结构

把多工程项目使用 IntelliJ IDEA 打开把项目从 GitHub 中下载到你的本地打开 IntelliJ IDEA 点击 File -> Open打开你下载到本地的项目目录springcloud-gateway -> springcloud-gateway-service（选择打开此工程）打开 service 工程后再次点击 File -> Project Structrue选择 Modules，点击 '+' 符号点击 Import Module还是打开你下载到本地的项目目录springcloud-gateway -> springcloud-gateway-commons -> pom.xml点击 OK点击 Next，Finish点击 Apply，OK

希望能够帮助到你
o————————————————版权声明：本文为CSDN博主「intomylife」的原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接及本声明。原文链接：https://blog.csdn.net/qq_41402200/article/details/94333830
查看全文

相关阅读:
战国时期主张合众联横的两位游士
 解读蓝帆“取势，明道，优术”
云起龙骧
 取势明道优术_百度百科
 曾鸣[长江商学院教授]_互动百科
 E=MC2
罗斯福6号_百度百科
 时尚大帝_百度视频
 群星云集 BOSS上海时装秀—情沪魅影- 在线观看
 林志玲“情沪魅影”时装片展情缘-中新网

原文地址：https://www.cnblogs.com/telwanggs/p/12485784.html

（转）SpringCloud之服务网关Gateway

源码

环境

开发工具

正文

commons 工程

commons 工程 - POM 文件

commons 工程 - 项目结构

service 工程

registry-service（注册中心）

registry-service - POM 文件

registry-service - application.yml 配置文件

registry-service - 启动类

a-service - application.yml 配置文件

a-service - controller 前端控制器（提供服务）

a-service - 启动类