1.rocketmq概念模型
producer:消息生产者,负责产生消息,一般由业务系统负责产生消息 consumer:消息消费者,负责消费消息,一般是后台系统负责异步消费 push consumer:consumer的一种,需要向consumer对象注册监听 pull consumer:consumer的一种,需要主动请求broker拉取消息 producer group:生产者集合,一般用于发送一类消息 consumer group:消费者集合,一般用于接受一类消息进行消费 broker:mq消息服务(中转角色,用于消息存储与生产消费转发)
2.rocketmq源码包编译与结构说明
rocketmq-broker 主要的业务逻辑,消息收发,主从同步,pagecache rocketmq-client 客户端接口,比如生产者和消费者 rocketmq-example 示例,比如生产者和消费者 rocketmq-common 公用数据结构等等 rocketmq-distribution 编译模块,编译输出等 rocketmq-filter 进行broker过滤的不感兴趣的消息传输,减小带宽压力 rocketmq-logappender,rocketmq-logging日志相关 rocketmq-namesrv namesrv服务,用于服务协调 rocketmq-openmessaging 对外提供服务 rocketmq-remoting 远程调用接口,封装netty底层通信 rocketmq-srvutil 提供一些公用的工具方法,比如解析命令行参数
3.