1 角色

RocketMQ由四个角色组成：

• Producer 消息生产者

• Consumer 消息消费者

• Broker MQ服务，负责接收、分发消息

• NameServer 负责MQ服务之间的协调

2 架构设计

NameServer-MQ服务注册发现中心

提供轻量级服务发现和路由。
每个名称服务器记录完整的路由信息，提供相应的读写服务，并支持快速存储扩展。

NameServer 充当路由信息提供者。生产者/消费者客户查找主题以查找相应的broker列表。

3 搭建

配置

• runserver.sh设置小点
  

• runbroker.sh 设置小点
  

启动

nohup sh bin/mqnamesrv > logs/namesrv.log 2>&1 &nohup sh bin/mqbroker -n localhost:9876 > ~/logs/rocketmqlogs/broker.log 2>&1 &

• 启动报错
  

• 查看日志

• 改启动文件,添加JAVA_HOME变量

• 启动成功
  
  

启动broker

nohup sh bin/mqbroker   -c conf/broker.conf   -n localhost:9876 >   logs/broker.log 2>&1 &

3 remoting模块架构

往期推荐