Spring Cloud Alibaba：Gateway网关之Weight路由断言工厂

Spring Cloud Alibaba：Gateway网关之Weight路由断言工厂

之前已经介绍了Gateway的十种路由断言工厂，因为博主之前看的官方文档是旧版本（相较于博主使用的框架版本2.2.6.RELEASE），该文档只介绍了十种路由断言工厂。

• Spring Cloud Alibaba：Gateway网关 & 路由断言工厂

博主重新看了2.2.9.RELEASE版本的官方文档，新增了Weight路由断言工厂，更新还是很快的，想阅读官方文档可以如下图所示获取相关版本的Gateway文档。

接下来博主给大家演示一下它的使用方式，基于配置文件和基于Java DSL这两种方式，然后使用Postman对网关进行批量请求，看效果是否符合预期。

搭建工程

一个父module和两个子module（server module提供服务，gateway module实现网关）。

父module的pom.xml：

    4.0.0

    com.kaven
    alibaba
    pom
    1.0-SNAPSHOT

    Spring Cloud Alibaba
    
        gateway
        server
    

    
        8
        8
        Hoxton.SR9
        2.2.6.RELEASE
    

    
        org.springframework.boot
        spring-boot-starter-parent
        2.3.2.RELEASE
    

    
        
            
                org.springframework.cloud
                spring-cloud-dependencies
                ${spring-cloud-version}
                pom
                import
            
            
                com.alibaba.cloud
                spring-cloud-alibaba-dependencies
                ${spring-cloud-alibaba-version}
                pom
                import
            
        
    

server module

pom.xml：

    
        com.kaven
        alibaba
        1.0-SNAPSHOT
    
    4.0.0

    server

    
        8
        8
    

    
        
            org.springframework.boot
            spring-boot-starter-web
        
    

application.yml：

server:
  port: 8085

接口定义：

package com.kaven.alibaba.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.concurrent.atomic.AtomicInteger;

@RestController
public class MessageController {

    private static final AtomicInteger MESSAGE_COUNT = new AtomicInteger(0);
    private static final AtomicInteger NEW_MESSAGE_COUNT = new AtomicInteger(0);


    @GetMapping("/message")
    public Integer getMessage() {
        int count = MESSAGE_COUNT.incrementAndGet();
        System.out.println("message: " + count);
        return count;
    }

    @GetMapping("/new/message")
    public Integer getMessageNew() {
        int count = NEW_MESSAGE_COUNT.incrementAndGet();
        System.out.println("new message: " + count);
        return count;
    }
}

启动类：

package com.kaven.alibaba;

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

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

gateway module

pom.xml：

    
        com.kaven
        alibaba
        1.0-SNAPSHOT
    
    4.0.0

    gateway

    
        8
        8
    

    
        
            org.springframework.cloud
            spring-cloud-starter-gateway
        
    

启动类：

package com.kaven.alibaba;

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

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

基于配置文件

gateway module的application.yml：

server:
  port: 8086

spring:
  cloud:
    gateway:
      routes:
        - id: server
          uri: http://localhost:8085
          predicates:
            - Path=/message
            - Weight=group1, 75
        - id: new_server
          uri: http://localhost:8085
          predicates:
            - Path=/message
            - Weight=group1, 25
          filters:
            - PrefixPath=/new

Weight路由断言工厂接受两个参数：group和weight（int类型），权重是按组计算的（group参数需要相同）。如果请求网关的/message路径，会有75%的概率被路由到http://localhost:8085/message，25%的概率被路由到http://localhost:8085/new/message（PrefixPath是一种路由过滤器，它会将指定的路径以前缀的形式加在请求路径上，因此请求/message路径，会被路由到/new/message路径）。

• Spring Cloud Alibaba：Gateway之路由过滤器工厂（一）

可见，这种配置可用于有新版本的服务，但不确定新版本服务是否存在问题，就可以将小部分流量导入新版本服务中，进行线上测试，用较小的代价试错，即使出现了严重的错误，系统总体的损失也是可承受的，大家可以去了解一下金丝雀发布。

启动两个应用，使用Postman对网关发送批量请求，可以根据如下图所示进行 *** 作。

运行Collection。

输入运行Collection的配置（请求次数与请求间歇）。

服务端的输出如下图所示：

服务端的两个接口分别被请求了757次和243次，还是符合预期的。

基于Java DSL

修改gateway module的application.yml（删除网关的路由配置）：

server:
  port: 8086

在gateway module中增加两个bean，即以Java DSL的形式定义两个路由的处理流程。

    @Bean
    public RouteLocator routes1(RouteLocatorBuilder builder) {
        String uri = "http://127.0.0.1:8085";
        return builder.routes()
                .route("server", r -> r.path("/message")
                        .and().weight("group1", 75)
                        .uri(uri))
                .build();
    }

    @Bean
    public RouteLocator routes2(RouteLocatorBuilder builder) {
        String uri = "http://127.0.0.1:8085";
        return builder.routes()
                .route("new_server", r -> r.path("/message")
                        .and().weight("group1", 25)
                        .filters(f -> f.prefixPath("/new"))
                        .uri(uri))
                .build();
    }

上面代码的配置和之前的配置文件是一样的，重新启动两个应用，再用Postman给网关发送批量请求。

服务端的两个接口还是分别被请求了757次和243次，符合预期。

Gateway网关的Weight路由断言工厂就介绍到这里，如果博主有说错的地方或者大家有不同的见解，欢迎大家评论补充。