springcloud之gateway網(wǎng)關(guān)

是什么呀枢？

spring cloud gateway提供統(tǒng)一的路由方式且基于Filter鏈的方式提供了網(wǎng)關(guān)基本功能霉晕，例如：安全缕减，指標(biāo)/監(jiān)控雷客，和限流。使用webfluex中的reactor-netty響應(yīng)式編程組件桥狡，底層使用了Netty通信搅裙。

特性

基于spring framework5，project reactor和spring boot2構(gòu)建
可以對路由指定predicate（斷言）和filter（過濾器）裹芝，并且易于編寫
集成Hystrix
集成spring cloud服務(wù)發(fā)現(xiàn)功能
請求限流功能
支持路徑重寫

三大核心概念

Route部逮，路由是構(gòu)建網(wǎng)關(guān)的基本模塊，它由ID嫂易，目標(biāo)URI兄朋，一系列斷言和過濾器組成，如果斷言為true則匹配該路由
Predicate怜械，參考java8的java.util.function.Predicate颅和，開發(fā)人員可以匹配HTTP請求中所有內(nèi)容（例如請求頭或請求參數(shù)），如果請求與斷言相匹配宫盔，則進(jìn)行路由融虽。
Filter，過濾是指Spring框架中GatewayFilter的實(shí)例灼芭，使用過濾器有额，可以在請求被路由前或之后對請求進(jìn)行修改。發(fā)送給代理之前彼绷，可以做參數(shù)校驗(yàn)巍佑，權(quán)限校驗(yàn)，流量控制寄悯，日志輸出萤衰，協(xié)議轉(zhuǎn)換；在發(fā)送代理之后猜旬，可以做響應(yīng)內(nèi)容脆栋，響應(yīng)頭修改倦卖，日志輸出，流量監(jiān)控等椿争。

web請求怕膛，通過一些匹配條件，定位到真正的服務(wù)節(jié)點(diǎn)秦踪。并在這個(gè)轉(zhuǎn)發(fā)過程的前后褐捻，進(jìn)行一些精細(xì)化控制。predicate就是匹配條件椅邓，filter就是一個(gè)攔截器柠逞，有了這兩個(gè)元素，再加上目標(biāo)URI景馁，就可以實(shí)現(xiàn)一個(gè)具體的路由了板壮。

配置實(shí)現(xiàn)

server:
  port: 9527
  
spring:
  application:
    name: cloud-gateway

  cloud:
    gateway:
      routes:
      - id: payment_routh1 #路由ID，沒有固定規(guī)則合住，但要求唯一个束，建議配合服務(wù)名
        uri: http://localhost:8001 #匹配后提供服務(wù)的路由地址
        predicates:
        - Path=/payment/get/** #斷言，路徑相匹配的進(jìn)行路由
        
      - id: payment_routh2
        uri: http://localhost:8001
        predicates:
        - Path=/payment/discovery
        
eureka:
  instance:
    instance-id: ${spring.application.name}:${server.port}
    prefer-ip-address: true
  client:
    register-with-eureka: true
    fetch-registry: true
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka/
      
management:
  endpoints:
    web:
      exposure:
        include:
        - '*'

代碼實(shí)現(xiàn)

@Configuration
public class GatewayConifg {
    @Bean
    public RouteLocator customRouteLocator(RouteLocatorBuilder routeLocatorBuilder) {
        RouteLocatorBuilder.Builder routes = routeLocatorBuilder.routes();
        routes.route("path_route_guonei", r -> r.path("/guonei").uri("https://news.baidu.com/guonei")).build();
        routes.route("path_route_guoji", r->r.path("/guoji").uri("https://news.baidu.com/guoji")).build();
        return routes.build();
    }
}

通過微服務(wù)名進(jìn)行動(dòng)態(tài)路由

默認(rèn)情況下聊疲，Gateway會根據(jù)注冊中心注冊服務(wù)列表，以注冊中心上微服務(wù)名為路徑創(chuàng)建動(dòng)態(tài)路由進(jìn)行轉(zhuǎn)發(fā)沪悲，從而實(shí)現(xiàn)動(dòng)態(tài)路由的功能获洲。

server:
  port: 9527
  
spring:
  application:
    name: cloud-gateway

  cloud:
    gateway:
      routes:
      - id: payment_routh1 #路由ID，沒有固定規(guī)則殿如，但要求唯一贡珊，建議配合服務(wù)名
#        uri: http://localhost:8001 #匹配后提供服務(wù)的路由Q地址
        uri: lb://cloud-payment-service # 匹配后提供服務(wù)的路由地址
        predicates:
        - Path=/payment/get/** #斷言，路徑相匹配的進(jìn)行路由
        
      - id: payment_routh2
        uri: lb://cloud-payment-service
#        uri: http://localhost:8001
        predicates:
        - Path=/payment/discovery
      discovery:
        locator:
          enabled: true
        
eureka:
  instance:
    instance-id: ${spring.application.name}:${server.port}
    prefer-ip-address: true
  client:
    register-with-eureka: true
    fetch-registry: true
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka/

Predicate的使用

時(shí)間級別：After, Before, Between

   After=2020-06-09T23:26:40.434+08:00[Asia/Shanghai]

產(chǎn)生上述帶時(shí)區(qū)的時(shí)間字符串

    ZonedDateTime zbj = ZonedDateTime.now();
    System.out.println(zbj);

Cookie：不帶cookies訪問涉馁，帶cookies訪問

Cookie Route Predicate需要兩個(gè)參數(shù)门岔，一個(gè)是Cookie name，一個(gè)是正則表達(dá)式烤送。路由規(guī)則會通過獲取對應(yīng)的Cookie name值和正則表達(dá)式去匹配寒随，如果匹配上就執(zhí)行路由，如果沒匹配上則不執(zhí)行帮坚。

   After=2020-06-09T22:26:40.434+08:00[Asia/Shanghai]
   Cookie=username,james

測試curl

curl http://localhost:9527/payment/get/5 --cookie "username=james"

Header

Header=X-Request-Id, \d+ #請求頭要有X-Request-Id屬性并且值為正數(shù)的正則表達(dá)式

測試curl

curl http://localhost:9527/payment/get/5  -H "X-Request-Id: 1"

Filter的使用

路由過濾器可用于修改進(jìn)入的Http請求和返回的Http響應(yīng)妻往，路由過濾器只能指定路由進(jìn)行使用。Spring Cloud GateWay內(nèi)置了多種路由過濾器试和，他們都由GatewayFilter的工廠來產(chǎn)生讯泣。

按生命周期分：pre，post
按種類分：GatewayFilter阅悍，GlobalFilter

自定義filter實(shí)現(xiàn)GlobalFilter好渠，Ordered接口

package com.example.springcloud.filter;

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.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;

import lombok.extern.slf4j.Slf4j;
import reactor.core.publisher.Mono;

@Component
@Slf4j
public class MyLogGateWayFilter implements GlobalFilter, Ordered {

    @Override
    public int getOrder() {
        return 0;
    }

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        log.info("welcome my house...");
        String uname = exchange.getRequest().getQueryParams().getFirst("uname");
        if(uname==null) {
            log.info("who are you?");
            exchange.getResponse().setStatusCode(HttpStatus.NOT_ACCEPTABLE);
            return exchange.getResponse().setComplete();
        }
        return chain.filter(exchange);
    }
}