BestHub
Sign in
Tagged articles

RocketMQ

571 articles · Page 3 of 6
Sanyou's Java Diary
Sanyou's Java Diary
Apr 1, 2024 · Backend Development

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

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

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

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

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

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

RocketMQ Multi-Version Environment Isolation Practice in Test Environments

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

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

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

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

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

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

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

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

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

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

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

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

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

Data synchronizationElasticsearchRocketMQ
0 likes · 16 min read
How to Build a Scalable Billion‑Item Elasticsearch Search System from Scratch
LouZai
LouZai
Mar 14, 2024 · Backend Development

N Practical Strategies to Auto‑Cancel Timed‑Out Orders

This article analyzes multiple engineering solutions for automatically cancelling orders after the payment timeout, covering single‑machine and cluster scheduled‑task designs (Quartz, ElasticJob, XXL‑JOB), delayed‑message techniques (RocketMQ, custom delay service, Redis), and essential concurrency and monitoring best practices.

ElasticJobQuartzRedis
0 likes · 13 min read
N Practical Strategies to Auto‑Cancel Timed‑Out Orders
Tencent Cloud Middleware
Tencent Cloud Middleware
Mar 13, 2024 · Cloud Native

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

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

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

Why Is RocketMQ So Fast? 10 Core Techniques Explained

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

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

Why RocketMQ Is So Fast: 10 Core Performance Techniques Explained

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

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

How to Install and Deploy Apache RocketMQ 5.1.4 on Ubuntu

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

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

Mastering CompletableFuture: From Basics to RocketMQ Integration

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

Asynchronous ProgrammingCompletableFutureFuture
0 likes · 15 min read
Mastering CompletableFuture: From Basics to RocketMQ Integration
Sanyou's Java Diary
Sanyou's Java Diary
Feb 1, 2024 · Backend Development

Message Queues Unveiled: From Decoupling to Platformization and Core Architectures

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

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

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

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

RocketMQStreamTree Structure
0 likes · 11 min read
Assembling Hierarchical Tree Structures with Java Streams, Caching and Message Queues
Mike Chen's Internet Architecture
Mike Chen's Internet Architecture
Jan 17, 2024 · Backend Development

Mastering Message Middleware: From Basics to Choosing the Right Solution

This article explains what message middleware is, outlines its key use cases such as asynchronous communication and decoupling, details core principles and models like point‑to‑point and publish/subscribe, reviews popular solutions (Kafka, RabbitMQ, RocketMQ, Pulsar, etc.), and offers selection guidance.

KafkaMessage MiddlewareRocketMQ
0 likes · 8 min read
Mastering Message Middleware: From Basics to Choosing the Right Solution
Java High-Performance Architecture
Java High-Performance Architecture
Jan 7, 2024 · Backend Development

Why Use RocketMQ with Spring Boot? A Complete Integration Guide

This article explains why MQ is needed beyond in‑process event listeners, details the required dependencies for Spring Boot 3, shows how to configure RocketMQ, provides code snippets for producer, consumer, and testing, and offers practical tips for handling async, batch, and one‑way messaging.

Message QueueMicroservicesRocketMQ
0 likes · 9 min read
Why Use RocketMQ with Spring Boot? A Complete Integration Guide
MaGe Linux Operations
MaGe Linux Operations
Dec 29, 2023 · Backend Development

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

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

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

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

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

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

How to Diagnose and Resolve RocketMQ Message Accumulation Issues

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

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

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

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

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

How RocketMQ Implements Random Indexing for Cloud‑Native Storage

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

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

Understanding Transactional Messages in Distributed Systems: RocketMQ and Kafka

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

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

Why RocketMQ Producers Need Load Balancing and How It Works

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

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

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

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

ActiveMQRocketMQrabbitmq
0 likes · 42 min read
Message Queues: Concepts, Patterns, Evaluation Criteria, and Comparison of RabbitMQ, Kafka, RocketMQ, and ActiveMQ
Architect
Architect
Nov 2, 2023 · Backend Development

Understanding RocketMQ Consumer Scaling and MessageQueue Allocation Strategies

This article explains when adding consumers to a RocketMQ topic improves message consumption, the reasons for consumer pull delays, and details six MessageQueue allocation strategies—including average, round‑robin, custom, machine‑room, nearby, and consistent‑hash—accompanied by code examples.

Load BalancingMessageQueueRocketMQ
0 likes · 11 min read
Understanding RocketMQ Consumer Scaling and MessageQueue Allocation Strategies
Mike Chen's Internet Architecture
Mike Chen's Internet Architecture
Oct 19, 2023 · Backend Development

Understanding RocketMQ Core Architecture and Its Role in High‑Concurrency Systems

This article explains the core components of RocketMQ—including NameServer, Broker, Producer, and Consumer—detailing their functions, deployment diagrams, and how the middleware supports high‑concurrency scenarios such as peak shaving, asynchronous messaging, fault tolerance, and system decoupling.

Backend ArchitectureMessage QueueRocketMQ
0 likes · 7 min read
Understanding RocketMQ Core Architecture and Its Role in High‑Concurrency Systems
Architecture & Thinking
Architecture & Thinking
Oct 19, 2023 · Backend Development

Mastering RocketMQ Message Filtering: Tags, SQL92, and Best Practices

This article explains how Apache RocketMQ performs server‑side message filtering using Tag and SQL92 expressions, outlines the workflow for producers and consumers, compares the two methods, and provides Java code examples for implementing both simple tag filtering and advanced SQL‑based attribute filtering.

Message FilteringRocketMQSQL92
0 likes · 10 min read
Mastering RocketMQ Message Filtering: Tags, SQL92, and Best Practices
Alibaba Cloud Native
Alibaba Cloud Native
Oct 18, 2023 · Operations

How to Load Test RocketMQ with JMeter on Alibaba Cloud PTS

This guide walks you through using Alibaba Cloud PTS and JMeter 5.5 to create a custom JavaSampler for RocketMQ 5.0, package the sampler into a JAR, configure a PTS JMeter environment, run an RPS‑mode load test, and analyze the detailed performance report.

Alibaba Cloud PTSJMeterJavaSampler
0 likes · 16 min read
How to Load Test RocketMQ with JMeter on Alibaba Cloud PTS
Architecture & Thinking
Architecture & Thinking
Oct 17, 2023 · Backend Development

Boost Throughput with RocketMQ Batch Messaging: How and Why

This article explains why batch messaging in RocketMQ is crucial for high-throughput systems, outlines its characteristics and ideal scenarios, and provides complete Java code examples for sending and splitting large batches to improve performance and reduce downstream API calls.

Batch MessagingMessage QueueRocketMQ
0 likes · 7 min read
Boost Throughput with RocketMQ Batch Messaging: How and Why
Architect
Architect
Oct 13, 2023 · Backend Development

How to Implement Gray Release with RocketMQ: Step‑by‑Step Strategies

This article explains how to apply gray release techniques in RocketMQ by upgrading consumers, upgrading producers, and using consumer‑side filtering, tag filtering, and SQL92 filtering, providing concrete code examples, configuration steps, and trade‑off analysis for each approach.

Consumer FilteringMessage QueueRocketMQ
0 likes · 8 min read
How to Implement Gray Release with RocketMQ: Step‑by‑Step Strategies
Wukong Talks Architecture
Wukong Talks Architecture
Oct 13, 2023 · Backend Development

7 Common Message Queue Scenarios and Their Implementations

This article explains seven typical message‑queue use cases—including ordinary, ordered, delayed, transactional, trace, dead‑letter, and priority messages—detailing their business motivations, implementation challenges, and concrete code examples for Kafka, RocketMQ, Pulsar, and RabbitMQ.

KafkaMessage QueueRocketMQ
0 likes · 11 min read
7 Common Message Queue Scenarios and Their Implementations
Practical DevOps Architecture
Practical DevOps Architecture
Oct 8, 2023 · Backend Development

Comprehensive RocketMQ Course: Source Code Deep Dive, Advanced Features, Performance Tuning, and Real‑World Projects

This course provides an in‑depth study of RocketMQ, covering its fundamentals, source‑code analysis, advanced features such as transactional and ordered messages, performance optimization, operational monitoring, and hands‑on projects that guide learners through installation, configuration, clustering, and integration with Spring Boot.

Message QueuePractical projectsRocketMQ
0 likes · 4 min read
Comprehensive RocketMQ Course: Source Code Deep Dive, Advanced Features, Performance Tuning, and Real‑World Projects
Su San Talks Tech
Su San Talks Tech
Oct 8, 2023 · Backend Development

Unlocking RocketMQ: How Scheduled Tasks Keep Your Messaging System Healthy

This article examines the numerous scheduled tasks in RocketMQ—covering architecture, producer and consumer maintenance, broker housekeeping, and NameServer management—to reveal how periodic jobs ensure reliable message handling, performance monitoring, and system self‑protection.

RocketMQScheduled Tasksbackend development
0 likes · 26 min read
Unlocking RocketMQ: How Scheduled Tasks Keep Your Messaging System Healthy
Architect
Architect
Oct 3, 2023 · Backend Development

Understanding RocketMQ Scheduled Tasks and Their Implementation

This article explains the various scheduled tasks in RocketMQ, covering architecture overview, producer and consumer periodic operations, broker maintenance jobs, and NameServer housekeeping, while providing concrete Java code examples to illustrate how each task contributes to message handling, monitoring, and system reliability.

RocketMQScheduled Tasksbackend
0 likes · 25 min read
Understanding RocketMQ Scheduled Tasks and Their Implementation
dbaplus Community
dbaplus Community
Sep 24, 2023 · Backend Development

How to Sync MySQL Binlog to Elasticsearch Using Canal and RocketMQ

Learn step‑by‑step how to configure Alibaba’s open‑source Canal to capture MySQL binlog changes, route them through RocketMQ, and index the data into Elasticsearch, covering cluster mode, MySQL and Elasticsearch setup, Canal properties, and consumer implementation details.

CDCCanalMySQL
0 likes · 9 min read
How to Sync MySQL Binlog to Elasticsearch Using Canal and RocketMQ
ShiZhen AI
ShiZhen AI
Sep 19, 2023 · Backend Development

How RocketMQ Handles Concurrent and Ordered Message Consumption

This article explains RocketMQ's internal workflow for concurrent and ordered message consumption, covering thread‑pool configuration, pull‑message handling, request submission, execution steps, offset management, expired‑message cleanup, and answers common questions about batch retries and offset ordering.

Concurrent ConsumptionConsumeRequestMessage Queue
0 likes · 13 min read
How RocketMQ Handles Concurrent and Ordered Message Consumption
Su San Talks Tech
Su San Talks Tech
Sep 17, 2023 · Backend Development

Mastering CompletableFuture: From Basics to RocketMQ Integration

Explore how Java's CompletableFuture enhances asynchronous programming by overcoming Future's limitations, learn its core APIs, practical code examples, and see a real-world application in RocketMQ where combined futures streamline message persistence and replication.

Asynchronous ProgrammingCompletableFutureRocketMQ
0 likes · 15 min read
Mastering CompletableFuture: From Basics to RocketMQ Integration
Architect
Architect
Sep 14, 2023 · Backend Development

Message Queue Evolution, Architecture, and Storage Analysis

From the early days of ActiveMQ and RabbitMQ to the high‑throughput designs of Kafka, RocketMQ, and Pulsar, this article traces the development stages of message queues, explains core concepts such as topics, producers, consumers, and partitions, and compares their architectural and storage designs.

RocketMQbackendpulsar
0 likes · 16 min read
Message Queue Evolution, Architecture, and Storage Analysis
Su San Talks Tech
Su San Talks Tech
Sep 9, 2023 · Backend Development

How to Sync MySQL Binlog to Elasticsearch Using Canal and RocketMQ

This step‑by‑step tutorial shows how to configure Alibaba's Canal to capture MySQL binlog changes, route them through RocketMQ, and index the data into Elasticsearch, covering cluster mode, MySQL and Elasticsearch setup, RocketMQ topic creation, Canal properties, and consumer implementation.

CanalData synchronizationElasticsearch
0 likes · 8 min read
How to Sync MySQL Binlog to Elasticsearch Using Canal and RocketMQ
Mike Chen's Internet Architecture
Mike Chen's Internet Architecture
Sep 7, 2023 · Backend Development

Comprehensive Overview of Message Queues: Types, Core Concepts, and Comparison of Kafka, RocketMQ, and RabbitMQ

This article provides a detailed overview of popular message queue systems, explains their core concepts such as decoupling and eventual consistency, and compares the advantages and disadvantages of Kafka, RocketMQ, RabbitMQ, and other notable MQ solutions for high‑concurrency scenarios.

Backend ArchitectureKafkaMessage Queue
0 likes · 7 min read
Comprehensive Overview of Message Queues: Types, Core Concepts, and Comparison of Kafka, RocketMQ, and RabbitMQ
Spring Full-Stack Practical Cases
Spring Full-Stack Practical Cases
Sep 4, 2023 · Backend Development

Mastering RocketMQ with Spring Boot: From Simple to Transactional Messaging

This guide demonstrates how to integrate RocketMQ 4.8.0 into a Spring Boot 2.4.12 application, covering dependency setup, configuration, sending and receiving normal, ordered, cluster/broadcast, and transactional messages, complete with code snippets and execution results to help developers implement reliable messaging patterns.

BroadcastClusterRocketMQ
0 likes · 9 min read
Mastering RocketMQ with Spring Boot: From Simple to Transactional Messaging
Alibaba Cloud Native
Alibaba Cloud Native
Aug 25, 2023 · Cloud Native

How RocketMQ Guarantees Consistency with Transactions, Ordering, SQL Filters, and Delayed Messages

This article explains RocketMQ's advanced features—transactional messaging, ordered messaging, SQL‑based filtering, delayed messaging, and global high‑availability—detailing their principles, implementation steps, practical demos, and how they solve consistency challenges in large‑scale e‑commerce systems.

Ordered MessagingRocketMQSQL filtering
0 likes · 14 min read
How RocketMQ Guarantees Consistency with Transactions, Ordering, SQL Filters, and Delayed Messages
Sanyou's Java Diary
Sanyou's Java Diary
Aug 17, 2023 · Backend Development

How RocketMQ Achieves High Availability with Master‑Slave Replication

This article explains RocketMQ's master‑slave replication mechanism, comparing synchronous and asynchronous modes, detailing metadata and message data copying processes, and showing how synchronous guarantees are implemented using CompletableFuture to ensure high availability.

Asynchronous ReplicationRocketMQbackend messaging
0 likes · 9 min read
How RocketMQ Achieves High Availability with Master‑Slave Replication
Su San Talks Tech
Su San Talks Tech
Jul 21, 2023 · Backend Development

Mastering RocketMQ Transaction Messages: Theory, Flow, and Real‑World Example

This article explains RocketMQ transaction messages by covering their use cases, underlying mechanisms, and a step‑by‑step implementation that demonstrates how to ensure eventual consistency between message production and local database transactions in distributed Java back‑end systems.

Message QueueRocketMQTransaction Messages
0 likes · 8 min read
Mastering RocketMQ Transaction Messages: Theory, Flow, and Real‑World Example
Sohu Tech Products
Sohu Tech Products
Jul 19, 2023 · Backend Development

Understanding RocketMQ Consumption Logic in Version 4.9.x

This article provides a comprehensive walkthrough of RocketMQ 4.9.x consumption architecture, covering the four core roles, publish‑subscribe model, storage structures, load‑balancing, long‑polling, concurrent and ordered consumption flows, progress persistence, and retry mechanisms, with illustrative diagrams and code snippets.

Load BalancingMessage QueueRocketMQ
0 likes · 28 min read
Understanding RocketMQ Consumption Logic in Version 4.9.x
Su San Talks Tech
Su San Talks Tech
Jul 18, 2023 · Backend Development

Why Did My RocketMQ Consumer Stumble? The Hidden ClientId Bug in Docker Host Mode

After a massive message backlog in RocketMQ, the author discovered that identical clientIds generated by Docker containers using host network mode caused broker load‑balancing errors, leading to slow consumption; the article explains the root cause, code analysis, and how setting a unique clientId resolves the issue.

ClientIdDockerLoad Balancing
0 likes · 19 min read
Why Did My RocketMQ Consumer Stumble? The Hidden ClientId Bug in Docker Host Mode
21CTO
21CTO
Jul 15, 2023 · Backend Development

From ActiveMQ to Pulsar: The Evolution of Message Queues Explained

This article traces the development of message queues from early decoupling solutions like ActiveMQ and RabbitMQ, through high‑throughput designs such as Kafka and RocketMQ, to modern platform‑centric systems like Pulsar, while detailing core concepts, architecture diagrams, storage mechanisms and trade‑offs.

KafkaMessage QueueRocketMQ
0 likes · 15 min read
From ActiveMQ to Pulsar: The Evolution of Message Queues Explained
Tencent Cloud Developer
Tencent Cloud Developer
Jul 12, 2023 · Backend Development

Evolution and Architecture of Message Queues: Kafka, RocketMQ, and Pulsar

The article traces two decades of message‑queue evolution—from early decoupling tools like ActiveMQ, through Kafka’s high‑throughput log model, to Pulsar’s layered, cloud‑native architecture—explaining core concepts, storage designs, and trade‑offs that guide choosing the right MQ for modern workloads.

KafkaRocketMQpulsar
0 likes · 16 min read
Evolution and Architecture of Message Queues: Kafka, RocketMQ, and Pulsar
Code Ape Tech Column
Code Ape Tech Column
Jul 6, 2023 · Backend Development

How to Effectively Read Open‑Source Java Project Source Code

This guide explains why and how to read open‑source Java code, covering essential JDK knowledge, design patterns, official documentation, module structure, demo‑first approaches, purposeful reading strategies, class‑name clues, class hierarchy analysis, commenting practices, and leveraging related resources.

Design PatternsRocketMQbackend development
0 likes · 13 min read
How to Effectively Read Open‑Source Java Project Source Code
政采云技术
政采云技术
Jun 29, 2023 · Backend Development

Understanding RocketMQ: Architecture, Modules, and Deployment Essentials

This article provides a comprehensive overview of RocketMQ, covering its origin, core concepts, component roles, cluster deployment architecture, workflow, feature details, persistence mechanisms, and cleanup policies, offering developers a solid foundation for using this high‑performance messaging middleware.

Message QueueMiddlewareRocketMQ
0 likes · 18 min read
Understanding RocketMQ: Architecture, Modules, and Deployment Essentials
Alibaba Cloud Native
Alibaba Cloud Native
Jun 26, 2023 · Cloud Native

How RocketMQ Evolved Its High‑Availability Architecture for Cloud‑Native Deployments

This article examines RocketMQ's high‑availability evolution—from early master‑slave and Raft‑based designs to the v5 DLedger fusion model—detailing replica groups, data sharding, election mechanisms, replication strategies, metric trade‑offs, log‑divergence handling, controller roles, heartbeat optimizations, and comparisons with Kafka and Pulsar, all illustrated with diagrams and code snippets.

Cloud NativeDLedgerHigh Availability
0 likes · 36 min read
How RocketMQ Evolved Its High‑Availability Architecture for Cloud‑Native Deployments
Sanyou's Java Diary
Sanyou's Java Diary
Jun 12, 2023 · Backend Development

Master RocketMQ 4.9.x Consumption: Architecture, Load Balancing, and Retry Strategies

This article walks through RocketMQ 4.9.x’s consumption architecture, explaining the roles of NameServer, Broker, Producer and Consumer, the publish‑subscribe model, storage structures, load‑balancing algorithms, long‑polling, concurrent and ordered consumption, progress persistence, and the built‑in retry mechanism.

Load BalancingMessage QueueRetry Mechanism
0 likes · 28 min read
Master RocketMQ 4.9.x Consumption: Architecture, Load Balancing, and Retry Strategies
Architect's Guide
Architect's Guide
Jun 12, 2023 · Backend Development

Design and Implementation of a Payment Center System: Flow, Challenges, and Design Patterns

This article explains the architecture of a payment center that unifies internal payment services and external third‑party integrations, details the three‑step payment flow, discusses common issues such as order timeout and result reliability, and demonstrates how template‑method and strategy patterns together with RocketMQ delay queues solve these problems in a SpringBoot backend.

RocketMQdesign-patternspayment
0 likes · 15 min read
Design and Implementation of a Payment Center System: Flow, Challenges, and Design Patterns
Code Ape Tech Column
Code Ape Tech Column
Jun 8, 2023 · Backend Development

RocketMQ Consumer Scaling and MessageQueue Allocation Strategies Explained

The article explains when adding consumers can reduce RocketMQ backlog, the reasons for delayed message pulling, handling slow external services, and details six different MessageQueue allocation strategies—including average, round‑robin, custom, machine‑room, nearby, and consistent‑hash—accompanied by Java code examples.

Load BalancingMessageQueueRocketMQ
0 likes · 10 min read
RocketMQ Consumer Scaling and MessageQueue Allocation Strategies Explained
Wukong Talks Architecture
Wukong Talks Architecture
Apr 15, 2023 · Backend Development

Design and Implementation of RocketMQ Tiered Storage

The article explains how RocketMQ 5.1.0 introduces a tiered storage module that offloads messages to cheaper media, describes its design, architecture layers, quick‑start configuration, upload and read mechanisms, prefetch cache, fault recovery, current development plans, and remaining challenges.

Message QueueRocketMQTiered Storage
0 likes · 13 min read
Design and Implementation of RocketMQ Tiered Storage
Tencent Cloud Middleware
Tencent Cloud Middleware
Apr 13, 2023 · Fundamentals

RocketMQ, Kafka, Pulsar: Core Concepts, Architecture & Transactional Messaging

This article provides a comprehensive overview of major message‑queue middleware—including RocketMQ, Kafka, Pulsar, and RabbitMQ—covering fundamental concepts such as tags, groups, offsets, architectural components, storage mechanisms, transaction workflows, rebalance strategies, and recent developments, while comparing their features and performance characteristics.

KafkaMessage QueueMiddleware
0 likes · 19 min read
RocketMQ, Kafka, Pulsar: Core Concepts, Architecture & Transactional Messaging
Code Ape Tech Column
Code Ape Tech Column
Apr 11, 2023 · Backend Development

Comprehensive Comparison of Kafka, RabbitMQ, ZeroMQ, RocketMQ, and ActiveMQ

This article provides a detailed side‑by‑side comparison of five popular message‑queue systems—Kafka, RabbitMQ, ZeroMQ, RocketMQ, and ActiveMQ—covering documentation, programming languages, supported protocols, storage, transactions, load balancing, clustering, management UI, availability, duplication handling, throughput, subscription models, ordering, acknowledgments, replay, retry, concurrency, and includes promotional information from the author.

ActiveMQComparisonKafka
0 likes · 24 min read
Comprehensive Comparison of Kafka, RabbitMQ, ZeroMQ, RocketMQ, and ActiveMQ
Sanyou's Java Diary
Sanyou's Java Diary
Apr 3, 2023 · Backend Development

How RocketMQ’s Storage Model Powers Fast Message Retrieval

This article breaks down RocketMQ’s storage architecture, explaining how its commitlog, consumequeue, and index files work together to ensure reliable persistence, quick offset-based lookups, and efficient message consumption in a publish‑subscribe model.

CommitLogConsumeQueueIndexFile
0 likes · 9 min read
How RocketMQ’s Storage Model Powers Fast Message Retrieval
JD Retail Technology
JD Retail Technology
Apr 3, 2023 · Fundamentals

How to Master Clean Code: From Learning to Refactoring with Real Examples

This article explores a systematic approach to becoming a better programmer, covering learning mindset, selecting role models, applying knowledge, coding principles, performance considerations, and refactoring techniques, illustrated with a RocketMQ file‑prewarm case study and practical guidelines for writing maintainable, high‑quality code.

LearningRocketMQSoftware Engineering
0 likes · 17 min read
How to Master Clean Code: From Learning to Refactoring with Real Examples
Alibaba Cloud Native
Alibaba Cloud Native
Mar 28, 2023 · Cloud Native

How RocketMQ 5.0 Enables Distributed End‑to‑End Tracing with OpenTelemetry

This article explains how Apache RocketMQ 5.0 integrates standardized distributed tracing via OpenTelemetry, detailing the underlying span model, semantic conventions for messaging, automatic and manual instrumentation options, configuration steps, a complete example workflow, and how to export traces to Alibaba Cloud SLS and ARMS for observability.

Cloud NativeRocketMQdistributed tracing
0 likes · 17 min read
How RocketMQ 5.0 Enables Distributed End‑to‑End Tracing with OpenTelemetry
Su San Talks Tech
Su San Talks Tech
Mar 22, 2023 · Backend Development

Why Does RocketMQ Duplicate Message Consumption? Root Causes Explained

This article examines the various reasons why RocketMQ can deliver the same message to consumers multiple times, covering send‑retry mechanisms, consumer‑side exceptions, offset commit and persistence failures, master‑slave synchronization issues, rebalance events, and long‑processing cleanup, and offers guidance on designing idempotent solutions.

Message QueueOffset ManagementRetry Mechanism
0 likes · 15 min read
Why Does RocketMQ Duplicate Message Consumption? Root Causes Explained
Programmer DD
Programmer DD
Mar 17, 2023 · Backend Development

Master RocketMQ: Transaction, Ordered, Filtered & Delayed Messaging in Java & Spring

This tutorial walks through practical implementations of RocketMQ transaction, ordered, filtered, and delayed messages using native Java code and Spring Boot, explaining the underlying concepts, showing complete code examples, and highlighting how to configure producers, consumers, and listeners for reliable distributed messaging.

Delayed MessagingMessage FilteringOrdered Messaging
0 likes · 16 min read
Master RocketMQ: Transaction, Ordered, Filtered & Delayed Messaging in Java & Spring
Code Ape Tech Column
Code Ape Tech Column
Mar 6, 2023 · Backend Development

Thread Creation Techniques in RocketMQ Source Code

This article explains how RocketMQ creates and manages threads, covering single‑thread creation via Runnable and Thread inheritance, the ServiceThread abstract class, ThreadPoolExecutor configuration, custom thread factories, and the importance of descriptive thread names for debugging.

RocketMQThreadPoolbackend
0 likes · 9 min read
Thread Creation Techniques in RocketMQ Source Code
Su San Talks Tech
Su San Talks Tech
Feb 15, 2023 · Backend Development

Master Open‑Source Code Reading: 18 Proven Strategies for Java Developers

This guide explains why reading open‑source code matters—from interview prep to design mastery—and offers 18 practical steps, including mastering the JDK, understanding design patterns, using official docs, exploring module structures, starting with demos, and adopting purposeful, efficient reading habits.

RocketMQSoftware Engineeringjava
0 likes · 14 min read
Master Open‑Source Code Reading: 18 Proven Strategies for Java Developers
ITPUB
ITPUB
Feb 12, 2023 · Backend Development

Uncovering RocketMQ Sync Lag: Why Messages Reach the Broker but Not the Consumer

A detailed investigation reveals that RocketMQ can report successful writes to the broker while consumers see minutes‑long delays because the transient store pool and commit‑log forwarding mechanisms delay the transfer of messages from the broker’s memory to the consumer queue.

Lag DiagnosisMessage QueueRocketMQ
0 likes · 10 min read
Uncovering RocketMQ Sync Lag: Why Messages Reach the Broker but Not the Consumer
Sanyou's Java Diary
Sanyou's Java Diary
Feb 6, 2023 · Backend Development

Master Reading Open‑Source Code: 18 Proven Strategies for Java Projects

This guide explains why reading source code matters and presents 18 practical techniques—covering JDK fundamentals, design patterns, official documentation, module analysis, demo‑first approach, purposeful reading, and effective note‑taking—to help developers confidently explore Java open‑source projects like RocketMQ.

Design PatternsRocketMQbackend
0 likes · 15 min read
Master Reading Open‑Source Code: 18 Proven Strategies for Java Projects
Architect
Architect
Feb 4, 2023 · Backend Development

Understanding the Consumer Startup Process in RocketMQ (Pull Mode)

This article explains RocketMQ's consumer startup process in pull mode, detailing the underlying push‑like implementation, configuration validation, instance naming, client initialization, load‑balancing, wrapper handling, offset storage, scheduled tasks, and trace dispatching, accompanied by Java code examples.

Message QueuePull ModeRocketMQ
0 likes · 11 min read
Understanding the Consumer Startup Process in RocketMQ (Pull Mode)
Sohu Tech Products
Sohu Tech Products
Jan 25, 2023 · Backend Development

Standardizing and Automating the Review Middleware: Protocols, Processes, and Implementation

This article describes how a review middle‑platform for a video service standardizes communication protocols with RocketMQ, defines unified data processing flows, and implements an automated business‑access detector with Java code to reduce duplication and improve development efficiency.

Backend ArchitectureRocketMQreview platform
0 likes · 15 min read
Standardizing and Automating the Review Middleware: Protocols, Processes, and Implementation
Xianyu Technology
Xianyu Technology
Jan 18, 2023 · Backend Development

Java Ternary Operator NPE, Message Storm, and Network Latency Cases

The article uses a safety‑principle analogy to introduce three real‑world backend incidents—a Java ternary‑operator NullPointerException caused by unintended unboxing, a RocketMQ message‑storm triggered by swapped parameters, and a network‑path latency spike—showing how language semantics, messaging contracts, and infrastructure topology each can create production bugs.

DistributedSystemsNPENetworkLatency
0 likes · 10 min read
Java Ternary Operator NPE, Message Storm, and Network Latency Cases
vivo Internet Technology
vivo Internet Technology
Jan 11, 2023 · Cloud Native

Practices of Distributed Message Middleware at vivo: From RocketMQ to Kafka and Pulsar

vivo’s Internet Storage team details how it operates RocketMQ for low‑latency online services and Kafka for massive big‑data pipelines, outlines resource isolation, traffic balancing, intelligent throttling, and governance practices, and describes its migration from RabbitMQ and planned shift from Kafka to cloud‑native Pulsar.

Big DataCloud NativeKafka
0 likes · 22 min read
Practices of Distributed Message Middleware at vivo: From RocketMQ to Kafka and Pulsar
Sanyou's Java Diary
Sanyou's Java Diary
Jan 9, 2023 · Backend Development

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

This article walks through every stage of a RocketMQ message—how producers create and route messages, the storage mechanisms and zero‑copy techniques used by brokers, high‑availability modes, consumption models, ordering guarantees, and the automatic cleanup policies that finally retire messages.

High AvailabilityMessage QueueRocketMQ
0 likes · 26 min read
Unveiling the Full Lifecycle of a RocketMQ Message: From Production to Deletion
Architecture & Thinking
Architecture & Thinking
Dec 28, 2022 · Backend Development

Ensuring Idempotency in Message Queues: Strategies for Reliable Messaging

This article explains the concept of idempotency, illustrates why repeated operations must yield identical results, and details how RocketMQ’s components—NameServer, Broker, Producer, and Consumer—can be designed with unique message IDs and acknowledgment mechanisms to achieve reliable, duplicate‑free messaging in backend systems.

IdempotencyMessage QueueRocketMQ
0 likes · 10 min read
Ensuring Idempotency in Message Queues: Strategies for Reliable Messaging
Alibaba Cloud Native
Alibaba Cloud Native
Dec 27, 2022 · Cloud Native

Contribute to Apache RocketMQ 5.0 SDK: New Cloud‑Native Features & How‑to Guide

Apache RocketMQ 5.0 introduces a stateless proxy, gRPC‑based multi‑language SDK with immutable APIs, enhanced error handling, SimpleConsumer, and pop consumption, and the article outlines the technical improvements, roadmap, and step‑by‑step guide for developers to set up the environment, understand the new protocols, and contribute language client implementations.

Cloud NativeMessage QueueOpen Source
0 likes · 8 min read
Contribute to Apache RocketMQ 5.0 SDK: New Cloud‑Native Features & How‑to Guide
Code Ape Tech Column
Code Ape Tech Column
Dec 20, 2022 · Backend Development

Building a High‑Availability RocketMQ Cluster (Version 4.9.4)

This tutorial explains why message queues are essential, compares popular MQ products, details RocketMQ's core components, and provides step‑by‑step instructions—including environment setup, broker configuration, firewall rules, and monitoring—to deploy a fault‑tolerant RocketMQ cluster on CentOS 7.

ClusterMessage QueueMiddleware
0 likes · 23 min read
Building a High‑Availability RocketMQ Cluster (Version 4.9.4)
Laravel Tech Community
Laravel Tech Community
Dec 19, 2022 · Cloud Native

Understanding RocketMQ Load Balancing Mechanism and Best Practices

This article explains RocketMQ's load balancing process, including when rebalancing occurs, the impact on message consumption, common strategies such as average allocation and consistent hashing, and practical recommendations like minimizing client churn and choosing appropriate strategies for cloud‑native deployments.

Message QueueRocketMQbest practices
0 likes · 8 min read
Understanding RocketMQ Load Balancing Mechanism and Best Practices
Top Architect
Top Architect
Nov 26, 2022 · Backend Development

Comprehensive Overview of RabbitMQ, RocketMQ, and Kafka: Architecture, Features, and Best Practices

This article provides an in-depth comparison of RabbitMQ, RocketMQ, and Kafka, detailing their core components, exchange types, message durability, acknowledgment mechanisms, TTL, dead‑letter queues, load balancing, ordering, transaction handling, high‑availability configurations, and practical solutions for common messaging challenges.

KafkaRocketMQdistributed systems
0 likes · 33 min read
Comprehensive Overview of RabbitMQ, RocketMQ, and Kafka: Architecture, Features, and Best Practices
Top Architect
Top Architect
Nov 25, 2022 · Backend Development

Comprehensive Guide to RocketMQ Message Types, Production, and Consumption

This article provides an in‑depth tutorial on RocketMQ, covering normal, ordered, delayed, transactional, and batch messages, their production and consumption patterns, retry mechanisms, message filtering, and dead‑letter handling, complete with Java code examples for each scenario.

Message FilteringRocketMQbackend development
0 likes · 36 min read
Comprehensive Guide to RocketMQ Message Types, Production, and Consumption