胖不了小陆

信你所信，为你所见

0%

Gateway与Nacos实现动态路由

发表于 分类于

一、前言

  • 一般Gateway配置路由会在配置文件中写死，如下
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
spring:
  application:
    name: gateway
  cloud:
    gateway:
      enabled: true
      discovery:
        locator:
          enabled: true 
          lower-case-service-id: true #是将请求路径上的服务名配置为小写
      routes:
        - id: provider
          uri: lb://nacos-provider
          predicates:
            - Path=/provider/**
          filters:
            # StripPrefix 数字表示要截断的路径的数量
            - StripPrefix=1
        - id: consumer
          uri: lb://nacos-consumer
          predicates:
            - Path=/consumer/**
          filters:
            - StripPrefix=1
  • 当我们想添加新路由的时候还得，在routes中添加新路由然后重启服务
  • 这样显然是不太合理的，那路由是不是可以动态获取与更新呢（废话）

二、实现思路

  • 在Gateway启动的时候，读取nacos的路由信息配置，然后刷到Gateway路由
  • 监听nacos信息变化，如果配置修改了，重新调用Gateway刷新事件，刷新最新路由信息
  • Gateway的路由信息，默认是保存在内存中的，可查看GatewayAutoConfiguration源码
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
**
 * @author Spencer Gibb
 * @author Ziemowit Stolarczyk
 */
@Configuration(proxyBeanMethods = false)
@ConditionalOnProperty(name = "spring.cloud.gateway.enabled", matchIfMissing = true)
@EnableConfigurationProperties
@AutoConfigureBefore({ HttpHandlerAutoConfiguration.class,
		WebFluxAutoConfiguration.class })
@AutoConfigureAfter({ GatewayLoadBalancerClientAutoConfiguration.class,
		GatewayClassPathWarningAutoConfiguration.class })
@ConditionalOnClass(DispatcherHandler.class)
public class GatewayAutoConfiguration {


	@Bean
	@ConditionalOnMissingBean(RouteDefinitionRepository.class)
	public InMemoryRouteDefinitionRepository inMemoryRouteDefinitionRepository() {
		return new InMemoryRouteDefinitionRepository();
	}

	@Bean
	@Primary
	public RouteDefinitionLocator routeDefinitionLocator(
			List<RouteDefinitionLocator> routeDefinitionLocators) {
		return new CompositeRouteDefinitionLocator(
				Flux.fromIterable(routeDefinitionLocators));
	}
	//...
}
  • 默认就是InMemoryRouteDefinitionRepository，实现了RouteDefinitionRepository，底层是一个线程安全的Map:SynchronizedMap
  • 其中注解@ConditionalOnMissingBean(RouteDefinitionRepository.class) 表示RouteDefinitionRepository没有实现类时，使用InMemoryRouteDefinitionRepository

实现动态路由

方法1

  • 既然知道了 路由信息 是保存在内存中，那我们可以自定义路由保存的位置，如：redis 等
  • 只需要继承 RouteDefinitionRepository 接口，重写其中的三个方法逻辑即可
1
2
3
4
5
6
7
8
// 获取所有路由信息
Flux<RouteDefinition> getRouteDefinitions();

// 添加路由信息
Mono<Void> save(Mono<RouteDefinition> route);

// 删除路由信息
Mono<Void> delete(Mono<String> routeId);
  • 他们的save和delete都是 RouteDefinitionWriter 接口的方法

方法二

  • 监听Nacos的路由配置变化，Nacos变化了，我们这边收到数据
  • 收到数据之后，发布刷新路由事件，通知所有存储路由的组件更新路由即可

1、自定义动态路由发布事件

  • 实现Spring的ApplicationEventPublisherAware 接口。
  • 初始化时监听Nacos路由配置信息，注入：RouteDefinitionWriter更新InMemoryRouteDefinitionRepository 数据，并发布RefreshRoutesEvent事件
  • 完整代码如下：
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
/**
 * 动态路由配置
 *
 */
@Slf4j
@Component
@ConditionalOnProperty(name = "route.dynamic.enabled", matchIfMissing = true)
public class DynamicGatewayRouteConfig implements ApplicationEventPublisherAware {

    @Value("${route.dynamic.enabled}")
    private Boolean enabled =Boolean.FALSE;

    @Value("${route.dynamic.dataId}")
    private String dataId;

    @Value("${route.dynamic.namespace}")
    private String namespace;

    @Value("${route.dynamic.group}")
    private String group;

    @Value("${spring.cloud.nacos.config.server-addr}")
    private String serverAddr;

    @Value("${spring.cloud.nacos.config.username}")
    private String username;

    @Value("${spring.cloud.nacos.config.password}")
    private String password;

    private RouteDefinitionWriter routeDefinitionWriter;
    
    private final long timeoutMs=5000;

    @Autowired
    public void setRouteDefinitionWriter(RouteDefinitionWriter routeDefinitionWriter) {
        this.routeDefinitionWriter = routeDefinitionWriter;
    }

    private ApplicationEventPublisher applicationEventPublisher;

    private static final List<String> ROUTES = new ArrayList<String>();

    @PostConstruct
    public void dynamicRouteByNacosListener() {
        if(enabled){
            try {
                Properties properties = new Properties();
                properties.put("serverAddr", serverAddr);
                properties.put("namespace", namespace);
                properties.put("username", username);
                properties.put("password", password);
                // 参考官网：https://nacos.io/zh-cn/docs/sdk.html
                ConfigService configService = NacosFactory.createConfigService(properties);
                // 程序首次启动, 并加载初始化路由配置
                String initConfigInfo = configService.getConfig(dataId, group, timeoutMs);
                batchAddOrUpdateRouteAndPublish(initConfigInfo);
                configService.addListener(dataId, group, new Listener() {
                    @Override
                    public void receiveConfigInfo(String configInfo) {
                        batchAddOrUpdateRouteAndPublish(configInfo);
                    }

                    @Override
                    public Executor getExecutor() {
                        return null;
                    }
                });
            } catch (NacosException e) {
                e.printStackTrace();
            }
        }

    }

    /**
     * 清空所有路由
     */
    private void clearRoute() {
        for(String id : ROUTES) {
            this.routeDefinitionWriter.delete(Mono.just(id)).subscribe();
        }
        ROUTES.clear();
    }

    /**
     * 添加单条路由信息
     * @param definition RouteDefinition
     */
    private void addRoute(RouteDefinition definition) {
        routeDefinitionWriter.save(Mono.just(definition)).subscribe();
        ROUTES.add(definition.getId());
    }

    /**
     * 批量添加或更新路由，及发布 路由
     * @param configInfo 配置文件字符串, 必须为json array格式
     */
    private void batchAddOrUpdateRouteAndPublish(String configInfo) {
        try {
            clearRoute();
            List<RouteDefinition> gatewayRouteDefinitions = JSONObject.parseArray(configInfo, RouteDefinition.class);
            for (RouteDefinition routeDefinition : gatewayRouteDefinitions) {
                addRoute(routeDefinition);
            }
            publish();
            log.info("添加路由信息. {}", JSON.toJSONString(gatewayRouteDefinitions));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private void publish() {
        this.applicationEventPublisher.publishEvent(new RefreshRoutesEvent(this.routeDefinitionWriter));
    }

    @Override
    public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
        this.applicationEventPublisher = applicationEventPublisher;
    }
}

  • 配置文件内容：
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
spring:
  application:
    name: gateway
  redis:
    host: 127.0.0.1
    port: 6379
    password:
  profiles:
    active: dev
  cloud:
    nacos:
      config:
        server-addr: 127.0.0.1:8848
        file-extension: yaml
        group: DEFAULT_GROUP
        username: nacos
        password: nacos
      discovery:
        server-addr: 127.0.0.1:8848
        username: nacos
        password: nacos
#  # 网关配置在nacos中配置
    gateway:
      enabled: true
      discovery:
        locator:
          enabled: true 
          lower-case-service-id: true #是将请求路径上的服务名配置为小写
# 动态路由配置
route:
  dynamic:
    enabled: true
    namespace:
    dataId: gateway_route
    group: DEFAULT_GROUP

2、Nacos配置路由信息

  • Nacos中的gateway_route配置内容如下：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
[{
    "id":"provider",
    "predicates":[
      {
        "args":{
          "pattern": "/provider/**"
        },
        "name": "Path"
      }
    ],
    "filters": [
      {
        "name": "StripPrefix",
        "args": {
          "parts": "1"
        }
      }
    ],
    "uri": "lb://nacos-provider"
},{
    "id":"consumer",
    "predicates":[
      {
        "args":{
          "pattern": "/consumer/**"
        },
        "name": "Path"
      }
    ],
    "filters": [
      {
        "name": "StripPrefix",
        "args": {
          "parts": "1"
        }
      },
      {
      	"name":"MyRequestRateLimiter",
      	"args":{
      		"redis-rate-limiter.replenishRate": 1,
      		"redis-rate-limiter.burstCapacity": 2,
      		"key-resolver": "#{@pathKeyResolver}"
      	}
      }
    ],
    "uri": "lb://nacos-consumer"
}]
  • 启动网关服务，查看控制台

  • 每个json对象都是一个：org.springframework.cloud.gateway.route.RouteDefinition
  • MyRequestRateLimiter 这个是我随便配置的Redis限流，也是生效的

自此就Gateway动态路由就结束了，完整SpringCloud-alibaba示例源码如下：

您的打赏，是我创作的动力！不给钱？那我只能靠想象力充饥了。