A6
ZuulFilterChainHandler
nextStage;
PassportItem
stop();
HttpBodySizeRecordingChannelHandler
Passport
HashSet<PassportState> statesAdded;
putFilter(File file);
A5
PassportState
ClientResponseWriter
A2: 创建boss&work
SampleServerStartup
incrementStateCounter(PassportState state);
SessionContext context;
endpoint
ServerChannelMetrics
IdleStateHandler
time;
getFilterChainRunner();
CountingCurrentPassport
LinkedList<PassportItem> history;
右边这部分本图尚未涉及
ZUUL
什么是 Passport1. CurrentPassport以ch.attr(CHANNEL_ATTR).set(passport)的方式绑定在 每个channel 上.2. 每个 channel只有一个 passport.3. 每次状态变化都会盖戳.4. CountingCurrentPassport 对一些状态做了全局计数.5. 有点像Dapper(Google的生产环境下的分布式系统跟踪平台)里的 traceID.
ServerGroup
ServerStatusHeaderHandler
ElbProxyProtocolChannelHandler
HttpRequestInfo
pipeline
A4
HttpServerCodec
add(PassportState state);
requestFilters
A7
HttpRequestMessageImpl
SourceAddressChannelHandler
rateLimitingChannelHandler
A8: create
PassportStateServerHandler
ZuulFilter newInstance(Class clazz);
CurrentPassport
A3: init
HttpRequestMessage
PassportStateHttpServerHandler
ZuulMessage
TCP
setupServerBootstrap();1. 标准的 netty server 的启动过程2. bossgroup/workgroup从ServerGroup里取.
ZuulServerChannelInitializer
ServerGroup serverGroup;
BaseZuulChannelInitializer
Http1ConnectionExpiryHandler
TIMEOUT
ChannelGroup channels;
EventLoopGroup clientToProxyWorkerPool
initChannel(Channel ch);
HTTP
HttpMetricsChannelHandler
choosePortsAndChannels();
load
EurekaClient discoveryClient;
A1: 创建 server
addZuulHandlers()
perEventLoopRequestsMetricsHandler
responseFilters
perEventLoopMetricsHandler
requestFilterChain;
ClientRequestReceiver
responseFilterChain;
HttpServerLifecycleChannelHandler
getFiltersByType();
BaseServerStartup
LoggingHandler
init();
requestFilterChain
start();启动所有给定端口服务
ChannelInitializer extends ChannelInboundHandlerAdapter
EventLoopGroup clientToProxyBossPool
ZuulMessageImpl
Server
passportLoggingHandler
ZuulFilter getFilter();
FilterLoader
SessionContext
addZuulFilterChainHandler( pipeline)
EventLoopConfig eventLoopConfig;
Server server;
Http1ConnectionCloseHandler
StripUntrustedProxyHeadersHandler
responseFilterChain
Zuul 2系列[1]之启动过程: 左侧链路
FilterFactory
channelRead();
FilterRegistry
endPoint
CloseOnIdleStateHandler
HTTP1
![Mpush系列[3]之限流过程分析1](https://www.processon.com/chart_image/template/thumb/5d3e5963e4b0fe2602d4caf8.png?tid=5d39b2bfe4b0d11c8911075a)
![Mpush系列[1]之启动过程分析](https://www.processon.com/chart_image/template/thumb/5d391288e4b0fe2602d4ac18.png?tid=5d36dc80e4b0b3e4dccfc8d2)
