RocketMQ实战(二)-架构

1 RocketMQ角色介绍

RocketMQ由四个角色组成

• Producer: 消息生产者
• Consumer:消费者
• Broker: MQ服务，负责接收、分发消息
• NameServer:负责MQ服务之间的协调

2 RocketMQ架构方案

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模块架构