前言 众所周知，作为一个出色的分布式消息中间件，RocketMQ 在全球范围内获得了广泛的应用，那么作为一个分布式消息中间件，最重要的是什么？ 协议？持久化？消息分发实现？高可用？高可靠？ 好...

MQ系列1：消息中间件执行原理MQ系列2：消息中间件的技术选型MQ系列3：RocketMQ 架构分析MQ系列4：NameServer 原理解析MQ系列5：RocketMQ消息的发送模式MQ系列6：消息的消费MQ系列7：消息通信，...

Broker端文件详解 dubbo的核心是spi，看懂了spi那么dubbo基本上也懂了。对于rmq来说，它的核心是broker，而broker的核心是commitlog、consumequeue、indexfile，而这些文件对应的最终都是Mapped...

消息重复的场景 发送消息异常,重试发送导致消息重复★ 当一条消息已被成功发送到服务端并完成持久化。此时出现网络闪断或者客户端宕机，导致服务端对生产者的确认应答失败。生产者发送消息到mq...

在分布式系统中，实现事务的一致性和可靠性是一项重要的挑战。本文将详细介绍如何利用 RocketMQ 的半消息机制来实现分布式事务，并提供具体的代码示例和最佳实践。 1. 引言 在分布式系统中，事...

消息中间件如何选型 RabbitMQ erlang开发，对消息堆积的支持并不好，当大量消息积压的时候，会导致 RabbitMQ 的性能急剧下降。每秒钟可以处理几万到十几万条消息。 RocketMQ java开发，面向互联...

本文主要有以下内容： 简单消息的发送 顺序消息的发送 RocketMQTemplate的API介绍 环境搭建： RocketMQ的安装教程：在官网上下载bin文件，解压到本地，并配置环境变量，如下图所示： 在 Spring ...

生产者发送消息的流程图 生产者发送消息的调用链路如下: org.apache.rocketmq.client.producer.DefaultMQProducer#send(org.apache.rocketmq.common.message.Message) ​ org.apache.rocketmq.c...

标签：RocketMq5.Dashboard； 一、简介 RocketMQ因其架构简单、业务功能丰富、具备极强可扩展性等特点被广泛应用，比如金融业务、互联网、大数据、物联网等领域的业务场景； 二、环境部署 1、编...

Broker启动流程:BrokerStartup#main  public static void main(String[] args) {        //手动指定了 nameServer        start(createBrokerController(args));   } public static B...

MQ系列1：消息中间件执行原理MQ系列2：消息中间件的技术选型MQ系列3：RocketMQ 架构分析MQ系列4：NameServer 原理解析MQ系列5：RocketMQ消息的发送模式MQ系列6：消息的消费MQ系列7：消息通信，...

RocketMQ是通过DefaultMQProducer进行消息发送的，它实现了MQProducer接口，MQProducer接口中定义了消息发送的方法，方法主要分为三大类： send同步进行消息发送，向Broker发送消息之后等待响应...

Broker读写磁盘文件的核心技术:mmap Broker中大量的使用mmap技术去实现CommitLog这种大磁盘文件的高性能读写优化的。 通过之前的学习，我们知道了一点，就是Broker对磁盘文件的写入主要是借助直...

NameServer 路由管理 Broker消息服务器在启动的时向所有NameServer注册。 消息生产者Producer在发送消息之前先从NameServer获取Broker服务器地址列表然后根据负载均衡算法从列表中选择一台服务...

1.5 死信队列 当一条消息初次消费失败，消息队列 RocketMQ 会自动进行消息重试；达到最大重试次数后，若消费依然失败，则表明消费者在正常情况下无法正确地消费该消息，此时，消息队列 RocketMQ...

Rocket MQ 背景 至 2010 年，随着阿里业务的快速发展，急需一款支持顺序消息，拥有海量消息堆积能力的消息 Meta Q 1.0 在 2011 年诞生。 到 2012 年， Meta Q 已经发展到了 Meta Q 3.0 ，并抽象...

Broker消息存储概要设计 RocketMQ主要存储的文件包括Commitlog文件，ConsumeQueue文件，IndexFile文件。 RMQ把所有主题的消息存储在同一个文件中，确保消息发送时顺序写文件。 为了提高消费效率...