This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch dev-0729
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit a853bbc9287a59d6e72d6b9e81eba720838f9a80
Author: RongtongJin <jinrongton...@mails.ucas.ac.cn>
AuthorDate: Mon Jul 29 16:35:13 2024 +0800
Some important statistical items should also be deleted to prevent memory
leakage when a topic or group is deleted
---
.../org/apache/rocketmq/common/stats/Stats.java | 3 +++
.../rocketmq/store/stats/BrokerStatsManager.java | 24 +++++++++++++---------
2 files changed, 17 insertions(+), 10 deletions(-)
diff --git a/common/src/main/java/org/apache/rocketmq/common/stats/Stats.java
b/common/src/main/java/org/apache/rocketmq/common/stats/Stats.java
index b70f96e412..f67ccf9ae9 100644
--- a/common/src/main/java/org/apache/rocketmq/common/stats/Stats.java
+++ b/common/src/main/java/org/apache/rocketmq/common/stats/Stats.java
@@ -44,4 +44,7 @@ public class Stats {
public static final String GROUP_GET_FALL_SIZE = "GROUP_GET_FALL_SIZE";
public static final String GROUP_GET_FALL_TIME = "GROUP_GET_FALL_TIME";
public static final String GROUP_GET_LATENCY = "GROUP_GET_LATENCY";
+ public static final String TOPIC_PUT_LATENCY = "TOPIC_PUT_LATENCY";
+ public static final String GROUP_ACK_NUMS = "GROUP_ACK_NUMS";
+ public static final String GROUP_CK_NUMS = "GROUP_CK_NUMS";
}
diff --git
a/store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java
b/store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java
index c165d333fd..a6c33f6131 100644
---
a/store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java
+++
b/store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java
@@ -69,9 +69,9 @@ public class BrokerStatsManager {
@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";
- public static final String GROUP_CK_NUMS = "GROUP_CK_NUMS";
+ @Deprecated public static final String TOPIC_PUT_LATENCY =
"TOPIC_PUT_LATENCY";
+ @Deprecated public static final String GROUP_ACK_NUMS = "GROUP_ACK_NUMS";
+ @Deprecated public static final String GROUP_CK_NUMS = "GROUP_CK_NUMS";
public static final String DLQ_PUT_NUMS = "DLQ_PUT_NUMS";
public static final String BROKER_ACK_NUMS = "BROKER_ACK_NUMS";
public static final String BROKER_CK_NUMS = "BROKER_CK_NUMS";
@@ -179,10 +179,10 @@ public class BrokerStatsManager {
this.statsTable.put(Stats.TOPIC_PUT_SIZE, new
StatsItemSet(Stats.TOPIC_PUT_SIZE, this.scheduledExecutorService, log));
this.statsTable.put(Stats.GROUP_GET_NUMS, new
StatsItemSet(Stats.GROUP_GET_NUMS, this.scheduledExecutorService, log));
this.statsTable.put(Stats.GROUP_GET_SIZE, new
StatsItemSet(Stats.GROUP_GET_SIZE, this.scheduledExecutorService, log));
- this.statsTable.put(GROUP_ACK_NUMS, new StatsItemSet(GROUP_ACK_NUMS,
this.scheduledExecutorService, log));
- this.statsTable.put(GROUP_CK_NUMS, new StatsItemSet(GROUP_CK_NUMS,
this.scheduledExecutorService, log));
+ this.statsTable.put(Stats.GROUP_ACK_NUMS, new
StatsItemSet(Stats.GROUP_ACK_NUMS, this.scheduledExecutorService, log));
+ this.statsTable.put(Stats.GROUP_CK_NUMS, new
StatsItemSet(Stats.GROUP_CK_NUMS, this.scheduledExecutorService, log));
this.statsTable.put(Stats.GROUP_GET_LATENCY, new
StatsItemSet(Stats.GROUP_GET_LATENCY, this.scheduledExecutorService, log));
- this.statsTable.put(TOPIC_PUT_LATENCY, new
StatsItemSet(TOPIC_PUT_LATENCY, this.scheduledExecutorService, log));
+ this.statsTable.put(Stats.TOPIC_PUT_LATENCY, new
StatsItemSet(Stats.TOPIC_PUT_LATENCY, this.scheduledExecutorService, log));
this.statsTable.put(Stats.SNDBCK_PUT_NUMS, new
StatsItemSet(Stats.SNDBCK_PUT_NUMS, this.scheduledExecutorService, log));
this.statsTable.put(DLQ_PUT_NUMS, new StatsItemSet(DLQ_PUT_NUMS,
this.scheduledExecutorService, log));
this.statsTable.put(Stats.BROKER_PUT_NUMS, new
StatsItemSet(Stats.BROKER_PUT_NUMS, this.scheduledExecutorService, log));
@@ -338,10 +338,13 @@ public class BrokerStatsManager {
}
this.statsTable.get(Stats.GROUP_GET_NUMS).delValueByPrefixKey(topic,
"@");
this.statsTable.get(Stats.GROUP_GET_SIZE).delValueByPrefixKey(topic,
"@");
+ this.statsTable.get(Stats.GROUP_CK_NUMS).delValueByPrefixKey(topic,
"@");
+ this.statsTable.get(Stats.GROUP_ACK_NUMS).delValueByPrefixKey(topic,
"@");
this.statsTable.get(Stats.QUEUE_GET_NUMS).delValueByPrefixKey(topic,
"@");
this.statsTable.get(Stats.QUEUE_GET_SIZE).delValueByPrefixKey(topic,
"@");
this.statsTable.get(Stats.SNDBCK_PUT_NUMS).delValueByPrefixKey(topic,
"@");
this.statsTable.get(Stats.GROUP_GET_LATENCY).delValueByInfixKey(topic,
"@");
+
this.statsTable.get(Stats.TOPIC_PUT_LATENCY).delValueBySuffixKey(topic, "@");
this.momentStatsItemSetFallSize.delValueByInfixKey(topic, "@");
this.momentStatsItemSetFallTime.delValueByInfixKey(topic, "@");
}
@@ -349,6 +352,8 @@ public class BrokerStatsManager {
public void onGroupDeleted(final String group) {
this.statsTable.get(Stats.GROUP_GET_NUMS).delValueBySuffixKey(group,
"@");
this.statsTable.get(Stats.GROUP_GET_SIZE).delValueBySuffixKey(group,
"@");
+ this.statsTable.get(Stats.GROUP_CK_NUMS).delValueBySuffixKey(group,
"@");
+ this.statsTable.get(Stats.GROUP_ACK_NUMS).delValueBySuffixKey(group,
"@");
if (enableQueueStat) {
this.statsTable.get(Stats.QUEUE_GET_NUMS).delValueBySuffixKey(group, "@");
this.statsTable.get(Stats.QUEUE_GET_SIZE).delValueBySuffixKey(group, "@");
@@ -434,12 +439,12 @@ public class BrokerStatsManager {
public void incGroupCkNums(final String group, final String topic, final
int incValue) {
final String statsKey = buildStatsKey(topic, group);
- this.statsTable.get(GROUP_CK_NUMS).addValue(statsKey, incValue, 1);
+ this.statsTable.get(Stats.GROUP_CK_NUMS).addValue(statsKey, incValue,
1);
}
public void incGroupAckNums(final String group, final String topic, final
int incValue) {
final String statsKey = buildStatsKey(topic, group);
- this.statsTable.get(GROUP_ACK_NUMS).addValue(statsKey, incValue, 1);
+ this.statsTable.get(Stats.GROUP_ACK_NUMS).addValue(statsKey, incValue,
1);
}
public String buildStatsKey(String topic, String group) {
@@ -509,9 +514,8 @@ public class BrokerStatsManager {
statsKey = new StringBuilder(6);
}
statsKey.append(queueId).append("@").append(topic);
- this.statsTable.get(TOPIC_PUT_LATENCY).addValue(statsKey.toString(),
incValue, 1);
+
this.statsTable.get(Stats.TOPIC_PUT_LATENCY).addValue(statsKey.toString(),
incValue, 1);
}
-
public void incBrokerPutNums() {
this.statsTable.get(Stats.BROKER_PUT_NUMS).getAndCreateStatsItem(this.clusterName).getValue().add(1);
}
