安装
(1)编译安装
下载地址:
http://rocketmq.apache.org/release_notes/release-notes-4.3.0/
解压
$ unzip rocketmq-all-4.3.0-source-release.zip
编译
$ cd rocketmq-all-4.3.0/
$ mvn -Prelease-all -DskipTests clean install -U
$ cd distribution/target/apache-rocketmq
(2)快速安装
rocketmq 提供了编译后的版本,直接下载解压即可。
还是上面的下载页面,选择 bin
版本,如 rocketmq-all-4.3.0-bin-release.zip,下载后解压。
启动
(1) 启动 Name Server
$ nohup sh bin/mqnamesrv &
# 查看启动日志
$ tail -f ~/logs/rocketmqlogs/namesrv.log
(2) 启动 Broker
$ nohup sh bin/mqbroker -n localhost:9876 &
# 查看启动日志
$ tail -f ~/logs/rocketmqlogs/broker.log
关闭
$ sh bin/mqshutdown broker
$ sh bin/mqshutdown namesrv
测试
$ export NAMESRV_ADDR=localhost:9876
# 生产消息
$ sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
# 消费消息
$ sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
问题
在启动 broker 时遇到报错:
...
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000005c0000000, 8589934592, 0) failed; error='Cannot allocate memory' (errno=12)
...
内存不足,查看启动文件 bin/mqbroker,其调用了 bin/runbroker.sh,打开查看,发现:
JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g"
过大了,本机测试改小一点即可,如:
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m"
再次启动后成功。
RocketMQ 官方文档: