This is an automated email from the ASF dual-hosted git repository.
ltamber pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new f86fb40904 [ISSUE #9188] Use fastjson2 in
org/apache/rocketmq/broker/config/v1 (#9189)
f86fb40904 is described below
commit f86fb4090442ecdb0dda7583c5edbc6cd87c22cd
Author: yx9o <[email protected]>
AuthorDate: Fri Apr 11 14:24:25 2025 +0800
[ISSUE #9188] Use fastjson2 in org/apache/rocketmq/broker/config/v1 (#9189)
---
.../config/v1/RocksDBConsumerOffsetManager.java | 15 +++++++-------
.../config/v1/RocksDBSubscriptionGroupManager.java | 23 +++++++++++-----------
.../config/v1/RocksDBTopicConfigManager.java | 13 ++++++------
3 files changed, 27 insertions(+), 24 deletions(-)
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBConsumerOffsetManager.java
b/broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBConsumerOffsetManager.java
index 963c5046f2..db3a38a9bf 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBConsumerOffsetManager.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBConsumerOffsetManager.java
@@ -16,12 +16,8 @@
*/
package org.apache.rocketmq.broker.config.v1;
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.serializer.SerializerFeature;
-import java.io.File;
-import java.util.Iterator;
-import java.util.Map.Entry;
-import java.util.concurrent.ConcurrentMap;
+import com.alibaba.fastjson2.JSON;
+import com.alibaba.fastjson2.JSONWriter;
import org.apache.rocketmq.broker.BrokerController;
import org.apache.rocketmq.broker.RocksDBConfigManager;
import org.apache.rocketmq.broker.offset.ConsumerOffsetManager;
@@ -34,6 +30,11 @@ import org.apache.rocketmq.remoting.protocol.DataVersion;
import org.rocksdb.CompressionType;
import org.rocksdb.WriteBatch;
+import java.io.File;
+import java.util.Iterator;
+import java.util.Map.Entry;
+import java.util.concurrent.ConcurrentMap;
+
public class RocksDBConsumerOffsetManager extends ConsumerOffsetManager {
protected static final Logger log =
LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
@@ -147,7 +148,7 @@ public class RocksDBConsumerOffsetManager extends
ConsumerOffsetManager {
byte[] keyBytes = topicGroupName.getBytes(DataConverter.CHARSET_UTF8);
RocksDBOffsetSerializeWrapper wrapper = new
RocksDBOffsetSerializeWrapper();
wrapper.setOffsetTable(offsetMap);
- byte[] valueBytes = JSON.toJSONBytes(wrapper,
SerializerFeature.BrowserCompatible);
+ byte[] valueBytes = JSON.toJSONBytes(wrapper,
JSONWriter.Feature.BrowserCompatible);
writeBatch.put(keyBytes, valueBytes);
}
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBSubscriptionGroupManager.java
b/broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBSubscriptionGroupManager.java
index b208169e41..b82e050909 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBSubscriptionGroupManager.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBSubscriptionGroupManager.java
@@ -16,15 +16,9 @@
*/
package org.apache.rocketmq.broker.config.v1;
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONObject;
-import com.alibaba.fastjson.serializer.SerializerFeature;
-import java.io.File;
-import java.util.Map;
-import java.util.Set;
-import java.util.concurrent.ConcurrentHashMap;
-import java.util.concurrent.ConcurrentMap;
-import java.util.function.BiConsumer;
+import com.alibaba.fastjson2.JSON;
+import com.alibaba.fastjson2.JSONObject;
+import com.alibaba.fastjson2.JSONWriter;
import org.apache.rocketmq.broker.BrokerController;
import org.apache.rocketmq.broker.RocksDBConfigManager;
import org.apache.rocketmq.broker.subscription.SubscriptionGroupManager;
@@ -35,6 +29,13 @@ import
org.apache.rocketmq.remoting.protocol.subscription.SubscriptionGroupConfi
import org.rocksdb.CompressionType;
import org.rocksdb.RocksIterator;
+import java.io.File;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ConcurrentMap;
+import java.util.function.BiConsumer;
+
public class RocksDBSubscriptionGroupManager extends SubscriptionGroupManager {
protected transient RocksDBConfigManager rocksDBConfigManager;
@@ -132,7 +133,7 @@ public class RocksDBSubscriptionGroupManager extends
SubscriptionGroupManager {
try {
byte[] keyBytes = groupName.getBytes(DataConverter.CHARSET_UTF8);
- byte[] valueBytes = JSON.toJSONBytes(subscriptionGroupConfig,
SerializerFeature.BrowserCompatible);
+ byte[] valueBytes = JSON.toJSONBytes(subscriptionGroupConfig,
JSONWriter.Feature.BrowserCompatible);
this.rocksDBConfigManager.put(keyBytes, keyBytes.length,
valueBytes);
} catch (Exception e) {
log.error("kv put sub Failed, {}",
subscriptionGroupConfig.toString());
@@ -147,7 +148,7 @@ public class RocksDBSubscriptionGroupManager extends
SubscriptionGroupManager {
if (oldConfig == null) {
try {
byte[] keyBytes =
groupName.getBytes(DataConverter.CHARSET_UTF8);
- byte[] valueBytes = JSON.toJSONBytes(subscriptionGroupConfig,
SerializerFeature.BrowserCompatible);
+ byte[] valueBytes = JSON.toJSONBytes(subscriptionGroupConfig,
JSONWriter.Feature.BrowserCompatible);
this.rocksDBConfigManager.put(keyBytes, keyBytes.length,
valueBytes);
} catch (Exception e) {
log.error("kv put sub Failed, {}",
subscriptionGroupConfig.toString());
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBTopicConfigManager.java
b/broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBTopicConfigManager.java
index d64f808067..c2ec70ac38 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBTopicConfigManager.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBTopicConfigManager.java
@@ -16,11 +16,8 @@
*/
package org.apache.rocketmq.broker.config.v1;
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.serializer.SerializerFeature;
-import java.io.File;
-import java.util.Map;
-import java.util.concurrent.ConcurrentMap;
+import com.alibaba.fastjson2.JSON;
+import com.alibaba.fastjson2.JSONWriter;
import org.apache.rocketmq.broker.BrokerController;
import org.apache.rocketmq.broker.RocksDBConfigManager;
import org.apache.rocketmq.broker.topic.TopicConfigManager;
@@ -30,6 +27,10 @@ import org.apache.rocketmq.common.utils.DataConverter;
import org.apache.rocketmq.remoting.protocol.DataVersion;
import org.rocksdb.CompressionType;
+import java.io.File;
+import java.util.Map;
+import java.util.concurrent.ConcurrentMap;
+
public class RocksDBTopicConfigManager extends TopicConfigManager {
protected transient RocksDBConfigManager rocksDBConfigManager;
@@ -113,7 +114,7 @@ public class RocksDBTopicConfigManager extends
TopicConfigManager {
TopicConfig oldTopicConfig = this.topicConfigTable.put(topicName,
topicConfig);
try {
byte[] keyBytes = topicName.getBytes(DataConverter.CHARSET_UTF8);
- byte[] valueBytes = JSON.toJSONBytes(topicConfig,
SerializerFeature.BrowserCompatible);
+ byte[] valueBytes = JSON.toJSONBytes(topicConfig,
JSONWriter.Feature.BrowserCompatible);
this.rocksDBConfigManager.put(keyBytes, keyBytes.length,
valueBytes);
} catch (Exception e) {
log.error("kv put topic Failed, {}", topicConfig.toString(), e);
