Reproduce moquette-io#629 based on the 0.17 version

blankbro · Jun 21, 2023 · b6fe5de · b6fe5de
1 parent c7017bf
commit b6fe5de
Showing 1 changed file with 15 additions and 0 deletions.
diff --git a/broker/src/test/java/io/moquette/broker/subscriptions/CTrieSpeedTest.java b/broker/src/test/java/io/moquette/broker/subscriptions/CTrieSpeedTest.java
@@ -18,6 +18,9 @@
 import static io.moquette.broker.subscriptions.Topic.asTopic;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Random;
+
+import io.netty.handler.codec.mqtt.MqttQoS;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.Timeout;
 import org.slf4j.Logger;
@@ -49,6 +52,18 @@ public void testDeep() {
         createSubscriptions(results);
     }
 
+    @Test
+    public void testIssue629Case(){
+        CTrie tree = new CTrie();
+        List<Subscription> subscriptionList = new ArrayList<>();
+        for (int i = 0; i < 620000; i++) {
+            Topic topic = asTopic("topic/test/" + new Random().nextInt(10) + "/test");
+            subscriptionList.add(new Subscription("TestClient-" + i, topic, MqttQoS.AT_LEAST_ONCE));
+        }
+
+        createSubscriptions(subscriptionList);
+    }
+
     public void createSubscriptions(List<Subscription> results) {
         int count = 0;
         long start = System.currentTimeMillis();