1. 阿里云>
  2. 云栖社区>
  3. 主题地图>
  4. R>
  5. rocketmq消息存储

当前主题:rocketmq消息存储

rocketmq消息存储相关的博客

查看更多 写博客

消息队列(三)RocketMQ如何存储消息

Rocket的消息是有consume queue和commit log组成。 Consume Queue Consume queue是消息的逻辑队列,相当于字典目录,用来指定消息在物理文件(commit log)上的位置,我们可以在配置中指定consumequ

阅读全文

RocketMQ消息轨迹-设计篇

RocketMQ 消息轨迹主要包含两篇文章:设计篇与源码分析篇,本节将详细介绍RocketMQ消息轨迹-设计相关。 RocketMQ消息轨迹,主要跟踪消息发送、消息消费的轨迹,即详细记录消息各个处理环节的日志,从设计上至少需要解决如下三个核心问题: 消费轨迹

阅读全文

rocketMq-broker消息存储介绍

broker的消息存储做了那些事     rocketMq的broker消息存储主要包括3个部分,分别commitLog的存储,consumeQueue的存储,index的存储,这章分享会把这三个过程分解清楚,同时会对里面涉及的存储位置的偏移量着重讲解清楚。

阅读全文

51. 源代码解读-RocketMQ消息重新消费

一. 前言 RocketMQ支持消息消费失败后重新消费,具体代码如下: /* * Register callback to execute on arrival of messages fetched from brokers. */ consumer.reg

阅读全文

RocketMQ高可用探究:消息存储技术

RocketMQ是阿里开源的分布式消息中间件,跟其它中间件相比,RocketMQ的特点是纯JAVA实现、集群和HA实现相对简单、在发生宕机和其它故障时消息丢失率更低,具有良好的高可用架构及稳定性。其发展的迭代历史如下图所示,从2007年至今已发展超过10年。

阅读全文

RocketMQ源码分析之RocketMQ事务消息实现原理上篇(二阶段提交)

在阅读本文前,若您对RocketMQ技术感兴趣,请加入 RocketMQ技术交流群 根据上文的描述,发送事务消息的入口为: TransactionMQProducer#sendMessageInTransaction: public TransactionS

阅读全文

rocketMq概念介绍

rocketMq官网     http://rocketmq.apache.org/ rocketMq逻辑概念介绍 rocketMq逻辑图 备注:    改图片分享自李占卫的网上家园 说明:     在rocketMq的中核心4组件为namesrv、brok

阅读全文

RocketMQ源码分析之RocketMQ事务消息实现原下篇(事务提交或回滚)

若您对RocketMQ技术感兴趣,请加入 RocketMQ技术交流群 本文将重点分析RocketMQ Broker如何处理事务消息提交、回滚命令,根据前面的介绍,其入口EndTransactionProcessor#processRequest: Opera

阅读全文