RocketMQ 端口9876 安装

收心

发布于 2022-01-19 14:59:37

2K0

发布于 2022-01-19 14:59:37

文章被收录于专栏：Java实战博客

官网：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/#/