4.1-Gateway-概述

  • 网关旨在为微服务架构提供一种简单而有效的统一的API路由管理方式。
  • 在微服务架构中，不同的微服务可以有不同的网络地址，各个微服务之间通过互相调用完成用户请求，客户端可能通过调用N个微服务的接口完成一个用户请求。
  • 存在的问题： 
  1.     1.客户端多次请求不同的微服务，增加客户端的复杂性
  2.     2.认证复杂，每个服务都要进行认证
  3.     3.http请求不同服务次数增加，性能不高
  • 网关就是系统的入口，封装了应用程序的内部结构，为客户端提供统一服务，一些与业务本身功能无关的公共逻辑可以在这里实现，诸如认证、鉴权、监控、缓存、负载均衡、流量管控、路由转发等
  • 在目前的网关解决方案里，有Nginx+ Lua、Netflix Zuul 、Spring Cloud Gateway等等

1587544847831.png

4.2-Gateway-快速入门

  1. 搭建网关模块
    创建api-gateway-server模块

  2. 引入依赖：starter-gateway 

    1. <dependencies>
    2.     <!--引入gateway 网关-->
    3.     <dependency>
    4.         <groupId>org.springframework.cloud</groupId>
    5.         <artifactId>spring-cloud-starter-gateway</artifactId>
    6.     </dependency>
    7.     <!-- eureka-client -->
    8.     <dependency>
    9.         <groupId>org.springframework.cloud</groupId>
    10.         <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    11.     </dependency>
    12. </dependencies>

  3. 编写启动类
    ```java package com.itheima.gateway;

import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

@SpringBootApplication @EnableEurekaClient public class ApiGatewayApp {

  1. public static void main(String[] args) {
  2.     SpringApplication.run(ApiGatewayApp.class,args);
  3. }

}

  2. 4.  编写配置文件<br />application.yml  
  3. ```yml
  4. server:
  5.   port: 80
  7. spring:
  8.   application:
  9.     name: api-gateway-server
  11.   cloud:
  12.     # 网关配置
  13.     gateway:
  14.       # 路由配置：转发规则
  15.       routes: #集合。
  16.       # id: 唯一标识。默认是一个UUID
  17.       # uri: 转发路径
  18.       # predicates: 条件,用于请求网关路径的匹配规则
  21.       - id: gateway-provider
  22.         uri: http://localhost:8001/
  23.         predicates:
  24.         - Path=/goods/**
  1. 启动测试

4.3-Gateway-静态路由

application.yml 中的uri是写死的，就是静态路由

  1. server:
  2.   port: 80
  4. spring:
  5.   application:
  6.     name: api-gateway-server
  8.   cloud:
  9.     # 网关配置
  10.     gateway:
  11.       # 路由配置：转发规则
  12.       routes: #集合。
  13.       # id: 唯一标识。默认是一个UUID
  14.       # uri: 转发路径
  15.       # predicates: 条件,用于请求网关路径的匹配规则
  16.       # filters：配置局部过滤器的
  17.       - id: gateway-provider
  18.         # 静态路由
  19.         uri: http://localhost:8001/
  20.         predicates:
  21.         - Path=/goods/**

4.4-Gateway-动态路由

启动类添加@EnableEurekaClient（新版本不加也可以）

  1. package com.itheima.gateway;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
  7. @SpringBootApplication
  8. @EnableEurekaClient
  9. public class ApiGatewayApp {
  11.     public static void main(String[] args) {
  12.         SpringApplication.run(ApiGatewayApp.class,args);
  13.     }
  15. }

引入eureka-client配置

application.yml 中修改uri属性：uri: lb://服务名称

  1. server:
  2.   port: 80
  4. spring:
  5.   application:
  6.     name: api-gateway-server
  8.   cloud:
  9.     # 网关配置
  10.     gateway:
  11.       # 路由配置：转发规则
  12.       routes: #集合。
  13.       # id: 唯一标识。默认是一个UUID
  14.       # uri: 转发路径
  15.       # predicates: 条件,用于请求网关路径的匹配规则
  16.       # filters：配置局部过滤器的
  18.       - id: gateway-provider
  19.           # 静态路由
  20.         # uri: http://localhost:8001/
  21.         # 动态路由
  22.         uri: lb://GATEWAY-PROVIDER
  23.         predicates:
  24.         - Path=/goods/**

4.5-Gateway-微服务名称配置

1587545848975.png

application.yml中配置微服务名称配置

  1.       # 微服务名称配置
  2.       discovery:
  3.         locator:
  4.           enabled: true # 设置为true 请求路径前可以添加微服务名称
  5.           lower-case-service-id: true # 允许为小写

4.6-Gateway-过滤器

4.6.1-过滤器-概述

  • Gateway 支持过滤器功能，对请求或响应进行拦截，完成一些通用操作。
  • Gateway 提供两种过滤器方式：“pre”和“post”
    pre 过滤器，在转发之前执行，可以做参数校验、权限校验、流量监控、日志输出、协议转换等。
    post 过滤器，在响应之前执行，可以做响应内容、响应头的修改，日志的输出，流量监控等。
  • Gateway 还提供了两种类型过滤器
    GatewayFilter：局部过滤器，针对单个路由
    GlobalFilter ：全局过滤器，针对所有路由

1587546321584.png

4.6.2-局部过滤器

  • GatewayFilter 局部过滤器，是针对单个路由的过滤器。
  • 在Spring Cloud Gateway 组件中提供了大量内置的局部过滤器，对请求和响应做过滤操作。
  • 遵循约定大于配置的思想，只需要在配置文件配置局部过滤器名称，并为其指定对应的值，就可以让其生效。

具体配置参见gateway内置过滤器工厂.md

测试配置

api-gateway-server application.yml

  1. server:
  2.   port: 80
  3. spring:
  4.   application:
  5.     name: api-gateway-server
  6.   cloud:
  7.     # 网关配置
  8.     gateway:
  9.       # 路由配置：转发规则
  10.       routes: #集合。
  11.       # id: 唯一标识。默认是一个UUID
  12.       # uri: 转发路径
  13.       # predicates: 条件,用于请求网关路径的匹配规则
  14.       # filters：配置局部过滤器的
  16.       - id: gateway-provider
  17.         # 静态路由
  18.         # uri: http://localhost:8001/
  19.         # 动态路由
  20.         uri: lb://GATEWAY-PROVIDER
  21.         predicates:
  22.         - Path=/goods/**
  23.         filters:
  24.         - AddRequestParameter=username,zhangsan

gateway-provider模块中GoodsController中的findOne添加username参数

  1.  public Goods findOne(@PathVariable("id") int id,String username){
  3.         System.out.println(username);
  5.         //如果id == 1 ，则出现异常，id != 1 则正常访问
  6.         if(id == 1){
  7.             //1.造个异常
  8.             int i = 3/0;
  9.         }
  11.         /*try {
  12.             //2. 休眠2秒
  13.             Thread.sleep(2000);
  14.         } catch (InterruptedException e) {
  15.             e.printStackTrace();
  16.         }*/
  17.         Goods goods = goodsService.findOne(id);
  19.         goods.setTitle(goods.getTitle() + ":" + port);//将端口号，设置到了 商品标题上
  20.         return goods;
  21.     }

4.6.3-全局过滤器

  • GlobalFilter 全局过滤器，不需要在配置文件中配置，系统初始化时加载，并作用在每个路由上。
  • Spring Cloud Gateway 核心的功能也是通过内置的全局过滤器来完成。

  • 自定义全局过滤器步骤：

    1. 定义类实现 GlobalFilter 和 Ordered接口
    2. 复写方法
    3. 完成逻辑处理


    1587546455139.png

MyFilter

  1. package com.itheima.gateway.filter;
  3. import org.springframework.cloud.gateway.filter.GatewayFilterChain;
  4. import org.springframework.cloud.gateway.filter.GlobalFilter;
  5. import org.springframework.core.Ordered;
  6. import org.springframework.stereotype.Component;
  7. import org.springframework.web.server.ServerWebExchange;
  8. import reactor.core.publisher.Mono;
  10. @Component
  11. public class MyFilter implements GlobalFilter, Ordered {
  12.     @Override
  13.     public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
  15.         System.out.println("自定义全局过滤器执行了~~~");
  17.         return chain.filter(exchange);//放行
  18.     }
  20.     /**
  21.      * 过滤器排序
  22.      * @return 数值越小 越先执行
  23.      */
  24.     @Override
  25.     public int getOrder() {
  26.         return 0;
  27.     }
  28. }

4.7 通过feign调用spring cloud gateway代理的服务

router.png

4.7.1工程结构

工程搭建参考代码目录SpringCloud\day02\代码\3. Gateway\2. gateway最终代码

  • api-gateway-server 80端口
  • eureka-server-gateway 8761端口
  • gateway-consumer 9000端口
  • gateway-provider 8001端口

4.7.2 配置consumer通过gateway调用provider

修改feign接口上FeignClient注解的value值为api-gateway-server的应用名称

  1. package com.itheima.consumer.feign;
  4. import com.itheima.consumer.domain.Goods;
  5. import org.springframework.cloud.openfeign.FeignClient;
  6. import org.springframework.web.bind.annotation.GetMapping;
  7. import org.springframework.web.bind.annotation.PathVariable;
  11. @FeignClient(value = "api-gateway-server",fallback = GoodsFeignClientFallback.class)
  12. public interface GoodsFeignClient {
  15.     @GetMapping("/goods/findOne/{id}")
  16.     public Goods findGoodsById(@PathVariable("id") int id);
  18. }

4.7.3 调用方式