Tagged articles

RocketMQ

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

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

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

Message LossRocketMQSync Flush
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.

Financial ServicesMessage QueueRocketMQ
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.

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

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

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

RocketMQdistributed systemsexactly-once
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.

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

RocketMQdistributed systemsexactly-once
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.

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

NameServerRocketMQRoute Management
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).

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

High AvailabilityKafka ComparisonMessage Queue
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.

RocketMQdistributed systemsexactly-once
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.

Message QueueNettyRocketMQ
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 QueueOrdered Messaging
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 ArchitectureKafkaMessage Queue
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.

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

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

High AvailabilityKafkaMessage 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 QueueRocketMQdatabase-consistency
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.

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

MavenMessage QueueRocketMQ
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 CenterHigh AvailabilityMessage Queue
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.

Message QueueRocketMQSpring Boot
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.

ActiveMQKafkaMQ
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
Alibaba Cloud Native
Alibaba Cloud Native
Jun 16, 2021 · Backend Development

How to Build a Scalable Distributed Message Governance Platform for High Availability

This article shares Haro's practical experience in designing and operating a distributed message governance platform that unifies RocketMQ, Kafka, and other middleware, covering metrics, monitoring, alerting, scenario‑based controls, and high‑availability strategies to keep microservices reliable under sudden traffic spikes.

MicroservicesMonitoringRocketMQ
0 likes · 14 min read
How to Build a Scalable Distributed Message Governance Platform for High Availability
Alibaba Cloud Native
Alibaba Cloud Native
Jun 14, 2021 · Backend Development

Why RocketMQ Beats Other Open‑Source Queues: A Practical Selection Guide

This article evaluates open‑source message‑queue options by examining company, middleware‑team, and end‑user criteria, then explains why RocketMQ’s low technical and labor costs, stability, rich features, high performance, built‑in management tools, monitoring support, and active community make it a cost‑effective choice over alternatives like Kafka and Pulsar.

ComparisonMessage QueueOpen Source
0 likes · 12 min read
Why RocketMQ Beats Other Open‑Source Queues: A Practical Selection Guide
Full-Stack Internet Architecture
Full-Stack Internet Architecture
May 19, 2021 · Backend Development

Understanding Message Queues: Benefits, Design Challenges, and Transactional Solutions

This article explores the role of message queues in microservice architectures, discussing their advantages such as decoupling, asynchronous processing, and load shedding, while also addressing design challenges like concurrency, ordering, duplicate handling, and transactional messaging with solutions including Kafka partitions, outbox patterns, CDC, and RocketMQ.

CDCKafkaMessage Queue
0 likes · 12 min read
Understanding Message Queues: Benefits, Design Challenges, and Transactional Solutions
ITPUB
ITPUB
May 10, 2021 · Backend Development

Unveiling RocketMQ NameServer: How Seven Classes Power the Registry

This article breaks down the design and source‑code implementation of RocketMQ's NameServer, detailing its core responsibilities, component interactions, and the seven Java classes that together provide network handling, connection management, routing, configuration, and startup logic.

Backend ArchitectureMessage QueueNameServer
0 likes · 11 min read
Unveiling RocketMQ NameServer: How Seven Classes Power the Registry
HelloTech
HelloTech
May 9, 2021 · Cloud Native

Distributed Message Governance and Microservice High‑Availability Practices

The guide details how to build a distributed message‑governance platform for the Hello mobility service, covering unified SDK design, RocketMQ pitfalls, client and cluster health monitoring, risk mitigation, and a tiered microservice high‑availability architecture that uses circuit‑breaking, rate‑limiting, and pre‑heating to ensure resilient traffic handling.

High AvailabilityMessage QueueRocketMQ
0 likes · 14 min read
Distributed Message Governance and Microservice High‑Availability Practices
Full-Stack Internet Architecture
Full-Stack Internet Architecture
May 8, 2021 · Backend Development

Graceful Shutdown of RocketMQ Consumer in Spring Applications

The article recounts a production incident caused by an ungraceful RocketMQ consumer shutdown, analyzes the root cause involving Spring's bean destruction order and ShutdownHook behavior, and presents two solutions—using the official Spring‑Boot starter with SmartLifecycle or handling ContextClosedEvent—to achieve orderly termination.

RocketMQShutdownHookSmartLifecycle
0 likes · 5 min read
Graceful Shutdown of RocketMQ Consumer in Spring Applications
ITPUB
ITPUB
Apr 23, 2021 · Backend Development

How to Set Up a High‑Availability RocketMQ Cluster on Two Servers (2‑Master‑2‑Slave Async)

This guide walks through the complete process of installing RocketMQ 4.8.0, configuring a two‑master‑two‑slave asynchronous high‑availability cluster across two Linux servers, setting up the web console, and troubleshooting common pitfalls such as missing JDK, memory limits, firewall rules, and network address issues.

High AvailabilityLinuxMessage Queue
0 likes · 20 min read
How to Set Up a High‑Availability RocketMQ Cluster on Two Servers (2‑Master‑2‑Slave Async)
vivo Internet Technology
vivo Internet Technology
Apr 21, 2021 · Operations

System Health Check: Principles and Implementation

System health checks, akin to medical exams, are vital for modern IT infrastructure, using active and passive monitoring, failover strategies, and tools like Spring Boot Actuator to detect hardware, network, load, or software issues, prevent single points of failure, and ensure continuous high‑availability service operation.

FailoverHigh AvailabilityMonitoring
0 likes · 12 min read
System Health Check: Principles and Implementation
Code Ape Tech Column
Code Ape Tech Column
Apr 9, 2021 · Backend Development

Comprehensive Comparison of Kafka, RabbitMQ, RocketMQ, and ActiveMQ Across 17 Dimensions

This article provides a detailed side‑by‑side analysis of four major distributed message‑queue systems—Kafka, RabbitMQ, RocketMQ, and ActiveMQ—examining them across seventeen criteria such as documentation, language support, protocols, storage, transactions, load balancing, clustering, management UI, availability, duplication, throughput, subscription models, ordering, acknowledgments, replay, retry, and concurrency.

ActiveMQKafkaMessage Queue
0 likes · 22 min read
Comprehensive Comparison of Kafka, RabbitMQ, RocketMQ, and ActiveMQ Across 17 Dimensions
Alibaba Cloud Native
Alibaba Cloud Native
Apr 6, 2021 · Operations

How to Build a RocketMQ Monitoring System with Prometheus Exporter

This guide explains the design and implementation of RocketMQ‑Exporter, walks through setting up RocketMQ, compiling and running the exporter, configuring Prometheus to scrape its metrics, defining alert rules, and visualizing data with Grafana for a complete DevOps monitoring solution.

Cloud NativeExporterGrafana
0 likes · 15 min read
How to Build a RocketMQ Monitoring System with Prometheus Exporter
High Availability Architecture
High Availability Architecture
Apr 6, 2021 · Backend Development

Ensuring Distributed Transaction Consistency in High‑Concurrency Flash‑Sale Systems with Transactional Messages and RocketMQ

This article explains how to achieve strong consistency for high‑traffic flash‑sale (seckill) scenarios by using distributed transaction principles, flexible transaction models, and Alibaba Cloud RocketMQ transactional messages, providing detailed architectural guidance, implementation steps, code examples, and operational best practices.

MicroservicesRocketMQdistributed transactions
0 likes · 33 min read
Ensuring Distributed Transaction Consistency in High‑Concurrency Flash‑Sale Systems with Transactional Messages and RocketMQ
Alibaba Cloud Native
Alibaba Cloud Native
Apr 3, 2021 · Cloud Native

How RocketMQ Achieved Zero‑Failure Double‑11 with Cloud‑Native Operator and POP Consumption

This article details RocketMQ's 2020 Double‑11 transformation, covering its migration to a Kubernetes‑based operator, a MessageType‑indexed filter optimization that cut CPU usage by up to 32%, and the introduction of a POP consumption model that eliminates rebalance‑induced latency and improves reliability.

Cloud NativeKubernetesMessage Queue
0 likes · 14 min read
How RocketMQ Achieved Zero‑Failure Double‑11 with Cloud‑Native Operator and POP Consumption
Byte Quality Assurance Team
Byte Quality Assurance Team
Mar 31, 2021 · Backend Development

Root Cause Analysis and Optimization of RocketMQ Message Dispatch in the Tesla Interface Testing Platform

The article investigates a performance bottleneck in Tesla's interface testing platform where large test tasks experience up to nine‑minute report delays, identifies the hidden latency in RocketMQ message dispatch to handlers, and proposes a redesign of channel scheduling that reduces execution time to under four minutes.

Channel SchedulingMessage QueueRocketMQ
0 likes · 6 min read
Root Cause Analysis and Optimization of RocketMQ Message Dispatch in the Tesla Interface Testing Platform
High Availability Architecture
High Availability Architecture
Mar 29, 2021 · Backend Development

Design and Implementation of a WebSocket Long‑Connection Gateway for Real‑Time Push

This article presents the design, implementation, and performance evaluation of a Netty‑based WebSocket long‑connection gateway that centralizes session management, decouples business logic, supports horizontal scaling, and provides monitoring and alerting for high‑throughput real‑time data push in iQIYI’s platform.

Distributed ArchitectureGatewayNetty
0 likes · 12 min read
Design and Implementation of a WebSocket Long‑Connection Gateway for Real‑Time Push
dbaplus Community
dbaplus Community
Mar 23, 2021 · Operations

Why RocketMQ Took 10 Minutes to Recover: Deep Dive into a Production Outage

A production RocketMQ cluster suffered a 10‑minute message‑send timeout after a broker’s memory failure caused a server reboot, and the post analyzes the routing registration, name‑server removal logic, client‑side timeout handling, root cause of name‑server “dead‑lock”, and proposes deployment and code‑level fixes to prevent recurrence.

OperationsRocketMQbest-practices
0 likes · 9 min read
Why RocketMQ Took 10 Minutes to Recover: Deep Dive into a Production Outage
Alibaba Cloud Native
Alibaba Cloud Native
Mar 18, 2021 · Backend Development

5 Ways to Integrate Apache RocketMQ into the Spring Ecosystem

This article outlines five Spring-based approaches for using Apache RocketMQ—including Spring Messaging, Spring Cloud Stream, Spring Cloud Bus, Spring Cloud Data Flow, and Spring Cloud Function—detailing each project's features, typical use cases, and how they fit into modern Java microservice architectures.

RocketMQSpringSpring Boot
0 likes · 11 min read
5 Ways to Integrate Apache RocketMQ into the Spring Ecosystem
Alibaba Cloud Developer
Alibaba Cloud Developer
Mar 17, 2021 · Backend Development

5 Ways to Harness RocketMQ in the Spring Ecosystem

This article explores five integration approaches for using Apache RocketMQ within the Spring ecosystem, detailing each project's features, typical use cases, and how they complement Spring Boot, Spring Messaging, and Spring Cloud Stream for building robust, scalable microservices.

MicroservicesRocketMQSpring Boot
0 likes · 12 min read
5 Ways to Harness RocketMQ in the Spring Ecosystem
Big Data Technology & Architecture
Big Data Technology & Architecture
Mar 3, 2021 · Backend Development

Design and Deployment of an Online Messaging System Using RocketMQ at Kuaishou

This article explains why Kuaishou needed a dedicated online messaging system, how RocketMQ was chosen and integrated, the deployment strategies, client SDK design, load‑balancing and disaster‑recovery mechanisms, diverse message features, distributed reconciliation monitoring, and performance‑tuning parameters.

Backend ArchitectureMessaging SystemRocketMQ
0 likes · 15 min read
Design and Deployment of an Online Messaging System Using RocketMQ at Kuaishou
iQIYI Technical Product Team
iQIYI Technical Product Team
Feb 26, 2021 · Backend Development

Design and Implementation of a WebSocket Long‑Connection Gateway for iQIYI Services

iQIYI built a Netty‑based WebSocket long‑connection gateway that centralizes session management, uses RocketMQ for cluster‑wide broadcast, provides a simple HTTP push API, scales horizontally to millions of connections, integrates Prometheus/Grafana monitoring, and dramatically cuts development effort for real‑time features such as comments and authentication.

GatewayNettyPerformance Testing
0 likes · 15 min read
Design and Implementation of a WebSocket Long‑Connection Gateway for iQIYI Services
Architecture Digest
Architecture Digest
Feb 17, 2021 · Operations

Step‑by‑Step Installation and Configuration of a 2‑Master‑2‑Slave Asynchronous RocketMQ Cluster

This article provides a comprehensive guide to installing and configuring Apache RocketMQ, covering its history, core features, high‑availability architectures, detailed port planning, downloading, editing broker configuration files, creating data directories, starting NameServer and brokers, troubleshooting common issues, and deploying the web console for monitoring.

High AvailabilityInstallationMessage Queue
0 likes · 18 min read
Step‑by‑Step Installation and Configuration of a 2‑Master‑2‑Slave Asynchronous RocketMQ Cluster
Top Architect
Top Architect
Feb 16, 2021 · Backend Development

Message Queue Interview Guide: Why Use MQ, Its Pros & Cons, and Comparison of Kafka, ActiveMQ, RabbitMQ, and RocketMQ

This article explains why message queues are used, outlines their advantages and disadvantages, compares Kafka, ActiveMQ, RabbitMQ, and RocketMQ in terms of throughput, latency, reliability and features, and provides interview‑style guidance on high availability, idempotency, data loss prevention, ordering, and scaling strategies.

ActiveMQInterviewMQ
0 likes · 33 min read
Message Queue Interview Guide: Why Use MQ, Its Pros & Cons, and Comparison of Kafka, ActiveMQ, RabbitMQ, and RocketMQ
Architect
Architect
Feb 14, 2021 · Backend Development

Message Idempotency and Exactly‑Once Processing in RocketMQ

This article explains why message middleware like RocketMQ guarantees at‑least‑once delivery, the resulting duplicate‑delivery problem, and presents both transaction‑based and non‑transactional idempotency solutions—including select‑for‑update, optimistic locking, and a Redis‑backed deduplication table—to achieve exactly‑once semantics in distributed systems.

Message IdempotencyRedisRocketMQ
0 likes · 16 min read
Message Idempotency and Exactly‑Once Processing in RocketMQ
Practical DevOps Architecture
Practical DevOps Architecture
Feb 8, 2021 · Backend Development

Comparison of Common Message Queues: ActiveMQ, RocketMQ, and Kafka

This article compares ActiveMQ, RocketMQ, and Kafka across multiple dimensions such as messaging models, API completeness, language support, throughput, latency, availability, message loss risk, documentation, community activity, and commercial backing, helping readers choose the most suitable queue for their backend needs.

ActiveMQComparisonKafka
0 likes · 4 min read
Comparison of Common Message Queues: ActiveMQ, RocketMQ, and Kafka
21CTO
21CTO
Feb 7, 2021 · Backend Development

Why We Chose RocketMQ for Our Online Messaging System and How We Built It

This article explains why the team built a dedicated online messaging system, the scenarios where Kafka fell short, the decision to adopt RocketMQ, deployment strategies, SDK design, load‑balancing, distributed monitoring, and performance tuning tips for a robust backend solution.

Load BalancingMessaging SystemRocketMQ
0 likes · 14 min read
Why We Chose RocketMQ for Our Online Messaging System and How We Built It
Code Ape Tech Column
Code Ape Tech Column
Feb 3, 2021 · Backend Development

Understanding RocketMQ Consumer Mechanisms: Consumption Modes, Idempotent Handling, Load Balancing, and Rebalancing

This article explains RocketMQ consumer fundamentals, covering concurrent and ordered consumption modes, how to achieve idempotent processing with Redis locks, the load‑balancing strategy implemented by RebalanceImpl, and the complete pull‑process‑consume workflow including code examples.

Load BalancingMessage QueueRocketMQ
0 likes · 13 min read
Understanding RocketMQ Consumer Mechanisms: Consumption Modes, Idempotent Handling, Load Balancing, and Rebalancing
Alibaba Cloud Developer
Alibaba Cloud Developer
Feb 1, 2021 · Backend Development

How Does RocketMQ Ensure End-to-End Message Reliability?

This article examines RocketMQ's end‑to‑end reliability mechanisms, covering producer‑side sending strategies, broker storage guarantees, and consumer‑side consumption semantics to show how the system minimizes message loss in distributed environments.

Consumer RetryMessage QueueMessage reliability
0 likes · 11 min read
How Does RocketMQ Ensure End-to-End Message Reliability?
Sohu Tech Products
Sohu Tech Products
Jan 13, 2021 · Operations

Introducing MQCloud: A One‑Stop Service Platform for RocketMQ Monitoring, Management, and Operations

This article explains RocketMQ’s core features, the operational challenges of using its console, and how the MQCloud platform was designed to separate business and admin roles, provide comprehensive monitoring, automated deployment, security hardening, and a customized client, ultimately turning operational pain into a scalable, open‑source solution.

Distributed MessagingMQCloudRocketMQ
0 likes · 15 min read
Introducing MQCloud: A One‑Stop Service Platform for RocketMQ Monitoring, Management, and Operations
Laravel Tech Community
Laravel Tech Community
Jan 3, 2021 · Backend Development

Apache RocketMQ 4.8.0 Released with Major DLedger Performance Improvements

Apache RocketMQ 4.8.0 has been released, featuring extensive optimizations and bug fixes, with significant performance, functionality, and stability enhancements to the Raft‑based DLedger mode, including asynchronous pipeline processing, batch log replication, and various lock and cache improvements that boost throughput by multiple times.

DLedgerRocketMQdistributed systems
0 likes · 4 min read
Apache RocketMQ 4.8.0 Released with Major DLedger Performance Improvements
Alibaba Cloud Native
Alibaba Cloud Native
Dec 16, 2020 · Cloud Native

RocketMQ’s Cloud‑Native Operator: 30% Faster Filtering and POP Consumption

This article details how Alibaba Cloud transformed RocketMQ with a Kubernetes‑based operator, optimized message filtering by indexing MessageType for up to 30% CPU reduction, and introduced a POP consumption model that eliminates rebalance delays, achieving stable performance during the 2020 Double‑11 peak.

Cloud NativeKubernetesMessage Filtering
0 likes · 14 min read
RocketMQ’s Cloud‑Native Operator: 30% Faster Filtering and POP Consumption
New Oriental Technology
New Oriental Technology
Nov 30, 2020 · Backend Development

Five Implementation Approaches for Delayed Messages in Message Queues

This article explains the concept and common use cases of delayed messages and compares five practical implementation methods—using Redis sorted sets, RabbitMQ delayed‑message exchange plugin, ActiveMQ scheduled messages, RocketMQ fixed delay levels, and a custom RocketMQ solution—detailing their workflows, advantages, and drawbacks.

ActiveMQImplementationMessage Queue
0 likes · 19 min read
Five Implementation Approaches for Delayed Messages in Message Queues
Full-Stack Internet Architecture
Full-Stack Internet Architecture
Nov 23, 2020 · Backend Development

Message Middleware: Benefits, Drawbacks, and Design Patterns for Concurrency, Ordering, Duplicate, and Transactional Messaging

This article explains the advantages and disadvantages of using message middleware in microservice architectures and details practical solutions for handling concurrency, ordered processing, duplicate messages, and transactional messaging using patterns like partitioning, outbox tables, CDC, and RocketMQ's two‑phase commit.

KafkaMicroservicesRocketMQ
0 likes · 12 min read
Message Middleware: Benefits, Drawbacks, and Design Patterns for Concurrency, Ordering, Duplicate, and Transactional Messaging
Java Backend Technology
Java Backend Technology
Nov 21, 2020 · Backend Development

Why Your RocketMQ Consumer Stalls: Uncovering the Hidden VIP Port Issue

This article walks through a real‑world RocketMQ failure where a consumer could not receive messages due to an unreachable VIP port, explains the broker’s three‑port architecture, shows how to diagnose the problem via logs, and provides code and configuration fixes to restore normal consumption.

Message QueueRocketMQVIP Port
0 likes · 9 min read
Why Your RocketMQ Consumer Stalls: Uncovering the Hidden VIP Port Issue
Full-Stack Internet Architecture
Full-Stack Internet Architecture
Oct 22, 2020 · Backend Development

Core Concepts and Architecture of RocketMQ

This article introduces RocketMQ’s core concepts, including its deployment architecture, naming server, broker and client roles, subscription model, consumption modes, queue allocation algorithms, rebalancing, offset storage, transaction and delayed messages, as well as filtering mechanisms, providing a solid foundation for further practice.

Message QueueQueue AllocationRocketMQ
0 likes · 13 min read
Core Concepts and Architecture of RocketMQ
21CTO
21CTO
Oct 20, 2020 · Backend Development

How RocketMQ Transformed Cainiao’s Logistics System for Double‑11 Peaks

The article examines the scaling challenges of Cainiao's logistics platform during Alibaba's Double‑11 shopping festivals and explains how adopting RocketMQ for asynchronous decoupling dramatically reduced costs, stabilized the transaction‑logistics chain, and enabled sustainable high‑throughput processing.

AlibabaBackend ArchitectureDistributed Messaging
0 likes · 6 min read
How RocketMQ Transformed Cainiao’s Logistics System for Double‑11 Peaks
Architect
Architect
Oct 17, 2020 · Backend Development

Deep Dive into RocketMQ: History, Architecture, Core Modules, Storage, and Transactional Messaging

This article provides a comprehensive overview of RocketMQ, covering its evolution from early Alibaba messaging engines, the detailed architecture of NameServer, brokers, producers and consumers, the internal source‑code structure, startup process, storage mechanisms, flushing strategies, high‑availability replication, and the implementation of transactional messages.

RocketMQjavatransactional messaging
0 likes · 14 min read
Deep Dive into RocketMQ: History, Architecture, Core Modules, Storage, and Transactional Messaging
Java Architect Essentials
Java Architect Essentials
Oct 8, 2020 · Backend Development

Preventing Message Loss in RocketMQ: Scenarios and Solutions

This article analyzes the possible message loss scenarios in RocketMQ—including producer network issues, broker persistence failures, and consumer acknowledgment problems—and presents practical solutions such as transactional messaging, synchronous disk flushing, and proper consumer handling to achieve zero message loss.

Message QueueRocketMQZero Message Loss
0 likes · 7 min read
Preventing Message Loss in RocketMQ: Scenarios and Solutions
Full-Stack Internet Architecture
Full-Stack Internet Architecture
Sep 19, 2020 · Backend Development

An Introduction to Apache RocketMQ: Concepts, Architecture, Message Types, and Best Practices

This article provides a comprehensive overview of Apache RocketMQ, covering its core concepts, architecture, various message types, reasons for adoption such as asynchronous decoupling and peak‑shaving, as well as best practices and local transaction patterns for reliable distributed messaging.

Message QueueRocketMQTransaction Messaging
0 likes · 17 min read
An Introduction to Apache RocketMQ: Concepts, Architecture, Message Types, and Best Practices
Architecture Digest
Architecture Digest
Sep 17, 2020 · Backend Development

Preventing Message Loss in RocketMQ: Scenarios and Solutions

This article explains the three common scenarios where messages can be lost in RocketMQ, analyzes their root causes, and presents concrete solutions—including transactional messaging, synchronous disk flushing with replication, and proper consumer acknowledgment—to achieve zero‑message loss while noting the performance trade‑offs.

Consumer FailoverMessage QueueRocketMQ
0 likes · 7 min read
Preventing Message Loss in RocketMQ: Scenarios and Solutions
JavaEdge
JavaEdge
Sep 16, 2020 · Backend Development

How RocketMQ Implements Distributed Transactional Messaging

This article explains the design and implementation of RocketMQ transactional messages, covering a complete order‑creation example, the producer’s transaction listener, the broker’s handling of half messages, transaction checks, and the final commit or rollback process.

RocketMQbackend developmentjava
0 likes · 8 min read
How RocketMQ Implements Distributed Transactional Messaging
IT Architects Alliance
IT Architects Alliance
Sep 1, 2020 · Operations

How to Build a High‑Availability RocketMQ Cluster on Two Servers

This guide walks through the complete process of setting up a fault‑tolerant RocketMQ cluster on two Linux servers, covering environment preparation, Java installation, NameServer and Broker deployment, configuration of master‑slave modes, startup commands, troubleshooting, port opening, verification, and optional console installation.

ClusterHigh AvailabilityInstallation
0 likes · 22 min read
How to Build a High‑Availability RocketMQ Cluster on Two Servers