瓜农老梁

一个想分享点干货的家伙，微信公众号「瓜农老梁」

0%

发表于 更新于 分类于

查看broker状态信息

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
bin/mqadmin brokerStatus -b 192.168.1.x:10911 -n 192.168.1.x:9876

Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0

Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0

bootTimestamp : 1535597348792

brokerVersion : 232

brokerVersionDesc : V4_1_0_SNAPSHOT

commitLogDirCapacity : Total : 8.7 TiB, Free : 7.7 TiB.

commitLogDiskRatio : 0.11147464487710743

commitLogMaxOffset : 6652182757965

commitLogMinOffset : 5676873023488

consumeQueueDiskRatio : 0.11147464487710743

dispatchBehindBytes : 0

dispatchMaxBuffer : 0

earliestMessageTimeStamp : 1539290831130

getFoundTps : 24229.27707229277 24670.716261707163 24323.07766631239

getMessageEntireTimeMax : 4895

getMissTps : 23384.56154384562 24047.195280471955 23735.196223133637

getTotalTps : 47613.83861613839 48717.91154217912 48058.27388944603

getTransferedTps : 28046.395360463954 28519.931340199313 28905.699949690646

msgGetTotalTodayMorning : 30682264110

msgGetTotalTodayNow : 31750490006

msgGetTotalYesterdayMorning : 29219504313

msgPutTotalTodayMorning : 7329767893

msgPutTotalTodayNow : 7523090457

msgPutTotalYesterdayMorning : 7031035625

pageCacheLockTimeMills : 0

pullThreadPoolQueueCapacity : 100000

pullThreadPoolQueueHeadWaitTimeMills: 0

pullThreadPoolQueueSize : 0

putMessageAverageSize : 807.2943103360182

putMessageDistributeTime : [<=0ms]:229497 [0~10ms]:1275 [10~50ms]:4 [50~100ms]:0 [100~200ms]:0 [200~500ms]:0 [500ms~1s]:0 [1~2s]:0 [2~3s]:0 [3~4s]:0 [4~5s]:0 [5~10s]:0 [10s~]:0

putMessageEntireTimeMax : 10885

putMessageSizeTotal : 6073348121272

putMessageTimesTotal : 7523090456

putTps : 4424.957504249575 4466.0700596607 4577.724617932119

remainHowManyDataToCommit : 6.9 KiB

remainHowManyDataToFlush : 0 B

remainTransientStoreBufferNumbs : 3

runtime : [ 48 days, 7 hours, 52 minutes, 34 seconds ]

scheduleMessageOffset_1 : 5169358,5169358

scheduleMessageOffset_10 : 8161108,8171531

scheduleMessageOffset_11 : 7864781,7877885

scheduleMessageOffset_12 : 7584977,7601110

scheduleMessageOffset_13 : 7278660,7297334

scheduleMessageOffset_14 : 7123700,7146082

scheduleMessageOffset_15 : 7013493,7063463

scheduleMessageOffset_16 : 6864847,6950753

scheduleMessageOffset_17 : 6549491,6803414

scheduleMessageOffset_18 : 12887811,12894744

scheduleMessageOffset_3 : 13667462,13667752

scheduleMessageOffset_4 : 9780224,9781009

scheduleMessageOffset_5 : 63142105,63144981

scheduleMessageOffset_6 : 9185173,9188251

scheduleMessageOffset_7 : 9002046,9006727

scheduleMessageOffset_8 : 8834782,8841531

scheduleMessageOffset_9 : 1112865066,1112879874

sendThreadPoolQueueCapacity : 10000

sendThreadPoolQueueHeadWaitTimeMills: 0

sendThreadPoolQueueSize : 0

startAcceptSendRequestTimeStamp : 0

You have mail in /var/spool/mail/root
阅读全文 »

发表于 更新于 分类于

查看所有Topic吞吐Tps

1
2
3
4
5
6
7
8
9
10
11
12
bin/mqadmin statsAll -n localhost:9876

Topic Consumer Group InTPS OutTPS InMsg24Hour OutMsg24Hour

T_SCANRECORD_NEW_groy 0.00 0 NO_CONSUMER

T_SCANRECORD_NEW internationalScanRecordAll 5480.10 0.00 310165682 0

T_SCANRECORD_NEW realnameConsumer 5480.10 79.98 310165682 29896917

T_SCANRECORD_NEW AdpMqCluster_consumer2 5480.10 0.00 310165682 0

阅读全文 »

发表于 更新于 分类于

查看集群信息

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
bin/mqadmin clusterList -n localhost:9876

Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0

Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0

Cluster Name Broker Name BID Addr Version InTPS OutTPS

AdpMqCluster broker-a 0 192.168.1.x:10911 V3_4_6 2819.22 1077.39

AdpMqCluster broker-b 0 192.168.1.x:10911 V3_4_6 2839.42 1070.89

AdpMqCluster broker-c 0 192.168.1.x:10919 V3_4_6 2800.12 1058.39

AdpMqCluster broker-d 0 192.168.1.x:10915 V3_4_6 2897.04 1126.04

AdpMqCluster broker-e 0 192.168.1.x:10919 V3_4_6 2987.20 1181.88

AdpMqCluster broker-f 0 192.168.1.x:10915 V3_4_6 3010.40 1187.08
阅读全文 »

发表于 更新于 分类于

创建订阅组

1
bin/mqadmin updateSubGroup -n localhost:9876 -c DefaultCluster -g zto-tst-consumer

删除订阅组

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
bin/mqadmin deleteSubGroup -n 192.168.1.x:9876 -c AdpMqCluster -g CODCANCELSIGN

Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0

Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0

delete subscription group [CODCANCELSIGN] from broker [192.168.1.x:10911] in cluster [AdpMqCluster] success.

delete subscription group [CODCANCELSIGN] from broker [192.168.1.x:10911] in cluster [AdpMqCluster] success.

delete subscription group [CODCANCELSIGN] from broker [192.168.1.x:10919] in cluster [AdpMqCluster] success.

delete subscription group [CODCANCELSIGN] from broker [192.168.1.x:10915] in cluster [AdpMqCluster] success.

delete subscription group [CODCANCELSIGN] from broker [192.168.1.x:10915] in cluster [AdpMqCluster] success.

delete subscription group [CODCANCELSIGN] from broker [192.168.1.x:10919] in cluster [AdpMqCluster] success.

delete topic [%RETRY%CODCANCELSIGN] from cluster [xMqCluster] success.

delete topic [%RETRY%CODCANCELSIGN] from NameServer success.

delete topic [%DLQ%CODCANCELSIGN] from cluster [xMqCluster] success.

delete topic [%DLQ%CODCANCELSIGN] from NameServer success.
阅读全文 »

发表于 更新于 分类于

前言

继上文分析Channel实例化流程后，本文通过分析Channel的初始化流程。旨在从整体上厘清DefaultChannelPipeline、ChannelHandlerContext、ChannelHandler的逻辑关系。

阅读全文 »

发表于 更新于 分类于

消费端连接信息

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
bin/mqadmin consumerConnection -g T_SCANRECORD_NEW_GROUP -n 192.168.1.x:9876



Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0

Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0

001 127.0.0.1@60190 192.168.2.x:50104 JAVA V3_2_6_SNAPSHOT

002 127.0.0.1@7454 192.168.7.x:27692 JAVA V3_2_6_SNAPSHOT

003 127.0.0.1@31600 192.168.21.x:40243 JAVA V3_2_6_SNAPSHOT

004 127.0.0.1@21322 192.168.21.x:31416 JAVA V3_2_6_SNAPSHOT

005 127.0.0.1@39557 192.168.2.x:45959 JAVA V3_2_6_SNAPSHOT

006 127.0.0.1@24765 192.168.7.x:15166 JAVA V3_2_6_SNAPSHOT

007 127.0.0.1@26993 192.168.7.x:57864 JAVA V3_2_6_SNAPSHOT

008 127.0.0.1@652 192.168.21.x:59261 JAVA V3_2_6_SNAPSHOT

009 127.0.0.1@10388 192.168.21.x:1671 JAVA V3_2_6_SNAPSHOT

Below is subscription:001 Topic: %RETRY%T_SCANRECORD_NEW_GROUP SubExpression: *

002 Topic: T_SCANRECORD_NEW SubExpression: 1||2||3||4 || 5 || -5||7 || 45

ConsumeType: CONSUME_PASSIVELY

MessageModel: CLUSTERING

ConsumeFromWhere: CONSUME_FROM_FIRST_OFFSET
阅读全文 »

发表于 更新于 分类于

一、Channel概述

Channel提供了I/O的基本操作。从以下子接口中可以看出Netty对不同的底层协议提供了对应的channel来处理，例如：TCP/IP、UDP/IP、SCTP/IP、HTTP2等。

阅读全文 »

发表于 更新于 分类于

前言

Reactor模型是基于事件驱动的线程模型，可以分为Reactor单线程模型、Reactor多线程模型、主从Reactor多线程模型，通常基于在I/O多路复用实现。不同的角色职责有：Dispatcher负责事件分发、Acceptor负责处理客户端连接、Handler处理非连接事件（例如：读写事件）。

阅读全文 »

发表于 更新于 分类于

前言

前面三篇介绍了HPPT/2的“连接前言”、“二进制桢”、“头部压缩”。本文从“流及多路复用”、“流状态”、“流量控制”、“流优先级”、“HTTP/2扩展”介绍HTTP/2协议流相关知识。

阅读全文 »