大家好，我是烤鸭：

1. 官方介绍

官方文档：

看的是 2.2.5.RELEASE 版本的

https://docs.spring.io/spring-cloud-gateway/docs/2.2.5.RELEASE/reference/html/

看一下官方这段说明，gateway 使用的是 webflux 和 reactor，有一些同步的包(data,security 可能不支持)。

还有就是需要netty作为服务器，传统的 servlet 模型和 war 包不支持。

工作流程：

简单说就是网关收到客户端的 request 之后经过一系列请求过滤器到代理的服务，收到 response之后，再经过一系列的响应过滤器返回到网关->客户端。

2. 源码分析

2.1 reactor 介绍

由于 gateway 是基于 reactor 的，先看下 reactor 的 Flux 和 Mono

reactor 是响应式编程，相对的传统模式遍历-> 拉取 ->TODO ，而响应式遍历（发布） -> 订阅者 -> TODO，是基于发布 — 订阅的模式。

而 Flux 和 Mono 是 Reactor 中的两个基本概念。都实现 CorePublisher 接口。(用于发布的元素)

Flux 表示的是包含 0 到 N 个元素的异步序列。在该序列中可以包含三种不同类型的消息通知：正常的包含元素的消息、序列结束的消息和序列出错的消息。当消息通知产生时，订阅者中对应的方法 onNext(), onComplete()和 onError()会被调用。Mono 表示的是包含 0 或者 1 个元素的异步序列。该序列中同样可以包含与 Flux 相同的三种类型的消息通知。Flux 和 Mono 之间可以进行转换。对一个 Flux 序列进行计数操作，得到的结果是一个 Mono对象。把两个 Mono 序列合并在一起，得到的是一个 Flux 对象。

2.2 handler 和 filter

看了网上一些资料，从 ReactorHttpHandlerAdapter.apply 开始，debug 看看从哪发起的。

HttpServerHandle.onStateChange 这个是监听连接状态的方法，可以看到请求刚进来的时候是 request_received

HttpWebHandlerAdapter.apply ，包装模式，request 和 response，继续执行 handle方法，生成 exchange 对象，将 request ,response 还有其他的 attribute 封装到一个对象

之后进去 Dispatcherhandler.handle ，这里边会有3个操作，获取路由(getHandler)、请求路由(invokeHandler)、解析结果(handleResult)

获取路由：AbstractHandlerMapping.getHandler (代码没贴,有个判断是否跨域配置的判断) 中间调用RoutePredicateHandlerMapping.getHandlerInternal，从RouteLocator 获取路由信息

请求路由：默认走的是 SimpleHandlerAdapter.handle

FilteringWebHandler.handle，获取路由对象和对应的 filter，经过过滤器链，默认是9个全局过滤器，主要看下 NettyRoutingFilter 和 NettyWriteResponseFilter

NettyRoutingFilter.filter 就是发送http请求，调用第三方服务，对response 请求头过滤处理，将response 封装到 Mono

NettyWriteResponseFilter.filter

可以看出来这时候netty 已经响应结果，并且往 exchange的reponse 写入

会判断响应的 content-type 是流还是其他的，如果是流的话，写入并刷新。这个地方看一下 wrap 方法，我找了半天都没有找到 gateway 在哪保存的第三方服务的返回值，就在这个byteBuf，封装 DataBuffer，设置到 DataBufferFactory，和 response 绑定。

看一下 wrap 方法

之后的方法调用 ReactorServerHttpResponse.writeWithInternal ，感兴趣可以看出，代码就不贴了。

由于 SimpleHandlerAdapter 返回的是 `Mono.empty()` ，所以不会触发 handleResult 方法。

其中还有HttpServerHandle.onStateChange 监听到其他的状态，也不贴了。

3. 总结

以上就是 gateway 收到请求后，到返回一系列的流程，内容也不是特别全。

监听到请求进入：HttpServerHandle.onStateChange(newState = request_received) ->

包装 request和response：ReactorHttpHandlerAdapter.apply ->

生成 exchange(包含 request和 response)，用于netty请求 : HttpWebHandlerAdapter.apply ->

获取路由、请求路由、解析结果：Dispatcherhandler.handle ->

获取路由 AbstractHandlerMapping.getHandler：-> RoutePredicateHandlerMapping.getHandlerInternal

请求路由：SimpleHandlerAdapter.handle：-> FilteringWebHandler.handle

默认9个全局过滤器：

发送http请求，调用第三方服务，对response 请求头过滤处理，将response 封装到 Mono：NettyRoutingFilter.filter

获取netty 响应结果，并且往 exchange的reponse 写入：NettyWriteResponseFilter.filter

结果解析：ResponseBodyResultHandler.handleResult （由于 SimpleHandlerAdapter 返回的是 Mono.empty()，所以不会触发 handleResult 方法）

写入response并返回：NettyWriteResponseFilter.wrap （byteBuf，封装 DataBuffer，设置到 DataBufferFactory，和 response 绑定）

所以看到有一些想在网关层面修改 response 的需求，只需要增加一个filter 修改 response绑定的 DataBufferFactory 中的 DataBuffer 即可。

还有一些不错的文章推荐：

https://developer.ibm.com/zh/articles/j-cn-with-reactor-response-encode/

https://blog.csdn.net/chengqiuming/article/details/103394337

https://www.jianshu.com/p/c40a757fad01

springcloud gateway 源码解析、请求响应流程、第三方响应结果在 gateway 的经过相关推荐

Retrofit2源码解析——网络调用流程(下)
Retrofit2源码解析系列 Retrofit2源码解析(一) Retrofit2源码解析--网络调用流程(上) 本文基于Retrofit2的2.4.0版本 implementation 'com. ...
android 输入法如何启动流程_android输入法02：openwnn源码解析01—输入流程
android 输入法 02:openwnn 源码解析 01-输入流程之后要开始 android 日文输入法的测试,因此现在开始研究 android 输入法.之前两篇文章已经对 android 自 ...
Spring Cloud Gateway 源码解析（3） —— Predicate
目录 RoutePredicateFactory GatewayPredicate AfterRoutePredicateFactory RoutePredicateHandlerMapping Fi ...
Spring Cloud Gateway 源码解析（1） —— 基础
目录 Gateway初始化启用Gateway GatewayClassPathWarningAutoConfiguration GatewayLoadBalancerClientAutoConfig ...
Glide源码解析-加载流程
1 引言一直想要阅读Glide源码,但是苦于时间和功力都不够,总是断断续续的,趁着现在有一些空暇时间,来简要分析Glide的源码.Glide的实现太过复杂,不可能做到面面俱到,如果每一行都细致分析, ...
【ceph】CEPH源码解析：读写流程
相同过程 Ceph的读/写操作采用Primary-Replica模型,客户端只向Object所对应OSD set的Primary OSD发起读/写请求,这保证了数据的强一致性.当Primary OSD ...
Ceph源码解析：读写流程
一.OSD模块简介 1.1 消息封装:在OSD上发送和接收信息. cluster_messenger -与其它OSDs和monitors沟通 client_messenger -与客户端沟通 1.2 ...
api网关揭秘--spring cloud gateway源码解析
要想了解spring cloud gateway的源码,要熟悉spring webflux,我的上篇文章介绍了spring webflux. 1.gateway 和zuul对比 I am the au ...
3.MyBatis源码解析-CRUD执行流程--阿呆中二
CRUD执行流程 MyBatis CRUD执行流程与我联系 MyBatis 本文是对mybatis 3.x源码深度解析与最佳实践学习的总结,包括XML文件解析流程.SqlSession构建流程.CR ...

springcloud gateway 源码解析、请求响应流程、第三方响应结果在 gateway 的经过