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