1.rocketmq

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.

 

上一篇:【JavaWeb】HttpClient


下一篇:Centos7搭建基于GTID的MySQL的M-M-S-S架构