spring gateway 动态路由

embedded/2024/11/15 3:36:48/

##yml配置

java">spring:application:name: public-gateway
#  cloud:
#    gateway:
#      routes:
#        - id: mybatis-plus-test # 路由的唯一标识
#          uri: http://192.168.3.188:9898 # 目标服务的地址
#          predicates:
#            - Path=/test/** # 匹配以 /user/ 开头的请求路径
#          filters:
#            - AddRequestHeader=X-Request-Example, Example # 添加一个请求头
#            - AddRequestParameter=param1, value1 # 添加一个请求参数
server:port: 8180
logging:config: classpath:config/logback-spring.xml

##DynamicRoutesService动态路由

ApplicationEventPublisherAware得到publisher发布事件刷新路由缓存

ApplicationRunner设置路由

java">import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.cloud.gateway.event.RefreshRoutesEvent;
import org.springframework.cloud.gateway.filter.FilterDefinition;
import org.springframework.cloud.gateway.handler.predicate.PredicateDefinition;
import org.springframework.cloud.gateway.route.RouteDefinition;
import org.springframework.cloud.gateway.route.RouteDefinitionWriter;
import org.springframework.cloud.gateway.route.RouteLocator;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationEventPublisherAware;
import org.springframework.stereotype.Service;
import reactor.core.publisher.Mono;import java.net.URI;
import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;@Service
public class DynamicRoutesService implements ApplicationEventPublisherAware, ApplicationRunner {@Autowiredprivate RouteLocator routeLocator;@Autowiredprivate RouteDefinitionWriter routeDefinitionWriter;private ApplicationEventPublisher publisher;private void loadDynamicRoutes() {routeDefinitionWriter.save(Mono.just(createRoute())).subscribe();}@Overridepublic void run(ApplicationArguments args) throws Exception {loadDynamicRoutes();publisher.publishEvent(new RefreshRoutesEvent(this));}public RouteDefinition createRoute() {PredicateDefinition predicateDefinition = new PredicateDefinition();List<PredicateDefinition> predicates = new ArrayList<>();predicates.add(predicateDefinition);Map<String, String> argsPredicate = new LinkedHashMap<>();argsPredicate.put("key0", "/test/**");predicateDefinition.setName("Path");predicateDefinition.setArgs(argsPredicate);FilterDefinition filterDefinition = new FilterDefinition();List<FilterDefinition> filters = new ArrayList<>();filters.add(filterDefinition);Map<String, String> argsFilter = new LinkedHashMap<>();argsFilter.put("name", "X-Request-Example");argsFilter.put("value", "Example");filterDefinition.setName("AddRequestHeader");filterDefinition.setArgs(argsFilter);RouteDefinition routeDefinition = new RouteDefinition();routeDefinition.setUri(URI.create("http://192.168.3.104:9898"));routeDefinition.setOrder(1);routeDefinition.setId("mybatis-plus-test");routeDefinition.setPredicates(predicates);routeDefinition.setFilters(filters);return routeDefinition;}@Overridepublic void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {this.publisher = applicationEventPublisher;}}

##publisher.publishEvent(new RefreshRoutesEvent(this));发布事件。调用CachingRouteLocator刷新缓存源码

private final Map<String, List> cache = new ConcurrentHashMap<>();

java">@Overridepublic void onApplicationEvent(RefreshRoutesEvent event) {try {fetch().collect(Collectors.toList()).subscribe(list -> Flux.fromIterable(list).materialize().collect(Collectors.toList()).subscribe(signals -> {applicationEventPublisher.publishEvent(new RefreshRoutesResultEvent(this));cache.put(CACHE_KEY, signals);}, throwable -> handleRefreshError(throwable)));}catch (Throwable e) {handleRefreshError(e);}}

##fetch方法

java">private Flux<Route> fetch() {return this.delegate.getRoutes().sort(AnnotationAwareOrderComparator.INSTANCE);}

##fetch方法通过CompositeRouteLocator获取路由

java">@Overridepublic Flux<Route> getRoutes() {return this.delegates.flatMapSequential(RouteLocator::getRoutes);}

##spring gateway 请求阶段查找路由

从CachingRouteLocator缓存中查找

##AsyncPredicate.DefaultAsyncPredicate.apply 判断路径是否匹配

 ##匹配方法

 


http://www.ppmy.cn/embedded/137664.html

相关文章

假设检验——基于Python实现

第 7 章——假设检验 7.1 假设检验的原理 7.2 总体均值的检验 【例7-3】——一个 总体均值的检验——大样本 【代码框7-1】——一个 总体均值的检验——大样本 # 一个总体均值的检验(大样本) import pandas as pd from statsmodels.stats.weightstats import ztest exa…

LuaJIT源码分析(六)语法分析

LuaJIT源码分析&#xff08;六&#xff09;语法分析 lua虚拟机在编译lua脚本时&#xff0c;在对源代码进行词法分析之后&#xff0c;还需要进行语法分析&#xff0c;把源代码翻译成字节码。lua 5.1完整的语法描述如下&#xff1a; LuaJIT采用的是递归下降的解析方式&#xff0c…

前端呈现效果:鱼眼相机城市环境图像分割

鱼眼相机城市环境图像分割系统源码&#xff06;数据集分享 [yolov8-seg-SPDConv&#xff06;yolov8-seg-vanillanet等50全套改进创新点发刊_一键训练教程_Web前端展示] 1.研究背景与意义 项目参考ILSVRC ImageNet Large Scale Visual Recognition Challenge 项目来源AAAI G…

爬虫补环境案例---问财网(rpc,jsdom,代理,selenium)

目录 一.环境检测 1. 什么是环境检测 2.案例讲解 二 .吐环境脚本 1. 简介 2. 基础使用方法 3.数据返回 4. 完整代理使用 5. 代理封装 6. 封装所有使用方法 jsdom补环境 1. 环境安装 2. 基本使用 3. 添加参数形式 Selenium补环境 1. 简介 2.实战案例 1. 逆向目…

C哈的刷题计划之输出数字螺旋矩阵(1)

1、盲听C哈说 都说数据结构与算法是编程的核心&#xff0c;它们两个是内功与心法&#x1f600;&#xff0c;其它编程工具只是招式&#xff0c;学会了内功与心法&#xff0c;学习新事物&#xff08;这里特指层出不穷的IT技术&#xff09;就没有那么难了&#xff0c;实际上&#…

【面试全纪实 | Nginx 04】请回答,你真的精通Nginx吗?

&#x1f5fa;️博客地图 &#x1f4cd;1、location的作用是什么&#xff1f; &#x1f4cd;2、你知道漏桶流算法和令牌桶算法吗&#xff1f; &#x1f4cd;3、Nginx限流怎么做的&#xff1f; &#x1f4cd;4、为什么要做动静分离&#xff1f; &#x1f4cd;5、Nginx怎么做…

thinkphp如何查出值是null的布尔类型的值

exp 是用原生表达式查询的意思 $resDb::table(tbcardlist)->where(qc_hr_wac_hadsend,exp,is null or qc_hr_wac_hadsend0)->order(ID,asc)->find();查询值是null的字段的值时&#xff0c;要写 name is null 写 name null 是查不出正确的数据的 要写 name is null …

【K8S问题系列 | 9】如何监控集群CPU使用率并设置告警?

监控 Kubernetes 集群的 CPU 使用率并设置告警是确保集群健康和性能的关键步骤。以下是详细的步骤,包括所需工具和配置方法。 1. 安装监控工具 1.1 Prometheus Prometheus 是一个开源监控系统,能够收集和存储时间序列数据。你可以通过 Helm 或 Kubernetes 清单来安装 Prom…