BestHub
Sign in
Tagged articles

RocketMQ

583 articles · Page 2 of 6
Cognitive Technology Team
Cognitive Technology Team
Sep 5, 2025 · Backend Development

How RocketMQ and DDMQ Achieve Ordered Message Consumption – Deep Dive with Code

This article explores the sequential consumption mechanisms of RocketMQ and its derivative DDMQ, detailing the underlying source‑code implementation, differences in producer ordering, broker handling, consumer locking, and how DDMQ simplifies ordering with a single‑node proxy, complete with code examples and diagrams.

DDMQRocketMQordered consumption
0 likes · 29 min read
How RocketMQ and DDMQ Achieve Ordered Message Consumption – Deep Dive with Code
Su San Talks Tech
Su San Talks Tech
Sep 1, 2025 · Backend Development

How to Eliminate a 1M‑Message MQ Backlog Without Adding Servers: 5 Proven Strategies

This article explains why message queues can accumulate millions of messages, analyzes root causes such as over‑fast producers and slow consumers, and presents five practical solutions—including consumer code optimization, queue‑strategy tweaks, producer rate limiting, dead‑letter handling, and automated monitoring—to dramatically reduce backlog without costly hardware scaling.

JavaPerformance OptimizationRocketMQ
0 likes · 22 min read
How to Eliminate a 1M‑Message MQ Backlog Without Adding Servers: 5 Proven Strategies
Architecture & Thinking
Architecture & Thinking
Aug 26, 2025 · Backend Development

How RocketMQ Achieves Million‑TPS with Sequential Writes and Multi‑Level Indexes

RocketMQ tackles the high‑performance, high‑reliability challenges of distributed messaging by combining sequential disk writes, memory caching, and multi‑level indexing, detailing its storage logic, core structures, zero‑copy techniques, replication modes, static topic scaling, and practical tuning guidelines for optimal throughput.

RocketMQmessage queuestorage architecture
0 likes · 8 min read
How RocketMQ Achieves Million‑TPS with Sequential Writes and Multi‑Level Indexes
Cognitive Technology Team
Cognitive Technology Team
Aug 22, 2025 · Backend Development

Unlocking Ordered Messaging: How RocketMQ and DDMQ Ensure Sequence

This article deeply explores the sequential consumption mechanisms of RocketMQ and its derivative DDMQ, comparing their source‑code implementations, detailing producer ordering, broker locking, consumer locking, and the architectural differences that allow DDMQ to achieve ordered processing with only proxy‑side locks.

DDMQJavaRocketMQ
0 likes · 30 min read
Unlocking Ordered Messaging: How RocketMQ and DDMQ Ensure Sequence
Didi Tech
Didi Tech
Aug 14, 2025 · Backend Development

How RocketMQ and DDMQ Achieve Ordered Consumption: Deep Source Code Dive

This article deeply explores the ordered consumption mechanisms of RocketMQ and its derivative DDMQ, explaining the implementation differences, source‑code details of sequential sending, broker locking, client‑side processing, and compares the two systems' approaches to guarantee message order.

DDMQJavaRocketMQ
0 likes · 30 min read
How RocketMQ and DDMQ Achieve Ordered Consumption: Deep Source Code Dive
Wukong Talks Architecture
Wukong Talks Architecture
Aug 14, 2025 · Backend Development

Understanding RocketMQ Architecture: Components, Protocols, and Storage

This article provides a comprehensive overview of RocketMQ's architecture, detailing its core components, network protocols, storage mechanisms, producer‑consumer workflow, and transactional messaging, while highlighting differences between Remoting and gRPC and explaining key design choices for high performance and reliability.

NettyRocketMQgRPC
0 likes · 15 min read
Understanding RocketMQ Architecture: Components, Protocols, and Storage
Sanyou's Java Diary
Sanyou's Java Diary
Jul 17, 2025 · Backend Development

Unlocking RocketMQ 4.x: Deep Dive into Architecture, Protocols, and High‑Performance Messaging

This article provides a comprehensive technical overview of RocketMQ 4.x, covering its core roles, publish‑subscribe model, communication protocol, reactor thread model, storage files, high‑performance read/write techniques, consumption flow, deployment patterns, DLedger Raft integration, transaction and broadcast messaging, ordered message handling, architectural drawbacks, and the new stateless proxy architecture introduced in RocketMQ 5.0.

High PerformanceRocketMQTransaction Messaging
0 likes · 22 min read
Unlocking RocketMQ 4.x: Deep Dive into Architecture, Protocols, and High‑Performance Messaging
Tech Freedom Circle
Tech Freedom Circle
Jul 15, 2025 · Databases

One‑Order Four‑Split: Solving MySQL Deadlocks in Million‑Row Imports

During massive daily imports of up to one million reconciliation records, MySQL deadlocks can cripple performance; this article dissects the four classic deadlock conditions, then presents a systematic “One‑Order Four‑Split” strategy—ordered writes, transaction splitting, index management, partitioning, and gap‑lock removal—backed by benchmarks, code samples, and configuration tweaks that cut lock rates by up to 90% and reduce batch times to under ten minutes.

Batch InsertIndex OptimizationJava
0 likes · 27 min read
One‑Order Four‑Split: Solving MySQL Deadlocks in Million‑Row Imports
Su San Talks Tech
Su San Talks Tech
Jul 12, 2025 · Backend Development

Unlocking RocketMQ 4.x: Architecture, Protocols, and High‑Performance Messaging

This article provides a comprehensive overview of RocketMQ 4.x, detailing its core architecture—including NameServer, Broker, Producer, and Consumer roles—its publish‑subscribe model, its communication protocols, reactor threading, storage mechanisms, high‑performance read/write strategies, deployment options, transaction handling, broadcast and ordered messaging, and the strengths and limitations of its master‑slave and DLedger designs.

RocketMQmessage queue
0 likes · 29 min read
Unlocking RocketMQ 4.x: Architecture, Protocols, and High‑Performance Messaging
Architecture & Thinking
Architecture & Thinking
Jun 30, 2025 · Backend Development

Mastering RocketMQ Retry: Producer & Consumer Strategies for Reliable Messaging

This article deeply explores Apache RocketMQ's retry mechanisms, detailing producer and consumer retry strategies, flow control handling, dead‑letter queue management, advanced configurations, best practices, and comparisons with Kafka and RabbitMQ, providing practical code examples and monitoring recommendations for building highly reliable distributed systems.

Message RetryRocketMQdead letter queue
0 likes · 8 min read
Mastering RocketMQ Retry: Producer & Consumer Strategies for Reliable Messaging
Lin is Dream
Lin is Dream
Jun 27, 2025 · Backend Development

How to Solve Common RocketMQ Issues: Duplicates, Throttling, Retries, and Loss

This article examines frequent RocketMQ problems such as duplicate sending, flow‑control throttling, message retries, duplicate consumption, backlog, and loss, and provides practical configuration tweaks, scaling strategies, batch sending, idempotent handling, and retry mechanisms to ensure reliable message delivery.

JavaRocketMQdistributed systems
0 likes · 9 min read
How to Solve Common RocketMQ Issues: Duplicates, Throttling, Retries, and Loss
Lin is Dream
Lin is Dream
Jun 26, 2025 · Backend Development

Unveiling RocketMQ: How Messages Journey Through Storage, Delivery, and Expiration

This article systematically breaks down RocketMQ's core mechanisms—covering message roles, disk storage, push/pull delivery, expiration handling, retry queues, and cluster failover—so developers can understand every stage a message undergoes from creation to cleanup and ensure reliable, high‑performance messaging.

JavaRocketMQdistributed systems
0 likes · 13 min read
Unveiling RocketMQ: How Messages Journey Through Storage, Delivery, and Expiration
Lin is Dream
Lin is Dream
Jun 25, 2025 · Backend Development

12 Essential RocketMQ Best Practices for Reliable Messaging

This article presents a comprehensive set of RocketMQ usage guidelines—including topic and tag conventions, producer and consumer group naming, key handling, logging, retry mechanisms, and cluster deployment recommendations—to help engineers build stable, high‑performance, and observable messaging systems in production environments.

RocketMQdistributed systemsmessage queue
0 likes · 9 min read
12 Essential RocketMQ Best Practices for Reliable Messaging
Lin is Dream
Lin is Dream
Jun 24, 2025 · Backend Development

Master RocketMQ Console: From Zero to Full Monitoring in Minutes

This article walks you through installing and using the RocketMQ Dashboard to monitor topics, brokers, producers, consumers, and message details, explains common pitfalls such as client‑ID conflicts in Docker, and demonstrates how to troubleshoot consumption issues, TPS metrics, and dead‑letter handling.

JavaRocketMQdashboard
0 likes · 9 min read
Master RocketMQ Console: From Zero to Full Monitoring in Minutes
Lobster Programming
Lobster Programming
Jun 23, 2025 · Backend Development

How RocketMQ’s CommitLog Powers Million‑Level Concurrency

This article explains how RocketMQ’s CommitLog architecture—sequential writes, mmap zero‑copy, PageCache acceleration, fixed‑size log files, flexible flushing strategies, and efficient ConsumeQueue indexing—enables the system to sustain million‑level QPS with high reliability and low latency.

CommitLogPageCacheRocketMQ
0 likes · 6 min read
How RocketMQ’s CommitLog Powers Million‑Level Concurrency
Lin is Dream
Lin is Dream
Jun 20, 2025 · Backend Development

Unlocking RocketMQ: What Every SendResult Field Means

This article explains the composition of RocketMQ's SendResult object returned after a successful synchronous send, detailing each field such as sendStatus, msgId, offsetMsgId, messageQueue, and queueOffset, and provides practical examples and a full field‑by‑field breakdown for Java developers.

JavaRocketMQSendResult
0 likes · 6 min read
Unlocking RocketMQ: What Every SendResult Field Means
Lin is Dream
Lin is Dream
Jun 19, 2025 · Backend Development

Master RocketMQ with Spring Boot: Complete Guide to Messaging APIs

This tutorial walks through integrating Alibaba's RocketMQ into a Spring Boot application, covering Maven dependencies, producer and consumer configurations, and detailed examples of synchronous, asynchronous, one‑way, delayed, ordered, transactional, request‑response, batch, and pull messaging APIs, along with best‑practice recommendations.

JavaMessaging APIRocketMQ
0 likes · 21 min read
Master RocketMQ with Spring Boot: Complete Guide to Messaging APIs
Architecture & Thinking
Architecture & Thinking
Jun 19, 2025 · Backend Development

Why Does Message Backlog Occur in Kafka/RocketMQ and How to Fix It

The article explains how message backlog arises when producers outpace consumers in systems like Kafka or RocketMQ, outlines primary causes such as unexpected production spikes, broker failures, and consumer bottlenecks, and provides step‑by‑step mitigation strategies including capacity scaling, temporary queues, and optimization techniques for producers, brokers, and consumers.

BacklogPerformanceRocketMQ
0 likes · 7 min read
Why Does Message Backlog Occur in Kafka/RocketMQ and How to Fix It
Java Architect Essentials
Java Architect Essentials
Jun 17, 2025 · Backend Development

Transforming Task Systems: Configurable Completion Rules with QLExpress

This article explains how to redesign a company's activity middle‑platform task system by standardizing message formats, introducing a rule engine (QLExpress) for configurable task completion conditions, and enabling dynamic backend configuration, dramatically reducing integration time from weeks to minutes.

ConfigurationJavaRocketMQ
0 likes · 11 min read
Transforming Task Systems: Configurable Completion Rules with QLExpress
Pan Zhi's Tech Notes
Pan Zhi's Tech Notes
Jun 16, 2025 · Backend Development

How RocketMQ Guarantees No Message Loss, Duplication, or Disorder

This article explains RocketMQ’s architecture, the roles of NameServer, Broker, Producer, Consumer, and how each component ensures reliable message delivery—covering synchronous, asynchronous, and one‑way sending, storage mechanisms, consumer retries, dead‑letter queues, installation steps, and Java client integration with code examples.

InstallationJavaRocketMQ
0 likes · 20 min read
How RocketMQ Guarantees No Message Loss, Duplication, or Disorder
Raymond Ops
Raymond Ops
Jun 1, 2025 · Backend Development

RocketMQ vs Others: Key Features, Reliability, and Performance

RocketMQ, an Apache‑licensed distributed message queue from Alibaba, offers low latency, high reliability, and high throughput through features like distributed architecture, synchronous disk flushing, master‑slave replication, and flexible messaging models, and it compares favorably against Kafka, RabbitMQ, and ActiveMQ in various scenarios.

Distributed ArchitectureHigh reliabilityRocketMQ
0 likes · 11 min read
RocketMQ vs Others: Key Features, Reliability, and Performance
Tencent Cloud Middleware
Tencent Cloud Middleware
May 28, 2025 · Backend Development

Inside RocketMQ ConsumeQueue: Design, File-Based Indexing, and RocksDB Optimization

This article provides an in‑depth technical exploration of RocketMQ 5.0's ConsumeQueue component, explaining why it is needed, its design principles, the traditional file‑based implementation, and a performance‑focused RocksDB‑based redesign, complete with code excerpts and implementation details.

BackendConsumeQueueDistributedSystems
0 likes · 25 min read
Inside RocketMQ ConsumeQueue: Design, File-Based Indexing, and RocksDB Optimization
Su San Talks Tech
Su San Talks Tech
May 23, 2025 · Backend Development

Kafka vs RabbitMQ vs RocketMQ vs ActiveMQ: Key Differences and How to Choose

This article explains the fundamentals, architectures, key concepts, advantages, and disadvantages of Kafka, RabbitMQ, RocketMQ, and ActiveMQ, and provides practical guidance on selecting the most suitable message queue for various application scenarios such as high‑throughput logging, financial transactions, or small‑scale services.

KafkaRabbitMQRocketMQ
0 likes · 19 min read
Kafka vs RabbitMQ vs RocketMQ vs ActiveMQ: Key Differences and How to Choose
IT Services Circle
IT Services Circle
May 7, 2025 · Backend Development

Understanding RocketMQ Long‑Polling Mechanism and Its Implementation

This article explains how RocketMQ implements long‑polling for message consumption, detailing the pull‑based model, the broker and consumer timeout settings, the internal suspension of pull requests, and the processing loop that resumes suspended requests to improve efficiency.

BackendConsumerJava
0 likes · 7 min read
Understanding RocketMQ Long‑Polling Mechanism and Its Implementation
Cognitive Technology Team
Cognitive Technology Team
Apr 30, 2025 · Backend Development

Preventing Message Loss, Duplicate Consumption, and Backlog in RocketMQ: Best Practices and Strategies

This article examines the three major reliability challenges of message queues—loss, duplicate consumption, and backlog—and provides detailed RocketMQ‑specific strategies, including producer acknowledgment, broker replication, idempotent consumer design, monitoring, scaling, and parameter tuning to ensure high‑availability distributed systems.

RocketMQmessage queue
0 likes · 17 min read
Preventing Message Loss, Duplicate Consumption, and Backlog in RocketMQ: Best Practices and Strategies
Lobster Programming
Lobster Programming
Apr 28, 2025 · Backend Development

How RocketMQ Transactional Messages Ensure Distributed Data Consistency

This article explains RocketMQ's transactional message mechanism, covering half‑message storage, three transaction states, status‑check procedures, key APIs, storage reliability, and the two‑phase commit process that guarantees eventual consistency in distributed systems.

Data ConsistencyRocketMQdistributed systems
0 likes · 6 min read
How RocketMQ Transactional Messages Ensure Distributed Data Consistency
Tencent Cloud Middleware
Tencent Cloud Middleware
Apr 24, 2025 · Backend Development

How TDMQ RocketMQ Implements Distributed Rate Limiting for High‑Throughput Messaging

This article explains TDMQ RocketMQ's distributed rate‑limiting mechanism, covering conversion rules, fast‑fail behavior, token‑based implementation, counting periods, client best practices, elastic TPS options, code examples for different SDK versions, monitoring tips, and answers to common throttling questions.

BackendRocketMQdistributed systems
0 likes · 15 min read
How TDMQ RocketMQ Implements Distributed Rate Limiting for High‑Throughput Messaging
dbaplus Community
dbaplus Community
Apr 19, 2025 · Fundamentals

Why Thread.sleep(0) Can Influence GC: Uncovering JVM Safepoint Tricks

This article explores the puzzling "prevent gc" comment in RocketMQ source code, explains how Thread.sleep(0) interacts with JVM safepoints, distinguishes counted and uncounted loops, and demonstrates practical experiments that reveal why altering loop variables can change GC behavior.

GCJVMJava
0 likes · 12 min read
Why Thread.sleep(0) Can Influence GC: Uncovering JVM Safepoint Tricks
Pan Zhi's Tech Notes
Pan Zhi's Tech Notes
Apr 16, 2025 · Cloud Native

Quick 3‑Minute Guide to the Full Spring Cloud Alibaba Suite

This article introduces Spring Cloud Alibaba, outlines its key components such as Nacos, Dubbo, Sentinel, RocketMQ and Seata, explains how to manage its versions with Maven, highlights compatibility checks, and compares the first‑ and second‑generation Spring Cloud stacks.

DubboNacosRocketMQ
0 likes · 8 min read
Quick 3‑Minute Guide to the Full Spring Cloud Alibaba Suite
Cognitive Technology Team
Cognitive Technology Team
Apr 13, 2025 · Backend Development

Understanding RocketMQ Master‑Slave Architecture and High‑Availability Mechanisms

This article explains how RocketMQ achieves high availability and data reliability through its master‑slave broker design, covering synchronous and asynchronous replication, flush strategies, transaction messaging, automatic failover with Dledger, and read‑write separation for load balancing in distributed systems.

Master‑SlaveRocketMQdata replication
0 likes · 7 min read
Understanding RocketMQ Master‑Slave Architecture and High‑Availability Mechanisms
Cognitive Technology Team
Cognitive Technology Team
Apr 12, 2025 · Backend Development

Implementation Principles of RocketMQ Distributed Transaction Messages

The article explains how RocketMQ implements distributed transaction messages using a two‑phase commit model to ensure data consistency across micro‑service subsystems, detailing the workflow from half‑message production, broker handling, local transaction execution, commit/rollback decisions, and periodic status checks.

RocketMQbackend developmentdistributed transaction
0 likes · 7 min read
Implementation Principles of RocketMQ Distributed Transaction Messages
Java Tech Enthusiast
Java Tech Enthusiast
Apr 11, 2025 · Backend Development

Ensuring Message Processing Once in High-Concurrency Scenarios

The article explains how to guarantee that messages are processed only once in high‑concurrency environments by combining production‑side idempotent publishing, broker‑level deduplication with unique IDs, and consumption‑side business idempotency such as database constraints or distributed locks, while also recommending monitoring, metrics, and reconciliation as safety nets.

RocketMQdistributed systemsduplicate processing
0 likes · 6 min read
Ensuring Message Processing Once in High-Concurrency Scenarios
macrozheng
macrozheng
Apr 11, 2025 · Backend Development

How to Guarantee Exactly‑Once Message Consumption in High‑Concurrency Systems

This article explains common causes of duplicate message consumption in high‑traffic systems and presents a three‑layer defense—producer idempotence, broker de‑duplication, and consumer idempotent design—plus monitoring and reconciliation strategies to achieve reliable exactly‑once processing.

Exactly-OnceIdempotenceKafka
0 likes · 7 min read
How to Guarantee Exactly‑Once Message Consumption in High‑Concurrency Systems
Sanyou's Java Diary
Sanyou's Java Diary
Apr 10, 2025 · Backend Development

Why RocketMQ Beats Kafka: Architecture Simplified and Features Amplified

This article explains how RocketMQ, a Chinese‑origin message queue, simplifies Kafka’s architecture while adding powerful features such as tag‑based filtering, transactional messaging, delayed and dead‑letter queues, and a unified commit‑log storage model, making delayed processing and high‑throughput scenarios easier to implement.

KafkaRocketMQarchitecture
0 likes · 10 min read
Why RocketMQ Beats Kafka: Architecture Simplified and Features Amplified
Cognitive Technology Team
Cognitive Technology Team
Apr 8, 2025 · Backend Development

Design and Implementation of RocketMQ NameServer: Core Functions, Architecture, and Optimization Strategies

The article explains RocketMQ NameServer's lightweight, stateless design, its core routing and metadata management functions, AP‑oriented architecture, fault‑tolerant mechanisms, scalability features, and practical optimization techniques for high availability and low operational cost.

Distributed MessagingNameServerRocketMQ
0 likes · 6 min read
Design and Implementation of RocketMQ NameServer: Core Functions, Architecture, and Optimization Strategies
Ma Wei Says
Ma Wei Says
Mar 28, 2025 · Backend Development

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

This article compares Kafka, RocketMQ, and RabbitMQ, detailing their architectures, performance characteristics, strengths, and ideal use‑cases to help engineers select the most suitable message‑queue solution for high‑throughput, fault‑tolerant, and real‑time processing scenarios.

Event StreamingKafkaRabbitMQ
0 likes · 11 min read
Choosing the Right Message Queue: Kafka vs RocketMQ vs RabbitMQ Explained
Java Tech Enthusiast
Java Tech Enthusiast
Mar 14, 2025 · Backend Development

RocketMQ Message Tracing: Concepts, Configuration, and Implementation

RocketMQ’s message tracing feature records each message’s full lifecycle—including producer, broker, and consumer details such as timestamps, latency, and success flags—by enabling traceTopicEnable, creating an internal RMQ_SYS_TRACE_TOPIC, and allowing custom trace topics for fast diagnostics, end‑to‑end tracking, monitoring, and audit compliance.

BackendJavaMessage Tracing
0 likes · 7 min read
RocketMQ Message Tracing: Concepts, Configuration, and Implementation
Code Ape Tech Column
Code Ape Tech Column
Mar 14, 2025 · Backend Development

Eight Common Use Cases of Message Queues in Backend Development

This article explores eight common scenarios for using message queues in backend development, covering asynchronous processing, service decoupling, traffic shaping, delayed tasks, log aggregation, distributed transactions, remote calls, and broadcast notifications, each illustrated with Java, RocketMQ, and Kafka code examples.

JavaKafkaMQ
0 likes · 15 min read
Eight Common Use Cases of Message Queues in Backend Development
IT Services Circle
IT Services Circle
Mar 9, 2025 · Backend Development

Understanding RocketMQ Message Tracing: Concepts, Configuration, and Custom TraceTopic Implementation

This article explains RocketMQ's message tracing feature, covering its definition, key data attributes, core benefits, configuration steps for both normal and IO‑isolated modes, the underlying implementation mechanism, supported trace topics, and provides complete Java code examples for custom TraceTopic usage and verification.

BackendConfigurationJava
0 likes · 11 min read
Understanding RocketMQ Message Tracing: Concepts, Configuration, and Custom TraceTopic Implementation
dbaplus Community
dbaplus Community
Feb 26, 2025 · Operations

Choosing the Right Message Queue: A Deep Dive into Kafka, Pulsar, RocketMQ, RabbitMQ, and NSQ

This comprehensive guide explains the role of message queues in distributed systems, compares the architectures and core concepts of Kafka, Pulsar, RocketMQ, RabbitMQ, and NSQ, and provides practical criteria for selecting, configuring, and operating a message‑queue solution in high‑performance, high‑availability environments.

KafkaNSQPulsar
0 likes · 50 min read
Choosing the Right Message Queue: A Deep Dive into Kafka, Pulsar, RocketMQ, RabbitMQ, and NSQ
Ops Development & AI Practice
Ops Development & AI Practice
Feb 20, 2025 · Backend Development

Mastering Apache RocketMQ: Ports, Commands, and Monitoring Tips

This guide explains the key port configurations of Apache RocketMQ brokers, details essential mqadmin commands for managing topics, checking status, and monitoring consumer progress, and provides practical examples to help administrators efficiently operate and troubleshoot RocketMQ clusters.

CLIRocketMQdistributed systems
0 likes · 7 min read
Mastering Apache RocketMQ: Ports, Commands, and Monitoring Tips
Sanyou's Java Diary
Sanyou's Java Diary
Jan 23, 2025 · Backend Development

How RocketMQ Achieves High Performance and Scalability with Queues, Brokers, and mmap

This article explains how RocketMQ tackles synchronous registration bottlenecks, tight coupling, and traffic‑burst risks by introducing an intermediate queue layer, designing a durable high‑availability broker, leveraging page cache and mmap for zero‑copy I/O, and using a nameserver for automatic routing, ultimately delivering a high‑throughput, low‑latency messaging system.

Distributed MessagingHigh PerformanceRocketMQ
0 likes · 27 min read
How RocketMQ Achieves High Performance and Scalability with Queues, Brokers, and mmap
Architecture & Thinking
Architecture & Thinking
Jan 14, 2025 · Backend Development

Master RocketMQ Basic Messages: Lifecycle, Code Samples & Use Cases

This guide explains Apache RocketMQ’s ordinary message concept, its full lifecycle, how to create topics, Java code for sending and receiving messages, key configuration tips, and real‑world scenarios such as asynchronous decoupling and traffic‑shaping for micro‑service architectures.

JavaRocketMQdistributed systems
0 likes · 9 min read
Master RocketMQ Basic Messages: Lifecycle, Code Samples & Use Cases
Java Tech Enthusiast
Java Tech Enthusiast
Jan 10, 2025 · Backend Development

RocketMQ Consumer Scaling and Load Balancing Strategies

In RocketMQ, adding consumers speeds consumption only when they are fewer than MessageQueues, while pull delays arise from ProcessQueue thresholds or ordered‑lock timeouts; slow processing often stems from heavy business logic or external calls, and load can be balanced using average, round‑robin, custom, machine‑room, nearby‑room, or consistent‑hash allocation strategies.

ConsumerRocketMQload balancing
0 likes · 9 min read
RocketMQ Consumer Scaling and Load Balancing Strategies
IT Architects Alliance
IT Architects Alliance
Jan 9, 2025 · Backend Development

Understanding Message Queues: Comparing Kafka, RabbitMQ, and RocketMQ

Message queues act as asynchronous communication bridges in distributed systems, and this article examines three leading solutions—Kafka, RabbitMQ, and RocketMQ—detailing their performance, scalability, reliability, strengths, drawbacks, and suitable use‑cases to guide developers in selecting the right technology.

KafkaRabbitMQRocketMQ
0 likes · 13 min read
Understanding Message Queues: Comparing Kafka, RabbitMQ, and RocketMQ
macrozheng
macrozheng
Jan 7, 2025 · Backend Development

8 Real-World Scenarios for Using Message Queues in Modern Applications

This article explores eight practical use cases for message queues—including asynchronous processing, service decoupling, traffic shaping, delayed tasks, log collection, distributed transactions, remote calls, and broadcast notifications—providing code examples and architectural guidance for building robust backend systems.

RocketMQSpring Bootasynchronous-processing
0 likes · 13 min read
8 Real-World Scenarios for Using Message Queues in Modern Applications
IT Services Circle
IT Services Circle
Jan 3, 2025 · Backend Development

Eight Common Use Cases of Message Queues (MQ) with Code Examples

This article explains eight typical scenarios for using message queues—including asynchronous processing, service decoupling, traffic shaping, delayed tasks, log collection, distributed transactions, remote invocation, and broadcast notifications—providing clear explanations and Java code snippets for each case.

KafkaRocketMQasynchronous-processing
0 likes · 13 min read
Eight Common Use Cases of Message Queues (MQ) with Code Examples
Architecture & Thinking
Architecture & Thinking
Dec 18, 2024 · Backend Development

Mastering RocketMQ: Core Concepts of Topics, Queues, and Messaging

This article explains RocketMQ’s fundamental architecture, detailing the definitions, roles, and interactions of topics, message queues, messages, producers, consumers, consumer groups, and subscription relationships, and highlights how these components work together to achieve high performance, availability, and scalability.

Distributed MessagingMessaging ArchitectureRocketMQ
0 likes · 7 min read
Mastering RocketMQ: Core Concepts of Topics, Queues, and Messaging
Su San Talks Tech
Su San Talks Tech
Dec 14, 2024 · Backend Development

Mastering CompletableFuture: From Basics to RocketMQ Integration

This article explains the limitations of Java's Future, introduces CompletableFuture with its rich API for non‑blocking asynchronous programming, demonstrates practical usage including task creation, result retrieval, chaining, exception handling, and shows how RocketMQ leverages CompletableFuture to coordinate disk flush and replica sync tasks efficiently.

@AsyncCompletableFutureConcurrency
0 likes · 16 min read
Mastering CompletableFuture: From Basics to RocketMQ Integration
JD Cloud Developers
JD Cloud Developers
Dec 11, 2024 · Operations

How to Prevent Message Queue Disorder in Distributed Systems

This article examines the causes of message queue disorder in distributed systems and presents practical solutions such as ordered messaging, pre‑consumption checks, state machines, and monitoring to improve system stability and data consistency.

KafkaRocketMQmessage ordering
0 likes · 9 min read
How to Prevent Message Queue Disorder in Distributed Systems
Architecture & Thinking
Architecture & Thinking
Dec 5, 2024 · Backend Development

Understanding Apache RocketMQ: Domain Model, Communication & Message Patterns

This article explains Apache RocketMQ's core components—including producers, topics, queues, and consumer groups—covers synchronous RPC versus asynchronous messaging, compares point‑to‑point and publish‑subscribe transmission models, and highlights their suitable scenarios and trade‑offs.

RocketMQasynchronous communicationbackend development
0 likes · 9 min read
Understanding Apache RocketMQ: Domain Model, Communication & Message Patterns
ITPUB
ITPUB
Dec 1, 2024 · Fundamentals

Why Does Kafka Outperform RocketMQ? The Role of Zero‑Copy Techniques

The article explains how Kafka’s use of sendfile zero‑copy gives it higher throughput than RocketMQ, which relies on mmap, and discusses the trade‑offs between performance and feature richness when choosing between the two message‑queue systems.

PerformanceRocketMQmessage queue
0 likes · 9 min read
Why Does Kafka Outperform RocketMQ? The Role of Zero‑Copy Techniques
Architecture & Thinking
Architecture & Thinking
Nov 25, 2024 · Backend Development

Mastering RocketMQ: Core Concepts, Comparison, and Java Implementation

This comprehensive guide introduces RocketMQ's architecture, compares it with RabbitMQ and Kafka, outlines typical use cases, explains key concepts such as producers, brokers, consumers, topics, tags, and offsets, and provides complete Java code examples for building producers and consumers.

JavaMessaging MiddlewareRocketMQ
0 likes · 14 min read
Mastering RocketMQ: Core Concepts, Comparison, and Java Implementation
Programmer1970
Programmer1970
Nov 18, 2024 · Backend Development

How to Resolve Message Backlog and Why Kafka Outperforms RocketMQ

The article outlines practical solutions for RocketMQ message backlog—including scaling consumers, optimizing logic, batch consumption, producer throttling, broker tuning, monitoring, and emergency plans—then explains why Kafka delivers higher performance through sendfile zero‑copy, simple log storage, efficient memory use, and batch sending, and finally compares the two systems on reliability, retry, transactions, filtering, ordering, and suitable use cases.

BacklogKafkaPerformance
0 likes · 8 min read
How to Resolve Message Backlog and Why Kafka Outperforms RocketMQ
macrozheng
macrozheng
Nov 11, 2024 · Backend Development

Why Did My RocketMQ Consumer Accumulate 300M Messages? The Hidden ClientId Bug

An unexpected RocketMQ alert revealed over 300 million queued messages, traced to identical clientIds generated by Docker host‑network containers; the article explains the root cause, examines clientId generation, load‑balancing logic, and provides a fix by customizing the clientId to prevent message backlog.

ClientIdMessage AccumulationRocketMQ
0 likes · 20 min read
Why Did My RocketMQ Consumer Accumulate 300M Messages? The Hidden ClientId Bug
Architect
Architect
Nov 5, 2024 · Backend Development

Implementing Transactional Messages with RocketMQ in Microservices

This article explains RocketMQ's transactional message mechanism, covering half‑message concepts, back‑check processes, implementation steps with code examples, and how to achieve reliable event handling and distributed transaction consistency in a microservice architecture.

JavaRocketMQTransactional Messaging
0 likes · 12 min read
Implementing Transactional Messages with RocketMQ in Microservices
Xiaohongshu Tech REDtech
Xiaohongshu Tech REDtech
Oct 23, 2024 · Backend Development

Pulsar vs RocketMQ: Architecture, Cost Benefits, and Migration Strategy for Xiaohongshu Online Messaging

Xiaohongshu replaced its RocketMQ‑based online messaging platform with Apache Pulsar, achieving up to 48% total cost reduction, 43% higher CPU utilization, 30% resource savings, and a latency drop from 20.2 ms to 5.7 ms through cloud‑native, elastic scaling and a phased migration strategy.

Apache PulsarRocketMQcost optimization
0 likes · 12 min read
Pulsar vs RocketMQ: Architecture, Cost Benefits, and Migration Strategy for Xiaohongshu Online Messaging
Alibaba Cloud Native
Alibaba Cloud Native
Oct 20, 2024 · Backend Development

How Adaptive K‑Value Backoff Locks Boost RocketMQ Performance by Up to 38%

A recent CCF‑A conference paper reveals that an adaptive K‑value backoff lock, derived from queueing theory and implemented in Apache RocketMQ, can replace both spin and mutex locks, achieving up to 37.58% performance gains on x86 CPUs and 32.82% on ARM while reducing CPU usage and resource consumption.

RocketMQbackend systemshigh concurrency
0 likes · 7 min read
How Adaptive K‑Value Backoff Locks Boost RocketMQ Performance by Up to 38%
MaGe Linux Operations
MaGe Linux Operations
Oct 7, 2024 · Operations

Why Choose RocketMQ? Features, Comparisons, and Reliability Explained

This article provides a comprehensive overview of RocketMQ, covering its architecture, key features such as high reliability, low latency and high throughput, comparisons with Kafka, RabbitMQ and ActiveMQ, and detailed mechanisms that ensure message durability, performance, and ordered consumption.

RocketMQdistributed systemslow latency
0 likes · 12 min read
Why Choose RocketMQ? Features, Comparisons, and Reliability Explained
IT Services Circle
IT Services Circle
Sep 24, 2024 · Backend Development

Ensuring Message Reliability in RocketMQ: Producer, Storage, and Consumer Guarantees

This article explains how RocketMQ guarantees message reliability across the production, storage, and consumption stages, covering synchronous, asynchronous, and transactional sending, disk persistence and replication strategies, consumption models (at-least-once, at-most-once, exactly-once), and handling consumer crashes without message loss.

Consumer CrashMessage reliabilityRocketMQ
0 likes · 6 min read
Ensuring Message Reliability in RocketMQ: Producer, Storage, and Consumer Guarantees
DevOps Operations Practice
DevOps Operations Practice
Sep 23, 2024 · Operations

Root Cause Analysis and Optimization of High Load on Alibaba Cloud RocketMQ Consumer Service

The article investigates why a RocketMQ consumer service running on a 4‑core ECS experiences sustained high load despite low CPU, I/O and memory usage, identifies excessive thread creation and frequent trace‑module context switches as the main causes, and proposes configuration and SDK upgrades to resolve the issue.

JavaRocketMQThread Management
0 likes · 9 min read
Root Cause Analysis and Optimization of High Load on Alibaba Cloud RocketMQ Consumer Service
Sanyou's Java Diary
Sanyou's Java Diary
Sep 19, 2024 · Operations

Message Queue Showdown: Choosing Kafka, Pulsar, RabbitMQ, RocketMQ or NSQ

This comprehensive guide compares five popular message queue systems—Kafka, Pulsar, RabbitMQ, RocketMQ, and NSQ—covering their architectures, core concepts, selection criteria, feature differences such as ordering, latency, durability, scaling, and operational considerations, to help engineers select the most suitable solution for their use cases.

KafkaNSQPulsar
0 likes · 46 min read
Message Queue Showdown: Choosing Kafka, Pulsar, RabbitMQ, RocketMQ or NSQ
Code Farming
Code Farming
Sep 14, 2024 · Backend Development

How RocketMQ Handles Concurrency: Deep Dive into Its Design Principles

This article dissects RocketMQ's concurrency mechanisms, explaining why it uses ReentrantReadWriteLock with HashMaps, how Semaphore controls async send rates, the SemaphoreReleaseOnlyOnce wrapper, the CountDownLatch‑based sync‑to‑async pattern, and the CompletableFuture redesign that reduces blocking in message replication.

CompletableFutureConcurrencyDistributed Messaging
0 likes · 10 min read
How RocketMQ Handles Concurrency: Deep Dive into Its Design Principles
Architect
Architect
Sep 7, 2024 · Backend Development

How to Reset RocketMQ Consumer Offsets Using Message Backtracking – A Step‑by‑Step Guide

When a SMS service fails and messages need to be re‑sent, this article shows how to use RocketMQ's message backtracking feature to reset consumer offsets, verify the reset, and explore the internal workflow and alternative pull‑consumer strategies with concrete code examples and detailed analysis.

Distributed MessagingJavaMessage Backtracking
0 likes · 21 min read
How to Reset RocketMQ Consumer Offsets Using Message Backtracking – A Step‑by‑Step Guide
Tencent Cloud Developer
Tencent Cloud Developer
Sep 6, 2024 · Backend Development

Message Queue (MQ) Overview, Selection Criteria, and Comparison of Kafka, Pulsar, RocketMQ, RabbitMQ, and NSQ

The article surveys major message‑queue systems—Kafka, Pulsar, RocketMQ, RabbitMQ, and NSQ—detailing their architectures, key features, selection criteria such as ordering, scalability and latency, performance benchmarks, operational considerations, and typical use cases, and advises which platform best fits high‑throughput, reliability, low‑latency, or lightweight Go‑centric scenarios.

KafkaNSQPulsar
0 likes · 47 min read
Message Queue (MQ) Overview, Selection Criteria, and Comparison of Kafka, Pulsar, RocketMQ, RabbitMQ, and NSQ
JavaEdge
JavaEdge
Aug 27, 2024 · Backend Development

How RocketMQ Transaction Messages Decouple Financial Services

This article explains how RocketMQ's transaction messaging can break tight coupling between heterogeneous systems in fund companies, outlines topic/tag classification, compares distributed‑transaction solutions, and details the end‑to‑end workflow and consumption guarantees for financial use cases.

Financial ServicesRocketMQdistributed transactions
0 likes · 13 min read
How RocketMQ Transaction Messages Decouple Financial Services
Su San Talks Tech
Su San Talks Tech
Aug 26, 2024 · Backend Development

7 Real-World Message Queue Patterns Every Backend Engineer Should Know

This article shares seven classic message‑queue use cases—from asynchronous decoupling and peak‑smoothing to delayed tasks, broadcast consumption, distributed transactions, and data hub integration—illustrated with real‑world examples, diagrams, and RocketMQ code snippets.

KafkaRocketMQ
0 likes · 12 min read
7 Real-World Message Queue Patterns Every Backend Engineer Should Know
Architect
Architect
Aug 23, 2024 · Backend Development

Understanding RocketMQ: Basic Concepts, Ordered Messages, and Transactional Messages

This article explains RocketMQ's core components, including domain models, message transmission models, reliability mechanisms, the challenges of ordered messaging, practical usage scenarios, and the design and implementation of transactional messages in both open‑source and proprietary versions.

BackendRocketMQdistributed systems
0 likes · 21 min read
Understanding RocketMQ: Basic Concepts, Ordered Messages, and Transactional Messages
Architect's Journey
Architect's Journey
Aug 19, 2024 · Backend Development

Flexible Multi-MQ Component Update: Switch Between RocketMQ, Redis, Kafka, and RabbitMQ

The article explains why adopting a message‑queue improves microservice decoupling and responsibility boundaries, then details the design of a pluggable Base‑MQ component—including @MQEventListener, MQEvent base class, configuration, and MQClient interface—followed by concrete implementations for RocketMQ, Kafka, Redis and RabbitMQ, an example event flow, and guidance for extending the framework.

JavaKafkaRabbitMQ
0 likes · 27 min read
Flexible Multi-MQ Component Update: Switch Between RocketMQ, Redis, Kafka, and RabbitMQ
DaTaobao Tech
DaTaobao Tech
Aug 14, 2024 · Backend Development

Deep Dive into RocketMQ Architecture and Core Components

The article thoroughly explains RocketMQ’s architecture—including stateless NameServers for routing, master‑slave Brokers with sequential CommitLog storage, stateless Producers and pull‑or‑push Consumers, message flow, indexing, and synchronous double‑write reliability—showing how these components deliver high‑throughput, scalable, fault‑tolerant messaging for distributed systems.

ConsumerRocketMQbroker
0 likes · 20 min read
Deep Dive into RocketMQ Architecture and Core Components
DaTaobao Tech
DaTaobao Tech
Aug 9, 2024 · Cloud Native

Deep Dive into RocketMQ: Storage Architecture and Consumer Processing Flow

RocketMQ stores messages in a sequential CommitLog while using a ConsumerQueue index for fast random access, and employs two looping threads—RebalanceService for load‑balancing queue assignments and PullMessageService for continuously pulling messages and dispatching them to user callbacks via a thread‑pooled consumer pipeline.

ConsumerJavaRocketMQ
0 likes · 12 min read
Deep Dive into RocketMQ: Storage Architecture and Consumer Processing Flow
Shepherd Advanced Notes
Shepherd Advanced Notes
Jul 24, 2024 · Backend Development

11 Ways to Implement Delayed Tasks – 16k Words, 28 Diagrams

This article surveys eleven Java‑based delayed‑task solutions—including DelayQueue, Timer, ScheduledThreadPoolExecutor, RocketMQ, RabbitMQ, Redis key‑expiration, Redisson, Netty’s HashedWheelTimer, Hutool SystemTimer, Quartz, and a simple polling loop—providing code demos, implementation principles, and practical pros and cons for each approach.

DelayQueueRabbitMQRedis
0 likes · 25 min read
11 Ways to Implement Delayed Tasks – 16k Words, 28 Diagrams
Architect
Architect
Jul 12, 2024 · Backend Development

How to Prevent Message Loss and Duplication in Kafka and RocketMQ

This article analyzes the root causes of message loss and duplication in modern message queues, explains how synchronous and asynchronous sending affect reliability, compares storage strategies like sync‑flush and broker clustering, and offers concrete idempotent handling techniques using database constraints and Redis.

BackendKafkaMessage reliability
0 likes · 8 min read
How to Prevent Message Loss and Duplication in Kafka and RocketMQ
Volcano Engine Developer Services
Volcano Engine Developer Services
Jul 3, 2024 · Backend Development

How We Scaled a Billion‑Item Search Engine with Elasticsearch: From Zero to One

This article details the practical journey of building and scaling an Elasticsearch‑based search system that supports tens of millions to billions of items, covering architecture design, capacity planning, multi‑data‑center deployment, data synchronization via RocketMQ and Flink, and multi‑layer reconciliation to ensure consistency and high QPS.

ElasticsearchFlinkRocketMQ
0 likes · 15 min read
How We Scaled a Billion‑Item Search Engine with Elasticsearch: From Zero to One
Shepherd Advanced Notes
Shepherd Advanced Notes
Jul 1, 2024 · Fundamentals

18 Essential Practices for Effectively Reading Open‑Source Code

The article outlines why reading source code matters—interview prep, skill growth, design insight—and presents a step‑by‑step guide of 18 practical habits, from mastering the JDK and design patterns to exploring demos, focusing on purpose, main flows, and thoughtful annotation.

Design PatternsJavaRocketMQ
0 likes · 14 min read
18 Essential Practices for Effectively Reading Open‑Source Code
macrozheng
macrozheng
Jun 25, 2024 · Backend Development

7 Real-World Message Queue Patterns Every Backend Engineer Should Master

This article explores seven classic message‑queue use cases—from asynchronous decoupling and traffic‑shaping to delayed tasks, broadcast consumption, distributed transactions, and using Kafka as a data hub—illustrated with real‑world examples and code snippets.

Broadcast ConsumptionDelayed MessageKafka
0 likes · 12 min read
7 Real-World Message Queue Patterns Every Backend Engineer Should Master
Wukong Talks Architecture
Wukong Talks Architecture
Jun 20, 2024 · Backend Development

Seven Classic Use Cases of Message Queues

This article shares seven practical scenarios—such as asynchronous processing, traffic smoothing, message bus, delayed tasks, broadcast consumption, distributed transactions, and data hub integration—where message queues like RocketMQ, Kafka, ActiveMQ, and RabbitMQ help solve high‑concurrency challenges in modern backend systems.

Broadcast ConsumptionDelay MessagesKafka
0 likes · 11 min read
Seven Classic Use Cases of Message Queues
Mike Chen's Internet Architecture
Mike Chen's Internet Architecture
Jun 6, 2024 · Backend Development

Comprehensive Introduction to RocketMQ: Architecture, Principles, and Use Cases

This article provides a detailed overview of RocketMQ, covering its core concepts, four primary usage scenarios, architectural components such as NameServer, Broker, Producer, and Consumer, as well as message storage, ordering guarantees, high availability, fault tolerance, and transactional messaging.

RocketMQbackend developmentdistributed systems
0 likes · 6 min read
Comprehensive Introduction to RocketMQ: Architecture, Principles, and Use Cases
Sanyou's Java Diary
Sanyou's Java Diary
Jun 3, 2024 · Backend Development

Understanding the Full Lifecycle of a RocketMQ Message: From Production to Deletion

This article walks through every stage of a RocketMQ message—from producer creation, routing, queue selection, and storage with zero‑copy techniques, through high‑availability replication, consumption modes, ordering guarantees, and finally automatic cleanup—providing code examples and architectural diagrams for each step.

RocketMQZero-Copybackend development
0 likes · 26 min read
Understanding the Full Lifecycle of a RocketMQ Message: From Production to Deletion