BestHub
Sign in
Tagged articles
525 articles
Page 4 of 6
Selected Java Interview Questions
Selected Java Interview Questions
Jul 7, 2022 · Backend Development

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

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

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

RocketMQ Consumer Startup Process and Message Consumption Mechanisms

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

ConsumerDistributed SystemsJava
0 likes · 24 min read
RocketMQ Consumer Startup Process and Message Consumption Mechanisms
Top Architect
Top Architect
Jul 6, 2022 · Backend Development

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

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

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

Mastering CompletableFuture: From Basics to RocketMQ Integration

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

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

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

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

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

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

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

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

Understanding RocketMQ Producer and Consumer Load Balancing Mechanisms

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

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

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

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

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

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

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

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

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

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

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

Ensuring Message Reliability in RocketMQ and RabbitMQ

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Common Issues and Solutions for Message Queue Middleware

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

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

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

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

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

Research on Delayed Queue Technologies and Implementation Approaches

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

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

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

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

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

Message Deduplication and Exactly‑Once Semantics in RocketMQ

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

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

Load Balancing Mechanism in RocketMQ Producer and Consumer

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

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

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

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

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

Spring Cloud Alibaba 2021.0.1.0: New Features, Version Rules Explained

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

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

Gray Deployment Solution for RocketMQ in the LUBAN MQ Platform

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

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

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

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

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

Design and Implementation of Delayed Message Queues in Distributed Systems

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

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

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

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

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

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

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

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

Common Issues in Message Queues and Distributed Transaction Solutions

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

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

Delayed Queue Technology Research and Implementation Overview

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

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

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

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

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

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

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

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

Implementation Strategies for Delayed (Scheduled) Messages in Distributed Systems

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

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

Mastering Delayed Tasks with RocketMQ and Spring Boot

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Cloud NativeInLong‑TubeMQKafka
0 likes · 18 min read
Design and Implementation Differences between Pulsar, Kafka, RocketMQ, and InLong‑TubeMQ
Tencent Cloud Developer
Tencent Cloud Developer
Oct 26, 2021 · Cloud Native

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

Pulsar’s cloud‑native, multi‑tenant architecture with hierarchical flow control, stateless brokers separated from BookKeeper storage, global partitions supporting multiple consumers, push‑based dispatch, and precise acknowledgment outperforms Kafka, RocketMQ, and InLong‑TubeMQ, though its reliance on ZooKeeper and higher resource usage demand careful operational planning.

Flow ControlInLong‑TubeMQKafka
0 likes · 17 min read
Design and Implementation Differences between Pulsar, Kafka, RocketMQ, and InLong‑TubeMQ
Full-Stack Internet Architecture
Full-Stack Internet Architecture
Oct 26, 2021 · Backend Development

Analysis of RocketMQ Routing Registration Mechanism, Its Defects, and the Impact of Network Partitions

This article examines RocketMQ's routing registration process, identifies its two main shortcomings—delayed failure detection and NameServer inconsistency—and explores how network partitions can cause prolonged data inconsistency, uneven message distribution, and partitioned consumption, while discussing the architectural trade‑offs behind these design choices.

MessagingRocketMQRouting
0 likes · 6 min read
Analysis of RocketMQ Routing Registration Mechanism, Its Defects, and the Impact of Network Partitions
Top Architect
Top Architect
Oct 24, 2021 · Backend Development

Message Deduplication and Exactly‑Once Semantics in RocketMQ

This article explains why RocketMQ guarantees at‑least‑once delivery, describes the three typical duplicate‑message scenarios, compares transaction‑based and non‑transactional deduplication approaches (including a Redis‑based solution), provides sample SQL and Java code, and discusses the limitations and best‑practice recommendations for achieving idempotent message consumption.

Exactly-OnceIdempotencyJava
0 likes · 20 min read
Message Deduplication and Exactly‑Once Semantics in RocketMQ
Top Architect
Top Architect
Oct 24, 2021 · Backend Development

Preventing Message Loss in RocketMQ: Scenarios, Solutions, and Trade‑offs

The article analyzes three typical RocketMQ message‑loss scenarios—network glitches during production, incomplete disk persistence, and premature consumer acknowledgments—and presents concrete solutions such as transactional messaging, synchronous flush with replication, and proper consumer‑ack handling, while discussing their performance impact.

JavaMessage LossRocketMQ
0 likes · 7 min read
Preventing Message Loss in RocketMQ: Scenarios, Solutions, and Trade‑offs
Alibaba Cloud Native
Alibaba Cloud Native
Oct 17, 2021 · Backend Development

How RocketMQ Improves Financial Customer‑Accompaniment Efficiency with Transactional Messaging

This article presents a Boshi Fund case study showing how RocketMQ’s decoupling, topic/tag best practices, and transactional messaging streamline multi‑system financial customer‑accompaniment, enhance operational efficiency, and enable reliable distributed transactions in online fund‑purchase scenarios.

Backend DevelopmentFinancial ServicesMessage Queue
0 likes · 12 min read
How RocketMQ Improves Financial Customer‑Accompaniment Efficiency with Transactional Messaging
Java Interview Crash Guide
Java Interview Crash Guide
Oct 13, 2021 · Backend Development

How to Achieve Exactly-Once Message Processing with RocketMQ Deduplication

Message middleware guarantees at-least-once delivery, but duplicate deliveries can cause issues; this article explains RocketMQ’s three duplication scenarios, explores simple and advanced deduplication strategies—including database-transaction and non-transactional approaches using Redis—and provides practical code samples for implementing reliable exactly-once processing.

DeduplicationDistributed SystemsExactly-Once
0 likes · 21 min read
How to Achieve Exactly-Once Message Processing with RocketMQ Deduplication
Selected Java Interview Questions
Selected Java Interview Questions
Oct 9, 2021 · Backend Development

RocketMQ vs Kafka: Detailed Feature, Performance, and Reliability Comparison

This article provides a comprehensive comparison between RocketMQ and Kafka, covering data reliability, performance, queue capacity, real‑time delivery, retry mechanisms, ordering guarantees, scheduled messages, transactional support, query capabilities, message tracing, consumer parallelism, filtering, and commercial backing, helping engineers choose the right messaging middleware for their workloads.

Distributed SystemsKafkaMessage Queue
0 likes · 11 min read
RocketMQ vs Kafka: Detailed Feature, Performance, and Reliability Comparison
Code Ape Tech Column
Code Ape Tech Column
Oct 6, 2021 · Operations

An Overview of Four Popular Distributed Message Queue Middleware: Kafka, ActiveMQ, RabbitMQ, and RocketMQ

This article introduces the concepts, core features, deployment environments, architectures, high‑availability solutions, advantages and disadvantages of four widely used open‑source distributed message queue systems—Kafka, ActiveMQ, RabbitMQ, and RocketMQ—and provides a comparative analysis to help practitioners choose the right middleware for their distributed applications.

ActiveMQDistributed SystemsKafka
0 likes · 37 min read
An Overview of Four Popular Distributed Message Queue Middleware: Kafka, ActiveMQ, RabbitMQ, and RocketMQ
Java Backend Technology
Java Backend Technology
Sep 20, 2021 · Backend Development

How to Achieve Exactly‑Once Message Processing in RocketMQ Without Transactions

This article explains why message middleware guarantees at‑least‑once delivery, the problems caused by duplicate consumption, and presents both transaction‑based and non‑transactional deduplication solutions—including a Redis‑backed idempotent table—to achieve exactly‑once semantics in RocketMQ.

Distributed SystemsExactly-OnceIdempotence
0 likes · 19 min read
How to Achieve Exactly‑Once Message Processing in RocketMQ Without Transactions
Java Architect Essentials
Java Architect Essentials
Sep 17, 2021 · Backend Development

How to Achieve Exactly‑Once Message Processing in RocketMQ Without Transactions

This article analyzes the at‑least‑once guarantee of message middleware, explains why duplicate deliveries occur, compares simple database‑based deduplication methods, explores concurrency challenges, and presents a non‑transactional, status‑driven idempotence solution using MySQL or Redis with practical code examples and limitations.

Distributed SystemsExactly-OnceIdempotence
0 likes · 19 min read
How to Achieve Exactly‑Once Message Processing in RocketMQ Without Transactions
Architecture Digest
Architecture Digest
Sep 17, 2021 · Backend Development

Message Deduplication and Exactly-Once Semantics in RocketMQ

This article explains why message middleware guarantees at‑least‑once delivery, describes three common duplication scenarios in RocketMQ, and presents both transactional and non‑transactional deduplication solutions—including SQL examples and a Redis‑based idempotence library—to achieve exactly‑once processing.

Distributed SystemsExactly-OnceIdempotence
0 likes · 19 min read
Message Deduplication and Exactly-Once Semantics in RocketMQ
Programmer DD
Programmer DD
Sep 16, 2021 · Backend Development

Why RocketMQ Solves Core Messaging Challenges – Architecture and Features Explained

This article examines the key problems message middleware must address—such as publish/subscribe, ordering, filtering, persistence, reliability, latency, and transaction support—and explains how Apache RocketMQ’s architecture and design choices provide high‑performance, high‑throughput solutions to each of these challenges.

Distributed SystemsMessage QueueReliability
0 likes · 17 min read
Why RocketMQ Solves Core Messaging Challenges – Architecture and Features Explained
vivo Internet Technology
vivo Internet Technology
Sep 15, 2021 · Backend Development

RocketMQ NameServer Architecture Design and Source Code Analysis

The article thoroughly examines RocketMQ’s NameServer, detailing its lightweight registration-center architecture, startup sequence, and the three core routing mechanisms—registration via broker heartbeats, timed removal of stale brokers, and client‑pulled discovery—while explaining key metadata tables and design patterns such as JVM shutdown hooks and read‑write locks for high‑concurrency safety.

Distributed SystemsNameServerRocketMQ
0 likes · 30 min read
RocketMQ NameServer Architecture Design and Source Code Analysis
Tencent Cloud Developer
Tencent Cloud Developer
Sep 14, 2021 · Backend Development

A Comparative Overview of Transactional Messaging in RocketMQ, Kafka, and Pulsar

The article compares how RocketMQ, Apache Kafka, and Apache Pulsar implement transactional messaging—each using a two‑phase commit with half‑messages or transaction buffers, distinct coordinators, and idempotent producers—to provide atomicity and either strong consistency (RocketMQ) or exactly‑once delivery for high‑throughput stream processing (Kafka and Pulsar).

Distributed SystemsExactly-OnceKafka
0 likes · 22 min read
A Comparative Overview of Transactional Messaging in RocketMQ, Kafka, and Pulsar
Top Architect
Top Architect
Sep 8, 2021 · Backend Development

Understanding Apache RocketMQ Architecture: Components, Routing, and Message Flow

This article provides a comprehensive overview of Apache RocketMQ, detailing its core components—Namesrv, Broker, Producer, and Consumer—explaining routing registration, message storage, queue allocation strategies, and key concepts such as topics, tags, and consumer types, while comparing it with Kafka.

Kafka ComparisonMessage QueueMessaging Middleware
0 likes · 14 min read
Understanding Apache RocketMQ Architecture: Components, Routing, and Message Flow
Alibaba Cloud Native
Alibaba Cloud Native
Sep 7, 2021 · Cloud Native

Scaling Millions of IoT Vehicles: RocketMQ & Cloud‑Native Architecture in Action

Facing over a million concurrent connected vehicles, Chinese IoT leader ZhongRui chose RocketMQ over Kafka, leveraging Alibaba Cloud’s managed service to achieve low‑latency, high‑throughput, fault‑tolerant messaging, while adopting cloud‑native microservices, containerization, and serverless techniques to streamline operations and reduce costs.

Cloud NativeIoTKafka
0 likes · 13 min read
Scaling Millions of IoT Vehicles: RocketMQ & Cloud‑Native Architecture in Action
Java Interview Crash Guide
Java Interview Crash Guide
Aug 30, 2021 · Backend Development

How to Achieve Exactly-Once Message Processing with RocketMQ Deduplication

Message middleware guarantees at-least-once delivery, but repeated deliveries cause duplicate processing; this article explains RocketMQ's duplicate scenarios, explores simple and advanced deduplication techniques—including database-transactional and Redis-based idempotent tables—and provides practical Java code for implementing exactly-once semantics.

Distributed SystemsExactly-OnceIdempotence
0 likes · 20 min read
How to Achieve Exactly-Once Message Processing with RocketMQ Deduplication
IT Architects Alliance
IT Architects Alliance
Aug 19, 2021 · Backend Development

Deep Dive into RocketMQ Architecture, Principles, and Source Code

This article provides a comprehensive overview of RocketMQ's evolution, core architecture, communication flow, storage mechanisms, flushing strategies, high‑availability synchronization, and transaction message implementation, illustrating each component with diagrams and key source‑code excerpts for developers seeking an in‑depth understanding of the system.

JavaMessage QueueNetty
0 likes · 13 min read
Deep Dive into RocketMQ Architecture, Principles, and Source Code
Full-Stack Internet Architecture
Full-Stack Internet Architecture
Aug 19, 2021 · Backend Development

Ensuring Ordered Message Processing in RocketMQ: Partitioning, Routing, and Consumer Coordination

This article explains how to achieve high‑throughput, high‑availability ordered messaging in RocketMQ by using multi‑partition designs, routing strategies, and consumer locking mechanisms to guarantee local order while handling scaling, failures, and consumer concurrency.

Consumer CoordinationMessage QueuePartitioning
0 likes · 7 min read
Ensuring Ordered Message Processing in RocketMQ: Partitioning, Routing, and Consumer Coordination
Tencent Cloud Developer
Tencent Cloud Developer
Aug 19, 2021 · Backend Development

Message Queue Design Principles and Implementation Analysis

The article explains message queues, their primary use cases—async processing, system decoupling, and traffic peak shaving—compares five mainstream products (ActiveMQ, RabbitMQ, Kafka, RocketMQ, Pulsar), and examines core design principles such as architecture, storage choices, push/pull models, and consumer groups, highlighting broader relevance to distributed systems.

Backend ArchitectureDistributed SystemsKafka
0 likes · 17 min read
Message Queue Design Principles and Implementation Analysis
ITPUB
ITPUB
Aug 18, 2021 · Backend Development

Unveiling RocketMQ: From History to Deep Dive into Architecture and Source Code

This article traces RocketMQ's evolution from its early Alibaba projects, explains its core components and communication roles, walks through the startup process, client message flow, remoting layer, broker handling, storage mechanisms, flush strategies, HA synchronization, and finally details the implementation of transactional messages.

JavaMessage QueueRocketMQ
0 likes · 16 min read
Unveiling RocketMQ: From History to Deep Dive into Architecture and Source Code
Wukong Talks Architecture
Wukong Talks Architecture
Aug 13, 2021 · Fundamentals

Reliable Message-Based Distributed Transaction Consistency Solution

This article explains the fundamentals of distributed transactions, introduces the reliable message eventual consistency approach, analyzes its challenges such as atomicity and message reliability, and presents two practical solutions—local message tables and RocketMQ transactional messages—along with their advantages and drawbacks.

Local Message TableRocketMQdistributed transactions
0 likes · 8 min read
Reliable Message-Based Distributed Transaction Consistency Solution
ITFLY8 Architecture Home
ITFLY8 Architecture Home
Aug 11, 2021 · Backend Development

Building a High‑Throughput, Highly Available Message Center with RocketMQ, ES, and Kubernetes

This article outlines the technical and business goals, design architecture, technology selection, and operational considerations for creating a message center capable of handling 10,000 messages per second upstream and 1,000 downstream, while ensuring 100% high availability and easy integration with third‑party push services.

Backend ArchitectureDevOpsHigh Throughput
0 likes · 5 min read
Building a High‑Throughput, Highly Available Message Center with RocketMQ, ES, and Kubernetes
Architect
Architect
Aug 6, 2021 · Backend Development

Design of a High‑Throughput Messaging Center Architecture

This article outlines a backend messaging center architecture that targets 10,000 messages per second inbound via RocketMQ, 1,000 messages per second outbound to third‑party platforms, and ensures 100% high availability using Spring Cloud Gateway, Kubernetes, Elasticsearch, and related technologies.

DevOpsElasticsearchKubernetes
0 likes · 5 min read
Design of a High‑Throughput Messaging Center Architecture
Programmer DD
Programmer DD
Jul 22, 2021 · Backend Development

How to Achieve Exactly‑Once Message Processing in RocketMQ Without Heavy Transactions

This article explains why message middleware guarantees at‑least‑once delivery, the challenges of duplicate consumption, and presents both simple and advanced deduplication strategies—including transactional and non‑transactional approaches using relational databases or Redis—to achieve effectively exactly‑once semantics in RocketMQ.

DatabaseExactly-OnceIdempotence
0 likes · 18 min read
How to Achieve Exactly‑Once Message Processing in RocketMQ Without Heavy Transactions
Youzan Coder
Youzan Coder
Jul 15, 2021 · Backend Development

Message Queue Architecture Comparison: NSQ, Kafka, and RocketMQ in Distributed Systems

The article compares the architectures of NSQ (YouZan branch), Kafka, and RocketMQ—detailing their coordination mechanisms, storage models, consistency guarantees, and operational trade‑offs—while recommending Kafka for log‑big‑data workloads, RocketMQ for massive topic counts, and NSQ for extensibility and lightweight deployment.

Distributed SystemsKafkaMessage Queue
0 likes · 16 min read
Message Queue Architecture Comparison: NSQ, Kafka, and RocketMQ in Distributed Systems
Code Ape Tech Column
Code Ape Tech Column
Jul 13, 2021 · Backend Development

Ensuring Consistent Money Transfers: Distributed Transactions & Message Queues Explained

The article examines how to prevent data inconsistency during cross‑service money transfers by using local transactions, two‑phase commit, and message‑queue based eventual consistency, providing detailed code examples, performance considerations, and practical solutions for large‑scale backend systems.

Data ConsistencyMessage QueueRocketMQ
0 likes · 23 min read
Ensuring Consistent Money Transfers: Distributed Transactions & Message Queues Explained
IT Architects Alliance
IT Architects Alliance
Jul 11, 2021 · Backend Development

Understanding Distributed Transactions: Two‑Phase Commit, Message‑Queue Solutions, and RocketMQ Transactional Messaging

This article explains how to guarantee data consistency when updating multiple tables or services by using local transactions for single‑node systems, two‑phase commit for distributed databases, and reliable message‑queue patterns—including RocketMQ transactional messages—to achieve eventual consistency and handle duplicate delivery.

Message QueueRocketMQTransactional Messaging
0 likes · 21 min read
Understanding Distributed Transactions: Two‑Phase Commit, Message‑Queue Solutions, and RocketMQ Transactional Messaging
Java High-Performance Architecture
Java High-Performance Architecture
Jul 3, 2021 · Backend Development

Building a High‑Throughput, Highly Available Messaging Center with RocketMQ & Elasticsearch

This article outlines the technical, business, and product goals for a messaging center, presents a prototype and functional requirements, evaluates RocketMQ and Elasticsearch as core technologies, and details the architectural design, underlying frameworks, and DevOps strategies—including Spring Cloud Gateway, Kubernetes, and Docker—to achieve 10,000 msg/s upstream throughput, 1,000 msg/s downstream delivery, and 100 % high availability.

ElasticsearchKubernetesMessaging System
0 likes · 5 min read
Building a High‑Throughput, Highly Available Messaging Center with RocketMQ & Elasticsearch
macrozheng
macrozheng
Jul 2, 2021 · Backend Development

From Zero to Running RocketMQ: My First Producer‑Consumer Walkthrough

This article chronicles my step‑by‑step journey of learning Apache RocketMQ, from downloading the source and building it with Maven, configuring mirrors, launching NameServer, Broker, Producer and Consumer on Windows, to exploring the system’s architecture and design principles.

Distributed SystemsJavaMaven
0 likes · 17 min read
From Zero to Running RocketMQ: My First Producer‑Consumer Walkthrough
Alibaba Cloud Native
Alibaba Cloud Native
Jun 30, 2021 · Operations

How We Built a Dual‑Center, High‑Availability RocketMQ Platform

This article explains why RocketMQ was chosen, describes its large‑scale usage, details the design and implementation of a same‑city dual‑center architecture with near‑by production and consumption, outlines failover mechanisms, governance practices, lessons learned, and future plans for the messaging platform.

Dual CenterGovernanceJava
0 likes · 15 min read
How We Built a Dual‑Center, High‑Availability RocketMQ Platform
Full-Stack Internet Architecture
Full-Stack Internet Architecture
Jun 27, 2021 · Backend Development

Integrating Apache RocketMQ with Spring Boot: Features, Configuration, Code Samples, and Interview Essentials

This article provides a comprehensive guide to using Apache RocketMQ with Spring Boot, covering core components, basic concepts, key features, step‑by‑step configuration, producer and consumer code examples, advanced message types, transaction handling, and common interview questions for distributed messaging systems.

Distributed SystemsJavaMessage Queue
0 likes · 16 min read
Integrating Apache RocketMQ with Spring Boot: Features, Configuration, Code Samples, and Interview Essentials
Selected Java Interview Questions
Selected Java Interview Questions
Jun 25, 2021 · Backend Development

Message Queues for Interviews: Why Use MQ, Benefits, Drawbacks, and Comparison of Kafka, ActiveMQ, RabbitMQ, and RocketMQ

This article explains why message queues are used in modern systems, outlines common interview questions about MQ, discusses the advantages of decoupling, asynchronous processing, and traffic shaping, examines the pros and cons of MQ, and compares the four major MQ products—Kafka, ActiveMQ, RabbitMQ, and RocketMQ—to help candidates prepare for technical interviews.

ActiveMQBackend DevelopmentKafka
0 likes · 11 min read
Message Queues for Interviews: Why Use MQ, Benefits, Drawbacks, and Comparison of Kafka, ActiveMQ, RabbitMQ, and RocketMQ
Su San Talks Tech
Su San Talks Tech
Jun 19, 2021 · Backend Development

How a Hidden NPE Revealed Deep Issues in Our Java Backend and RocketMQ Integration

After receiving a Sentry alert for a NullPointerException in a Java backend, the author traced the issue through user context handling with TransmittableThreadLocal, uncovered mismatched RocketMQ header propagation, multiple retry attempts, and a manual message injection, ultimately revealing how a missing header caused the NPE.

NPERocketMQSentry
0 likes · 18 min read
How a Hidden NPE Revealed Deep Issues in Our Java Backend and RocketMQ Integration