[ISSUE #10173] Improve PopLite: rename RocksDB CQ path and schedule autoClean (#10242)

Author: imzs

broker/src/main/java/org/apache/rocketmq/broker/pop/orderly/QueueLevelConsumerManager.java

@@ -291,8 +291,7 @@ public void updateNextVisibleTime(String topic, String group, int queueId, long
         updateLockFreeTimestamp(topic, group, queueId, orderInfo);
     }
 
-    @VisibleForTesting
-    protected void autoClean() {
+    public void autoClean() {
         if (brokerController == null) {
             return;
         }

broker/src/main/java/org/apache/rocketmq/broker/processor/PopLiteMessageProcessor.java

@@ -438,6 +438,9 @@ public GetMessageResult getMessage(String clientHost, String group, String lmqNa
     }
 
     public class PopLiteLockManager extends ServiceThread {
+        private static final long AUTO_CLEAN_INTERVAL = 5 * 60 * 1000;
+        private long lastCleanTime = System.currentTimeMillis();
+
         @Override
         public String getServiceName() {
             if (brokerController.getBrokerConfig().isInBrokerContainer()) {
@@ -452,6 +455,10 @@ public void run() {
                 try {
                     waitForRunning(60000);
                     lockService.removeTimeout();
+                    if (System.currentTimeMillis() - lastCleanTime >= AUTO_CLEAN_INTERVAL) {
+                        ((MemoryConsumerOrderInfoManager) consumerOrderInfoManager).autoClean();
+                        lastCleanTime = System.currentTimeMillis();
+                    }
                 } catch (Exception ignored) {
                 }
             }

store/src/main/java/org/apache/rocketmq/store/config/StorePathConfigHelper.java

@@ -32,7 +32,7 @@ public static String getStorePathBatchConsumeQueue(final String rootDir) {
     }
 
     public static String getStorePathRocksDBConsumeQueue(final String rootDir) {
-        return rootDir + File.separator + "consumequeue_r";
+        return rootDir + File.separator + "consumequeue_rocksdb";
     }
 
     public static String getStorePathIndex(final String rootDir) {