消息的写入和读取流程

接之前几篇消息中间件组件的模块划分,本篇内容讲述消息的写入和读取流程。 消息的队列模型 队列模型 在描述消息的写入和读取流程之前,首先要弄清楚消息队列的模型是怎么样的,包括消息是怎么存储的。 简化的队列模型大致如上图所示。 一个Topic由多个Partition组成,每个Partition是一个队列,即一个Partition内部的消息是先进先出的(顺序的) Producer会写多个Partitio
相关文章
相关标签/搜索