Skip to content

Latest commit

 

History

History
34 lines (31 loc) · 1.66 KB

README.md

File metadata and controls

34 lines (31 loc) · 1.66 KB
Raw

整体介绍

  • 丰富API，各种方式的消息投递
  • 采用Netty NIO框架
  • NameServer代替Zookeeper
  • 强调集群无单点，可扩展，任意一点高可用，水平可扩展
  • 消息失败重试（rabbitmq需要自己实现），消息可查询进度
  • 活跃

概念模型

Producer： 消息生产者，负责产生消息，一般由业务系统负责产生消息 Consumer: 消息消费者，负责消费消息，一般是后台系统负责异步消费 Push Consumer: Consumer的一种，需要向Consumer对象注册监听 Pull Consumer: Consumer的一种，需要主动请求Broker拉取消息 Producer Group: 生产者集合，一般用于发送一类消息, 一个jvm只能启动一个 Consumer Group: 消费者集合，一般用于接受一类消息进行消费 Broker: MQ消息服务（中转角色，用于消息存储与生产消费转发）

源码

  • rocketmq-broker: 主要的业务逻辑，消息收发，主从同步，pagecache
  • rocketmq-client: 客户端接口
  • rocketmq-common: 公用数据结构
  • rocketmq-distribution: 编译模块，编译输出
  • rocketmq-filter: Broker过滤不感兴趣的消息传输，减小带宽压力
  • rocketmq-logappender，rocketmq-logging: 日志相关
  • rocketmq-namesrv: 用于服务协调
  • rocketmq-openmessing: 对外提供服务
  • rocketmq-remoting: 远程调用接口，基于Netty
  • rocketmq-srvutil: 提供一些公用的工具方法，比如解析命令行参数
  • rocketmq-store: 消息存储
  • rocketmq-tools管理工具，比如mqadmin

命令行

nohup /usr/local/apache-rocketmq/bin/mqnamesrv & nohup /usr/local/apache-rocketmq/bin/mqbroker -c /usr/local/apache-rocketmq/conf/2m-2s-async/broker-a.properties &