1.消费方式和消费者组 1.消费方式: 拉取和推送两种(事实上所有从远程获取数据都是这两种方式).2.消费者组与消费模式多个消费者组成一个消费组...

Broker 怎么响应Consumer请求?Broker 如何处理已经消费的消息?Broker 的消息是 at least once还是exac...

本文重点描述如何利用Netty实现一个代理扫描服务, 对Netty的一些基本概念只简单介绍. 1.Netty中几个比较重要的概念 1.0 Boo...

本文分析broker在接收到消息生产者发送的消息后的处理. broker通过底层的通信框架接收到消息后会交给SendMessageProcess...

broker是消息队列的核心组建,承载了消息接收,存储和转发的职责. 因此, broker需要具备各种基本功能和高阶功能.1.基本功能 承载消息...

前面几片文章介绍了RocketMQ底层的文件存储技术, 后续的文章会分析RocketMQ的消息发送和处理. 本文先介绍一下RocketMQ的部署...

前文已经介绍了消息存储中使用到的充要对象, 本文分析一下消息介绍的主流程. 另外, 此篇主要分析消息存储主流程的代码, 不影响主流程的代码先不看...

RocketMQ的消息存储过程非常复杂, 本文先介绍存储模块中几个重要对象. 1. MappedFile 对MappedByteBuffer的封...