下载安装包

https://archive.apache.org/dist/rocketmq/4.9.4/

修改内存参数

进入bin目录
修改 runserver.sh 和 runbroker.sh
把 -Xms4g -Xmx4g改为 -Xms256m -Xmx256m
备注：机器配置高可以不改，我是测试机，配置低

启动

启动nameserver

后台启动如下

nohup sh mqnamesrv & 

在日志文件中看到如下信息表示启动成功

The Name Server boot success. serializeType=JSON

启动broker

后台启动如下

#localhost 客户可改为具体ip地址
nohup sh mqbroker -n localhost:9876 &

在日志文件中看到如下信息表示启动成功

boot success. serializeType=JSON and name server is  略:9876

备注：可以从配置文件启动
修改配置文件
conf/broker.conf,最后增加如下配置项

namesrvAddr=此处是nameserver的ip地址:9876

从配置文件启动命令如下

nohup ./mqbroker -c ../conf/broker.conf &

安装结果检查

验证broker是否注册到nameserver上

执行如下命令：

#nameserver地址
 ./mqadmin clusterList -n localhost:9876

如果出现如下信息（显示出broker列表），表示正常

#Cluster Name     #Broker Name            #BID  #Addr                  #Version                #InTPS(LOAD)       #OutTPS(LOAD) #PCWait(ms) #Hour #SPACE
DefaultCluster    host-略        0     略:10911      V4_9_4                   0.00(0,0ms)         0.00(0,0ms)       

验证生产/消费消息

生产消息

./tools.sh org.apache.rocketmq.example.quickstart.Producer

正常会展示，如下信息（共生产1000条消息）

略
9-41, queueId=1], queueOffset=249]
SendResult [sendStatus=SEND_OK, msgId=7F000001231375B84C9245343B2303E7, offsetMsgId=0A00A92900002A9F000000000002ECD2, messageQueue=MessageQueue [topic=TopicTest, brokerName=, queueId=2], queueOffset=249]
10:30:50.939 [NettyClientSelector_1] INFO RocketmqRemoting - closeChannel: close the connection to remote address[127.0.0.1:9876] result: true
10:30:50.946 [NettyClientSelector_1] INFO RocketmqRemoting - closeChannel: close the connection to remote address[] result: true

消费消息

./tools.sh org.apache.rocketmq.example.quickstart.Consumer

正常会展示，如下信息（消费上边生产的1000条消息）

略
ConsumeMessageThread_please_rename_unique_group_name_4_12 Receive New Messages: [MessageExt [brokerName=, queueId=1, storeSize=192, queueOffset=249, sysFlag=0, bornTimestamp=1657765850913, bornHost=/:41788, storeTimestamp=1657765850913, storeHost=/:10911, msgId=0A00A92900002A9F000000000002EC12, commitLogOffset=191506, bodyCRC=1359908749, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic='TopicTest', flag=0, properties={MIN_OFFSET=0, MAX_OFFSET=250, CONSUME_START_TIME=1657766365497, UNIQ_KEY=7F000001231375B84C9245343B2103E6, CLUSTER=DefaultCluster, TAGS=TagA}, body=[72, 101, 108, 108, 111, 32, 82, 111, 99, 107, 101, 116, 77, 81, 32, 57, 57, 56], transactionId='null'}]] 
ConsumeMessageThread_please_rename_unique_group_name_4_18 Receive New Messages: [MessageExt [brokerName=, queueId=1, storeSize=192, queueOffset=248, sysFlag=0, bornTimestamp=1657765850906, bornHost=/:41788, storeTimestamp=1657765850906, storeHost=/:10911, msgId=0A00A92900002A9F000000000002E912, commitLogOffset=190738, bodyCRC=1488503718, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic='TopicTest', flag=0, properties={MIN_OFFSET=0, MAX_OFFSET=250, CONSUME_START_TIME=1657766365497, UNIQ_KEY=7F000001231375B84C9245343B1A03E2, CLUSTER=DefaultCluster, TAGS=TagA}, body=[72, 101, 108, 108, 111, 32, 82, 111, 99, 107, 101, 116, 77, 81, 32, 57, 57, 52], transactionId='null'}]] 

安装控制台

代码安装

https://github.com/apache/rocketmq-externals/releases/tag/rocketmq-console-1.0.0
这就是一个spirng boot项目，不多说了
导入idea等开发工具后，修改application.properties文件
修改配置项 rocketmq.config.namesrvAddr 即可

#if this value is empty,use env value rocketmq.config.namesrvAddr  NAMESRV_ADDR | now, you can set it in ops page.default localhost:9876
rocketmq.config.namesrvAddr=此处为nameserver的ip地址:9876

docker 安装

# 下载镜像
docker pull styletang/rocketmq-console-ng
# 启动镜像
docker run -e "JAVA_OPTS=-Drocketmq.namesrv.addr=127.0.0.1:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false" -p 8080:8080 -t styletang/rocketmq-console-ng

启动后的界面

在这可以看到配置的nameserver地址

在这可以看到集群分片和上边生产和消费的消息数量

备注

关闭rocketmq命令

# 关闭broker
./mqshutdown broker
# 关闭 namesrv
./mqshutdown namesrv

清除数据

 rm -rf /root/logs/rocketmqlogs/*
 rm -rf /root/store/*

文档地址

https://github.com/apache/rocketmq/tree/master/docs/cn