SpringCloud Gateway 2020.0.2最新版本的講解

   <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
            <version>2.4.4</version>
        </dependency>
				<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-gateway</artifactId>
          	<version>3.0.2</version>
        </dependency>

server:
  port: 9527
spring:
  application:
    name: cloud-gateway
  # 以下是gateway的配置
  cloud:
    gateway:
      routes:
        - id: gateway_route_1
          uri: https://www.baidu.com/s
          predicates:
            - Path=/s/**

package org.example.springcloud.config;

import org.springframework.cloud.gateway.route.RouteLocator;
import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @Auth: guohui.wang
 * @Date: 2021-04-07 11:07
 * @desc:
 */
@Configuration
public class GatewayConfig {
    /**
     * <p>將 "ip:${server.port}+${route.path}" 轉(zhuǎn)發(fā)到 "${route.url}"</p>
     * <p>例 "120.0.0.1:9527/s" 轉(zhuǎn)發(fā)到 "https://www.baidu.com/s"</p><br>
     * <p>可以嘗試訪問以下鏈接獲取配置效果</p>
     * <li>"http://localhost:9527/s"</li>
     * <li>"http://localhost:9527/s?wd=spring"</li>
     * <br>
     * <div>
     * <b>routes().route(參數(shù)1，參數(shù)2).route(參數(shù)1，參數(shù)2)……</b>
     * <li>參數(shù)1：id，一個(gè)可以隨便取得名字，標(biāo)識(shí)此路由規(guī)則</li>
     * <li>參數(shù)2：具體的路由規(guī)則內(nèi)容</li>
     *
     * <b>路由規(guī)則：</b>
     * <li>path: 網(wǎng)關(guān)服務(wù)地址之后的內(nèi)容（比如上面的"/s")</li>
     * <li>uri: 符合path之后需要轉(zhuǎn)發(fā)到的位置</li>
     * </div>
     *
     * @param builder
     * @return
     */
    @Bean
    public RouteLocator routes(RouteLocatorBuilder builder) {
        return builder
                .routes()
                .route("gateway_route_1",
                        r -> r.path("/s")
                                .uri("https://www.baidu.com/s")
                )
                .build();
    }
}

package org.example.springcloud;

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

@SpringBootApplication
@EnableEurekaClient
public class GatewayMain9527 {
    public static void main(String[] args) {
        SpringApplication.run(GatewayMain9527.class, args);
    }
}

<dependencyManagement>
        <dependencies>
            <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-dependencies -->
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>2.4.4</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>

            <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-dependencies -->
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>2020.0.2</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

 <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
    </dependencies>

package org.example.springcloud.eureka;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaApplication.class, args);
    }
}

server:
  port: 9001
eureka:
  instance:
    hostname: localhost
  client:
    # 不向注冊中心注冊自己
    register-with-eureka: false
    # 表示自己端就是注冊中心，不需要檢索服務(wù)
    fetch-registry: false
    service-url:
      # 設(shè)置與eureka server交互地址查詢服務(wù)和注冊服務(wù)都需要依賴這個(gè)地址
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

<dependencies>
        <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>

package org.example.springcloud.provider;

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

@SpringBootApplication
@EnableEurekaClient
public class ProviderApplication {
    public static void main(String[] args) {
        SpringApplication.run(ProviderApplication.class, args);
    }
}

package org.example.springcloud.provider.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RequestMapping("/test")
@RestController
public class TestController {
    @GetMapping("/lb")
    public String lb() {
        return "訪問成功";
    }
}

server:
  port: 9003
spring:
  application:
    name: cloud-provider
#eureka相關(guān)配置
eureka:
  instance:
    instance-id: cloud-provider-01
  client:
    service-url:
      defaultZone: http://127.0.0.1:9001/eureka
    register-with-eureka: true
    fetch-registry: true

 <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-gateway</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
    </dependencies>

package org.example.springcloud.gateway;

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

@SpringBootApplication
@EnableEurekaClient
public class GatewayApplication {
    public static void main(String[] args) {
        SpringApplication.run(GatewayApplication.class, args);
    }
}

server:
  port: 9002
spring:
  application:
    name: cloud-gateway
  cloud:
    gateway:
      discovery:
        locator:
          #開啟從注冊中心動(dòng)態(tài)創(chuàng)建路由功能，利用微服務(wù)名進(jìn)行路由
          enabled: true
      routes:
        - id: payment_routh2
          # lb:// + ${目標(biāo)服務(wù)的spring.application.name的值}
          uri: lb://cloud-provider
          # 映射的路徑 訪問符合Path值的路徑，轉(zhuǎn)發(fā)到響應(yīng)的uri對(duì)應(yīng)服務(wù)下Path
          predicates:
            - Path=/test/lb/**
#eureka相關(guān)配置
eureka:
  instance:
    instance-id: cloud-gateway-01
  client:
    service-url:
      defaultZone: http://127.0.0.1:9001/eureka
    register-with-eureka: true
    fetch-registry: true

package org.example.springcloud.gateway.filter;

import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;

@Component
public class MyLogGatewayFilter implements GlobalFilter, Ordered {
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        // 不用log.info了，為了省點(diǎn)事，別較真
        System.out.println("進(jìn)入到了我們的自定義日志過濾器");
        // request、response啥的都能拿到，要干啥自己看著辦吧，獲取在下兩行，
        // 你是要判斷參數(shù)啊還是判斷token啊還是咋地那你自己定義去吧。
        // ServerHttpRequest request = exchange.getRequest();
        // ServerHttpResponse response = exchange.getResponse();

        // 返回chain.filter(exchange); 表示此過濾器通過，將請求繼續(xù)傳遞下去
        // 交由下面的過濾器繼續(xù)處理
        // 如果是 return null; 則表示被過濾掉了，沒通過。
        return chain.filter(exchange);
    }

    @Override
    public int getOrder() {
        // 加載過濾器的順序，數(shù)值越小優(yōu)先級(jí)越高。
        // Integer.MIN_VALUE 到 Integer.MAX_VALUE
        return 0;
    }
}