spring gateway 动态路由

ops/2024/11/14 15:18:21/

##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/ops/133597.html

相关文章

SpringBoot后端解决跨域问题

1.全局方式 新建一个conifg配置类&#xff0c;内容如下&#xff1a; Configuration public class CorsConfig implements WebMvcConfigurer {Overridepublic void addCorsMappings(CorsRegistry registry) {registry.addMapping("/**")//是否发送Cookie.allowCrede…

某m大厂面经1

mybatisplus有什么优点 mybatisplus如何进行多表查询 项目中有哪些表 xxl-job如何实现分布式定时任务 feign和nacos之间怎么交互 springboot服务启动流程 怎么用jar包启动类 maven打包的形式 dependence和dependencemanagement区别 redis应用场景 redisson怎么实现 …

无人机反制技术与方法:主动防御,被动防御技术原理详解

无人机反制技术与方法主要分为主动防御和被动防御两大类&#xff0c;以下是关于这两类防御技术的原理详解&#xff1a; 主动防御技术原理 主动防御系统旨在通过直接干扰或摧毁来攻击入侵的无人机。这类系统通常包括电子干扰、激光武器、定向能武器以及硬杀伤手段&#xff08;如…

数据库SQLite的使用

SQLite是一个C语言库&#xff0c;实现了一个小型、快速、独立、高可靠性、功能齐全的SQL数据库引擎。SQLite文件格式稳定、跨平台且向后兼容。SQLite源代码属于公共领域(public-domain)&#xff0c;任何人都可以免费将其用于任何目的。源码地址&#xff1a;https://github.com/…

Spring Boot 携手 Deeplearning4j:构建高效的企业知识图谱系统

Springboot 整合 Java DL4J 打造企业知识图谱构建系统 文章目录 Springboot 整合 Java DL4J 打造企业知识图谱构建系统DL4J 如何打造企业知识图谱构建系统!一、给您的引言二、技术概述1. Spring Boot2. Deeplearning4j3. 知识图谱构建技术 三、神经网络选择及理由四、数据集格式…

OpenCV DNN

OpenCV DNN 和 PyTorch 都是常用的深度学习框架&#xff0c;但它们的定位、使用场景和功能有所不同。让我们来对比一下这两个工具&#xff1a; 1. 框架和功能 OpenCV DNN&#xff1a;OpenCV DNN 模块主要用于加载和运行已经训练好的深度学习模型&#xff0c;支持多种深度学习…

docker配置代理解决不能拉镜像问题

Docker 客户端在尝试连接 Docker Hub&#xff08;registry-1.docker.io&#xff09;时遇到了超时问题&#xff0c;可能是网络连接不稳定或配置了代理等问题导致的。 1. 检查网络连接 首先&#xff0c;确保你能够访问互联网并且能够连接到 Docker Hub。 你可以尝试用 curl 来检…

【MongoDB】MongoDB的集群,部署架构,OptLog,集群优化等详解

文章目录 一、引入复制集的原因二、复制集成员&#xff08;一&#xff09;基本成员&#xff08;二&#xff09;主节点&#xff08;Primary&#xff09;细化成员 三、复制集常见部署架构&#xff08;一&#xff09;基础三节点&#xff08;二&#xff09;跨数据中心 四、复制集保…