opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-01 15:47:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #5804] Optimize BrokerStatsManager#incTopicPutLatency create statsKey (#5805)

Browse Source
This commit is contained in:
mxsm
2023-01-12 10:42:41 +08:00
committed by GitHub
parent fa22a78387
commit dc902082bd
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java
+8 -3
View File
@@ -68,7 +68,6 @@ public class BrokerStatsManager {
@Deprecated public static final String COMMERCIAL_RCV_SIZE = Stats.COMMERCIAL_RCV_SIZE;
@Deprecated public static final String COMMERCIAL_PERM_FAILURES = Stats.COMMERCIAL_PERM_FAILURES;
// Send message latency
public static final String TOPIC_PUT_LATENCY = "TOPIC_PUT_LATENCY";
public static final String GROUP_ACK_NUMS = "GROUP_ACK_NUMS";
@@ -500,8 +499,14 @@ public class BrokerStatsManager {
}
public void incTopicPutLatency(final String topic, final int queueId, final int incValue) {
final String statsKey = String.format("%d@%s", queueId, topic);
this.statsTable.get(TOPIC_PUT_LATENCY).addValue(statsKey, incValue, 1);
StringBuilder statsKey;
if (topic != null) {
statsKey = new StringBuilder(topic.length() + 6);
} else {
statsKey = new StringBuilder(6);
}
statsKey.append(queueId).append("@").append(topic);
this.statsTable.get(TOPIC_PUT_LATENCY).addValue(statsKey.toString(), incValue, 1);
}
public void incBrokerPutNums() {