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 &

  

 

  
1
 

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

  

 

  
1
  
2
 

• 启动报错
  

• 查看日志

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

• 启动成功
  

启动broker

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

  

 

  
1
 

remoting模块架构

文章来源: javaedge.blog.csdn.net，作者：JavaEdge.，版权归原作者所有，如需转载，请联系作者。

原文链接：javaedge.blog.csdn.net/article/details/102735079