一、介绍

Apache RocketMQ是一个分布式、队列模型的消息中间件，具有低延迟、高性能和高可靠、万亿级容量和灵活的可扩展性。核心组件由四部分组成：Name Servers，Brokers，Producer 和 Consumer；它们中的每一个都可以水平扩展，而没有单一的故障节点。

file

  1. NameServer：是一个几乎无状态的节点，可集群部署，节点之间无任何信息同步
  2. Broker：部署相对复杂，Broker分为Master与Slave，一个Master可以对应多个Slaver，但是一个Slaver只能对应一个Master，Master与Slaver的对应关系通过指定相同的BrokerName，不同的BrokerId来定义，BrokerId为0表示Master，非0表示Slaver。Master可以部署多个。每个Broker与NameServer集群中的所有节点建立长连接，定时注册Topic信息到所有的NameServer
  3. Producer：与NameServer集群中的其中一个节点（随机选择）建立长连接，定期从NameServer取Topic路由信息，并向提供Topic服务的Master建立长连接，且定时向Master发送心跳。Produce完全无状态，可集群部署
  4. Consumer：与NameServer集群中的其中一个节点（随机选择）建立长连接，定期从NameServer取Topic路由信息，并向提供Topic服务的Master、Slaver建立长连接，且定时向Master、Slaver发送心跳。Consumer即可从Master订阅消息，也可以从Slave订阅消息，订阅规则由Broker配置决定

 

二、MQ安装部署

2.1. 下载

直接找最新版下载后解压
upload/201909171143570227.jpg" alt="file" style="margin: 0px; padding: 0px; border: 0px; max-width: 900px; height: auto;" />

 

2.2. 修改配置

修改 conf/broker.conf
添加以下配置
file

brokerIP1：配置broker所在服务器的ip地址，以便Name Server连接

 
修改 runserver.sh 和 runbroker.sh (可不改)
因为rocketMQ默认的启动参数内存占用非常大，如果环境没有这么多内存就必需修改JAVA_OPT参数

  • runserver.sh
    file
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn125m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
  • runbroker.sh
    file
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn125m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

 

2.3. 运行Name Server

nohup sh bin/mqnamesrv &

查看运行日志：tail -f ~/logs/rocketmqlogs/namesrv.log

 

2.4. 运行Broker

nohup sh bin/mqbroker -n localhost:9876 -c conf/broker.conf &

通过-c参数指定配置文件
查看运行日志：tail -f ~/logs/rocketmqlogs/broker.log

 

2.5. 停止服务的方式

如果需要停止RocketMQ的服务，在生产环境不建议直接用kill，应该使用以下命令

sh bin/mqshutdown broker  sh bin/mqshutdown namesrv

 

三、安装可视化管理界面