RocketMQ是阿里巴巴开源的分布式消息中间件,现在是Apache的一个顶级项目。在阿里内部使用非常广泛,已经经过了"双11"这种万亿级的消息流转。
接下来我们先在linux平台下安装一个RocketMQ的服务
http://rocketmq.apache.org/release_notes/release-notes-4.7.1/
2.2.1 上传文件到/opt/software 2.2.2 解压到安装目录/opt/module
unzip rocketmq-all-4.7.1-bin-release.zip2.3.1 切换到安装目录 2.3.2 启动NameServer
[root@origin rocketmq-4.7.1]# nohup ./bin/mqnamesrv & [1] 1467 # 只要进程不报错,就应该是启动成功了,可以查看一下日志 [root@heima rocketmq]# tail -f /root/logs/rocketmqlogs/namesrv.log2.3.3 启动Broker
# 编辑bin/runbroker.sh 和 bin/runserver.sh文件,修改里面的 # JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g" # 为JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m" [root@origin rocketmq-4.7.1]# nohup bin/mqbroker -n localhost:9876 & [root@origin rocketmq-4.7.1]# tail -f /root/logs/rocketmqlogs/broker.log3.1 测试消息发送
[root@origin rocketmq-4.7.1]# export NAMESRV_ADDR=localhost:9876 [root@origin rocketmq-4.7.1]# bin/tools.sh org.apache.rocketmq.example.quickstart.Producer2 测试消息接收
[root@origin rocketmq-4.7.1]# export NAMESRV_ADDR=localhost:9876 [root@origin rocketmq-4.7.1]# bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer7.2.1.5 关闭RocketMQ
[root@origin rocketmq-4.7.1]# bin/mqshutdown broker [root@origin rocketmq-4.7.1]# bin/mqshutdown namesrv