首页 > TAG信息列表 > mQClientFactory

从入门到入土(八)RocketMQ的Consumer是如何做的负载均衡的

精彩推荐 一百期Java面试题汇总SpringBoot内容聚合IntelliJ IDEA内容聚合Mybatis内容聚合 接上一篇:RocketMQ入门到入土(七 )为什么同一个消费组设置不同tag会出现奇怪现象 一、问题描述面试官:RocketMQ的Consumer是如何做的负载均衡?比如:5个Consumer进程同时消费一个Topic,这个Topic只

RocketMQ源码之 consumer是怎样消费消息的

DefaultMQPushConsumer(以push为例).start()调用mQClientFactory.start(),其中pullMessageService.start在一个循环中从pullRequestQueue中获取pullRequest, 执行pullMessage方法,调用的是remotingClient的invokeAsync方法,传入一个封装了PullCallback的回调函数,等响应到来的时候,PullC

消息队列学习笔记7——生产、消费源码分析

文章目录一、RocketMQ 生产者源码分析1.启动过程2.消息发送过程二、Kafka 消费者源码分析1.订阅过程2.拉取消息 一、RocketMQ 生产者源码分析 版本 release-4.5.1 客户端是一个单独的 Module,在 rocketmq/client 目录中。 源码分析,可以从测试用例入手,一步一步跟踪其方法调用