SpringCloud Gateway 服務閘道器的快速入門

<!--閘道器--><dependency>    <groupId>org.springframework.cloud</groupId>    <artifactId>spring-cloud-starter-gateway</artifactId></dependency><!--nacos服務發現依賴--><dependency>    <groupId>com.alibaba.cloud</groupId>    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency>

複製程式碼

import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplicationpublic class GatewayApplication {
    public static void main(String[] args) {        SpringApplication.run(GatewayApplication.class, args);    }}

複製程式碼

server:  port: 10086 # 閘道器埠spring:  application:    name: gateway # 服務名稱  cloud:    nacos:      server-addr: localhost:8848 # nacos地址    gateway:      routes: # 閘道器路由配置        - id: user-service # 路由id，自定義，只要唯一即可          # uri: http://127.0.0.1:8081 # 路由的目標地址 http就是固定地址          uri: lb://userservice # 路由的目標地址 lb就是負載均衡，後面跟服務名稱          predicates: # 路由斷言，也就是判斷請求是否符合路由規則的條件            - Path=/user/** # 這個是按照路徑匹配，只要以/user/開頭就符合要求

複製程式碼

spring:  cloud:    gateway:      routes:      - id: user-service         uri: lb://user-service         predicates:         - Path=/user/**         filters: # 過濾器        - AddRequestHeader= ***      # 新增請求頭

複製程式碼

spring:  cloud:    gateway:      routes:      - id: user-service         uri: lb://user-service         predicates:         - Path=/user/**      default-filters: # 預設過濾項      - AddRequestHeader=  *** 

複製程式碼

public interface GlobalFilter {    /**     *  處理當前請求，有必要的話通過{@link GatewayFilterChain}將請求交給下一個過濾器處理     *     * @param exchange 請求上下文，裡面可以獲取Request、Response等資訊     * @param chain 用來把請求委託給下一個過濾器      * @return {@code Mono<Void>} 返回標示當前過濾器業務結束     */    Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain);}

複製程式碼

@Order(-1)@Componentpublic class AuthorizeFilter implements GlobalFilter {    @Override    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {        // 1.獲取請求引數        MultiValueMap<String, String> params = exchange.getRequest().getQueryParams();        // 2.獲取authorization引數        String auth = params.getFirst("authorization");        // 3.校驗        if ("admin".equals(auth)) {            // 放行            return chain.filter(exchange);        }        // 4.攔截        // 4.1.禁止訪問，設定狀態碼        exchange.getResponse().setStatusCode(HttpStatus.FORBIDDEN);        // 4.2.結束處理        return exchange.getResponse().setComplete();    }}

複製程式碼

spring:  cloud:    gateway:      globalcors:                 # 全域性的跨域處理        add-to-simple-url-handler-mapping: true # 解決options請求被攔截問題        corsConfigurations:          '[/**]':            allowedOrigins:             # 允許哪些網站的跨域請求               - "http://localhost:8090"            allowedMethods:             # 允許的跨域ajax的請求方式              - "GET"              - "POST"              - "DELETE"              - "PUT"              - "OPTIONS"            allowedHeaders: "*"         # 允許在請求中攜帶的頭資訊            allowCredentials: true         # 是否允許攜帶cookie            maxAge: 360000           # 這次跨域檢測的有效期

複製程式碼