BestHub
Sign in
Tagged articles

RocketMQ

571 articles · Page 4 of 6
Top Architect
Top Architect
Nov 19, 2022 · Backend Development

Implementing Distributed Transactions with RocketMQ and SEATA in a Microservice Architecture

This article explains the concept of distributed transactions, presents typical microservice scenarios that generate them, and demonstrates a complete implementation using RocketMQ transactional messages and SEATA, including database schema, producer and consumer code, transaction listeners, and idempotent consumption handling.

RocketMQSeataSpring Boot
0 likes · 14 min read
Implementing Distributed Transactions with RocketMQ and SEATA in a Microservice Architecture
Alibaba Cloud Native
Alibaba Cloud Native
Nov 17, 2022 · Cloud Native

How RocketMQ Harnesses Prometheus for Full‑Stack Observability

This article explains how RocketMQ integrates with Prometheus and Grafana to provide comprehensive metrics, tracing, and logging, detailing the exporter architecture, deployment choices, span topology, dashboard examples, and ARMS‑based alerting for cloud‑native message‑queue observability.

ARMSCloud NativePrometheus
0 likes · 14 min read
How RocketMQ Harnesses Prometheus for Full‑Stack Observability
Architect's Guide
Architect's Guide
Nov 15, 2022 · Backend Development

RocketMQ Message Types, Sending Modes, Ordering, Delayed, Transactional, Batch, Filtering, Retry and Dead‑Letter Queues

This article provides a comprehensive overview of RocketMQ messaging concepts—including synchronous, asynchronous and one‑way sending, ordered and delayed messages, transaction handling, batch processing, tag/SQL filtering, retry mechanisms, and dead‑letter queue management—accompanied by Java code examples for each scenario.

Message QueueRocketMQdistributed systems
0 likes · 36 min read
RocketMQ Message Types, Sending Modes, Ordering, Delayed, Transactional, Batch, Filtering, Retry and Dead‑Letter Queues
Top Architect
Top Architect
Nov 6, 2022 · Backend Development

Implementing Distributed Transactions with RocketMQ Transaction Messages

This article explains the concept of distributed transactions, presents typical micro‑service scenarios that generate them, and demonstrates a complete solution using RocketMQ transaction messages together with SQL table definitions and Java code for producers, transaction listeners, and consumers to achieve eventual consistency.

RocketMQSQLdistributed transaction
0 likes · 14 min read
Implementing Distributed Transactions with RocketMQ Transaction Messages
dbaplus Community
dbaplus Community
Oct 7, 2022 · Backend Development

How We Replaced RabbitMQ with RocketMQ for a High‑Performance, Highly‑Available Messaging Platform

This article details the challenges of scaling RabbitMQ, the evaluation of RocketMQ versus Pulsar, the design of a new messaging middleware platform with high availability, performance, and rich features, and the step‑by‑step migration strategy that enabled seamless, low‑cost transition for massive business traffic.

MiddlewareMigrationRocketMQ
0 likes · 15 min read
How We Replaced RabbitMQ with RocketMQ for a High‑Performance, Highly‑Available Messaging Platform
Cognitive Technology Team
Cognitive Technology Team
Oct 2, 2022 · Backend Development

Implementation Principles of RocketMQ Scheduled/Delayed Messages and Extending to Arbitrary Time Precision

This article explains how RocketMQ implements scheduled and delayed messages using fixed delay levels, the internal storage flow, code examples for setting delay levels, and advanced techniques such as RocksDB integration to achieve arbitrary time precision for delayed delivery.

Delayed MessageMessage QueueRocketMQ
0 likes · 6 min read
Implementation Principles of RocketMQ Scheduled/Delayed Messages and Extending to Arbitrary Time Precision
Alibaba Cloud Native
Alibaba Cloud Native
Sep 29, 2022 · Cloud Native

Why Use RocketMQ Connect for Scalable Data Pipelines?

This article explains the challenges of point‑to‑point data sync, introduces RocketMQ Connect as a cloud‑native solution that decouples upstream and downstream, details its architecture, connectors, REST API, metrics, deployment modes, and provides a step‑by‑step guide to building custom connectors for use cases such as CDC, data lakes, and system migration.

CDCCloud NativeConnector
0 likes · 19 min read
Why Use RocketMQ Connect for Scalable Data Pipelines?
Su San Talks Tech
Su San Talks Tech
Sep 17, 2022 · Fundamentals

Why Does Thread.sleep(0) Prevent GC? Uncovering JVM Safepoint Tricks

This article examines a puzzling 'prevent gc' comment in RocketMQ source, explains how inserting Thread.sleep(0) creates a JVM safepoint to avoid long GC pauses, explores counted vs uncounted loops, and demonstrates practical code modifications to improve performance.

Garbage CollectionJVMJava performance
0 likes · 13 min read
Why Does Thread.sleep(0) Prevent GC? Uncovering JVM Safepoint Tricks
ITPUB
ITPUB
Sep 14, 2022 · Backend Development

Mastering Thread Creation in RocketMQ: From ServiceThread to ThreadPoolExecutor

This article explains how RocketMQ creates and manages threads, covering single‑thread techniques, the ServiceThread abstract class, ThreadPoolExecutor fundamentals, custom thread‑pool wrappers, and the critical role of descriptive thread names for debugging and performance monitoring.

Java concurrencyRocketMQServiceThread
0 likes · 8 min read
Mastering Thread Creation in RocketMQ: From ServiceThread to ThreadPoolExecutor
ShiZhen AI
ShiZhen AI
Sep 10, 2022 · Interview Experience

When Does Adding Consumers Reduce RocketMQ Backlog?

The article walks through an interview scenario on RocketMQ, explaining when increasing consumer instances speeds up message consumption, the conditions that cause consumer pull delays, and the six built‑in queue‑allocation strategies with code examples and practical trade‑offs.

AllocationStrategyConsumerScalingLoadBalancing
0 likes · 10 min read
When Does Adding Consumers Reduce RocketMQ Backlog?
macrozheng
macrozheng
Sep 9, 2022 · Fundamentals

Why Does Thread.sleep(0) Appear in RocketMQ? Uncovering the Safepoint Trick

This article examines the puzzling 'prevent gc' comment and Thread.sleep(0) call in RocketMQ’s source, explains how it leverages JVM safepoint mechanics to trigger garbage collection, discusses counted vs uncounted loops, and demonstrates practical code modifications to improve performance.

GCRocketMQSafepoint
0 likes · 13 min read
Why Does Thread.sleep(0) Appear in RocketMQ? Uncovering the Safepoint Trick
ITPUB
ITPUB
Sep 5, 2022 · Backend Development

How to Choose the Right Message Queue: Kafka, RabbitMQ, RocketMQ, and ActiveMQ Compared

This comprehensive guide explains the core concepts, deployment modes, evaluation criteria, and detailed pros and cons of the four major message‑queue platforms—Kafka, RabbitMQ, RocketMQ, and ActiveMQ—helping engineers make informed decisions for interview preparation and system design.

ActiveMQMessage QueueRocketMQ
0 likes · 43 min read
How to Choose the Right Message Queue: Kafka, RabbitMQ, RocketMQ, and ActiveMQ Compared
21CTO
21CTO
Aug 23, 2022 · Cloud Native

How RocketMQ Evolved into a Cloud‑Native Super‑Fusion Messaging Platform

This article traces RocketMQ's transformation from a traditional message queue to a cloud‑native, ultra‑fusion platform that integrates messaging, event‑driven architecture, and streaming, highlighting its historical stages, architectural upgrades, multi‑language SDKs, stateless consumption, and future cloud‑native trends.

Cloud NativeMessage QueueRocketMQ
0 likes · 22 min read
How RocketMQ Evolved into a Cloud‑Native Super‑Fusion Messaging Platform
IT Architects Alliance
IT Architects Alliance
Aug 21, 2022 · Backend Development

How to Build a Scalable Delayed Queue with Redis and Java

This article explains why delayed queues are needed for scenarios like unpaid orders or auto‑generated comments, compares built‑in and third‑party solutions, and provides a detailed design and implementation guide for a Redis‑based delayed‑queue service, including version‑1.0 features, version‑2.0 optimizations, and multi‑node deployment.

Delayed QueueMessage QueueRedis
0 likes · 9 min read
How to Build a Scalable Delayed Queue with Redis and Java
Tencent Cloud Developer
Tencent Cloud Developer
Aug 19, 2022 · Backend Development

Message Queue Basics, Use Cases, and Selection Guide for Kafka, RabbitMQ, Pulsar, and RocketMQ

The article explains fundamental concepts, common use cases, and selection criteria for four popular message‑queue platforms—Kafka, RabbitMQ, Pulsar, and RocketMQ—detailing each system’s architecture, strengths, and drawbacks so readers can match workload, scalability, ordering, latency, and operational needs to the most suitable middleware.

KafkaMessage QueueRocketMQ
0 likes · 16 min read
Message Queue Basics, Use Cases, and Selection Guide for Kafka, RabbitMQ, Pulsar, and RocketMQ
High Availability Architecture
High Availability Architecture
Aug 10, 2022 · Backend Development

Design and Migration of a High‑Performance Message Middleware Platform from RabbitMQ to RocketMQ

To address RabbitMQ’s scalability, reliability, and feature limitations, Vivo’s middleware team evaluated RocketMQ and Pulsar, selected RocketMQ, and built a next‑generation message middleware platform with an AMQP‑proxy gateway, metadata services, and high‑availability mechanisms, enabling seamless, high‑throughput migration and richer messaging capabilities.

MiddlewareRocketMQhigh-availability
0 likes · 13 min read
Design and Migration of a High‑Performance Message Middleware Platform from RabbitMQ to RocketMQ
Sanyou's Java Diary
Sanyou's Java Diary
Aug 8, 2022 · Backend Development

How RocketMQ Achieves Smart Push Consumption with Long Polling

This article explains RocketMQ's push and pull consumption modes, shows how its pseudo‑push implementation uses long polling to balance real‑time delivery and consumer pressure, and walks through the core source‑code mechanisms that hold and resume pull requests.

RocketMQbackendconsumer pressure
0 likes · 10 min read
How RocketMQ Achieves Smart Push Consumption with Long Polling
Sohu Tech Products
Sohu Tech Products
Aug 3, 2022 · Fundamentals

Common Message Queues: RabbitMQ, RocketMQ, and Kafka – Components, Features, and Best Practices

This article introduces the core concepts, components, exchange types, reliability mechanisms, ordering, delay, transaction, high‑availability, and load‑balancing strategies of three popular message‑queue systems—RabbitMQ, RocketMQ, and Kafka—while also discussing common challenges such as message ordering, delayed consumption, reliability, idempotence, and backlog handling.

KafkaMessage QueueRocketMQ
0 likes · 33 min read
Common Message Queues: RabbitMQ, RocketMQ, and Kafka – Components, Features, and Best Practices
Alibaba Cloud Native
Alibaba Cloud Native
Aug 3, 2022 · Cloud Native

How RocketMQ Transactional Messages Ensure Distributed Consistency

This article explains the challenges of maintaining atomicity across multiple downstream services in distributed systems and details how RocketMQ's transactional message feature provides a two‑phase commit mechanism, lifecycle, implementation details, and practical usage to achieve eventual consistency.

Cloud NativeMessage QueueRocketMQ
0 likes · 14 min read
How RocketMQ Transactional Messages Ensure Distributed Consistency
IT Architects Alliance
IT Architects Alliance
Aug 1, 2022 · Backend Development

Overview of RabbitMQ, RocketMQ, and Kafka Components and Mechanisms

This article provides a comprehensive overview of the core components, exchange types, TTL, confirmation mechanisms, dead‑letter queues, and reliability features of RabbitMQ, RocketMQ, and Kafka, along with practical guidance on ordering, delayed consumption, transaction handling, high availability, load balancing, and message deduplication in distributed messaging systems.

KafkaRocketMQrabbitmq
0 likes · 33 min read
Overview of RabbitMQ, RocketMQ, and Kafka Components and Mechanisms
MaGe Linux Operations
MaGe Linux Operations
Jul 31, 2022 · Backend Development

Mastering Message Queues: Key Concepts of RabbitMQ, RocketMQ, and Kafka

This article provides a comprehensive overview of modern message‑queue systems, detailing RabbitMQ components and exchange types, RocketMQ’s core architecture and high‑availability features, and Kafka’s fundamental concepts, controller mechanisms, and consumer rebalance strategies, while also covering reliability, ordering, and dead‑letter handling techniques.

KafkaMessage QueueRocketMQ
0 likes · 31 min read
Mastering Message Queues: Key Concepts of RabbitMQ, RocketMQ, and Kafka
Su San Talks Tech
Su San Talks Tech
Jul 31, 2022 · Fundamentals

Mastering Message Queues: Core Concepts of RabbitMQ, RocketMQ, and Kafka

This article explains the fundamental components and mechanisms of RabbitMQ, RocketMQ, and Kafka—including exchanges, TTL, confirm and return listeners, consumer ACK/NACK, dead‑letter queues, delay and ordered messages, transactional flows, high‑availability setups, load balancing, partitioning, leader election, offset handling, and practical solutions to common messaging challenges.

KafkaMessage QueueRocketMQ
0 likes · 31 min read
Mastering Message Queues: Core Concepts of RabbitMQ, RocketMQ, and Kafka
Top Architect
Top Architect
Jul 31, 2022 · Backend Development

Design and Implementation of Delayed Message Queues in Distributed Systems

This article surveys common delayed‑message solutions in distributed asynchronous messaging, evaluates implementations based on external storage, databases, RocksDB, Redis, and open‑source MQs like RocketMQ, Pulsar and QMQ, and discusses their advantages, drawbacks, and practical design considerations.

Delayed MessagingRedisRocketMQ
0 likes · 13 min read
Design and Implementation of Delayed Message Queues in Distributed Systems
Top Architect
Top Architect
Jul 30, 2022 · Backend Development

Comprehensive Overview of RabbitMQ, RocketMQ, and Kafka: Architecture, Components, and Best Practices

This article provides an in‑depth technical guide to three major message‑queue systems—RabbitMQ, RocketMQ, and Kafka—covering their core components, exchange and routing mechanisms, durability features, consumer acknowledgment, dead‑letter handling, load balancing, and practical strategies for reliability, ordering, and scaling in distributed backend applications.

RocketMQdistributed systemsmessaging
0 likes · 29 min read
Comprehensive Overview of RabbitMQ, RocketMQ, and Kafka: Architecture, Components, and Best Practices
ITPUB
ITPUB
Jul 29, 2022 · Operations

Migrating to RocketMQ: Building a High‑Performance Cloud‑Native Messaging Platform

Facing scaling, high‑availability, and feature limitations of RabbitMQ, the vivo middleware team evaluated RocketMQ and Pulsar, chose RocketMQ, and detailed a seamless migration strategy—including a message gateway, metadata mapping, high‑performance push, consumption controls, and operational benefits that boosted TPS and reduced resource usage.

MigrationRocketMQmessaging
0 likes · 14 min read
Migrating to RocketMQ: Building a High‑Performance Cloud‑Native Messaging Platform
AI Illustrated Series
AI Illustrated Series
Jul 28, 2022 · Backend Development

How to Ensure Distributed Transaction Consistency Using Message Queues

This article analyzes the challenges of distributed transactions in multi‑node systems and compares various solutions—including 2PC, 3PC, TCC, Saga, local message tables, and MQ‑based approaches—detailing their mechanisms, trade‑offs, and practical implementations with concrete examples from order and cart services.

2PCKafkaMQ
0 likes · 19 min read
How to Ensure Distributed Transaction Consistency Using Message Queues
Architecture Digest
Architecture Digest
Jul 28, 2022 · Backend Development

Design and Smooth Migration of a High‑Availability Message Middleware Platform from RabbitMQ to RocketMQ

This article details the challenges of scaling RabbitMQ, the evaluation of RocketMQ versus Pulsar, the architectural design of a new high‑availability message middleware platform, and the step‑by‑step smooth migration strategy that enables higher throughput, richer features, and lower operational costs.

High AvailabilityMiddlewareMigration
0 likes · 12 min read
Design and Smooth Migration of a High‑Availability Message Middleware Platform from RabbitMQ to RocketMQ
vivo Internet Technology
vivo Internet Technology
Jul 27, 2022 · Operations

Building and Migrating to RocketMQ-based Message Middleware Platform at vivo

vivo’s Internet Middleware Team replaced its RabbitMQ service with a RocketMQ‑based platform, building an AMQP‑Proxy gateway and metadata layer to enable seamless, zero‑downtime migration while achieving over 100,000 TPS, billion‑message capacity, 50% resource savings, and advanced features such as transactions, ordered and delayed messaging, and tracing.

Message MiddlewareRabbitMQ MigrationRocketMQ
0 likes · 12 min read
Building and Migrating to RocketMQ-based Message Middleware Platform at vivo
Architect's Guide
Architect's Guide
Jul 27, 2022 · Backend Development

Design and Implementation of Delayed Messaging in Distributed Systems

This article surveys common delayed‑message solutions—including database, RocksDB, Redis, and open‑source MQs like RocketMQ, Pulsar, and QMQ—explaining their architectures, advantages, drawbacks, and practical considerations for building reliable distributed asynchronous messaging.

Backend ArchitectureDelayed MessagingRedis
0 likes · 13 min read
Design and Implementation of Delayed Messaging in Distributed Systems
Sanyou's Java Diary
Sanyou's Java Diary
Jul 21, 2022 · Fundamentals

How to Choose the Right Message Queue: Kafka vs RabbitMQ vs RocketMQ

This article explains the fundamentals of message queues, compares Kafka, RabbitMQ, and RocketMQ in terms of architecture, key concepts, advantages, and drawbacks, and provides practical guidance on selecting the most suitable queue for different application scenarios such as high‑throughput logging, financial transactions, or small‑scale services.

KafkaMiddlewareRocketMQ
0 likes · 16 min read
How to Choose the Right Message Queue: Kafka vs RabbitMQ vs RocketMQ
Selected Java Interview Questions
Selected Java Interview Questions
Jul 18, 2022 · Backend Development

Implementing Automatic Order Closure in E‑commerce: Scheduled Tasks, RocketMQ Delay Queue, RabbitMQ DLQ, Time Wheel, and Redis Expiration Listener

The article examines five backend techniques for automatically closing unpaid e‑commerce orders—scheduled tasks, RocketMQ delayed messages, RabbitMQ dead‑letter queues, a time‑wheel algorithm, and Redis key‑expiration listeners—detailing their principles, advantages, drawbacks, and sample Java code implementations.

Message QueueRocketMQTime Wheel
0 likes · 16 min read
Implementing Automatic Order Closure in E‑commerce: Scheduled Tasks, RocketMQ Delay Queue, RabbitMQ DLQ, Time Wheel, and Redis Expiration Listener
Architecture & Thinking
Architecture & Thinking
Jul 14, 2022 · Fundamentals

Understanding Message Queues: Execution Principles and Choosing the Right MQ

This article explains the fundamentals of message middleware, covering its architecture, components, communication models, advantages, common protocols, major open‑source solutions, detailed feature comparisons, and practical guidance for selecting the most suitable message queue based on system scale, business needs, performance, high availability, and operational considerations.

KafkaMQMessage Queue
0 likes · 21 min read
Understanding Message Queues: Execution Principles and Choosing the Right MQ
Alibaba Cloud Native
Alibaba Cloud Native
Jul 7, 2022 · Backend Development

Why RocketMQ’s Ordinary Messages Power Business Integration

This article explains how RocketMQ’s ordinary messages meet the core demands of business integration, detailing their architecture, lifecycle, key features, typical use cases, and practical code examples for sending and consuming messages.

Business IntegrationMicroservicesRocketMQ
0 likes · 11 min read
Why RocketMQ’s Ordinary Messages Power Business Integration
Selected Java Interview Questions
Selected Java Interview Questions
Jul 7, 2022 · Backend Development

Overview of RabbitMQ, RocketMQ, and Kafka: Components, Mechanisms, and Best Practices

This article provides a comprehensive introduction to three major message‑queue systems—RabbitMQ, RocketMQ, and Kafka—explaining their core components, exchange types, delivery guarantees, confirmation mechanisms, dead‑letter handling, high‑availability designs, load‑balancing strategies, and common troubleshooting techniques.

KafkaRocketMQ
0 likes · 32 min read
Overview of RabbitMQ, RocketMQ, and Kafka: Components, Mechanisms, and Best Practices
vivo Internet Technology
vivo Internet Technology
Jul 6, 2022 · Backend Development

RocketMQ Consumer Startup Process and Message Consumption Mechanisms

RocketMQ consumers initialize by validating configuration, creating subscription data, establishing a client instance, loading offsets, and starting services before registering with the client factory, after which they can receive messages via push (default low‑latency) or pull modes, support ordered processing, and handle acknowledgments with configurable retries and dead‑letter handling.

Ordered MessagingPush‑PullRocketMQ
0 likes · 24 min read
RocketMQ Consumer Startup Process and Message Consumption Mechanisms
Top Architect
Top Architect
Jul 6, 2022 · Backend Development

Implementing Automatic Order Closure in E‑commerce: Scheduled Tasks, RocketMQ Delay Queue, RabbitMQ Dead‑Letter Queue, Time Wheel Algorithm, and Redis Expiration

The article explains how to automatically close unpaid e‑commerce orders by comparing five approaches—simple scheduled tasks, RocketMQ delayed messages, RabbitMQ dead‑letter queues, a time‑wheel algorithm, and Redis key‑expiration listeners—detailing their advantages, drawbacks, and providing Java code examples for each method.

@OrderRocketMQrabbitmq
0 likes · 16 min read
Implementing Automatic Order Closure in E‑commerce: Scheduled Tasks, RocketMQ Delay Queue, RabbitMQ Dead‑Letter Queue, Time Wheel Algorithm, and Redis Expiration
Sanyou's Java Diary
Sanyou's Java Diary
Jul 4, 2022 · Backend Development

Mastering CompletableFuture: From Basics to RocketMQ Integration

This article introduces Java's CompletableFuture, compares it with Future, explains its core APIs, demonstrates common usage patterns—including creation, result retrieval, chaining, exception handling, and task combination—and shows a practical integration example within RocketMQ's message storage workflow.

CompletableFutureRocketMQasync
0 likes · 15 min read
Mastering CompletableFuture: From Basics to RocketMQ Integration
Architect
Architect
Jul 3, 2022 · Backend Development

Order Timeout Strategies: Scheduled Tasks, RocketMQ Delay Queue, RabbitMQ Dead‑Letter, Time Wheel, and Redis Expiration

The article compares five practical approaches for automatically closing unpaid orders—scheduled tasks, RocketMQ delayed messages, RabbitMQ dead‑letter queues, a time‑wheel algorithm, and Redis key‑expiration listeners—detailing their principles, advantages, limitations, and providing concrete Java code examples for each method.

RedisRocketMQorder timeout
0 likes · 17 min read
Order Timeout Strategies: Scheduled Tasks, RocketMQ Delay Queue, RabbitMQ Dead‑Letter, Time Wheel, and Redis Expiration
Java Captain
Java Captain
Jun 23, 2022 · Backend Development

Choosing the Right Delayed Task Implementation: Avoid Redis Expiration and RabbitMQ Dead‑Letter Queues

This article evaluates common delayed‑task solutions such as RocketMQ, Pulsar, Redisson DelayQueue, Redis expiration listeners, RabbitMQ dead‑letter queues, and time wheels, highlighting their drawbacks and recommending reliable approaches for accurate order‑closing tasks in e‑commerce systems.

Delayed TasksMessage QueueRedisson
0 likes · 7 min read
Choosing the Right Delayed Task Implementation: Avoid Redis Expiration and RabbitMQ Dead‑Letter Queues
Architecture Digest
Architecture Digest
Jun 15, 2022 · Backend Development

Understanding RocketMQ Producer and Consumer Load Balancing Mechanisms

This article explains RocketMQ’s overall architecture and details how producers and consumers achieve load balancing through routing synchronization, queue selection, and rebalance strategies, illustrated with code examples and a case study of assigning consumption to a specific machine.

ProducerRocketMQconsumer
0 likes · 20 min read
Understanding RocketMQ Producer and Consumer Load Balancing Mechanisms
NetEase Cloud Music Tech Team
NetEase Cloud Music Tech Team
Jun 8, 2022 · Backend Development

Design of a Bus‑Style Service (Pigeon) for Flexible Activity Composition in Live Streaming

The paper presents Pigeon, a lightweight, bus‑style routing service for live‑streaming activities that lets completed modules publish packets to a configurable dispatcher, enabling asynchronous, SDK‑driven composition without code changes, supporting automatic registration, high‑throughput RocketMQ delivery, and future FaaS/BaaS extensions.

Message BusMicroservicesRocketMQ
0 likes · 20 min read
Design of a Bus‑Style Service (Pigeon) for Flexible Activity Composition in Live Streaming
IT Services Circle
IT Services Circle
May 27, 2022 · Backend Development

Design Principles of a High‑Performance Message Broker (RocketMQ)

The article explains how to redesign a high‑traffic user‑registration flow by introducing an asynchronous queue layer, detailing the broker architecture, commitlog, consumeQueue, page‑cache, mmap, topic/tag routing, high‑availability strategies, and the role of a nameserver in a RocketMQ‑style system.

Message QueueRocketMQasynchronous processing
0 likes · 26 min read
Design Principles of a High‑Performance Message Broker (RocketMQ)
Spring Full-Stack Practical Cases
Spring Full-Stack Practical Cases
May 27, 2022 · Backend Development

Filtering RocketMQ Messages in Spring Boot: Tag vs SQL‑92 Techniques

This guide demonstrates how to integrate RocketMQ with Spring Boot, covering dependency setup, configuration, and two message‑filtering techniques—tag‑based and SQL‑92 expression filtering—complete with consumer and producer code examples, testing endpoints, and visual diagrams illustrating each approach.

Message FilteringRocketMQSQL filtering
0 likes · 6 min read
Filtering RocketMQ Messages in Spring Boot: Tag vs SQL‑92 Techniques
Architecture Digest
Architecture Digest
May 27, 2022 · Backend Development

Ensuring Message Reliability in RocketMQ and RabbitMQ

This article explains how RocketMQ and RabbitMQ guarantee message reliability by covering production, storage, and consumption stages, introducing confirm mechanisms, persistence settings, manual acknowledgments, and compensation strategies such as message database storage to achieve near‑zero data loss in distributed systems.

RocketMQbackend developmentrabbitmq
0 likes · 10 min read
Ensuring Message Reliability in RocketMQ and RabbitMQ
Java High-Performance Architecture
Java High-Performance Architecture
May 27, 2022 · Backend Development

How to Implement Precise Order Auto‑Close in E‑Commerce: Timers, MQs, and Redis

This article explores five practical techniques for automatically closing unpaid e‑commerce orders—ranging from simple scheduled tasks to advanced RocketMQ delay queues, RabbitMQ dead‑letter queues, time‑wheel algorithms, and Redis expiration listeners—detailing their mechanisms, trade‑offs, and implementation code.

RocketMQmessage-queueorder-closure
0 likes · 18 min read
How to Implement Precise Order Auto‑Close in E‑Commerce: Timers, MQs, and Redis
Code Ape Tech Column
Code Ape Tech Column
May 27, 2022 · Backend Development

Comparison of Four Popular Open-Source Distributed Message Queues: Kafka, ActiveMQ, RabbitMQ, and RocketMQ

This article introduces and compares four widely used open-source distributed message-queue systems—Kafka, ActiveMQ, RabbitMQ, and RocketMQ—detailing their architectures, deployment requirements, features, high-availability solutions, advantages, disadvantages, and provides guidance for selecting the appropriate middleware in large-scale applications.

ActiveMQKafkaMessage Queue
0 likes · 38 min read
Comparison of Four Popular Open-Source Distributed Message Queues: Kafka, ActiveMQ, RabbitMQ, and RocketMQ
macrozheng
macrozheng
May 26, 2022 · Backend Development

How RocketMQ Uses Queues, Page Cache, and mmap to Achieve High Performance and Scalability

This article explains how RocketMQ tackles registration latency, synchronous coupling, and traffic spikes by introducing an intermediate queue, designing a persistent high‑availability broker, leveraging Linux page cache and memory‑mapped files, and employing topics, tags, and sharding to enable efficient asynchronous processing and scalable consumption.

Message QueueRocketMQasynchronous processing
0 likes · 28 min read
How RocketMQ Uses Queues, Page Cache, and mmap to Achieve High Performance and Scalability
Sohu Tech Products
Sohu Tech Products
May 25, 2022 · Backend Development

Design Principles of RocketMQ: Broker Architecture, Persistence, High Performance and High Availability

The article explains how RocketMQ tackles growing business traffic by introducing an asynchronous broker layer, using commitlog and consumeQueue files, page‑cache, mmap, topic/tag routing, and a nameserver to achieve high‑throughput, low‑latency, and highly available message delivery.

Message QueueRocketMQbackend development
0 likes · 30 min read
Design Principles of RocketMQ: Broker Architecture, Persistence, High Performance and High Availability
Zhuanzhuan Tech
Zhuanzhuan Tech
May 25, 2022 · Backend Development

Comparison of Transaction Message Implementations in ZuanZuan's Custom RocketMQ Version and the Open‑Source Community Version

This article analyzes why ZuanZuan built its own RocketMQ transaction‑message solution, compares the custom implementation with the community edition’s two‑phase commit approach, explains the underlying principles, sending flow, failure handling, and unknown‑state processing, and summarizes the trade‑offs of each design.

Message QueueRocketMQbackend development
0 likes · 10 min read
Comparison of Transaction Message Implementations in ZuanZuan's Custom RocketMQ Version and the Open‑Source Community Version
macrozheng
macrozheng
May 13, 2022 · Backend Development

Why Use Message Queues? Exploring RocketMQ’s Architecture, Features & Best Practices

This article explains the three main reasons for using message queues—decoupling, asynchrony, and peak‑shaving—then compares popular MQ products, dives deep into RocketMQ’s components, models, reliability, ordering, filtering, delay, transactions, dead‑letter handling, high‑availability, storage, load balancing, and long‑polling, providing a comprehensive guide for backend engineers.

Messaging ArchitectureRocketMQbackend development
0 likes · 41 min read
Why Use Message Queues? Exploring RocketMQ’s Architecture, Features & Best Practices
DeWu Technology
DeWu Technology
May 9, 2022 · Backend Development

Common Issues and Solutions for Message Queue Middleware

Message‑queue middleware such as RabbitMQ, RocketMQ, ActiveMQ, and Kafka introduces challenges like ordering, loss, duplication, back‑pressure and delayed delivery, which can be mitigated by using single‑consumer queues or partitioning, enabling acknowledgments and replication, applying idempotent identifiers, scaling consumers, and employing dead‑letter or scheduling mechanisms.

KafkaMQMessage Queue
0 likes · 21 min read
Common Issues and Solutions for Message Queue Middleware
macrozheng
macrozheng
May 5, 2022 · Backend Development

Choosing the Right Message Queue: Kafka vs RabbitMQ vs RocketMQ vs ActiveMQ Explained

An in‑depth guide compares the four major message‑queue middleware—Kafka, RabbitMQ, RocketMQ and ActiveMQ—detailing their architectures, modes, evaluation criteria, strengths, weaknesses, and selection considerations to help engineers and interviewees answer critical MQ interview questions and make informed technology choices.

ActiveMQKafkaMessage Queue
0 likes · 47 min read
Choosing the Right Message Queue: Kafka vs RabbitMQ vs RocketMQ vs ActiveMQ Explained
Architect
Architect
Apr 17, 2022 · Backend Development

Research on Delayed Queue Technologies and Implementation Approaches

This article surveys various delayed‑queue solutions—including Kafka pause/resume, RocketMQ delay levels, Redis/Redisson zset timers, Youzan's custom design, Netty's HashedWheelTimer, and a Kafka‑based time‑wheel—analyzing their architectures, pros and cons, and offering practical implementation guidance.

Delayed QueueRedisRocketMQ
0 likes · 12 min read
Research on Delayed Queue Technologies and Implementation Approaches
YunZhu Net Technology Team
YunZhu Net Technology Team
Apr 7, 2022 · Operations

RocketMQ Cluster Migration: Issues, Preparation Steps, and Recommended Migration Plans

This article analyzes the problems caused by multiple independent RocketMQ clusters, outlines the current cluster architecture, details pre‑migration preparations, compares two migration schemes (one not recommended and one recommended), and summarizes the benefits of consolidating clusters into a single, well‑managed deployment.

Cluster MigrationDockerInfrastructure
0 likes · 9 min read
RocketMQ Cluster Migration: Issues, Preparation Steps, and Recommended Migration Plans
Top Architect
Top Architect
Mar 31, 2022 · Backend Development

Message Deduplication and Exactly‑Once Semantics in RocketMQ

This article explains why RocketMQ guarantees at‑least‑once delivery, describes the three typical duplication scenarios, evaluates simple idempotent approaches, discusses transactional and non‑transactional deduplication solutions—including a Redis‑based method—and outlines their advantages, limitations, and practical recommendations for achieving exactly‑once processing in distributed systems.

DistributedSystemsExactlyOnceMessageDeduplication
0 likes · 19 min read
Message Deduplication and Exactly‑Once Semantics in RocketMQ
vivo Internet Technology
vivo Internet Technology
Mar 30, 2022 · Backend Development

Load Balancing Mechanism in RocketMQ Producer and Consumer

The article explains RocketMQ’s load‑balancing for producers and consumers, detailing how producers obtain routing info from the NameServer, select MessageQueues via round‑robin while avoiding failed brokers, and how consumers periodically rebalance queue allocation using strategies such as AllocateMessageQueueAveragely to ensure even distribution and customizable assignment.

ProducerRocketMQconsumer
0 likes · 22 min read
Load Balancing Mechanism in RocketMQ Producer and Consumer
Java Interview Crash Guide
Java Interview Crash Guide
Mar 17, 2022 · Backend Development

How to Achieve Near‑Zero Message Loss with RocketMQ and RabbitMQ

This article explains how to guarantee almost 100% reliability of messages in distributed systems by examining RocketMQ’s three‑stage reliability model and RabbitMQ’s confirm, persistence, and manual‑ack mechanisms, plus a database‑backed compensation strategy for extreme failure cases.

Message QueueMessage reliabilityRocketMQ
0 likes · 11 min read
How to Achieve Near‑Zero Message Loss with RocketMQ and RabbitMQ
Programmer DD
Programmer DD
Mar 10, 2022 · Backend Development

Spring Cloud Alibaba 2021.0.1.0: New Features, Version Rules Explained

The Spring Cloud Alibaba 2021.0.1.0 release, built on Spring Boot 2.6.3 and Spring Cloud 2021.0.1, introduces upgraded Nacos client, RocketMQ 4.9.2 with batch and async support, Sentinel 1.8.3 enhancements for FeignClient, Spring Config import support, and a clarified version‑numbering scheme aligning with Spring Cloud.

NacosRocketMQSentinel
0 likes · 5 min read
Spring Cloud Alibaba 2021.0.1.0: New Features, Version Rules Explained
vivo Internet Technology
vivo Internet Technology
Mar 9, 2022 · Backend Development

Gray Deployment Solution for RocketMQ in the LUBAN MQ Platform

The LUBAN MQ platform introduces a gray‑deployment extension for RocketMQ that isolates gray traffic by assigning configurable gray queues, adds a graySubscriptionTable and grayFlag in broker and Namesrv, uses shared consumer groups with a custom rebalance strategy, and ensures loss‑less offset merging and seamless switch‑over.

Gray DeploymentMicroservicesRocketMQ
0 likes · 19 min read
Gray Deployment Solution for RocketMQ in the LUBAN MQ Platform
Java Interview Crash Guide
Java Interview Crash Guide
Mar 4, 2022 · Backend Development

Why Use Message Queues? Scenarios, Pros, Cons, and HA Strategies

This article explains the fundamentals of message queues, their typical use cases such as decoupling, asynchronous processing, and traffic shaping, compares popular MQ products, and outlines best practices for high availability, loss prevention, idempotency, ordering, backlog handling, and expiration management.

Message QueueRocketMQbackend development
0 likes · 8 min read
Why Use Message Queues? Scenarios, Pros, Cons, and HA Strategies
Code Ape Tech Column
Code Ape Tech Column
Feb 23, 2022 · Backend Development

Design and Implementation of Delayed Message Queues in Distributed Systems

This article examines various delayed‑message implementations in distributed message‑queue systems, comparing external‑storage approaches using databases, RocksDB and Redis, and reviewing built‑in solutions in open‑source MQs such as RocketMQ, Pulsar and QMQ, while discussing their advantages, drawbacks and design considerations.

RedisRocketMQRocksDB
0 likes · 15 min read
Design and Implementation of Delayed Message Queues in Distributed Systems
Tencent Cloud Developer
Tencent Cloud Developer
Feb 15, 2022 · Backend Development

Message Queue Middleware Selection Guide: Kafka vs Pulsar vs RocketMQ vs RabbitMQ vs NSQ

This guide compares Kafka, Pulsar, RocketMQ, RabbitMQ, and NSQ across architecture, consumption models, delay and dead‑letter support, persistence, ordering, multi‑tenant isolation, and performance, recommending Kafka for high‑throughput log processing, Pulsar for transactional delayed messaging and disaster recovery, and NSQ for Go‑centric custom solutions.

KafkaMessage QueueMiddleware
0 likes · 26 min read
Message Queue Middleware Selection Guide: Kafka vs Pulsar vs RocketMQ vs RabbitMQ vs NSQ
Selected Java Interview Questions
Selected Java Interview Questions
Feb 5, 2022 · Backend Development

Message Queue Fundamentals: Use Cases, Product Comparison, High Availability, and Reliability Strategies

This article explains why message queues are used, outlines common scenarios such as decoupling, asynchronous processing and traffic shaping, compares major MQ products, and provides practical guidance on high availability, preventing loss, duplicate consumption, ordering, backlog handling, and expiration.

High AvailabilityKafkaMessage Queue
0 likes · 8 min read
Message Queue Fundamentals: Use Cases, Product Comparison, High Availability, and Reliability Strategies
IT Architects Alliance
IT Architects Alliance
Feb 3, 2022 · Backend Development

Common Issues in Message Queues and Distributed Transaction Solutions

This article explains the typical problems encountered with message queues, such as message loss, duplicate delivery, and distributed transaction handling, and details various solutions including local message tables, MQ‑based transactions, and the specific mechanisms used by RocketMQ, Kafka, and RabbitMQ to ensure reliability and consistency.

KafkaMQMessage Queue
0 likes · 20 min read
Common Issues in Message Queues and Distributed Transaction Solutions
Top Architect
Top Architect
Jan 31, 2022 · Backend Development

Delayed Queue Technology Research and Implementation Overview

This article surveys various delayed queue implementations—including Kafka, RocketMQ, Redis (Redisson), and Netty’s HashedWheelTimer—examining their design principles, advantages, drawbacks, and integration strategies, and proposes a unified micro‑service architecture leveraging Kafka topics, Redis ZSETs, and thread‑pool optimizations for reliable message scheduling.

Delayed QueueKafkaMicroservices
0 likes · 15 min read
Delayed Queue Technology Research and Implementation Overview
Alibaba Cloud Native
Alibaba Cloud Native
Jan 23, 2022 · Cloud Native

Why Choose RocketMQ? Synchronous Writes, Multi‑Topic Speed, and SPI Extensibility

This article explains the reasons for selecting Apache RocketMQ—its synchronous double‑write safety, strong performance under massive multi‑topic loads, rich features like transactional and delayed messages, active community support, and demonstrates how to leverage Java’s SPI mechanism to build a configurable, dynamically adjustable client architecture.

Cloud NativeMessage QueueRocketMQ
0 likes · 13 min read
Why Choose RocketMQ? Synchronous Writes, Multi‑Topic Speed, and SPI Extensibility
Code Ape Tech Column
Code Ape Tech Column
Jan 21, 2022 · Backend Development

Message Deduplication and Exactly-Once Semantics in RocketMQ: Strategies and Implementation

This article explains the challenges of at‑least‑once delivery in distributed message middleware like RocketMQ, examines simple and concurrent deduplication techniques, and presents both transaction‑based and non‑transactional exactly‑once solutions using database tables or Redis, along with practical Java code examples.

RedisRocketMQdeduplication
0 likes · 17 min read
Message Deduplication and Exactly-Once Semantics in RocketMQ: Strategies and Implementation
IT Architects Alliance
IT Architects Alliance
Jan 18, 2022 · Backend Development

Implementation Strategies for Delayed (Scheduled) Messages in Distributed Systems

This article examines common delayed (scheduled) message implementations in distributed systems, comparing external storage approaches using databases, RocksDB, and Redis, as well as built-in solutions in open-source MQs like RocketMQ, Pulsar, and QMQ, and discusses their advantages, drawbacks, and design considerations.

RedisRocketMQRocksDB
0 likes · 12 min read
Implementation Strategies for Delayed (Scheduled) Messages in Distributed Systems
macrozheng
macrozheng
Dec 24, 2021 · Backend Development

Mastering Delayed Tasks with RocketMQ and Spring Boot

This guide explains how to replace inefficient cron polling with RocketMQ's delayed message feature in Spring Boot, covering the core concept, configuration, producer and consumer implementation, testing, and how to customize delay levels for reliable time‑sensitive operations.

Delayed TasksRocketMQSpring Boot
0 likes · 8 min read
Mastering Delayed Tasks with RocketMQ and Spring Boot
Architect
Architect
Dec 13, 2021 · Backend Development

Understanding Message Queues: Concepts, Benefits, Challenges, and Real-World Practices

This article explains what message queues are, why they are essential for decoupling, asynchronous processing, and traffic shaping, examines common architectural issues, and presents real‑world implementations such as RocketMQ, Kafka, and CMQ in high‑traffic scenarios like Double‑11, TikTok, and WeChat red‑packet payments.

Message QueueRocketMQ
0 likes · 12 min read
Understanding Message Queues: Concepts, Benefits, Challenges, and Real-World Practices
Wukong Talks Architecture
Wukong Talks Architecture
Dec 6, 2021 · Fundamentals

RocketMQ Core Concepts, Windows Installation, Configuration, and Best Practices

This article provides a comprehensive guide to RocketMQ, covering Windows installation, environment configuration, startup commands, visual monitoring integration, SpringBoot dependency setup, core components, message models, reliability strategies, idempotent processing, transactional messaging, and ordering guarantees for distributed systems.

InstallationMessage QueueRocketMQ
0 likes · 37 min read
RocketMQ Core Concepts, Windows Installation, Configuration, and Best Practices
Tencent Cloud Developer
Tencent Cloud Developer
Dec 3, 2021 · Cloud Native

Introducing RoP 0.2.0: Architecture Upgrade and New Features for RocketMQ on Pulsar

The article introduces RoP 0.2.0, a redesign of RocketMQ on Pulsar that eliminates message loss, duplicate consumption, and partial partition consumption, adds ACL authentication, partition expansion for higher throughput, native RocketMQ management APIs, refactors MessageID and routing models, and outlines future features such as tracing, delayed messages, and advanced monitoring.

ACLBrokerMetadataCloudNative
0 likes · 12 min read
Introducing RoP 0.2.0: Architecture Upgrade and New Features for RocketMQ on Pulsar
IT Architects Alliance
IT Architects Alliance
Nov 25, 2021 · Backend Development

RocketMQ Transactional, Batch, and Delayed Message Mechanisms – Detailed Explanation and Source Code

This article explains the principles and implementation of RocketMQ's transactional messages, batch messages, and delayed messages, describing the message flow, compensation mechanisms, broker and producer handling, and providing detailed source code snippets to illustrate each process.

Batch MessagingDelayed MessagingMessage Queue
0 likes · 19 min read
RocketMQ Transactional, Batch, and Delayed Message Mechanisms – Detailed Explanation and Source Code
Alibaba Cloud Native
Alibaba Cloud Native
Nov 6, 2021 · Backend Development

How RocketMQ Powers Double 11: Six Key Techniques for Massive Traffic

This article explains how RocketMQ's six core features—asynchronous decoupling, peak‑shaving, distributed transaction messages, message filtering, scheduled messages, and ordered delivery—enable Alibaba's Double 11 platform to handle billions of transactions and hundreds of thousands of orders per second while maintaining system stability and reliability.

Double 11Message QueueRocketMQ
0 likes · 7 min read
How RocketMQ Powers Double 11: Six Key Techniques for Massive Traffic
Su San Talks Tech
Su San Talks Tech
Nov 4, 2021 · Backend Development

How RocketMQ’s Storage Architecture Powers High Throughput and Low Latency

This article explains RocketMQ’s disk‑based storage design—including CommitLog, ConsumeQueue, and Index files—detailing sequential writes, memory‑mapped I/O, flexible flush strategies, and memory‑level read/write separation that together enable unlimited backlog, high throughput, and low latency messaging.

Memory Mapped FilesRocketMQSequential Write
0 likes · 13 min read
How RocketMQ’s Storage Architecture Powers High Throughput and Low Latency
Full-Stack Internet Architecture
Full-Stack Internet Architecture
Nov 3, 2021 · Backend Development

Understanding RocketMQ Storage Architecture: CommitLog, ConsumeQueue, and Index Files

This article explains the core storage design of RocketMQ, covering the CommitLog, ConsumeQueue, and Index files, their organization, sequential write strategy, memory‑mapped I/O, and flexible flushing policies that together provide high‑throughput, low‑latency messaging for backend systems.

CommitLogConsumeQueueMessage Queue
0 likes · 11 min read
Understanding RocketMQ Storage Architecture: CommitLog, ConsumeQueue, and Index Files
Full-Stack Internet Architecture
Full-Stack Internet Architecture
Oct 29, 2021 · Cloud Native

RocketMQ 5.0 Overview: A Cloud‑Native Messaging, Event and Stream Fusion Platform

This article reviews the evolution of RocketMQ from its early MetaQ roots through the 4.x releases, explains the motivations behind RocketMQ 5.0, and details its cloud‑native architecture, lightweight SDK, storage‑compute separation, POP consumption model, elastic scaling, and the upcoming RocketMQ Streams framework.

Message QueueRocketMQStreaming
0 likes · 18 min read
RocketMQ 5.0 Overview: A Cloud‑Native Messaging, Event and Stream Fusion Platform
High Availability Architecture
High Availability Architecture
Oct 28, 2021 · Cloud Native

Design and Implementation Differences between Pulsar, Kafka, RocketMQ, and InLong‑TubeMQ

This article compares Pulsar with Kafka, RocketMQ and InLong‑TubeMQ, focusing on cloud‑native multi‑tenant design, multi‑level flow control, compute‑storage separation, partitioning strategies, metadata storage, and message delivery mechanisms, highlighting each system's architectural advantages and trade‑offs.

Cloud NativeInLong‑TubeMQKafka
0 likes · 18 min read
Design and Implementation Differences between Pulsar, Kafka, RocketMQ, and InLong‑TubeMQ