Compare commits
5 Commits
81e540dda8
...
edc2e7cd87
Author | SHA1 | Date | |
---|---|---|---|
![]() |
edc2e7cd87 | ||
![]() |
7514add794 | ||
![]() |
ffc3d69ab9 | ||
![]() |
a77475ef44 | ||
![]() |
5bd51b3189 |
28
base/Resources/rocketmq/conf/broker-localhost.conf
Normal file
28
base/Resources/rocketmq/conf/broker-localhost.conf
Normal file
@ -0,0 +1,28 @@
|
|||||||
|
# Licensed to the Apache Software Foundation (ASF) under one or more
|
||||||
|
# contributor license agreements. See the NOTICE file distributed with
|
||||||
|
# this work for additional information regarding copyright ownership.
|
||||||
|
# The ASF licenses this file to You under the Apache License, Version 2.0
|
||||||
|
# (the "License"); you may not use this file except in compliance with
|
||||||
|
# the License. You may obtain a copy of the License at
|
||||||
|
#
|
||||||
|
# http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
#
|
||||||
|
# Unless required by applicable law or agreed to in writing, software
|
||||||
|
# distributed under the License is distributed on an "AS IS" BASIS,
|
||||||
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
|
# See the License for the specific language governing permissions and
|
||||||
|
# limitations under the License.
|
||||||
|
|
||||||
|
brokerClusterName = DefaultCluster
|
||||||
|
brokerName = broker-a
|
||||||
|
brokerId = 0
|
||||||
|
deleteWhen = 04
|
||||||
|
fileReservedTime = 48
|
||||||
|
brokerRole = ASYNC_MASTER
|
||||||
|
flushDiskType = ASYNC_FLUSH
|
||||||
|
autoCreateTopicEnable=true
|
||||||
|
autoCreateSubscriptionGroup=true
|
||||||
|
listenPort=10911
|
||||||
|
namesrvAddr=localhost:9876
|
||||||
|
storePathRootDir=./store
|
||||||
|
storePathCommitLog=./store/commitlog
|
1
base/Resources/rocketmq/sbin/.gitignore
vendored
Normal file
1
base/Resources/rocketmq/sbin/.gitignore
vendored
Normal file
@ -0,0 +1 @@
|
|||||||
|
store/
|
36
base/Resources/rocketmq/sbin/initial-consumer.bat
Normal file
36
base/Resources/rocketmq/sbin/initial-consumer.bat
Normal file
@ -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
|
37
base/Resources/rocketmq/sbin/initial-topic.bat
Normal file
37
base/Resources/rocketmq/sbin/initial-topic.bat
Normal file
@ -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
|
@ -5,49 +5,48 @@ title RocketMQ 5.x Quick Start (with Proxy)
|
|||||||
|
|
||||||
:: 1. 检查 ROCKETMQ_HOME 是否存在
|
:: 1. 检查 ROCKETMQ_HOME 是否存在
|
||||||
if "%ROCKETMQ_HOME%" == "" (
|
if "%ROCKETMQ_HOME%" == "" (
|
||||||
:: 如果未设置,尝试使用上级的上级目录作为默认值
|
:: 如果未设置,尝试使用上级的上级目录作为默认值
|
||||||
set "ROCKETMQ_HOME=%~dp0..\"
|
set "ROCKETMQ_HOME=%~dp0..\"
|
||||||
echo [INFO] ROCKETMQ_HOME is not set, using default: !ROCKETMQ_HOME!
|
echo [INFO] ROCKETMQ_HOME is not set, using default: !ROCKETMQ_HOME!
|
||||||
)
|
)
|
||||||
|
|
||||||
:: 2. 检查 mqnamesrv.cmd 是否存在
|
:: 2. 检查 mqnamesrv.cmd 是否存在
|
||||||
if not exist "%ROCKETMQ_HOME%\bin\mqnamesrv.cmd" (
|
if not exist "%ROCKETMQ_HOME%\bin\mqnamesrv.cmd" (
|
||||||
echo [ERROR] mqnamesrv.cmd not found in %ROCKETMQ_HOME%\bin
|
echo [ERROR] mqnamesrv.cmd not found in %ROCKETMQ_HOME%\bin
|
||||||
echo Please set correct ROCKETMQ_HOME environment variable
|
echo Please set correct ROCKETMQ_HOME environment variable
|
||||||
pause
|
pause
|
||||||
exit /b 1
|
exit /b 1
|
||||||
)
|
)
|
||||||
|
|
||||||
:: 3. 检查 JAVA_HOME
|
:: 3. 检查 JAVA_HOME
|
||||||
if "%JAVA_HOME%" == "" (
|
if "%JAVA_HOME%" == "" (
|
||||||
echo [WARN] JAVA_HOME is not set, trying to find Java automatically...
|
echo [WARN] JAVA_HOME is not set, trying to find Java automatically...
|
||||||
goto :FOUNING_JAVA
|
goto :FOUNING_JAVA
|
||||||
|
|
||||||
) else (
|
) else (
|
||||||
if not exist "%JAVA_HOME%\bin\java.exe" (
|
if not exist "%JAVA_HOME%\bin\java.exe" (
|
||||||
echo [WARN] %JAVA_HOME%\bin\java.exe is not exist, trying to find Java automatically...
|
echo [WARN] %JAVA_HOME%\bin\java.exe is not exist, trying to find Java automatically...
|
||||||
goto :FOUNING_JAVA
|
goto :FOUNING_JAVA
|
||||||
)
|
)
|
||||||
goto :START_SERVER
|
goto :START_SERVER
|
||||||
)
|
)
|
||||||
|
|
||||||
:FOUNING_JAVA
|
:FOUNING_JAVA
|
||||||
:: 尝试在常见位置查找Java
|
:: 尝试在常见位置查找Java
|
||||||
echo FOUNDING ===== START
|
echo FOUNDING ===== START
|
||||||
for %%d in (
|
for %%d in (
|
||||||
"%ProgramFiles%\Java\"
|
"%ProgramFiles%\Java\"
|
||||||
"%ProgramFiles(x86)%\Java\"
|
"%ProgramFiles(x86)%\Java\"
|
||||||
"%~dp0..\jdk"
|
"%~dp0..\jdk"
|
||||||
"%~dp0..\java"
|
"%~dp0..\java"
|
||||||
"%~dp0..\..\jdk"
|
"%~dp0..\..\jdk"
|
||||||
"%~dp0..\..\java"
|
"%~dp0..\..\java"
|
||||||
) do (
|
) do (
|
||||||
echo [INFO] == %%~d
|
echo [INFO] == %%~d
|
||||||
if exist "%%~d\bin\java.exe" (
|
if exist "%%~d\bin\java.exe" (
|
||||||
set "JAVA_HOME=%%~d"
|
set "JAVA_HOME=%%~d"
|
||||||
echo [INFO] Found Java at: !JAVA_HOME!
|
echo [INFO] Found Java at: !JAVA_HOME!
|
||||||
goto :START_SERVER
|
goto :START_SERVER
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
echo FOUNDING ===== END
|
echo FOUNDING ===== END
|
||||||
goto :NOT_FOUND_JAVA
|
goto :NOT_FOUND_JAVA
|
||||||
@ -67,14 +66,21 @@ exit /b 1
|
|||||||
:START_SERVER
|
:START_SERVER
|
||||||
echo [INFO] Using JAVA_HOME: %JAVA_HOME%
|
echo [INFO] Using JAVA_HOME: %JAVA_HOME%
|
||||||
|
|
||||||
|
if exist "%ROCKETMQ_HOME%\sbin\store\" (
|
||||||
|
set "INITIAL=TRUE"
|
||||||
|
)
|
||||||
|
|
||||||
:: 4. 启动 NameServer
|
:: 4. 启动 NameServer
|
||||||
start "RocketMQ NameServer" cmd /k "%ROCKETMQ_HOME%\bin\mqnamesrv.cmd"
|
start "RocketMQ NameServer" cmd /k "%ROCKETMQ_HOME%\bin\mqnamesrv.cmd"
|
||||||
|
|
||||||
:: 等待 NameServer 启动
|
:: 等待 NameServer 启动
|
||||||
timeout /t 10 /nobreak >nul
|
timeout /t 5 /nobreak >nul
|
||||||
|
|
||||||
:: 5. 启动 Broker(如果需要直接访问 Broker,可单独启动)
|
:: 5. 启动 Broker(如果需要直接访问 Broker,可单独启动)
|
||||||
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
|
||||||
|
:: 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" -c ../conf/broker-localhost.conf
|
||||||
|
|
||||||
:: 等待 Broker 启动
|
:: 等待 Broker 启动
|
||||||
timeout /t 10 /nobreak >nul
|
timeout /t 10 /nobreak >nul
|
||||||
@ -87,7 +93,7 @@ timeout /t 2 /nobreak >nul
|
|||||||
|
|
||||||
:: 7. 启动 Dashboard(可选)
|
:: 7. 启动 Dashboard(可选)
|
||||||
if exist "%ROCKETMQ_HOME%\bin\rocketmq-dashboard.jar" (
|
if exist "%ROCKETMQ_HOME%\bin\rocketmq-dashboard.jar" (
|
||||||
start "RocketMQ Dashboard" cmd /k "%JAVA_HOME%\bin\java -jar -Dserver.port=8088 %ROCKETMQ_HOME%\bin\rocketmq-dashboard.jar"
|
start "RocketMQ Dashboard" cmd /k "%JAVA_HOME%\bin\java -jar -Dserver.port=8088 %ROCKETMQ_HOME%\bin\rocketmq-dashboard.jar"
|
||||||
)
|
)
|
||||||
|
|
||||||
echo RocketMQ 5.x 服务已启动:
|
echo RocketMQ 5.x 服务已启动:
|
||||||
@ -96,5 +102,11 @@ echo - Broker (端口: 10911)
|
|||||||
echo - Proxy (端口: 8081)
|
echo - Proxy (端口: 8081)
|
||||||
echo - Dashboard (端口: 8080)
|
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
|
pause
|
||||||
endlocal
|
endlocal
|
Loading…
x
Reference in New Issue
Block a user