Mpush系列[4]之限流过程分析2
2019-08-01 13:33:02 0 举报Mpush系列之限流过程分析
作者其他创作
大纲/内容
boolean checkQps():判断瞬时 QPS 是否超限
void broadcast():只对 local route 广播.
AckTaskQueue ackTaskQueue;
void push(message):
GlobalFlowControl
FlowControl
void reset();
RollingNumber rollingNumber;
checkLocal():1. 查找本地 connection;2. 构造 PushMessage3. 调用 message 的 send()发送
A3: 调用流控检查
void run();
getDelay(): hardcode 为100ms
void addTask(PushTask task)
A1 推送开始
PushCenter
ExactFlowControl
PushTaskExecutor executor;
operationComplete():
int qps():平均 QPS
A2: 线程池执行: executor.execute()
Mpush系列之限流过程分析(3)
BroadcastPushTask
PushTask extends Runnable
FastFlowControl
getExecutor();
0 条评论
下一页
![Mpush系列[2]之推送过程分析](https://www.processon.com/chart_image/template/thumb/5d386b01e4b092b33467e064.png?tid=5d386b01e4b092b33467e061)
![Mpush系列[3]之限流过程分析1](https://www.processon.com/chart_image/template/thumb/5d39b2bfe4b0d11c8911075c.png?tid=5d39b2bfe4b0d11c8911075a)
![Mpush系列[5]之Alloc 分析](https://www.processon.com/chart_image/template/thumb/5d3cea4fe4b0b3e4dcd54071.png?tid=5d3cea4fe4b0b3e4dcd5406f)
![Mpush系列[1]之启动过程分析](https://www.processon.com/chart_image/template/thumb/5d36dc80e4b0b3e4dccfc8d4.png?tid=5d36dc80e4b0b3e4dccfc8d2)
![Mpush系列[6]之SPI分析](https://www.processon.com/chart_image/template/thumb/5d3fe75ee4b0208611166ad5.png?tid=5d3fe75ee4b0208611166ad4)
