安装平台为需要Linux、Unix或Mac,Windows不兼容。
下载安装包:rocketmq-all-4.4.0-source-release.zip
要安装JDK和maven环境
进行解压编译:
unzip rocketmq-all-4.4.0-source-release.zip cd rocketmq-all-4.4.0/ mvn -Prelease-all -DskipTests clean install -U cd distribution/target/apache-rocketmq
进入路径:
/distribution/target/apache-rocketmq
启动nameServer:
[root@192 apache-rocketmq]# nohup bin/mqnamesrv &
启动成功日志:
[root@192 apache-rocketmq]# tail -100f nohup.out Java HotSpot(TM) 64-Bit Server VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release Java HotSpot(TM) 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release. The Name Server boot success. serializeType=JSON
启动broker:
nohup sh bin/mqbroker -n localhost:9876 &
如果报堆内存不足,则需要修改runbroker.sh(默认配置的堆内存8g,根据机器配置修改)
#===========================================================================================
# JVM Configuration
#===========================================================================================
JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g"
修改后:
#===========================================================================================
# JVM Configuration
#===========================================================================================
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m"
再次运行
nohup sh bin/mqbroker -n localhost:9876 &
-n 指定nameServer地址,它的默认端口是9876
broker启动后默认端口是10911
查看进程
[root@192 bin]# jps -l 90651 org.apache.rocketmq.namesrv.NamesrvStartup 91898 sun.tools.jps.Jps 91774 org.apache.rocketmq.broker.BrokerStartup
nameServer和broker启动成功。
发送消息测试:
设置nameServer地址变量
[root@192 bin]# export NAMESRV_ADDR=localhost:9876
发送消息测试:
[root@192 apache-rocketmq]# bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
发送消息成功
消费消息测试:
bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
关闭RocketMQ,先关broker再关nameServer
[root@192 apache-rocketmq]# ./bin/mqshutdown broker [root@192 apache-rocketmq]# ./bin/mqshutdown namesrv



