Dubbo源码分析（二）：Dubbo之消费端（Consumer）
通观全部Dubbo代码，有两个很重要的对象就是Invoker和Exporter，Dubbo会根据用户配置的协议调用不同协议的Invoker，再通过ReferenceFonfig将Invoker的引用关联到Reference的ref属性上提供给消费端调用。当用户调用一个 ...
原文：RocketMQ源码分析——消费端
长轮询 RocketMQ使用 Consumer gt Broker RocketMQ采用的长轮询建立连接 consumer的处理能力Broker不知道 直接推送消息 broker端压力较大 采用长连接有可能consumer不能及时处理推送过来的数据 pull主动权在consumer手里 短轮询 client不断发送请求到server，每次都需要重新连接 长轮询 client发送请求到server， ...
2020-04-28 11:34 0 603 推荐指数：
相关推荐
RocketMQ源码解析-消息消费
RocketMQ源码解析-消息消费 1.消费者相关类 2.消费者的启动 3.消息的拉取 4.消息的消费 5.消费队列的负载 6.消费进度管理 看了很多遍的代码，还是决定动手把记录下来，梳理一下整体结构和实现细节 RocketMQ中消息的消费分为2种方式，一种是pull模式，一种 ...
RocketMQ消费者之消息消费过程分析
心跳机制 在Consumer启动后，它就会通过定时任务不断地向RocketMQ集群中的所有Broker实例发送心跳包 心跳包内容包含了 消息消费分组名称 订阅关系集合 消息通信模式 ...
Kafka2.0消费者客户端源码分析
1 KafkaConsumer 构造器 初始化参数配置。 初始化消费者网络客户端ConsumerNetworkClient。 初始化消费者协调器ConsumerCoordinator 初始化拉取器Fetcher 2 订阅主题 调用订阅方法subscribe ...
RocketMQ源码分析 consumer消费，并发、顺序、延时、事务消息总结
目录 1.消费客户端启动流程 2.消费队列负载均衡RebalanceService 3.消费拉取PullMessageService流程 3.1.并发消费 3.2.顺序消息消费 3.3.延时消费 3.4.事务消息 ...
阿里消息队列中间件 RocketMQ 源码分析 —— Message 拉取与消费（上）
🙂🙂🙂关注微信公众号：【芋艿的后端小屋】有福利： RocketMQ / MyCAT / Sharding-JDBC 所有源码分析文章列表 RocketMQ / MyCAT / Sharding-JDBC 中文注释源码 GitHub 地址 您对于源码的疑问每条 ...
【RocketMQ】RocketMQ生产者和消费者端的幂等性怎么保证?
RocketMQ 幂等性主要分为生产端和消费端幂等性 备注：这里只讨论生产者 和消费者集群部署下的情况 生产者端幂等性保证： 1RocketMQ 为消息生产者提供了消息查询的API，在消息发送之前，可以查询该条消息是否发送过，注意但是该方法在2020年5月之后的版本，已经被废掉 ...
RocketMQ 源码分析(二) —— Message 存储
CommitLog 结构 CommitLog、MappedFileQueue、MappedFile 的关系如下： CommitLog : MappedFileQueue : MappedFile ...