RocketMQ 设置远程能够消费消息

临时所记,无图,无排版。刚好有这需求,从同事那学习到方法,记录在此。

因为测试需要,希望能够在测试环境消费正式环境生产的消息,其实 RocketMQ 能够通过设置配置文件,实现该需求。

1、首先将 MQ 停了

如果 MQ 处于开启状态,会有四个端口,其中,一个 namesrv 端口,默认是 9876,还有三个 broker 端口(10909、10911、10912)。

可以使用 kill 命令将他们关闭,也可以使用以下命令

关闭 namesrv :sh bin/mqshutdown namesrv

关闭 broker  :sh bin/mqshutdown broker

2、接着修改配置文件,其实为了体验,这一步可以先做。

配置文件在 /conf /broker.conf

编辑它,在尾部加上两行配置

brokerIP1 = xx.xx.xx.xx
autoCreateTopicEnable = true

注意第一行 IP 一定要填写公网 IP

3、启动 MQ

bin 目录下使用如下命令,记得加上配置文件路径,别找错路径,是 target 目录下,不是外层。

rocketmq-all-4.2.0/distribution/target/apache-rocketmq/bin

nohup sh mqnamesrv &

nohup sh mqbroker -c ../conf/broker.conf -n 127.0.0.1:9876 >/dev/null 2>&1 &

本文由老郭种树原创,转载请注明:https://guozh.net/rocketmq-remote-consumer-message/

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注