标签:生产者 broker 编译 消息 consumer 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.
标签:生产者,broker,编译,消息,consumer,rocketmq 来源: https://www.cnblogs.com/hbxZJ/p/15421463.html
本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享; 2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关; 3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关; 4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除; 5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。