BestHub
Sign in
Tagged articles

RocketMQ

571 articles · Page 2 of 6
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.

Message QueueRocketMQdistributed 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.

Message QueueMiddlewareRocketMQ
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.

Message QueueRocketMQdistributed systems
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.

DashboardMessage QueueMonitoring
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.

Message QueueRocketMQSendResult
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.

Message QueueMessaging 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.

BacklogMessage QueueRocketMQ
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.

ConfigurationRocketMQTask System
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.

InstallationMessage QueueRocketMQ
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 ThroughputHigh reliability
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.

ConsumeQueueDistributedSystemsIndexing
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.

ComparisonKafkaRocketMQ
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.

BrokerMessage QueueRocketMQ
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.

Message QueueRocketMQ
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 ConsistencyMessage QueueRocketMQ
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.

Message QueueRocketMQbackend
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.

GCJVMRocketMQ
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.

DubboMicroservicesNacos
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.

Data ReplicationHigh AvailabilityRocketMQ
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.

Message QueueRocketMQbackend development
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.

IdempotencyRocketMQdistributed systems
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.

KafkaMessage QueueRocketMQ
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.

KafkaMessage QueueRocketMQ
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 MessagingFault ToleranceNameServer
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 StreamingHigh ThroughputKafka
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.

Message QueueMessage TracingRocketMQ
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.

KafkaMQMessage Queue
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.

ConfigurationMessage TracingRocketMQ
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.

KafkaNSQRocketMQ
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.

CLIMessage QueueRocketMQ
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 MessagingRocketMQbroker design
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.

Message QueueMicroservicesRocketMQ
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.

Load BalancingMessage QueueRocketMQ
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.

KafkaMessage QueueRocketMQ
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.

Delayed TasksMessage QueueRocketMQ
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.

KafkaMessage QueueRocketMQ
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 MessagingMessage QueueMessaging Architecture
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.

CompletableFutureFutureRocketMQ
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.

KafkaMessage OrderingMessage Queue
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.

Message QueueRocketMQasynchronous communication
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.

Message QueueRocketMQmmap
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.

Message QueueMessaging 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.

BacklogKafkaMessage Queue
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.

ClientIdDockerMessage Accumulation
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.

MicroservicesRocketMQjava
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 PulsarMessage QueueRocketMQ
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.

Message QueueRocketMQdistributed systems
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 QueueMessage reliability
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.

RocketMQThread Managementjava
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.

ComparisonKafkaMessage Queue
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.

CompletableFutureDistributed MessagingReadWriteLock
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 MessagingMessage BacktrackingOffset Reset
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.

Backend ArchitectureKafkaNSQ
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 ServicesMessage QueueRocketMQ
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.

Message QueueRocketMQbackend
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.

KafkaMessage QueueMicroservices
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.

BrokerMessage QueueProducer
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.

Load BalancingMessage QueueRocketMQ
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.

DelayQueueQuartzRedis
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.

KafkaMessage QueueMessage 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 PatternsOpen SourceRocketMQ
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.

Message QueueMiddlewareRocketMQ
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.

High AvailabilityRocketMQZero-Copy
0 likes · 26 min read
Understanding the Full Lifecycle of a RocketMQ Message: From Production to Deletion
Lobster Programming
Lobster Programming
May 17, 2024 · Backend Development

How to Implement Order Timeout Closure in E‑Commerce: 6 Proven Backend Solutions

This article compares six practical backend approaches—JDK DelayQueue, RocketMQ delayed messages, Redis expiration, Redis Zset, a dedicated task center, and passive closure—to automatically close unpaid e‑commerce orders after a configurable timeout, outlining their advantages, drawbacks, and suitable scenarios.

Delayed QueueRedisRocketMQ
0 likes · 8 min read
How to Implement Order Timeout Closure in E‑Commerce: 6 Proven Backend Solutions
Sohu Tech Products
Sohu Tech Products
May 15, 2024 · Backend Development

Design and Implementation of a Simplified RocketMQ SDK

To simplify RocketMQ usage, I designed an internal SDK that abstracts complex client configurations, offering single‑call ordered message sending, per‑message consumption, unified result handling, and enforced consistent subscription settings, thereby reducing developer effort and preventing common integration errors.

RocketMQSDKbackend development
0 likes · 6 min read
Design and Implementation of a Simplified RocketMQ SDK
Java Tech Enthusiast
Java Tech Enthusiast
Apr 30, 2024 · Backend Development

How to Prevent Message Loss and Duplication in Message Queues

This article examines why messages can be lost or duplicated in typical queue systems, explains the failure points from producer to broker to consumer, and provides practical techniques such as synchronous flushing, broker clustering, database unique constraints, and Redis deduplication to achieve reliable, idempotent processing.

IdempotencyKafkaMessage Duplication
0 likes · 7 min read
How to Prevent Message Loss and Duplication in Message Queues
Su San Talks Tech
Su San Talks Tech
Apr 25, 2024 · Backend Development

Choosing the Right Message Queue: Kafka, RabbitMQ, RocketMQ, and ActiveMQ Compared

This article provides a comprehensive overview of four major message queue systems—Kafka, RabbitMQ, RocketMQ, and ActiveMQ—covering their fundamentals, architectures, key concepts, advantages, disadvantages, and guidance for selecting the most suitable solution based on throughput, reliability, scalability, and use‑case requirements.

KafkaMessage QueueRocketMQ
0 likes · 18 min read
Choosing the Right Message Queue: Kafka, RabbitMQ, RocketMQ, and ActiveMQ Compared
Zhuanzhuan Tech
Zhuanzhuan Tech
Apr 24, 2024 · Backend Development

Understanding RocketMQ: Basics, Ordered Messages, and Transactional Messages

This article provides a comprehensive overview of Apache RocketMQ, covering its core concepts, message models, reliability mechanisms, ordered message challenges and solutions, as well as detailed explanations of transactional messages, including implementation principles, producer and broker workflows, and practical considerations for ensuring consistency in distributed systems.

Message QueueRocketMQordered messages
0 likes · 24 min read
Understanding RocketMQ: Basics, Ordered Messages, and Transactional Messages
Lobster Programming
Lobster Programming
Apr 23, 2024 · Backend Development

Comparing Distributed Transaction Strategies: Local Messages, RocketMQ, and Seata (AT & TCC)

This article compares four distributed transaction solutions—local message tables, RocketMQ transactional messages, Seata AT mode, and Seata TCC mode—detailing their advantages, limitations, workflow phases, and common exception‑handling techniques for ensuring data consistency across services.

Backend ArchitectureRocketMQSeata
0 likes · 6 min read
Comparing Distributed Transaction Strategies: Local Messages, RocketMQ, and Seata (AT & TCC)
Alibaba Cloud Native
Alibaba Cloud Native
Apr 18, 2024 · Cloud Native

What’s New in RocketMQ ACL 2.0? A Deep Dive into Features, Architecture, and Configuration

This article explains the motivations behind RocketMQ ACL 2.0, outlines its six major enhancements—including fine‑grained API permissions, flexible matching modes, and cluster‑wide access control—details the RBAC/ABAC model, authentication and authorization workflows, configuration examples, command‑line usage, and migration strategies, and discusses future planning for the access control system.

ACLRocketMQaccess control
0 likes · 24 min read
What’s New in RocketMQ ACL 2.0? A Deep Dive into Features, Architecture, and Configuration
dbaplus Community
dbaplus Community
Apr 17, 2024 · Backend Development

How We Scaled a Volunteer Registration System to 20k QPS with Redis, RocketMQ, and MySQL

This article recounts how a volunteer registration platform was redesigned to meet extreme concurrency demands—handling up to 40k QPS and 20k TPS—by evaluating MySQL limits, adding Redis caching, integrating RocketMQ, applying fault‑recovery mechanisms, and iteratively optimizing through multiple load‑testing rounds.

MySQLPerformance TestingRedis
0 likes · 16 min read
How We Scaled a Volunteer Registration System to 20k QPS with Redis, RocketMQ, and MySQL
Tongcheng Travel Technology Center
Tongcheng Travel Technology Center
Apr 17, 2024 · Backend Development

In-Depth Analysis of Apache RocketMQ Architecture, Operation Principles, and High‑Throughput Mechanisms

This article provides a comprehensive overview of Apache RocketMQ, detailing its core components, producer and consumer workflows, storage strategies, master‑slave synchronization, Raft‑based half‑write and leader election mechanisms, and best‑practice recommendations for high‑throughput, fault‑tolerant messaging systems.

Fault ToleranceHigh ThroughputMessage Queue
0 likes · 22 min read
In-Depth Analysis of Apache RocketMQ Architecture, Operation Principles, and High‑Throughput Mechanisms
Alibaba Cloud Native
Alibaba Cloud Native
Apr 11, 2024 · Cloud Native

How RocketMQ 5.0 EventBridge Powers Cloud‑Native Event‑Driven Architecture

This article explores the evolution of message middleware, defines event‑driven architecture, explains why it resurfaces in the cloud era, and details RocketMQ 5.0 EventBridge’s design—its CloudEvents‑based abstraction, schema support, rule engine, observability, and real‑world use cases—offering practical guidance for building scalable, decoupled systems.

CloudEventsEventBridgeIoT
0 likes · 15 min read
How RocketMQ 5.0 EventBridge Powers Cloud‑Native Event‑Driven Architecture
Alibaba Cloud Native
Alibaba Cloud Native
Apr 7, 2024 · Cloud Native

How RocketMQ 5.0 Solves IoT Messaging Challenges with MQTT

This article explains the rapid growth of IoT, the unique messaging requirements it creates, compares classic and IoT message scenarios, and details how RocketMQ 5.0’s MQTT sub‑product introduces a lightweight protocol, read‑amplify storage, edge‑cloud integration, massive queue support, and a push‑pull delivery model to meet cloud‑native IoT demands.

IoTMQTTMessage Queue
0 likes · 13 min read
How RocketMQ 5.0 Solves IoT Messaging Challenges with MQTT