gateway&reactive(响应式流)函数编程的webflux
2021-04-02 17:27
标签:添加 简单 build 关注 构造 ogg http uri 编程语言 springcloud.gateway是springcloud2的全新项目,该项目提供了一个构建在spring生态之上的API网关,包括spring5,springboot2,projectReactor。gateway旨在提高一种简单而有效的途径来转发请求,并为他们提供横切关注点,如安全性,监控/指标和弹性。在之前springcloud提供的网关是zull,zuul基于servlet2.5,使用阻塞架构,不支持长连接。zuul和negix相似,除了编程语言不同,zuul已经发布了zuul2,支持长连接,非阻塞,但是springcloud还没有整合。 项目构建: 引入gateway和eureka依赖,gateway的网关提供了路由配置,路由断言,过滤器等功能。 一, 路由断言: 路由断言接口由函数式接口RouterFunction接口提供支持,通过RouterFunctions的静态route方法来实现,如下: 而生成需要两个参数他们分别是:RequestPredicate predicate和 HandlerFunction predicate由RequestPredicates.path()产生,handlerFunction是接口HandlerFunction 所以添加路由断言的配置类方法如下: 此时路由断言的作用是当请求的路径是/test时,直接返回状态吗200,且响应体为this is ok。 为什么呢? 从上面可以看出,serverResponse持有serverHttpResponse,而serverHttpResponse持有HttpServletResponse。所以这就是webflux的reactive响应式流编程实现流程。 二,过滤器: 网关经常要做的是对路由请求进行过滤,对符合条件的请求进行一些操作,如增加请求头,增加请求参数,增加响应头和断路器等功能。这个功能通过函数接口RouteLocator实现,RouteLocator通过RouteLocatorBuilder来获得: RouteLocatorBuilder.Builder.routes就是路由表,如下图: 具体类调用流程如下: 上面第5行的意思是Builder.route(Function 我们需要一个asyncbuilder,所以需要实现Function接口,如下: 三,网关与服务中心结合 下面是service1的controller: 启动service1和gateway两个服务,注册到eureka,然后访问: ok,先到这里,源码后续再补充。 gateway&reactive(响应式流)函数编程的webflux 标签:添加 简单 build 关注 构造 ogg http uri 编程语言 原文地址:https://www.cnblogs.com/YsirSun/p/12552151.html 1 public static
private abstract static class AbstractRouterFunction
1 @Bean//路由断言
2 public RouterFunction
@FunctionalInterface
public interface HandlerFunction
下图的类都在org.springframework.web.reactive包下:
1 @Bean//过滤器
2 public RouteLocator customRouteLocator(RouteLocatorBuilder builder){
3 return builder.routes().route(
4
5 r -> r.path("/baidu")
6 .filters(f -> f.addResponseHeader("X-AnotherHeader","baz"))
7 .uri("http://www.baidu.com")
8
9 ).build();
10 } 1 public RouteLocatorBuilder.Builder routes() {
2 return new RouteLocatorBuilder.Builder(this.context);
3 }
4
5 public RouteLocatorBuilder.Builder route(Function
User
的话,那现在就返回Mono
;原来返回List
的话,那现在就返回Flux
。第18行调用build构造route。 r -> r.path("/baidu").filters(f -> f.addRequestHeader("X-AnotherHeader","baz")).uri("http://www.baidu.com")
上述方法体会最终得到一个asyncbuilder,然后开始上述带颜色部分的内容。上面的功能就是当请求路径中有baidu,就在返回头上加上一个属性,然后转到该http://www.baidu.com地址。 1 spring:
2 application:
3 name: gateway #hystrix服务类型
4 cloud:
5 gateway:
6 locator:
7 enabled: true #开启gateway和eureka的结合
8 routes:
9 - id: service_eureka-service1 #id
10 uri: lb://eureka-service1 #服务
11 predicates:
12 - Path=/service_eureka-service1/** #匹配路径
13 filters:
14 - StripPrefix=1 #使用路径过滤器去掉第一部分前缀 即去除service_eureka-service1这一部分
参考文章:https://blog.csdn.net/get_set/article/details/79480233 这兄弟的文章真不错。
下一篇:浅谈js的this指向问题
文章标题:gateway&reactive(响应式流)函数编程的webflux
文章链接:http://soscw.com/essay/71477.html