追加忽略，新增初始化脚本

base/Resources/rocketmq/sbin/.gitignore

@@ -0,0 +1 @@
+store/

base/Resources/rocketmq/sbin/initial-consumer.bat

@@ -0,0 +1,36 @@
+@echo off
+setlocal enabledelayedexpansion
+chcp 65001 >nul
+title RocketMQ Consumer Group Initialization
+
+:: BROKER_NAME
+set "BROKER_NAME=broker-a"
+:: 集群名称
+set "CLUSTER_NAME=DefaultCluster"
+
+echo.
+echo [INFO] 正在创建消费者组
+for %%g in (
+  "SIMULATION_FIFO_001"
+  "CID_standard_topic_sample"
+  "CID_ONSAPI_OWNER"
+  "SELF_TEST_C_GROUP"
+  "SIMULATION_FIFO_002"
+  "TOOLS_CONSUMER"
+  "CID_ONSAPI_PULL"
+  "CID_ONSAPI_PERMISSION"
+  "CID_RMQ_SYS_TRANS"
+  "FILTERSRV_CONSUMER"
+  "CID_ONS-HTTP-PROXY"
+) do (
+    echo [INFO] 创建消费者组: %%~g
+    curl -X POST ^
+      http://localhost:8088/consumer/createOrUpdate.do ^
+      -H "Content-Type: application/json" ^
+      -d "{\"brokerNameList\":[\"%BROKER_NAME%\"],\"subscriptionGroupConfig\":{\"groupName\":\"%%~g\",\"consumeEnable\":true,\"consumeMessageOrderly\":false,\"consumeFromMinEnable\":true,\"consumeBroadcastEnable\":true,\"retryQueueNums\":1,\"retryMaxTimes\":16,\"brokerId\":0,\"whichBrokerWhenConsumeSlowly\":1},\"clusterNameList\":[\"%CLUSTER_NAME%\"]}"
+    echo.
+)
+
+echo 所有消费者组创建完成!
+pause
+exit /b 0

base/Resources/rocketmq/sbin/initial-topic.bat

@@ -0,0 +1,37 @@
+@echo off
+setlocal enabledelayedexpansion
+chcp 65001 >nul
+title RocketMQ Topic Initialization
+
+:: BROKER_NAME
+set "BROKER_NAME=broker-a"
+:: 集群名称
+set "CLUSTER_NAME=DefaultCluster"
+
+echo.
+echo [INFO] 正在创建普通主题
+for %%t in (
+  "rt-efficiency-index"
+  "scenario-content-publish"
+  "scenario-content-subscribe"
+  "scenario-factor-publish"
+  "scenario-factor-subscribe"
+  "simulation-command"
+  "simulation-engine"
+  "simulation-running-control-percent"
+  "simulation-running-control-sse"
+  "simulation-task-feedback"
+  "simulation-task-publish"
+  "simulation-trainExRl"
+) do (
+    echo [INFO] 创建普通主题: %%~t
+    curl -X POST ^
+      http://localhost:8088/topic/createOrUpdate.do ^
+      -H "Content-Type: application/json" ^
+      -d "{\"writeQueueNums\":8,\"readQueueNums\":8,\"perm\":6,\"order\":false,\"topicName\":\"%%~t\",\"brokerNameList\":[\"%BROKER_NAME%\"],\"messageType\":\"NORMAL\",\"clusterNameList\":[\"%CLUSTER_NAME%\"]}"
+    echo.
+)
+
+echo 所有主题创建完成!
+pause
+exit /b 0

base/Resources/rocketmq/sbin/rocketmq.bat

@@ -22,7 +22,6 @@ if not exist "%ROCKETMQ_HOME%\bin\mqnamesrv.cmd" (
 if "%JAVA_HOME%" == "" (
   echo [WARN] JAVA_HOME is not set, trying to find Java automatically...
   goto :FOUNING_JAVA
-    
 ) else (
   if not exist "%JAVA_HOME%\bin\java.exe" (
     echo [WARN] %JAVA_HOME%\bin\java.exe is not exist, trying to find Java automatically...
@@ -67,6 +66,10 @@ exit /b 1
 :START_SERVER
 echo [INFO] Using JAVA_HOME: %JAVA_HOME%
 
+if exist "%ROCKETMQ_HOME%\sbin\store\" (
+  set "INITIAL=TRUE"
+)
+
 :: 4. 启动 NameServer
 start "RocketMQ NameServer" cmd /k "%ROCKETMQ_HOME%\bin\mqnamesrv.cmd"
 
@@ -76,8 +79,8 @@ timeout /t 5 /nobreak >nul
 :: 5. 启动 Broker（如果需要直接访问 Broker，可单独启动）
 :: start "RocketMQ Broker" cmd /k "%ROCKETMQ_HOME%\bin\mqbroker.cmd" -n localhost:9876
 :: start "RocketMQ Broker" cmd /k "%ROCKETMQ_HOME%\bin\mqbroker.cmd" -n localhost:9876 autoCreateTopicEnable=true
-start "RocketMQ Broker" cmd /k "%ROCKETMQ_HOME%\bin\mqbroker.cmd" -n localhost:9876 -c ../conf/broker.conf
+:: start "RocketMQ Broker" cmd /k "%ROCKETMQ_HOME%\bin\mqbroker.cmd" -n localhost:9876 -c ../conf/broker.conf
-:: start "RocketMQ Broker" cmd /k "%ROCKETMQ_HOME%\bin\mqbroker.cmd" -c ../conf/broker-localhost.conf
+start "RocketMQ Broker" cmd /k "%ROCKETMQ_HOME%\bin\mqbroker.cmd" -c ../conf/broker-localhost.conf
 
 :: 等待 Broker 启动
 timeout /t 10 /nobreak >nul
@@ -99,5 +102,11 @@ echo - Broker (端口: 10911)
 echo - Proxy (端口: 8081)
 echo - Dashboard (端口: 8080)
 
+:: if "%INITIAL%"="" (
+::   timeout /t 2 /nobreak >nul
+::   echo RocketMQ 数据初始化...
+::   start "Rocket Create Topic" "initial-topic.bat"
+::   start "Rocket Create Consumer" "initial-consumer.bat"
+:: )
 pause
 endlocal