一 部署阶段
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使用到的几个端口号为开放状态,如下图,否则会出现连接不上的情况
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
为何broker和生产者需要联通,可以参考下图理解。
生产者服务需要和nameServer以及broker进行数据交换,所以它们之间的网络需要是联通的。
同理,消费者服务也需要和nameServer以及broker网络联通。
2.消息发送成功后,就可以在管理控制台rocketmq-console中看到发送的消息了。