BestHub
Sign in
Tagged articles

RocketMQ

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

High concurrencyRocketMQdistributed 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.

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.

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

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

JavaMessage QueueMessage 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.

ConfigurationJavaMessage Tracing
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.

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.

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

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

Asynchronous CommunicationKafkaMessage Queue
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.

Backend DevelopmentDistributed MessagingMessage Queue
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.

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

Asynchronous CommunicationBackend DevelopmentMessage Queue
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 QueuePerformanceRocketMQ
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.

Backend DevelopmentJavaMessage Queue
0 likes · 14 min read
Mastering RocketMQ: Core Concepts, Comparison, and Java Implementation
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.

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

High concurrencyPerformance TuningRocketMQ
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 QueueReliabilityRocketMQ
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.

Backend DevelopmentConsumer CrashMessage Queue
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.

JavaPerformance TuningRocketMQ
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
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.

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

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.

JavaKafkaMessage Queue
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 QueueRocketMQ
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.

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

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

Backend DevelopmentMessage QueueMiddleware
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.

Backend DevelopmentHigh AvailabilityRocketMQ
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.

Order TimeoutRedisRocketMQ
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.

Backend DevelopmentJavaRocketMQ
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.

KafkaMessage DuplicationMessage Loss
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 QueueRabbitMQ
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.

RocketMQSeataTransactional Messaging
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.

ACLAccess ControlAuthorization
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.

High concurrencyMySQLRedis
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.

Backend DevelopmentMessage QueueRaft
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.

CloudEventsEvent-Driven ArchitectureEventBridge
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
Sanyou's Java Diary
Sanyou's Java Diary
Apr 1, 2024 · Backend Development

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

This article shares seven classic use cases of message queues—including asynchronous decoupling, traffic smoothing, bus architecture, delayed tasks, broadcast consumption, distributed transactions, and data hub integration—illustrated with real-world experiences and code examples to help engineers design robust high‑concurrency systems.

Broadcast ConsumptionKafkaRocketMQ
0 likes · 12 min read
7 Real-World Message Queue Patterns Every Backend Engineer Should Know
Su San Talks Tech
Su San Talks Tech
Mar 30, 2024 · Backend Development

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

From asynchronous decoupling to distributed transactions, this article explores seven classic message‑queue use cases—such as peak‑shaving, event buses, delayed tasks, broadcast consumption, and data hub integration—illustrated with real‑world examples from e‑commerce, ride‑hailing, and lottery systems, plus RocketMQ code snippets.

KafkaMessage QueueRocketMQ
0 likes · 13 min read
7 Real-World Message Queue Patterns Every Backend Engineer Should Know
vivo Internet Technology
vivo Internet Technology
Mar 27, 2024 · Backend Development

RocketMQ Multi-Version Environment Isolation Practice in Test Environments

The article details how vivo’s Internet Middleware Team migrated from RabbitMQ to RocketMQ and introduced a user‑property‑based multi‑version isolation layer that tags messages, filters them by consumer groups, and provides fallback and retry mechanisms, enabling test‑environment separation without SDK changes, though offline consumers may miss baseline messages.

Message MiddlewareMessage QueueMiddleware Architecture
0 likes · 12 min read
RocketMQ Multi-Version Environment Isolation Practice in Test Environments
Rare Earth Juejin Tech Community
Rare Earth Juejin Tech Community
Mar 25, 2024 · Backend Development

Design and Performance Optimization of a High‑Concurrency Volunteer Registration System

This article recounts the end‑to‑end design, bottleneck analysis, and iterative performance tuning—including MySQL, Redis, RocketMQ, compression, sharding, and connection‑pool adjustments—that enabled a volunteer registration platform to meet demanding high‑concurrency and data‑accuracy requirements under limited resources.

High concurrencyJavaMySQL
0 likes · 16 min read
Design and Performance Optimization of a High‑Concurrency Volunteer Registration System
Alibaba Cloud Native
Alibaba Cloud Native
Mar 24, 2024 · Cloud Native

How RocketMQ 5.0 Enables Lightweight Cloud‑Native Stream Processing with RStreams and RSQLDB

This article explains the evolution of message middleware, introduces core concepts of stream processing, and details RocketMQ 5.0's native lightweight stream engine RStreams and its stream database RSQLDB, showing how they simplify real‑time data integration, computation, and scaling in cloud‑native environments.

RSQLDBRStreamsRocketMQ
0 likes · 14 min read
How RocketMQ 5.0 Enables Lightweight Cloud‑Native Stream Processing with RStreams and RSQLDB
Selected Java Interview Questions
Selected Java Interview Questions
Mar 22, 2024 · Backend Development

Design and Performance Optimization of a High‑Concurrency Volunteer Registration System

This article recounts the end‑to‑end design, testing, and iterative optimization of a volunteer registration platform that required tens of thousands of QPS, covering requirement analysis, middleware benchmarking, data partitioning, compression, connection‑limit handling, and final deployment lessons.

RocketMQhigh-concurrencyperformance-testing
0 likes · 16 min read
Design and Performance Optimization of a High‑Concurrency Volunteer Registration System
dbaplus Community
dbaplus Community
Mar 17, 2024 · Backend Development

How to Build a Scalable Billion‑Item Elasticsearch Search System from Scratch

This article walks through the end‑to‑end design and implementation of a searchable system that scales from millions to hundreds of millions of products, covering business background, data‑center architecture, ES cluster sizing, multi‑room data sync, RocketMQ‑Flink pipelines, and multi‑layer reconciliation to achieve high QPS and strong consistency.

Data synchronizationElasticsearchRocketMQ
0 likes · 16 min read
How to Build a Scalable Billion‑Item Elasticsearch Search System from Scratch
Tencent Cloud Middleware
Tencent Cloud Middleware
Mar 13, 2024 · Cloud Native

What’s New in RocketMQ 5.x? A Deep Dive into Cloud‑Native Features, Proxy, Pop, and Tiered Storage

This article explores Apache RocketMQ 5.x’s new cloud‑native capabilities—including the Proxy component, gRPC client, Pop consumption model, timer‑based delayed messages, tiered storage, distributed rate‑limiting, and containerized deployment on Tencent Cloud—while outlining architecture changes, practical usage patterns, and future directions.

RocketMQTiered Storagecontainerization
0 likes · 32 min read
What’s New in RocketMQ 5.x? A Deep Dive into Cloud‑Native Features, Proxy, Pop, and Tiered Storage
Su San Talks Tech
Su San Talks Tech
Mar 12, 2024 · Backend Development

Why Is RocketMQ So Fast? 10 Core Techniques Explained

This article explores the ten key architectural and implementation techniques—such as batch messaging, compression, Netty networking, zero‑copy I/O, sequential writes, efficient storage structures, asynchronous processing, batch handling, lock optimizations, and thread‑pool isolation—that together make RocketMQ a high‑performance message middleware.

JavaNettyPerformance
0 likes · 21 min read
Why Is RocketMQ So Fast? 10 Core Techniques Explained
Sanyou's Java Diary
Sanyou's Java Diary
Mar 11, 2024 · Backend Development

Why RocketMQ Is So Fast: 10 Core Performance Techniques Explained

This article breaks down the ten key mechanisms—batch sending, message compression, Netty‑based networking, zero‑copy I/O, sequential writes, optimized storage structures, asynchronous flushing and replication, batch processing, lock refinements, and thread‑pool isolation—that together give RocketMQ its remarkable speed and efficiency.

Message QueueNettyPerformance
0 likes · 20 min read
Why RocketMQ Is So Fast: 10 Core Performance Techniques Explained
MaGe Linux Operations
MaGe Linux Operations
Feb 27, 2024 · Operations

How to Install and Deploy Apache RocketMQ 5.1.4 on Ubuntu

This guide walks you through setting up the Java environment, downloading Apache RocketMQ 5.1.4, installing its NameServer, Broker, and optional Proxy components on an Ubuntu 20.04 cloud instance, and configuring both local and cluster deployment modes with optional visual dashboard tools.

InstallationJavaMessage Queue
0 likes · 8 min read
How to Install and Deploy Apache RocketMQ 5.1.4 on Ubuntu
Su San Talks Tech
Su San Talks Tech
Feb 18, 2024 · Backend Development

Mastering CompletableFuture: From Basics to RocketMQ Integration

This article explains Java's CompletableFuture, its advantages over the traditional Future API, demonstrates common methods with code examples, and shows how RocketMQ leverages CompletableFuture to coordinate asynchronous disk flush and replica synchronization tasks.

CompletableFutureFutureJava
0 likes · 15 min read
Mastering CompletableFuture: From Basics to RocketMQ Integration
Mike Chen's Internet Architecture
Mike Chen's Internet Architecture
Feb 5, 2024 · Backend Development

Comprehensive Overview of RocketMQ: Architecture, Features, and Application Scenarios

This article provides an in‑depth introduction to RocketMQ, covering its evolution, core components, message domain model, key characteristics such as ordered delivery and deduplication, and typical use cases like traffic shaping, asynchronous decoupling, and distributed transaction messaging.

Backend DevelopmentMessage QueueRocketMQ
0 likes · 8 min read
Comprehensive Overview of RocketMQ: Architecture, Features, and Application Scenarios
Sanyou's Java Diary
Sanyou's Java Diary
Feb 1, 2024 · Backend Development

Message Queues Unveiled: From Decoupling to Platformization and Core Architectures

This article traces the two‑decade evolution of message queues—from early decoupling solutions like ActiveMQ, through high‑throughput designs such as Kafka, to modern platformized systems like RocketMQ and Pulsar—while explaining fundamental concepts, partitioning, and storage architectures that underpin today’s distributed messaging platforms.

KafkaMessage QueuePulsar
0 likes · 17 min read
Message Queues Unveiled: From Decoupling to Platformization and Core Architectures
Architecture Digest
Architecture Digest
Jan 19, 2024 · Backend Development

Assembling Hierarchical Tree Structures with Java Streams, Caching and Message Queues

This article demonstrates how to efficiently build department and regional hierarchical trees in Java by fetching all records in a single database query, using Stream API, Lambda expressions, in‑memory grouping, Redis caching and RocketMQ for asynchronous updates, achieving sub‑second response times even with tens of thousands of nodes.

JavaRocketMQStream
0 likes · 11 min read
Assembling Hierarchical Tree Structures with Java Streams, Caching and Message Queues
MaGe Linux Operations
MaGe Linux Operations
Dec 29, 2023 · Backend Development

How to Install and Run RocketMQ on CentOS 7: A Step‑by‑Step Guide

This article records a complete, step‑by‑step installation and startup process for Apache RocketMQ on a CentOS 7 system, covering environment checks, downloading the package, extracting files, launching the name server and broker, adjusting memory settings, and verifying the setup with a test client.

InstallationMessage QueueRocketMQ
0 likes · 4 min read
How to Install and Run RocketMQ on CentOS 7: A Step‑by‑Step Guide
Architect's Tech Stack
Architect's Tech Stack
Dec 29, 2023 · Cloud Native

Spring Cloud Alibaba Core Components and Practices: Nacos, Sentinel, Seata, RocketMQ

This article provides a comprehensive overview of Spring Cloud Alibaba’s core features—including Nacos service registration and configuration, Sentinel flow‑control and degradation rules, Seata distributed transaction modes, RocketMQ messaging capabilities, as well as guidance on service discovery, security, gray releases, and dynamic routing.

RocketMQSeataSentinel
0 likes · 33 min read
Spring Cloud Alibaba Core Components and Practices: Nacos, Sentinel, Seata, RocketMQ
Su San Talks Tech
Su San Talks Tech
Dec 26, 2023 · Backend Development

How to Diagnose and Resolve RocketMQ Message Accumulation Issues

This article explains why RocketMQ messages can pile up, analyzes the consumer pull‑process bottlenecks of consumption latency and concurrency, and provides practical strategies—including logging, JVM stack inspection, and concurrency tuning—to identify and eliminate the root causes of message backlog.

Consumer LagJavaMessage Accumulation
0 likes · 10 min read
How to Diagnose and Resolve RocketMQ Message Accumulation Issues
DaTaobao Tech
DaTaobao Tech
Dec 11, 2023 · Big Data

Design and Implementation of an Online Batch Processing Framework for Large-Scale Promotion Systems

The paper presents a centralized online batch‑processing framework for large‑scale promotion systems, where applications integrate via an SDK, a task‑center schedules and dispatches sub‑tasks through RocketMQ to Dubbo‑enabled containers, employing MapReduce‑style splitting, Guava rate‑limiting, heartbeat health checks, and has successfully handled over 1.3 million tasks during Double‑11.

Batch ProcessingBig DataDistributed Scheduling
0 likes · 9 min read
Design and Implementation of an Online Batch Processing Framework for Large-Scale Promotion Systems
Alibaba Cloud Native
Alibaba Cloud Native
Dec 6, 2023 · Cloud Native

How RocketMQ Implements Random Indexing for Cloud‑Native Storage

This article explains RocketMQ's random indexing mechanism, detailing its on‑disk three‑segment hash table structure, the compact format conversion process, multi‑threaded write and query workflows, layered system design, crash‑recovery strategy, and comparisons with RocksDB and InnoDB storage engines.

CompactionMessage IndexingRocketMQ
0 likes · 16 min read
How RocketMQ Implements Random Indexing for Cloud‑Native Storage
Architect
Architect
Nov 16, 2023 · Backend Development

Understanding Transactional Messages in Distributed Systems: RocketMQ and Kafka

This article explains the principles of distributed transaction messages, comparing 2PC, TCC, and transactional messaging, and provides detailed walkthroughs of RocketMQ and Kafka implementations, including their two‑phase processes, broker handling, and source‑code insights for ensuring data consistency in asynchronous systems.

2PCMessage QueueRocketMQ
0 likes · 16 min read
Understanding Transactional Messages in Distributed Systems: RocketMQ and Kafka
MaGe Linux Operations
MaGe Linux Operations
Nov 12, 2023 · Backend Development

Why RocketMQ Producers Need Load Balancing and How It Works

This article explains why load balancing is crucial for RocketMQ producers, details the internal selection algorithm using ThreadLocal indexes and round‑robin logic, and provides Java code examples illustrating how messages are distributed across queues.

JavaMessage QueueRocketMQ
0 likes · 5 min read
Why RocketMQ Producers Need Load Balancing and How It Works
Architect
Architect
Nov 11, 2023 · Backend Development

Message Queues: Concepts, Patterns, Evaluation Criteria, and Comparison of RabbitMQ, Kafka, RocketMQ, and ActiveMQ

This comprehensive article explains the fundamentals of message‑queue middleware, covering point‑to‑point and publish/subscribe models, key evaluation metrics, detailed comparisons of RabbitMQ, Kafka, RocketMQ and ActiveMQ, and deep dives into Kafka and RocketMQ architectures, features, and best‑practice usage.

ActiveMQRabbitMQRocketMQ
0 likes · 42 min read
Message Queues: Concepts, Patterns, Evaluation Criteria, and Comparison of RabbitMQ, Kafka, RocketMQ, and ActiveMQ