Spring Cloud 使用 GateWay 作为服务网关

GateWay简介

Spring Cloud GateWay是Spring Cloud的⼀个全新项⽬，⽬标是取代Netflix Zuul，它根据Spring5.0+SpringBoot2.0+WebFlux（根据⾼性能的Reactor模式响应式通讯框架Netty，异步⾮堵塞模型）等技术开发，性能⾼于Zuul，官⽅测验，GateWay是Zuul的1.6倍，旨在为微服务架构供给⼀种简略有效的统⼀的API路由办理⽅式。

Spring Cloud GateWay不仅供给统⼀的路由⽅式（反向署理）并且根据 Filter(界说过滤器对恳求过滤，完结⼀些功用) 链的⽅式供给了⽹关基本的功用，例如：鉴权、流量操控、熔断、途径重写、⽇志监控等。

网关在架构中的方位，能够看到是恳求进来由网关路由分配找到需求恳求的服务，其中Nginx是用来做网管高可用的。

Zuul1.x 堵塞式IO 2.x 根据Netty
Spring Cloud GateWay天⽣便是异步⾮堵塞的，根据Reactor模型；

⼀个恳求—>⽹关根据⼀定的条件匹配—匹配成功之后能够将恳求转发到指定的服务
地址；⽽在这个过程中，咱们能够进⾏⼀些⽐较详细的操控（限流、⽇志、⿊⽩名
单）

路由（route）： ⽹关最根底的部分，也是⽹关⽐较根底的⼯作单元。路由由⼀个ID、⼀个⽬标URL（终究路由到的地址）、⼀系列的断⾔（匹配条件判断）和Filter过滤器（精细化操控）组成。如决断⾔为true，则匹配该路由。

断⾔（predicates）：参考了Java8中的断⾔java.util.function.Predicate，开发⼈员能够匹配Http恳求中的一切内容（包括恳求头、恳求参数等）（类似于nginx中的location匹配⼀样），如决断⾔与恳求相匹配则路由。

过滤器（filter）：⼀个规范的Spring webFilter，使⽤过滤器，能够在恳求之前
或许之后执⾏事务逻辑。

Predicates断⾔便是咱们的匹配条件，⽽Filter就能够理解为⼀个⽆所不能的拦截器，有了这两个元素，结合⽬标URL，就能够完成⼀个详细的路由转发。

Spring Cloud GateWay 帮咱们内置了许多 Predicates功用，完成了各种路由匹配规矩（通过 Header、恳求参数等作为条件）匹配到对应的路由。

一般都会使用恳求途径正则匹配

spring:
  cloud:
    gateway:
      routes: # 路由能够有多个
        - id: service-xxx-router # 咱们⾃界说的路由 ID，保持唯⼀
          uri: lb://server-name
          predicates: #路由条件
            - Path=/xx/xxxx/** 

GateWay⼯作过程

客户端向Spring Cloud GateWay发出恳求，然后在GateWay Handler Mapping中找到与恳求相匹配的路由，将其发送到GateWay Web Handler；Handler再通过指定的过滤器链来将恳求发送到咱们实践的服务执⾏事务逻辑，然后回来。过滤器之
间⽤虚线分隔是因为过滤器或许会在发送署理恳求之前（pre）或许之后（post）执⾏事务逻辑。

Filter在“pre”类型过滤器中能够做参数校验、权限校验、流量监控、⽇志输出、协议转换等，在“post”类型的过滤器中能够做响应内容、响应头的修改、⽇志的输出、流量监控等。

从过滤器⽣命周期（影响时机点）的⻆度来说，主要有两个pre和post：

从过滤器类型的⻆度 ,Spring Cloud GateWay的过滤器分为GateWayFilter和
GlobalFilter两种。

一般情况下GlobalFilter大局过滤器是程序员使⽤⽐较多的过滤器；

能够用来自界说一些黑名单校验等

⾃界说GateWay大局过滤器时，咱们完成Global Filter接⼝即可，通过大局过滤器可
以完成⿊⽩名单、限流等功用。

@Slf4j
@Component
public class BlackListFilter implements GlobalFilter, Ordered {
    private static List<String> blackList = new ArrayList<>();
    static {
        blackList.add("0:0:0:0:0:0:0:1"); // 模拟本机地址
    }
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        // 思路：获取客户端ip，判断是否在⿊名单中，在的话就拒绝访问，不在的话就放⾏
        // 从上下⽂中取出request和response对象
        ServerHttpRequest request = exchange.getRequest();
        ServerHttpResponse response = exchange.getResponse();
        // 从request对象中获取客户端ip
        String clientIp = request.getRemoteAddress().getHostString();
        // 拿着clientIp去⿊名单中查询，存在的话就决绝访问
        if (blackList.contains(clientIp)) {
            // 决绝访问，回来
            response.setStatusCode(HttpStatus.UNAUTHORIZED); // 状况码
            log.debug("=====>IP:" + clientIp + " 在⿊名单中，将被拒绝访 问！");
            String data = "恳求被禁止!";
            DataBuffer wrap = response.bufferFactory().wrap(data.getBytes());
            return response.writeWith(Mono.just(wrap));
        }
        // 合法恳求，放⾏，执⾏后续的过滤器
        return chain.filter(exchange);
    }
    @Override
    public int getOrder() {
        return 0; //越小优先级越高
    }
}

GateWay 路由转发

这儿我供给了两个微服务 端口是 8082 的feign 微服务名是 server-pruduce-8082-feign调用8080 微服务名是cloud-eureka-client-8081的微服务

其中这两个接口中是有/api/test,/api2/test接口

导入依靠

   <!--spring boot ⽗启动器依靠-->
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.6.RELEASE</version>
    </parent>
    <artifactId>server_pruduce_9000_getWay</artifactId>
    <!-- GateWay不需求使⽤web模块，它引⼊的是WebFlux（类似于SpringMVC） -->
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-commons</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <!--GateWay ⽹关-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-gateway</artifactId>
        </dependency>
        <!--引⼊webflux-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-webflux</artifactId>
        </dependency>
        <!--⽇志依靠-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-logging</artifactId>
        </dependency>
        <!--测验依靠-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!--引⼊Jaxb，开端-->
        <dependency>
            <groupId>com.sun.xml.bind</groupId>
            <artifactId>jaxb-core</artifactId>
            <version>2.2.11</version>
        </dependency>
        <dependency>
            <groupId>javax.xml.bind</groupId>
            <artifactId>jaxb-api</artifactId>
        </dependency>
        <dependency>
            <groupId>com.sun.xml.bind</groupId>
            <artifactId>jaxb-impl</artifactId>
            <version>2.2.11</version>
        </dependency>
        <dependency>
            <groupId>org.glassfish.jaxb</groupId>
            <artifactId>jaxb-runtime</artifactId>
            <version>2.2.10-b140310.1920</version>
        </dependency>
        <dependency>
            <groupId>javax.activation</groupId>
            <artifactId>activation</artifactId>
            <version>1.1.1</version>
        </dependency>
        <!--引⼊Jaxb，结束-->
        <!-- Actuator能够协助你监控和办理Spring Boot应⽤-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <!--热布置-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <optional>true</optional>
        </dependency>
    </dependencies>
    <dependencyManagement>
        <!--spring cloud依靠版本办理-->
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Greenwich.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

#eureka server服务端口
server:
  port: 9000
spring:
  application:
    name: server-pruduce-9000-getWay # 使用称号，使用称号会在Eureka中作为服务称号
  cloud:
    inetutils:
      # 指定此客户端的ip
      default-ip-address: springcloud
      #getway装备
      ##### 动态路由设置时，uri以 lb: //最初（lb代表从注册中⼼获取服务），后⾯是需求转发到的服务称号
    gateway:
      routes: # 路由能够有多个
        - id: service-router1 # 咱们⾃界说的路由 ID，保持唯⼀
          #uri: http://127.0.0.1:8082 # ⽬标服务地址 布置多实例） 动态路由：uri装备的应该是⼀个服务称号，⽽不该该是⼀个详细的服务实例的地址
          uri: lb://server-pruduce-8082-feign # ⽬标服务地址 布置多实例） 动态路由：uri装备的应该是⼀个服务称号，⽽不该该是⼀个详细的服务实例的地址
          # gateway⽹关从服务注册中⼼获取实例信息然后负载后路由
          predicates: #断⾔：路由条件，Predicate 承受⼀个输⼊参数，回来⼀个布尔值成果。该接⼝包括多种默 认⽅法来将 Predicate 组合成其他杂乱的逻辑（⽐如：与，或，⾮）。
            - Path=/api/**
        - id: service-router2 # 咱们⾃界说的路由 ID，保持唯⼀
          uri: lb://cloud-eureka-client-8081 #服务名不要用下划线
          predicates: #断⾔：路由条件，Predicate 承受⼀个输⼊参数，回来⼀个布尔值成果。该接⼝包括多种默 认⽅法来将 Predicate 组合成其他杂乱的逻辑（⽐如：与，或，⾮）。
            - Path=/api2/**
          #filters:
            #- StripPrefix=1 #能够去掉url中的占位后转发路由 能够去掉api后转发
#eureka装备
eureka:
  instance:
    hostname: springcloud  # 当时eureka实例的主机名
    ip-address: springcloud
  client:
    service-url:
      prefer-ip-address: true
      lease-renewal-interval-in-seconds: 30
      # 租约到期，服务时效时间，默认值90秒,服务超过90秒没有发⽣⼼跳，服务注册中心会将服务从列表移除
      lease-expiration-duration-in-seconds: 90
      # 装备客户端所交互的Eureka Server的地址（Eureka Server集群中每一个Server其实相对于其它Server来说都是Client）
      # 集群模式下，defaultZone应该指向其它Eureka Server，假如有更多其它Server实例，逗号拼接即可
      defaultZone: http://127.0.0.1:8761/eureka,http://127.0.0.1:8762/eureka # 注册到集群汇总，多个用,拼接
    register-with-eureka: true  # 集群模式下能够改成true
    fetch-registry: true # 集群模式下能够改成true

恳求调用

GateWay⾼可⽤

⽹关作为⾮常核⼼的⼀个部件，假如挂掉，那么一切恳求都或许⽆法路由处理，因此咱们需求做GateWay的⾼可⽤。

GateWay的⾼可⽤很简略：能够启动多个GateWay实例来完成⾼可⽤，在GateWay的上游使⽤Nginx或许F5等负载均衡设备进⾏负载转发以到达⾼可⽤。

#装备多个GateWay实例
upstream gateway {
server 127.0.0.1:9000;
server 127.0.0.1:9001;
}
location / {
proxy_pass http://gateway;
}