Mpush系列[4]之限流过程分析2

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();