(一)调试RocketMq源码-蒲公英云

(一)调试RocketMq源码

文章目录

- - - 一.启动NameServer
    - 1.1namesrv模块找到NamesrvStartup.java
    - 1.2修改配置文件目录
    - 1.3启动NamesrvStartup.java
  - 二.配置Broker
  - - 2.1配置BrokerStartup.java
    - 2.2启动BrokerStartup.java
  - 三.启动producer和consumer

一.启动NameServer

1.1namesrv模块找到NamesrvStartup.java

修改Environment variables 新增ROCKETMQ_HOME
在这里插入2图片描述

1.2修改配置文件目录

Rocketmq主目录新建conf logs storedata三个文件夹,将distribution的broker.conf logback_broker.xml,logback_namesrv.xml复制到conf,修改日志目录,和增加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
storePathRootDir=/Library/Java/MySpace/rocketmq/storedata
storePathCommitLog=/Library/Java/MySpace/rocketmq/storedata/commitLog
storePathConsumeQueue=/Library/Java/MySpace/rocketmq/storedata/consumequeue
storePathIndex=/Library/Java/MySpace/rocketmq/storedata/index
storeCheckpoint=/Library/Java/MySpace/rocketmq/storedata/checkpoint
abortFile=/Library/Java/MySpace/rocketmq/storedata/abort

1.3启动NamesrvStartup.java

正确输出

The Name Server boot success. serializeType=JSON

二.配置Broker

2.1配置BrokerStartup.java

在这里插入图片描述

2.2启动BrokerStartup.java

The broker[broker-a, 10.253.16.161:10911] boot success. serializeType=JSON and name server is 127.0.0.1:9876

broker.log的日志信息
在这里插入图片描述

三.启动producer和consumer

org.apache.rocketmq.example.quickstart.Producer
org.apache.rocketmq.example.quickstart.Consumer
先修改NameServer地址然后启动观察日志
如果出现以下问题,需要在broker.conf配置brokerIP1=外网ip
在这里插入图片描述