【源码】RocketMQ如何实现获取指定消息
概要 消息查询是什么？ 消息查询就是根据用户提供的msgId从MQ中取出该消息 RocketMQ如果有多个节点如何查询？ 问题：RocketMQ分布式结构中，数据分散在各个节点，即便是同一Topic的数据，也未必都在一个broker上。客户端怎么知道数据该去哪个节点上查？ 猜想1：逐个 ...
原文：RocketMQ源码 — 五、 主要feature及其实现方式
RocketMQ的主要特点以及实现方式 单机支持 万以上持久队列 所有数据单独存储到一个CommitLog，完全顺序写，随机读 在一个broker上一个DefaultMessageStore管理一个commitLog 顺序写：在commitLog.putMessage里面获取mapedFile之后进入synchronized块，开始写内存，所以当有新的消息需要保存的时候会等待锁释放，所以写消息的时 ...
2017-01-18 23:01 1 1727 推荐指数：
相关推荐
RocketMQ源码 — 八、 RocketMQ消息重试
RocketMQ的消息重试包含了producer发送消息的重试和consumer消息消费的重试。 producer发送消息重试 producer在发送消息的时候如果发送失败了，RocketMQ会自动重试。 重试几次？ 由上面可以看出发送消息的重试次数区分不同的情况： 同步发送 ...
RocketMQ源码 — 六、 RocketMQ高可用（1）
高可用究竟指的是什么？请参考：关于高可用的系统 RocketMQ做了以下的事情来保证系统的高可用 多master部署，防止单点故障 消息冗余（主从结构），防止消息丢失 故障恢复（本篇暂不讨论） 那么问题来了： 怎么支持多broker的写？ 怎么实现消息冗余 ...
RocketMQ源码 — 七、 RocketMQ高可用（2）
上一篇说明了RocketMQ怎么支持broker集群的，这里接着说RocketMQ实现高可用的手段之一——冗余。 RocketMQ部署的时候一个broker set会有一个mater和一个或者多个slave，salve起到的作用就是同步master存储的的消息，并且会接收部分consumer读取 ...
RocketMQ源码 — 九、 RocketMQ延时消息
通过设置消息被投递的时间来实现的，但是Apache RocketMQ在版本4.2.0中尚不支持指定时间 ...
rocketmq源码分析4-事务消息实现原理
为什么消息要具备事务能力 参见还是比较清晰的。简单的说 就是在你业务逻辑过程中，需要发送一条消息给订阅消息的人，但是期望是 此逻辑过程完全成功完成之后才能使订阅者收到消息。业务逻辑过程 假设是这样的 ...
rocketmq 以广播方式实现消费者消费消息
package com.bfxy.rocketmq.model; import java.util.List; import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;import ...
EasyTransaction主要源码分析
EasyTransaction是一个全功能的分布式事务框架，以下特性摘抄自其首页：https://github.com/QNJR-GROUP/EasyTransaction 一个框架包含多种事 ...