RocketMQ 消息队列单机部署及使用

RocketMQ 消息队列单机部署及使用

RocketMQ是一个消息中间件。
消息中间件中有两个角色：消息生产者和消息消费者。RocketMQ里相同有这两个概念。
消息生产者负责创建消息并发送到RocketMQ服务器。RocketMQ服务器会将消息持久化到磁盘，
消息消费者从RocketMQ服务器拉取消息并提交给应用消费。

RocketMQ是一款分布式、队列模型的消息中间件，具有下面特点：
支持严格的消息顺序
支持Topic与Queue两种模式

安装环境：
1.jdk8
2.rocketmq4.2

export ROCKETMQ_HOME
export PATH

source /etc/profile

chmod +x mqadin mqbroker

单机部署：
(1)启动nameServer:
nohup mqnamesrv 1>/opt/rocketmq/log/ng.log 2>/opt/rocketmq/log/err.log &
ps aux|grep java
验证nameserver是否启动：
tail -f /log/ng.log
The Name Server boot success.

(2)启动broker,指定nameserver地址
nohup sh mqbroker -n localhost:9876 autoCreateTopicEnable=true >/log/bro.log &
验证broker是否启动：
tail -f /log/bro.log

(3)最后配置防火墙
nameserver端口为9876
broker端口为10911

lokkit -p 9876:tcp -p 10911:tcp

(4)关闭nameserver broker运行的命令
mqshutdown namesrv
mqshutdown broker

一台机上启动2个broker?
nohup sh mqbroker -n 127.0.0.1:9876 autoCreateTopicEnable=true listentPort=23 >broker3.log &

最后我配置策略如下
broker-c: listentPort=11
broker-c: listentPort=23

1、mqnamesrv单机启动2台服务，可以通过-c xxx.properties指定端口号（如：listenPort=9877，默认端口号9876）