Gateway的简单使用

CBeann

发布于 2023-12-25 17:44:41

960

发布于 2023-12-25 17:44:41

文章被收录于专栏：CBeann的博客CBeann的博客

构建项目

provider-8001

provider-8002

gateway-9527

eureka-7001

依赖，注意不要加web依赖

 <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-gateway</artifactId>
        </dependency>

application.yml

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

路由规则小案例

静态路由

配置yml方式

server:
  port: 9527
spring:
  application:
    name: cloud-gateway
  cloud:
    gateway:
      routes:
      - id: payment_routh #没有固定的规则但是要求唯一，建议配合服务名
        uri: http://localhost:8001 #匹配后提供的路由地址
        predicates:
        - Path=/payment/get/**  #断言，路径相匹配的进行路由

此处设置的路由规则是 http://localhost:9527/payment/get/** 会路由到 http://localhost:8001/payment/get/**

而不是 http://localhost:9527/payment/get/* 路由到 http://localhost:8001/*

此处我修改上面的代码把

uri: http://localhost:8001 #匹配后提供的路由地址

修改为

uri: http://localhost:8001/abc #匹配后提供的路由地址

访问 http://localhost:9527/payment/get/1 仍然能路由到 http://localhost:8001/payment/get/1

说明后面的/abc配置没有作用，而且官网里的小案例就是只有 ipd地址或者服务名称

编码方式

    @Bean
    public RouteLocator customRouteLocator(RouteLocatorBuilder routeLocatorBuilder){

        RouteLocatorBuilder.Builder routes = routeLocatorBuilder.routes();
        routes.route("payment_routh"
                , r->r.path("/payment/get/**").uri("http://localhost:8001"))
                .build();
        return routes.build();
    }

等价于

spring:
  application:
    name: cloud-gateway
  cloud:
    gateway:
      routes:
      - id: payment_routh #没有固定的规则但是要求唯一，建议配合服务名
        uri: http://localhost:8001 #匹配后提供的路由地址
        predicates:
        - Path=/payment/get/**  #断言，路径相匹配的进行路由

动态路由

以Eureka为注册中心为例

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

修改启动类

@EnableEurekaClient

修改yml配置文件

server:
  port: 9527
spring:
  application:
    name: cloud-gateway
  cloud:
    gateway:
      discovery:
        locator:
          enabled: true  #开启注册中心路由功能
      routes:
      - id: payment_routh #没有固定的规则但是要求唯一，建议配合服务名
        uri: lb://CLOUD-PROVIDER-PAYMENT #此处如果有问题，请注意依赖spring-cloud-starter-netflix-eureka-client依赖不能错
        #uri: http://localhost:8001 #匹配后提供的路由地址
        predicates:
        - Path=/payment/get/**  #断言，路径相匹配的进行路由

Route Predicate路由断言

就是下图中的箭头处下面的规则

下面是官网提供的配置规则

Spring Cloud Gateway

GateWay的Filter

官网地址

Spring Cloud Gateway

下面是复制官网上的一段代码，添加请求头 key=X-request-red,value=biue

spring:
  cloud:
    gateway:
      routes:
      - id: add_request_header_route
        uri: https://example.org
        filters:
        - AddRequestHeader=X-Request-red, blue

自定义过滤器

@Component
@Slf4j
public class MyLogGateWayFilter implements GlobalFilter, Ordered {
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        log.info("***********come in MyLogGateWayFilter: "+new Date());
        String uname = exchange.getRequest().getQueryParams().getFirst("uname");//每次进来后判断带不带uname这个key
        if(uname == null){
            log.info("*********用户名为null ，非法用户，o(╥﹏╥)o");
            exchange.getResponse().setStatusCode(HttpStatus.NOT_ACCEPTABLE);    //uname为null非法用户
            return exchange.getResponse().setComplete();
        }
        return chain.filter(exchange);
    }
    @Override
    public int getOrder() {
        return 0;
    }
}

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2022-03-07，如有侵权请联系 cloudcommunity@tencent.com 删除

cloud