mirror of
https://github.com/apache/rocketmq.git
synced 2026-08-30 18:10:44 +08:00
2.0 KiB
2.0 KiB
本地调试RocketMQ
Step0: 解决依赖问题
- 运行前下载RocketMQ需要的maven依赖,可以使用
mvn clean install -Dmaven.test.skip=true - 确保本地能够编译通过
Step1: 启动NameServer
- NamerServer的启动类在
org.apache.rocketmq.namesrv.NamesrvStartup Idea-Edit Configurations中添加环境变量ROCKETMQ_HOME=<rocketmq仓库目录>
- 运行NameServer,观察到如下日志输出则启动成功
The Name Server boot success. serializeType=JSON, address 0.0.0.0:9876
Step2: 启动Broker
- Broker的启动类在
org.apache.rocketmq.broker.BrokerStartup - 创建
/rocketmq/conf/broker.conf文件或直接在官方release发布包中拷贝即可
# broker.conf
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
namesrvAddr = 127.0.0.1:9876
Idea-Edit Configurations中添加运行参数-c /Users/xxx/rocketmq/conf/broker.conf以及环境变量ROCKETMQ_HOME=<rocketmq仓库目录>
- 运行Broker,观察到如下日志则启动成功
The broker[broker-a,192.169.1.2:10911] boot success...
Step3: 发送或消费消息
至此已经完成了RocketMQ的启动,可以使用/example里的示例进行收发消息
补充:本地启动Proxy
- RocketMQ5.x支持了Proxy模式,使用
LOCAL模式可以免去Step2,启动类在org.apache.rocketmq.proxy.ProxyStartup Idea-Edit Configurations中添加环境变量ROCKETMQ_HOME=<rocketmq仓库目录>- 在
/conf/下新建配置文件rmq-proxy.json
{
"rocketMQClusterName": "DefaultCluster",
"nameSrvAddr": "127.0.0.1:9876",
"proxyMode": "local"
}
- 运行Proxy,观察到如下日志则启动成功
Sat Aug 26 15:29:33 CST 2023 rocketmq-proxy startup successfully