早期的rocketmq版本的路由功能是使用zookeeper实现的，后来rocketmq为了追求性能，自己实现了一...[作者空间]
本文主要分析RocketMQ通信协议的设计。RocketMQ设计了自己的一个通信协议，用于消息内容和二进制格式之间...[作者空间]
RocketMQ介绍 Apache RocketMQ是一个分布式消息传递和流媒体平台，具有低延迟、高性能和可靠性、...[作者空间]
本文重点分析Broker接收到生产者发送消息请求后，如何存储在Broker上，本文暂不关注事务消息机制。 Rock...[作者空间]
如何在MQ中实现支持任意延迟的消息？ 什么是定时消息和延迟消息？ 定时消息：Producer 将消息发送到 MQ ...[作者空间]
一个消息中间件最核心的东西就是消息存储结构。 这是kafka的消息存储： 每个topic_partition对应一...[作者空间]
在写完上一篇《Pull or Push》之后，原本计划这一片写《存储层设计》，但是临时改变主意了，想先写一篇介绍一...[作者空间]
如果希望消息被所有的订阅者消费，可以使用广播机制。 生产者 producer就是最简单的发送代码。 消费者 再复制...[作者空间]
顺序消息 之前我本地使用的client版本是3.6.2的，但是公司服务器上安得是3.2.6的版本。导致我测试顺序消...[作者空间]
原创文章，转载请联系 RocketMq入门 RocketMq是一种消息中间件，作用是业务相互调用时解耦。可以想象有...[作者空间]
接之前几篇消息中间件组件的模块划分，本篇内容讲述消息的写入和读取流程。 消息的队列模型 队列模型 在描述消息的写入...[作者空间]
前言 接上一篇的《业务方对消息中间件的需求》，在可用性和可靠性的基础上，讨论各种架构的优缺点，最后给出自己关于消息...[作者空间]
什么是分布式消息中间件？对于分布式消息中间件，首先要了解两个基础的概念，即什么是分布式系统，什么又是中间件。 分布...[作者空间]
RocketMQ存储Topic消息时会按照TopicQueue进行划分. 如下图 首先按照BrokerName划分...[作者空间]
阿里巴巴有2大核心的分布式技术，一个是OceanBase，另一个就是RocketMQ。在实际项目中已经领教过Roc...[作者空间]
概述 如RocketMQ源码阅读(二)中所述, RocketMQ的总体架构如下: RocketMQ将注册中心单独提...[作者空间]
简介 在使用了消息队列的通信方之间, 总体的通信架构图如下: 在消息生产者, broker和消息消费者之间都会发生...[作者空间]
最近想深入学习一下消息队列, 本来想看kafka的源码, 但由于kafka是scala写的,本人又不懂kafaka...[作者空间]
