RocketMQ实战(二)-架构

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 &      

remoting模块架构