官网:http://rocketmq.apache.org/

下载地址:http://rocketmq.apache.org/release_notes/release-notes-4.9.1/ (注:不同版本需要去官网下载好吧!)

快速起步:http://rocketmq.apache.org/docs/quick-start/

RocketMQ 安装需要Maven环境,建议在Windows环境下 将下载的源文件进行相关命令打包

打包命令

mvn -Prelease-all -DskipTests clean install -U

打包结果

打包完成后,就去找 编译好的文件吧

请在此目录的基础上 加上:

distribution/target/rocketmq-4.9.1/rocketmq-4.9.1

这个就是我们自己的rocketmq,自己上传到Linux服务器吧

启动

启动 Name Server

# 后台启动
nohup sh bin/mqnamesrv &               或者             nohup runserver.sh &


# 查看日志是否启动成功
tail -f ~/logs/rocketmqlogs/namesrv.log

启动Broker

# 不指定配置文件启动
nohup sh bin/mqbroker -n localhost:9876 &


# 指定配置文件启动
nohup sh bin/mqbroker -c ./conf/broker.conf &


# 查看日志
tail -f ~/logs/rocketmqlogs/broker.log 

发送和接收消息

在发送/接收消息之前,我们需要告诉客户端名称服务器的位置。RocketMQ 提供了多种方法来实现这一点。为简单起见,我们使用环境变量NAMESRV_ADDR

 # 启动生产者生产消息
 > export NAMESRV_ADDR=localhost:9876
 > sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
 SendResult [sendStatus=SEND_OK, msgId= ...


 # 启动消费者消费
 > sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
 ConsumeMessageThread_%d Receive New Messages: [MessageExt...

关闭服务

关闭服务器

# 关闭broker
> sh bin/mqshutdown broker
The mqbroker(36695) is running...
Send shutdown request to mqbroker(36695) OK

# 关闭namesrv
> sh bin/mqshutdown namesrv
The mqnamesrv(36664) is running...
Send shutdown request to mqnamesrv(36664) OK

RocketMQ Connect Console

RocketMQ Connect Console 可视化界面地址:https://github.com/apache/rocketmq-externals/tree/release-rocketmq-console-1.0.0

老规矩 直接cmd进入 pom文件同级的位置,直接打包

mvn clean package -Dmaven.test.skip=true

成功,接下来放到服务器去启动!

nohup java -jar rocketmq-console-ng-1.0.0.jar --server.port=9877 --rocketmq.config.namesrvAddr=127.0.0.1:9876 &

# 说明,namesrvAddr是RocketMQ的地址。RocketMQ Connect Console启动时,确保开启namesrvAddr 和 Broker

# 开启防火墙
firewall-cmd --zone=public --add-port=9877/tcp --permanent
# 重载防火墙
firewall-cmd --zone=public --add-port=9877/tcp --permanent

去访问吧!http://127.0.0.1:9877/#/

成功!