目录 消息模型 集群部署 NameServer producer消息队列选择器MessageQueueSeleetor 消息存储 commitLog数据存储文件 ConsumeQueue索引文件 IndexFile索引文件 消息查找 根据偏移量查询 根据消息id查询 根据消息key查询 实时更新消息消费队列与索引文件 消息队列与索引文件恢复 过期...
一、项目背景 由于当前生产环境RocketMQ机器使用年限较长，已经过保，并且其中一台曾经发生过异常宕机事件。并且早期网络规划较乱，生产、开发、测试等网络没有分开，公司决定对当前网络进行规划，区分各个环境网段、机柜，涉及到MQ集群需要迁移，由于物理机比较老旧，使用决定使用新机器替换老机器，并且之前的MQ集群为多master模式，当master宕机是会导...
参考携程官网提供的https://github.com/ctripcorp/apollo/wiki/Java%E5%AE%A2%E6%88%B7%E7%AB%AF%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97 整个项目组的代码如下 项目的pom.xml代码如下 <project xmlns="http://maven...
一、rocketMQ是什么 rocketmq是一款低延迟、高可靠、可伸缩、已使用的消息中间件。具有以下特性： 1、支持发布/订阅、点对点（p2p）消息模型 2、同一个队列中支持先进先出（FIFO）和严格的顺序传递 3、支持拉（pull）和推（push）两种消息模式 4、单一队列百万消息的堆积能力 5、支持多种消息协议，比如： JMS 、MQTT 6、分布式...
向长辈致敬: 蠍: 卢兄 像RocketMq 这个怎么测试？ 卢兄: 中间件的测试，要结合中间件的特点来测试 蠍: 特点什么意思 卢兄: 比如，这个工具是作为发布消息和消费消息的，具有解耦的特点 卢兄: 那么你可以通过做交易，去看他是否能够正常发布消息，消费消息 卢兄: 最重要的还是要去测试他的性能 蠍: 性能怎么测试 卢兄: 让其消息队列积累大量的...
搜索镜像 可以选择在官方网站 hub.docker.com 上搜索镜像； 或者在命令行界面中执行命令 docker search rocketmq 搜索镜像； 以下表格是排名靠前的镜像对比： 镜像名称 下载量Downloads 收藏数Stars 最后维护时间 说明文档 foxiswho/rocketmq 500K+ 54 7个月前 有文档...
引言 本文以一张云进化历史图开场，来谈谈云原生时代消息中间件的演进路线，但本文绝对不是“开局一张图，内容全靠编”。 从虚拟化技术诞生以来，IaaS/PaaS/SaaS概念陆续被提了出来，各种容器技术层出不穷。到2015年，Cloud Native概念应运而生，一时间，各种云厂商，云服务以及云应用都加上了“云原生”前缀。 我们也一直在思考，传统的消息中间件...
1.消息队列介绍 消息队列本质上来说是一个符合先进先出原则的单向队列：一方发送消息并存入消息队列尾部(生产者投递消息)，一方从消息队列的头部取出消息(消费者消费消息)。但对于一个成熟可靠的消息队列来说，所需要解决的主要问题还包括：高效可靠的消息投递、存储；能承受高并发的流量冲击，可通过集群部署来解决单点故障等等。 由于消息队列具备了以上特点，因此在...
原文地址： http://jm.taobao.org/2017/01/12/rocketmq-quick-start-in-10-minutes/ 感谢原作者 十分钟入门RocketMQ 本文首先引出消息中间件通常需要解决哪些问题，在解决这些问题当中会遇到什么困难，Apache RocketMQ作为阿里开源的一款高性能、高吞吐量的分布式消息中间件否可以解...
最近看了@JavaGuide发布的一篇『面试官问我如何保证Kafka不丢失消息？我哭了！』，这篇文章承接这个主题，来聊聊如何保证 RocketMQ 不丢失消息。 0x00. 消息的发送流程 一条消息从生产到被消费，将会经历三个阶段： 生产阶段，Producer 新建消息，然后通过网络将消息投递给 MQ Broker存储阶段，消息将会存储在 Broker...