Mpush系列[3]之限流过程分析1
2025-03-24 17:15:20 0 举报mpush 的限流分析
作者其他创作
大纲/内容
RollingNumber
A4: 提供统计结果
0
long windowStart;
Bucket3
value
BucketCircularArray
time;
time
THREAD_POOL_REJECTED4
https://github.com/Netflix/Hystrix/blob/master/hystrix-core/src/main/java/com/netflix/hystrix/util/HystrixRollingNumber.java限流的核心包括: 1. 计数2. 策略本图分析计数部分.
Bucket
......
CumulativeSum
long get(Event type)
FAILURE1
1LongAdder
ListState
3LongAdder
LongAdder[] adderForCounterType;
ListState addBucket(Bucket b);
Bucket0
tail
4LongAdder
AtomicReferenceArray<Bucket> data;
Bucket5
addBucket(Bucket lastBucket)
4
timeInMilliseconds
Bucket2
Eventordinal()
...LongAdder
0LongAdder
addLast();
cumulativeSum
5LongAdder
head
Hystrix Rollingnumbr
long getCumulativeSum(type)
Bucket6
dataLength=8;1个定值. // 8为举例说明
Bucket1
..
SUCCESS0
SHORT_CIRCUITED3
1
2LongAdder
这里用到了设计模式之不变模式span style=\"font-size: inherit;\
A1: 通过 tail 找到当前的桶
Bucket4
∑
3
COLLAPSER_BATCHN
NLongAdder
LongAdder getAdder(Event type)
BucketCircularArray buckets;
current
7
2
numberOfBuckets
Bucket7
TIMEOUT2
numBuckets = dataLength -1;
6
SEMAPHORE_REJECTED5
size =(tail + dataLength - head) % dataLength
5
LongAdder getAdder(Event type);
AtomicReference<ListState> state;
return adderForCounterType[type.ordinal()]
![Mpush系列[3]之限流过程分析1](https://www.processon.com/chart_image/template/thumb/5d3e5963e4b0fe2602d4caf8.png?tid=5d39b2bfe4b0d11c8911075a)
0 条评论
下一页
![Mpush系列[6]之SPI分析](https://www.processon.com/chart_image/template/thumb/5d3fe75ee4b0208611166ad5.png?tid=5d3fe75ee4b0208611166ad4)
![Mpush系列[1]之启动过程分析](https://www.processon.com/chart_image/template/thumb/5d36dc80e4b0b3e4dccfc8d4.png?tid=5d36dc80e4b0b3e4dccfc8d2)
![Mpush系列[7]之gateway client分析](https://www.processon.com/chart_image/template/thumb/5d42a392e4b043dcf84e37a8.png?tid=5d42a392e4b043dcf84e37a7)
![Mpush系列[2]之推送过程分析](https://www.processon.com/chart_image/template/thumb/5d386b01e4b092b33467e064.png?tid=5d386b01e4b092b33467e061)
![Mpush系列[4]之限流过程分析2](https://www.processon.com/chart_image/template/thumb/5d3c45c6e4b065dc42b4959c.png?tid=5d3c45c6e4b065dc42b4959a)
