rocketmq常见问题及使用 新手篇

一 部署阶段

1.启动命令

nameServer启动:nohup sh bin/mqnamesrv  -n ip地址:9876 & 

broker启动:nohup sh bin/mqbroker -n ip地址:9876 autoCreateTopicEnable=true  -c conf/broker.conf &

注:autoCreateTopicEnable配置是否自动创建主题

 

2.服务关闭命令

nameServer关闭: sh bin/mqshutdown namesrv 

broker关闭: sh bin/mqshutdown broker

 

3.启动Broker如果因为内存不足失败,需要编辑如下两个配置文件,修改JVM内存大小

vi runbroker.sh
vi runserver.sh

参考设置:

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

在Linux中,如果仍然内存溢出,可以尝试配置swap空间。

 

4.在云服务器上部署要注意的问题

4.1 要在安全组中配置rocketmq使用到的几个端口号为开放状态,如下图,否则会出现连接不上的情况

rocketmq常见问题及使用 新手篇

 

 4.2 云服务器实例的公网访问一般通过私有网卡映射完成,在实例内部无法查询到公网IP地址

所带来的影响是,软件自动识别的出的IP地址是内网地址,无法访问,需要显式的配置公网IP地址。

在rocketmq中如何配置,会在下面说明。

 

二 生产者服务发送消息

1.代码报错:connect to <x.x.x.x:10911> failed或者sendDefaultImpl call timeout。

请检查broker启动日志中的brokerIP地址和生产者所在地址是否能连通

The broker[broker-a, x.x.x.x:10911] boot success. serializeType=JSON and name server is x.x.x.x:9876

 这里默认是系统自动识别的IP地址,可能是无法连接的内网地址。

需要在conf/broker.conf中配置brokerIP1,配置为公网IP

rocketmq常见问题及使用 新手篇

 

 为何broker和生产者需要联通,可以参考下图理解。

生产者服务需要和nameServer以及broker进行数据交换,所以它们之间的网络需要是联通的。

同理,消费者服务也需要和nameServer以及broker网络联通。

rocketmq常见问题及使用 新手篇

 

2.消息发送成功后,就可以在管理控制台rocketmq-console中看到发送的消息了。

rocketmq常见问题及使用 新手篇

 

上一篇:阿里P7大牛亲自教你!阿里面试100%会问到的JVM


下一篇:《RocketMQ源码系列》nameserver启动流程