Tagged articles

Message Queue

1036 articles · Page 2 of 11
FunTester
FunTester
Dec 21, 2025 · Backend Development

Why River Is the Go‑Friendly Queue That Guarantees Transactional Consistency

This article explains how the River library leverages PostgreSQL to provide a Go‑native job queue with true transactional guarantees, high concurrency via goroutines, and efficient scheduling using SKIP LOCKED, while offering step‑by‑step setup and code examples for rapid adoption.

ConcurrencyGoMessage Queue
0 likes · 15 min read
Why River Is the Go‑Friendly Queue That Guarantees Transactional Consistency
Ray's Galactic Tech
Ray's Galactic Tech
Dec 16, 2025 · Backend Development

Mastering RocketMQ 4.x Producer SDK: Configuration, Mechanics, and Best Practices

An in‑depth guide to Apache RocketMQ 4.x producer SDK covers essential and optional configurations, internal startup and sending workflows, transaction and ordered messaging, failure handling, performance tuning, monitoring, and practical code examples to help you build a reliable, high‑throughput messaging system.

Message QueueMonitoringProducer SDK
0 likes · 10 min read
Mastering RocketMQ 4.x Producer SDK: Configuration, Mechanics, and Best Practices
Ray's Galactic Tech
Ray's Galactic Tech
Nov 23, 2025 · Backend Development

Three Proven Spring Boot Strategies to Auto‑Cancel Orders After 30 Minutes

This guide walks you through three practical Spring Boot solutions—database scheduled scans, message‑queue delayed queues, and Redis key‑expiration notifications—to automatically cancel unpaid orders after 30 minutes, complete with code samples, architecture diagrams, pros and cons, and best‑practice recommendations.

BackendJavaMessage Queue
0 likes · 10 min read
Three Proven Spring Boot Strategies to Auto‑Cancel Orders After 30 Minutes
dbaplus Community
dbaplus Community
Nov 12, 2025 · Databases

Mastering Data Sync: From Full Loads to Real‑Time CDC in E‑Commerce

This guide walks a new e‑commerce developer through the evolution of order data synchronization—from naïve full‑table loads, through incremental and batch strategies, cursor‑based pagination, performance tuning, and finally to real‑time CDC with message queues—highlighting pitfalls and practical solutions.

Batch ProcessingCDCCursor Pagination
0 likes · 12 min read
Mastering Data Sync: From Full Loads to Real‑Time CDC in E‑Commerce
Architect Chen
Architect Chen
Nov 4, 2025 · Backend Development

Mastering RocketMQ: Architecture, Workflow, and Real‑World Use Cases

This article provides a comprehensive overview of RocketMQ, covering its core components (Producer, Broker, Consumer, NameServer), detailed architecture diagrams, step‑by‑step message production and consumption processes, and typical scenarios such as asynchronous decoupling, traffic shaping, transactional messaging, and event‑driven logging.

Backend ArchitectureBrokerConsumer
0 likes · 6 min read
Mastering RocketMQ: Architecture, Workflow, and Real‑World Use Cases
Top Architect
Top Architect
Oct 31, 2025 · Backend Development

Mastering Message Queues: A Deep Dive into RabbitMQ, RocketMQ, and Kafka

This comprehensive guide explains the core components, exchange types, TTL, confirm mechanisms, consumer ACK/NACK, dead‑letter queues, and high‑availability features of RabbitMQ, RocketMQ, and Kafka, while also covering load balancing, ordering, transaction handling, and best practices for reliable message delivery.

KafkaMessage QueueRocketMQ
0 likes · 32 min read
Mastering Message Queues: A Deep Dive into RabbitMQ, RocketMQ, and Kafka
Tech Freedom Circle
Tech Freedom Circle
Oct 29, 2025 · Backend Development

Combining RocketMQ Transaction Messages, Local Message Table, and XXL‑Job for 10‑100k QPS Distributed Transactions

This article presents a detailed design for a high‑concurrency (10‑100k QPS) distributed transaction solution that integrates RocketMQ transactional messages, an eBay‑style local message table, and XXL‑Job reconciliation to achieve eventual consistency while handling failures, retries, and data‑explosion challenges.

CAP theoremJavaLocal Message Table
0 likes · 34 min read
Combining RocketMQ Transaction Messages, Local Message Table, and XXL‑Job for 10‑100k QPS Distributed Transactions
Architect-Kip
Architect-Kip
Oct 28, 2025 · Operations

Mastering Failure Recovery: Fast‑Fail, Auto‑Retry, and Resilience Patterns for Distributed Systems

This guide outlines core principles and practical solutions for building resilient backend systems, covering fast‑failure handling, automatic retries with exponential back‑off, circuit‑breaker usage, idempotency, batch job strategies, online transaction patterns, and robust message‑queue processing.

Batch ProcessingFailure RecoveryMessage Queue
0 likes · 17 min read
Mastering Failure Recovery: Fast‑Fail, Auto‑Retry, and Resilience Patterns for Distributed Systems
Su San Talks Tech
Su San Talks Tech
Oct 28, 2025 · Backend Development

How to Prevent MQ Message Loss: 5 Proven Strategies for Reliable Messaging

Discover the three stages where MQ messages can be lost and explore five practical solutions—including producer confirmations, message persistence, consumer acknowledgments, transactional messaging, and retry with dead‑letter queues—complete with code examples and guidance on selecting the right approach for different scenarios.

Dead Letter QueueKafkaMessage Queue
0 likes · 14 min read
How to Prevent MQ Message Loss: 5 Proven Strategies for Reliable Messaging
JavaGuide
JavaGuide
Oct 21, 2025 · Backend Development

Xiaohongshu’s Explosive Salaries and a Complete Backend Interview Guide

The article reveals Xiaohongshu’s unusually high 2023 campus recruitment packages—over 51 w annual total—while also providing an extensive backend interview preparation guide covering TCP vs UDP differences, design patterns, workflow versus rule engines, message‑queue selection, and Redis data structures and eviction policies.

Design PatternsInterview PreparationMessage Queue
0 likes · 32 min read
Xiaohongshu’s Explosive Salaries and a Complete Backend Interview Guide
Code Wrench
Code Wrench
Oct 18, 2025 · Backend Development

Master High‑Performance Queues in Go: Kafka, RabbitMQ & Redis Compared

This article explains how to build a high‑throughput, low‑latency, and scalable queue system in Go by leveraging Kafka, RabbitMQ, and Redis, covering core concepts, practical code examples, performance optimizations, and guidance on choosing the right solution for different workloads.

ConcurrencyGoKafka
0 likes · 11 min read
Master High‑Performance Queues in Go: Kafka, RabbitMQ & Redis Compared
Architecture Digest
Architecture Digest
Oct 12, 2025 · Backend Development

Zero‑Loss RabbitMQ: Publisher Confirms, Persistence & Manual ACK

Learn how to prevent message loss in RabbitMQ by addressing three critical failure points—producer‑to‑broker, broker storage, and broker‑to‑consumer—using publisher confirms, durable queues with persistent messages, cluster mirroring, and manual consumer acknowledgments, complete with Java code examples.

JavaMessage QueuePersistence
0 likes · 11 min read
Zero‑Loss RabbitMQ: Publisher Confirms, Persistence & Manual ACK
Architecture Digest
Architecture Digest
Oct 8, 2025 · Backend Development

How Ticketing Platforms Handle Millions of Clicks Without Crashing

This article explains how modern ticketing systems achieve millisecond‑level response times under massive concurrent demand by combining client‑side defenses, API‑gateway signature verification, Redis atomic stock decrement, and message‑queue buffering, ensuring fairness, preventing bots, and protecting backend services from overload.

App SecurityMessage Queuehigh-concurrency
0 likes · 10 min read
How Ticketing Platforms Handle Millions of Clicks Without Crashing
Architect's Guide
Architect's Guide
Oct 7, 2025 · Backend Development

Mastering Backend Architecture: From Microservices to Service Mesh and Message Queues

This article presents a comprehensive roadmap for backend architects, covering microservice fundamentals, design principles, gateway patterns, communication protocols, service registration, configuration management, observability pillars, service mesh options, and a detailed comparison of modern message‑queue technologies.

BackendCloud NativeMessage Queue
0 likes · 29 min read
Mastering Backend Architecture: From Microservices to Service Mesh and Message Queues
IT Services Circle
IT Services Circle
Oct 4, 2025 · Backend Development

How to Solve Message Queue Backlog in High‑Traffic Scenarios: Interview‑Ready Strategies

This article explains why consumer instances cannot scale indefinitely, how to plan partition numbers, fast‑track solutions for message backlog, consumer‑side performance tweaks, and an advanced asynchronous consumption model, providing a complete, interview‑friendly framework for handling MQ congestion.

Message QueuePartitioningasynchronous consumption
0 likes · 22 min read
How to Solve Message Queue Backlog in High‑Traffic Scenarios: Interview‑Ready Strategies
Architecture Digest
Architecture Digest
Oct 2, 2025 · Backend Development

How to Reliably Close Unpaid Orders: Proven Backend Strategies

This article examines common pitfalls and compares five backend solutions—database scans, JDK DelayQueue, Redis keyspace notifications, Redis sorted sets, and delayed MQ messages—for reliably handling order timeout in high‑traffic e‑commerce systems, highlighting their advantages, drawbacks, and best‑fit scenarios.

BackendMessage Queueorder timeout
0 likes · 11 min read
How to Reliably Close Unpaid Orders: Proven Backend Strategies
Open Source Tech Hub
Open Source Tech Hub
Oct 1, 2025 · Backend Development

How to Build a High‑Performance Lightweight PHP Queue Using Redis Streams

This guide introduces a lightweight, high‑performance PHP queue library built on Redis 5.0+ Streams, detailing its features such as high concurrency, delayed tasks, multi‑producer/consumer support, ACK handling, message replay, audit mode, and provides step‑by‑step installation, configuration, and usage examples with code snippets.

BackendMessage QueuePHP
0 likes · 7 min read
How to Build a High‑Performance Lightweight PHP Queue Using Redis Streams
dbaplus Community
dbaplus Community
Sep 27, 2025 · Backend Development

How to Build a Billion‑User Real‑Time Step Leaderboard Like WeChat Sports

Designing a real‑time step leaderboard for billions of users requires tackling massive write spikes, fast friend‑based queries, scalable storage, and high availability; this guide outlines a three‑step architecture using asynchronous message queues, Redis ZSETs, and MySQL sharding to meet those challenges.

LeaderboardMessage Queuehigh-concurrency
0 likes · 7 min read
How to Build a Billion‑User Real‑Time Step Leaderboard Like WeChat Sports
JD Tech
JD Tech
Sep 26, 2025 · Operations

Avoiding High‑Availability Pitfalls: Real‑World JD Lessons and Solutions

This article examines common high‑availability challenges across applications, databases, caches, message queues, containers, and GC, presenting real JD engineering cases, root‑cause analyses, and practical mitigation strategies to help engineers design more resilient systems.

DatabaseHigh AvailabilityMessage Queue
0 likes · 37 min read
Avoiding High‑Availability Pitfalls: Real‑World JD Lessons and Solutions
Ray's Galactic Tech
Ray's Galactic Tech
Sep 25, 2025 · Backend Development

Master Spring Boot & RabbitMQ: From Setup to Advanced Patterns

This guide walks you through installing RabbitMQ, configuring Spring Boot, building basic producers and consumers, exploring work, fanout, direct and topic patterns, and applying advanced features like confirmations, manual ACKs, TTL, dead‑letter, delayed and priority queues, plus clustering, monitoring and troubleshooting tips.

IntegrationJavaMessage Queue
0 likes · 12 min read
Master Spring Boot & RabbitMQ: From Setup to Advanced Patterns
NiuNiu MaTe
NiuNiu MaTe
Sep 24, 2025 · Backend Development

How to Build a Fast, Reliable, and Cost‑Effective Like System

This article breaks down the design of a high‑traffic like service, detailing four core requirements—speed, accuracy, stability, and cost control—while recommending Redis, a message queue, and MySQL, and illustrating the full architecture from frontend to persistence with practical code examples and optimization tips.

Message Queuehigh-concurrencysystem design
0 likes · 17 min read
How to Build a Fast, Reliable, and Cost‑Effective Like System
Architecture Digest
Architecture Digest
Sep 23, 2025 · Backend Development

How to Ensure Zero Message Loss in Kafka: Proven Strategies for High‑Reliability Systems

This article explains Kafka's storage architecture, identifies three major message‑loss scenarios across production, storage, and consumption, and provides practical end‑to‑end configurations, detection methods, and business‑level patterns to achieve near‑zero message loss in high‑concurrency distributed systems.

Data ConsistencyKafkaMessage Queue
0 likes · 13 min read
How to Ensure Zero Message Loss in Kafka: Proven Strategies for High‑Reliability Systems
Ray's Galactic Tech
Ray's Galactic Tech
Sep 21, 2025 · Backend Development

How to Build a High‑Availability RocketMQ Cluster: Step‑by‑Step Guide

This guide walks you through designing, preparing the environment, installing, configuring, and validating a production‑grade RocketMQ cluster with multiple masters and slaves, including optional web console setup, one‑click deployment scripts, performance tuning, security hardening, and monitoring recommendations.

Cluster DeploymentLinuxMessage Queue
0 likes · 10 min read
How to Build a High‑Availability RocketMQ Cluster: Step‑by‑Step Guide
Architecture Digest
Architecture Digest
Sep 19, 2025 · Backend Development

Mastering Message Idempotency: From Simple Checks to State‑Machine Solutions

This article explores the challenges of duplicate message consumption in distributed systems, explains why naive de‑duplication fails under high concurrency, and presents four progressively robust idempotency strategies—from database pessimistic locks and local message tables to a state‑machine approach with Redis or MySQL, highlighting their trade‑offs.

Message QueueRedisbackend development
0 likes · 11 min read
Mastering Message Idempotency: From Simple Checks to State‑Machine Solutions
Liangxu Linux
Liangxu Linux
Sep 17, 2025 · Fundamentals

Mastering Event‑Driven Design and State Machines for Embedded Firmware

This article explains how event‑driven programming and state‑machine concepts can be applied to microcontroller firmware, compares a simple flag‑based approach with a message‑queue solution, and presents a reusable GF1.0 framework that combines ISR, message buffering, and a main state machine for robust embedded systems.

FirmwareMessage Queueembedded systems
0 likes · 32 min read
Mastering Event‑Driven Design and State Machines for Embedded Firmware
Mike Chen's Internet Architecture
Mike Chen's Internet Architecture
Sep 17, 2025 · Backend Development

4 Essential Message Queue Use Cases Every Backend Engineer Should Master

Message queues are foundational to large‑scale architectures, and this article explains four key scenarios—asynchronous communication, application decoupling, flash‑sale traffic buffering, and log processing—illustrated with diagrams to help backend engineers design resilient, high‑throughput systems.

Log ProcessingMessage QueueSystem Decoupling
0 likes · 4 min read
4 Essential Message Queue Use Cases Every Backend Engineer Should Master
Code Ape Tech Column
Code Ape Tech Column
Sep 17, 2025 · Backend Development

8 Powerful Ways to Implement Asynchronous Processing in Java

Explore eight practical techniques for achieving asynchronous execution in Java—from low‑level threads and Futures to Spring’s @Async, ApplicationEvent, message queues, and Guava ListenableFuture—complete with code samples, performance insights, and best‑practice recommendations for building responsive backend services.

AsynchronousFutureJava
0 likes · 13 min read
8 Powerful Ways to Implement Asynchronous Processing in Java
Code Ape Tech Column
Code Ape Tech Column
Sep 15, 2025 · Backend Development

Unlock Ultra‑Fast Messaging with Disruptor: A Hands‑On Java Guide

This article introduces the high‑performance Disruptor library, explains its core concepts such as Ring Buffer, Sequence, and Wait Strategy, and provides a step‑by‑step Java demo—including Maven setup, event model, producer, consumer, and test—showcasing how to build a lock‑free in‑memory message queue.

Concurrent ProgrammingDisruptorJava
0 likes · 11 min read
Unlock Ultra‑Fast Messaging with Disruptor: A Hands‑On Java Guide
Raymond Ops
Raymond Ops
Sep 13, 2025 · Operations

How to Build a High‑Availability RabbitMQ Cluster on CentOS with Docker

This guide walks through the full process of analyzing requirements, selecting self‑hosted servers, preparing CentOS nodes, installing Docker and Docker‑Compose, configuring RabbitMQ, and deploying a three‑node high‑availability RabbitMQ cluster with detailed commands and configuration files.

ClusterDockerDocker Compose
0 likes · 12 min read
How to Build a High‑Availability RabbitMQ Cluster on CentOS with Docker
NiuNiu MaTe
NiuNiu MaTe
Sep 10, 2025 · Backend Development

How to Quickly Resolve Message Queue Backlog and Keep Your System Stable

This article explains what message queue backlog is, why it harms system latency, and provides practical, step‑by‑step strategies—including temporary consumer scaling, prioritizing core messages, queue splitting, root‑cause analysis, performance tuning, message design, dead‑letter handling, traffic control, capacity planning, and monitoring—to eliminate backlog and ensure reliable asynchronous processing.

BacklogDead Letter QueueMessage Queue
0 likes · 21 min read
How to Quickly Resolve Message Queue Backlog and Keep Your System Stable
NiuNiu MaTe
NiuNiu MaTe
Sep 8, 2025 · Backend Development

How to Auto‑Close Expired E‑Commerce Orders: Timers, Queues & Redis Time Wheels

Learn how to design and implement automatic order expiration in e‑commerce systems using three approaches—simple scheduled table scans, delayed message queues, and a Redis time‑wheel—detailing their trade‑offs, code examples, indexing tips, distributed locking, and failure‑handling strategies.

Message QueueScheduled Tasksbackend design
0 likes · 16 min read
How to Auto‑Close Expired E‑Commerce Orders: Timers, Queues & Redis Time Wheels
Architecture & Thinking
Architecture & Thinking
Sep 8, 2025 · Backend Development

Mastering RocketMQ: 7 Core Techniques for Reliable Messaging

This article walks through seven essential RocketMQ concepts—including message ordering, delayed delivery, accumulation handling, transactional guarantees, retry mechanisms, storage strategies, and filtering—providing code examples, configuration tips, and visual diagrams to help developers build robust distributed messaging systems.

JavaMessage QueueRocketMQ
0 likes · 13 min read
Mastering RocketMQ: 7 Core Techniques for Reliable Messaging
IT Services Circle
IT Services Circle
Sep 7, 2025 · Backend Development

Master Java Backend Interview: JVM, ClassLoaders, AOP, and More

This article guides job seekers through the autumn recruitment season, highlights bank hiring timelines and English requirements, and then provides a comprehensive Java interview Q&A covering JVM memory structures, object allocation failures, the parent‑delegation model, message‑queue usage, Spring AOP principles, and database string type differences.

ClassLoaderJVMJava
0 likes · 17 min read
Master Java Backend Interview: JVM, ClassLoaders, AOP, and More
IT Services Circle
IT Services Circle
Sep 6, 2025 · Backend Development

10 Real‑World Scenarios Where Message Queues Transform Your System

This article explores ten practical use‑cases for message queues—covering system decoupling, asynchronous processing, traffic shaping, data synchronization, log collection, broadcast updates, ordered and delayed messages, retry mechanisms, and transactional messaging—illustrated with Java code examples and architectural diagrams.

JavaKafkaMQ
0 likes · 17 min read
10 Real‑World Scenarios Where Message Queues Transform Your System
Su San Talks Tech
Su San Talks Tech
Sep 4, 2025 · Backend Development

10 Real-World Message Queue (MQ) Scenarios Every Backend Engineer Should Know

This article explores ten practical use cases for message queues, from system decoupling and asynchronous processing to traffic shaping, data synchronization, log collection, broadcasting, ordered and delayed messages, retry mechanisms, and transactional messaging, providing code examples and best‑practice recommendations for robust backend design.

MQMessage QueueSystem Decoupling
0 likes · 21 min read
10 Real-World Message Queue (MQ) Scenarios Every Backend Engineer Should Know
AI Large Model Application Practice
AI Large Model Application Practice
Sep 4, 2025 · Artificial Intelligence

Can Message Queues Power the Next Generation of AI Agents? A Deep Dive into Pulsar

This article examines how traditional high‑performance message queues and event‑driven architectures can be revitalized for AI agents, tracing the evolution of messaging middleware, highlighting key integration points, and showcasing Apache Pulsar's cloud‑native features that enable reliable, scalable, and intelligent multi‑agent systems.

AI AgentApache PulsarCloud Native
0 likes · 16 min read
Can Message Queues Power the Next Generation of AI Agents? A Deep Dive into Pulsar
Su San Talks Tech
Su San Talks Tech
Sep 1, 2025 · Backend Development

How to Eliminate a 1M‑Message MQ Backlog Without Adding Servers: 5 Proven Strategies

This article explains why message queues can accumulate millions of messages, analyzes root causes such as over‑fast producers and slow consumers, and presents five practical solutions—including consumer code optimization, queue‑strategy tweaks, producer rate limiting, dead‑letter handling, and automated monitoring—to dramatically reduce backlog without costly hardware scaling.

JavaMessage QueueRocketMQ
0 likes · 22 min read
How to Eliminate a 1M‑Message MQ Backlog Without Adding Servers: 5 Proven Strategies
360 Zhihui Cloud Developer
360 Zhihui Cloud Developer
Aug 29, 2025 · Backend Development

How Apache Pulsar Achieves Sub‑millisecond Write Latency on NVMe

This article explains Apache Pulsar's architecture, client‑to‑broker and broker‑to‑bookie latency components, data storage model, write path, journal flush strategies, and presents detailed benchmark results showing sub‑millisecond write latency and up to 1.5 million TPS on NVMe storage.

Apache PulsarMessage QueueNVMe
0 likes · 10 min read
How Apache Pulsar Achieves Sub‑millisecond Write Latency on NVMe
Architecture & Thinking
Architecture & Thinking
Aug 26, 2025 · Backend Development

How RocketMQ Achieves Million‑TPS with Sequential Writes and Multi‑Level Indexes

RocketMQ tackles the high‑performance, high‑reliability challenges of distributed messaging by combining sequential disk writes, memory caching, and multi‑level indexing, detailing its storage logic, core structures, zero‑copy techniques, replication modes, static topic scaling, and practical tuning guidelines for optimal throughput.

Message QueueRocketMQStorage Architecture
0 likes · 8 min read
How RocketMQ Achieves Million‑TPS with Sequential Writes and Multi‑Level Indexes
Architect Chen
Architect Chen
Aug 24, 2025 · Backend Development

Mastering Distributed Transactions: 2PC, 3PC, TCC, and Message‑Queue Strategies

This article explains the fundamentals of distributed transactions, illustrates why they are essential for multi‑service operations such as e‑commerce order processing, and compares four major solutions—two‑phase commit, three‑phase commit, TCC, and message‑queue based eventual consistency—detailing their workflows, advantages, and drawbacks.

2PC3PCBackend Architecture
0 likes · 7 min read
Mastering Distributed Transactions: 2PC, 3PC, TCC, and Message‑Queue Strategies
Didi Tech
Didi Tech
Aug 14, 2025 · Backend Development

How RocketMQ and DDMQ Achieve Ordered Consumption: Deep Source Code Dive

This article deeply explores the ordered consumption mechanisms of RocketMQ and its derivative DDMQ, explaining the implementation differences, source‑code details of sequential sending, broker locking, client‑side processing, and compares the two systems' approaches to guarantee message order.

DDMQJavaMessage Queue
0 likes · 30 min read
How RocketMQ and DDMQ Achieve Ordered Consumption: Deep Source Code Dive
Wukong Talks Architecture
Wukong Talks Architecture
Aug 14, 2025 · Backend Development

Understanding RocketMQ Architecture: Components, Protocols, and Storage

This article provides a comprehensive overview of RocketMQ's architecture, detailing its core components, network protocols, storage mechanisms, producer‑consumer workflow, and transactional messaging, while highlighting differences between Remoting and gRPC and explaining key design choices for high performance and reliability.

Message QueueNettyRocketMQ
0 likes · 15 min read
Understanding RocketMQ Architecture: Components, Protocols, and Storage
Tencent Cloud Middleware
Tencent Cloud Middleware
Aug 1, 2025 · Backend Development

Mastering TDMQ CKafka Production: Configurations, Partitioning, and Reliable Messaging

This guide explains how to efficiently produce messages with TDMQ CKafka, covering topic creation, partition sizing, retry policies, asynchronous sending, key/value handling, batch tuning, sticky partitioning, idempotence, ACK settings, code examples, and strategies to avoid data skew and ensure high‑throughput, low‑latency messaging.

CKafkaKafkaMessage Queue
0 likes · 18 min read
Mastering TDMQ CKafka Production: Configurations, Partitioning, and Reliable Messaging
Architect's Guide
Architect's Guide
Jul 25, 2025 · Backend Development

8 Powerful Ways to Implement Asynchronous Programming in Java

This article explains why asynchronous execution shortens request latency and presents eight practical Java techniques—including raw threads, Future, CompletableFuture, Spring @Async, ApplicationEvent, message queues, ThreadUtil, and Guava ListenableFuture—complete with code examples and usage tips.

Asynchronous ProgrammingCompletableFutureFuture
0 likes · 13 min read
8 Powerful Ways to Implement Asynchronous Programming in Java
Sanyou's Java Diary
Sanyou's Java Diary
Jul 17, 2025 · Backend Development

Unlocking RocketMQ 4.x: Deep Dive into Architecture, Protocols, and High‑Performance Messaging

This article provides a comprehensive technical overview of RocketMQ 4.x, covering its core roles, publish‑subscribe model, communication protocol, reactor thread model, storage files, high‑performance read/write techniques, consumption flow, deployment patterns, DLedger Raft integration, transaction and broadcast messaging, ordered message handling, architectural drawbacks, and the new stateless proxy architecture introduced in RocketMQ 5.0.

Message QueueRocketMQTransaction Messaging
0 likes · 22 min read
Unlocking RocketMQ 4.x: Deep Dive into Architecture, Protocols, and High‑Performance Messaging
Su San Talks Tech
Su San Talks Tech
Jul 12, 2025 · Backend Development

Unlocking RocketMQ 4.x: Architecture, Protocols, and High‑Performance Messaging

This article provides a comprehensive overview of RocketMQ 4.x, detailing its core architecture—including NameServer, Broker, Producer, and Consumer roles—its publish‑subscribe model, its communication protocols, reactor threading, storage mechanisms, high‑performance read/write strategies, deployment options, transaction handling, broadcast and ordered messaging, and the strengths and limitations of its master‑slave and DLedger designs.

Message QueueRocketMQ
0 likes · 29 min read
Unlocking RocketMQ 4.x: Architecture, Protocols, and High‑Performance Messaging
MaGe Linux Operations
MaGe Linux Operations
Jul 7, 2025 · Operations

Master RabbitMQ: From Single‑Node to High‑Availability Cluster – Complete Ops Guide

This comprehensive guide walks you through RabbitMQ's core features, typical use cases, step‑by‑step local installation, cluster architecture, HA configuration, admin console, monitoring scripts, capacity planning, and automation, enabling reliable, high‑performance messaging in production environments.

Cluster DeploymentMessage Queuerabbitmq
0 likes · 14 min read
Master RabbitMQ: From Single‑Node to High‑Availability Cluster – Complete Ops Guide
FunTester
FunTester
Jul 5, 2025 · Big Data

Master Kafka: Core Concepts and Performance Testing Strategies

This article explains Kafka’s high‑performance distributed streaming architecture, key components such as topics, partitions, producers, consumers, brokers, offsets, and ZooKeeper, and provides step‑by‑step workflows for producers and consumers along with performance‑testing tips and Maven setup.

Big DataJavaKafka
0 likes · 9 min read
Master Kafka: Core Concepts and Performance Testing Strategies
JD Tech
JD Tech
Jul 2, 2025 · Backend Development

How We Tamed Database Lock Contention in High‑Volume Inventory Allocation

This article examines the severe row‑lock competition in MySQL during hot‑SKU inventory positioning, analyzes its causes and risks, and presents a comprehensive set of mitigation strategies—including DB account isolation, flow‑control, request merging, and message‑queue optimizations—validated by extensive performance testing and successful rollout across multiple clusters.

DatabaseMessage Queuebackend optimization
0 likes · 14 min read
How We Tamed Database Lock Contention in High‑Volume Inventory Allocation
Architecture & Thinking
Architecture & Thinking
Jun 30, 2025 · Backend Development

Mastering RocketMQ Retry: Producer & Consumer Strategies for Reliable Messaging

This article deeply explores Apache RocketMQ's retry mechanisms, detailing producer and consumer retry strategies, flow control handling, dead‑letter queue management, advanced configurations, best practices, and comparisons with Kafka and RabbitMQ, providing practical code examples and monitoring recommendations for building highly reliable distributed systems.

Dead Letter QueueMessage QueueMessage Retry
0 likes · 8 min read
Mastering RocketMQ Retry: Producer & Consumer Strategies for Reliable Messaging
Lin is Dream
Lin is Dream
Jun 27, 2025 · Backend Development

How to Solve Common RocketMQ Issues: Duplicates, Throttling, Retries, and Loss

This article examines frequent RocketMQ problems such as duplicate sending, flow‑control throttling, message retries, duplicate consumption, backlog, and loss, and provides practical configuration tweaks, scaling strategies, batch sending, idempotent handling, and retry mechanisms to ensure reliable message delivery.

JavaMessage QueuePerformance Tuning
0 likes · 9 min read
How to Solve Common RocketMQ Issues: Duplicates, Throttling, Retries, and Loss
Lin is Dream
Lin is Dream
Jun 26, 2025 · Backend Development

Unveiling RocketMQ: How Messages Journey Through Storage, Delivery, and Expiration

This article systematically breaks down RocketMQ's core mechanisms—covering message roles, disk storage, push/pull delivery, expiration handling, retry queues, and cluster failover—so developers can understand every stage a message undergoes from creation to cleanup and ensure reliable, high‑performance messaging.

JavaMessage QueueMiddleware
0 likes · 13 min read
Unveiling RocketMQ: How Messages Journey Through Storage, Delivery, and Expiration
Lin is Dream
Lin is Dream
Jun 25, 2025 · Backend Development

12 Essential RocketMQ Best Practices for Reliable Messaging

This article presents a comprehensive set of RocketMQ usage guidelines—including topic and tag conventions, producer and consumer group naming, key handling, logging, retry mechanisms, and cluster deployment recommendations—to help engineers build stable, high‑performance, and observable messaging systems in production environments.

Message QueueRocketMQdistributed systems
0 likes · 9 min read
12 Essential RocketMQ Best Practices for Reliable Messaging
Lin is Dream
Lin is Dream
Jun 24, 2025 · Backend Development

Master RocketMQ Console: From Zero to Full Monitoring in Minutes

This article walks you through installing and using the RocketMQ Dashboard to monitor topics, brokers, producers, consumers, and message details, explains common pitfalls such as client‑ID conflicts in Docker, and demonstrates how to troubleshoot consumption issues, TPS metrics, and dead‑letter handling.

DashboardJavaMessage Queue
0 likes · 9 min read
Master RocketMQ Console: From Zero to Full Monitoring in Minutes
Architect
Architect
Jun 22, 2025 · Backend Development

Mastering Idempotency: Ensure Reliable Operations in Distributed Systems

Idempotency ensures that repeated service calls or user actions produce the same effect without unintended side effects, a critical concern in distributed and microservice architectures; this article explains its principles, SQL examples, HTTP semantics, token strategies, lock handling, and message‑queue solutions.

Message Queueidempotencytoken
0 likes · 13 min read
Mastering Idempotency: Ensure Reliable Operations in Distributed Systems
Lin is Dream
Lin is Dream
Jun 20, 2025 · Backend Development

Unlocking RocketMQ: What Every SendResult Field Means

This article explains the composition of RocketMQ's SendResult object returned after a successful synchronous send, detailing each field such as sendStatus, msgId, offsetMsgId, messageQueue, and queueOffset, and provides practical examples and a full field‑by‑field breakdown for Java developers.

JavaMessage QueueRocketMQ
0 likes · 6 min read
Unlocking RocketMQ: What Every SendResult Field Means
Lin is Dream
Lin is Dream
Jun 19, 2025 · Backend Development

Master RocketMQ with Spring Boot: Complete Guide to Messaging APIs

This tutorial walks through integrating Alibaba's RocketMQ into a Spring Boot application, covering Maven dependencies, producer and consumer configurations, and detailed examples of synchronous, asynchronous, one‑way, delayed, ordered, transactional, request‑response, batch, and pull messaging APIs, along with best‑practice recommendations.

JavaMessage QueueMessaging API
0 likes · 21 min read
Master RocketMQ with Spring Boot: Complete Guide to Messaging APIs
Architecture & Thinking
Architecture & Thinking
Jun 19, 2025 · Backend Development

Why Does Message Backlog Occur in Kafka/RocketMQ and How to Fix It

The article explains how message backlog arises when producers outpace consumers in systems like Kafka or RocketMQ, outlines primary causes such as unexpected production spikes, broker failures, and consumer bottlenecks, and provides step‑by‑step mitigation strategies including capacity scaling, temporary queues, and optimization techniques for producers, brokers, and consumers.

BacklogMessage QueuePerformance
0 likes · 7 min read
Why Does Message Backlog Occur in Kafka/RocketMQ and How to Fix It
Pan Zhi's Tech Notes
Pan Zhi's Tech Notes
Jun 16, 2025 · Backend Development

How RocketMQ Guarantees No Message Loss, Duplication, or Disorder

This article explains RocketMQ’s architecture, the roles of NameServer, Broker, Producer, Consumer, and how each component ensures reliable message delivery—covering synchronous, asynchronous, and one‑way sending, storage mechanisms, consumer retries, dead‑letter queues, installation steps, and Java client integration with code examples.

InstallationJavaMessage Queue
0 likes · 20 min read
How RocketMQ Guarantees No Message Loss, Duplication, or Disorder
ITPUB
ITPUB
Jun 14, 2025 · Backend Development

When Should You Choose RPC Over MQ? A Practical Guide to Decoupling Services

The article explains why RPC should be used when callers need immediate results, while MQ is preferable for fire‑and‑forget notifications, illustrating the trade‑offs with code examples, common pitfalls of misusing each method, and practical steps to achieve physical and logical decoupling in backend systems.

Backend ArchitectureDecouplingMessage Queue
0 likes · 6 min read
When Should You Choose RPC Over MQ? A Practical Guide to Decoupling Services
Architect
Architect
Jun 6, 2025 · Backend Development

How to Prevent Duplicate Messages in Kafka and Pulsar: A Practical Guide

This article explains the three message delivery semantics, the common causes of duplicate messages in queue systems, and presents concrete producer‑side, broker‑side, and consumer‑side deduplication techniques for Kafka and Pulsar, including code samples and best‑practice recommendations.

BackendKafkaMessage Queue
0 likes · 9 min read
How to Prevent Duplicate Messages in Kafka and Pulsar: A Practical Guide
Instant Consumer Technology Team
Instant Consumer Technology Team
Jun 5, 2025 · Big Data

Mastering Kafka in Production: Boost Throughput, Ensure Reliability, and Avoid Data Loss

This article shares practical Kafka production insights, covering architecture overview, producer throughput tuning, message loss prevention, broker and consumer configurations, duplicate consumption avoidance, backlog mitigation, ordering guarantees, and the mechanics of consumer group rebalancing, helping engineers build stable, high‑performance streaming pipelines.

Big DataConsumer GroupKafka
0 likes · 15 min read
Mastering Kafka in Production: Boost Throughput, Ensure Reliability, and Avoid Data Loss
Raymond Ops
Raymond Ops
Jun 1, 2025 · Backend Development

RocketMQ vs Others: Key Features, Reliability, and Performance

RocketMQ, an Apache‑licensed distributed message queue from Alibaba, offers low latency, high reliability, and high throughput through features like distributed architecture, synchronous disk flushing, master‑slave replication, and flexible messaging models, and it compares favorably against Kafka, RabbitMQ, and ActiveMQ in various scenarios.

Distributed ArchitectureHigh reliabilityHigh throughput
0 likes · 11 min read
RocketMQ vs Others: Key Features, Reliability, and Performance
Selected Java Interview Questions
Selected Java Interview Questions
May 19, 2025 · Backend Development

Designing Automatic Order Closure: Comparing DB Polling, Redis Expiration, Redis Zset Delay Queue, and Message Queue Delayed Messages

This article examines four techniques for automatically closing overdue orders—database polling, Redis key‑expiration listeners, Redis sorted‑set delay queues, and message‑queue delayed messages—detailing their implementations, advantages, drawbacks, and practical recommendations for reliable backend systems.

Message Queuedatabase pollingdelayed tasks
0 likes · 11 min read
Designing Automatic Order Closure: Comparing DB Polling, Redis Expiration, Redis Zset Delay Queue, and Message Queue Delayed Messages
Su San Talks Tech
Su San Talks Tech
May 19, 2025 · Backend Development

Mastering Asynchronous Architecture: Real‑World Scenarios and Spring Cloud Gateway

This article explains synchronous versus asynchronous processing through a parcel‑delivery example, outlines core async concepts, presents common async techniques such as message queues, event‑driven design and non‑blocking I/O, and demonstrates practical implementations with Spring Cloud Gateway, Netty, ELK‑Kafka pipelines, and CompletableFuture batch processing.

Asynchronous ProgrammingJava concurrencyMessage Queue
0 likes · 17 min read
Mastering Asynchronous Architecture: Real‑World Scenarios and Spring Cloud Gateway
Java Tech Enthusiast
Java Tech Enthusiast
May 11, 2025 · Backend Development

Implementing Automatic Order Cancellation After 30 Minutes: Five Practical Solutions

This article explains why orders that remain unpaid for 30 minutes should be automatically cancelled and compares five technical approaches—database polling, JDK Timer, message‑queue delayed queues, distributed schedulers like Quartz, and Redis expiration listeners—detailing their implementation steps, code samples, pros, cons, and suitable scenarios.

Message QueueQuartzScheduled Tasks
0 likes · 19 min read
Implementing Automatic Order Cancellation After 30 Minutes: Five Practical Solutions
Architecture Digest
Architecture Digest
May 9, 2025 · Backend Development

Implementing Order Auto‑Close with Delayed Tasks: Best Practices and Pitfalls

The article examines how e‑commerce platforms implement order auto‑closure using delayed tasks, compares methods such as message‑queue delayed delivery, Redisson delay queue, Redis expiration listening, RabbitMQ dead‑letter queues and time wheels, and recommends reliable approaches while warning against unsafe practices.

Message QueueRedisbackend development
0 likes · 6 min read
Implementing Order Auto‑Close with Delayed Tasks: Best Practices and Pitfalls
IT Services Circle
IT Services Circle
May 7, 2025 · Backend Development

Understanding RocketMQ Long‑Polling Mechanism and Its Implementation

This article explains how RocketMQ implements long‑polling for message consumption, detailing the pull‑based model, the broker and consumer timeout settings, the internal suspension of pull requests, and the processing loop that resumes suspended requests to improve efficiency.

BackendBrokerConsumer
0 likes · 7 min read
Understanding RocketMQ Long‑Polling Mechanism and Its Implementation
Architect
Architect
May 3, 2025 · Backend Development

Why Rebuild a Job Scheduler? Inside a Lightweight Distributed Timing Framework

This article explains the motivation, design choices, and implementation details of a custom distributed job scheduling framework, covering its architecture, load‑balancing strategy, message‑queue handling, persistence mechanisms, and key code snippets, while comparing it to existing solutions like Quartz, XXL‑Job, and PowerJob.

JavaMessage Queuedistributed systems
0 likes · 16 min read
Why Rebuild a Job Scheduler? Inside a Lightweight Distributed Timing Framework
Architect
Architect
May 2, 2025 · Backend Development

Understanding and Implementing LMAX Disruptor in Java

This article introduces the high‑performance LMAX Disruptor library, explains its core concepts such as Ring Buffer, Sequence, Sequencer, and Wait Strategy, and provides a step‑by‑step Java demo with complete code to build a producer‑consumer message queue.

ConcurrencyDisruptorJava
0 likes · 11 min read
Understanding and Implementing LMAX Disruptor in Java
Cognitive Technology Team
Cognitive Technology Team
Apr 30, 2025 · Backend Development

Preventing Message Loss, Duplicate Consumption, and Backlog in RocketMQ: Best Practices and Strategies

This article examines the three major reliability challenges of message queues—loss, duplicate consumption, and backlog—and provides detailed RocketMQ‑specific strategies, including producer acknowledgment, broker replication, idempotent consumer design, monitoring, scaling, and parameter tuning to ensure high‑availability distributed systems.

Message QueueRocketMQ
0 likes · 17 min read
Preventing Message Loss, Duplicate Consumption, and Backlog in RocketMQ: Best Practices and Strategies
Lobster Programming
Lobster Programming
Apr 28, 2025 · Backend Development

How RocketMQ Transactional Messages Ensure Distributed Data Consistency

This article explains RocketMQ's transactional message mechanism, covering half‑message storage, three transaction states, status‑check procedures, key APIs, storage reliability, and the two‑phase commit process that guarantees eventual consistency in distributed systems.

Data ConsistencyMessage QueueRocketMQ
0 likes · 6 min read
How RocketMQ Transactional Messages Ensure Distributed Data Consistency
Java Architect Essentials
Java Architect Essentials
Apr 25, 2025 · Backend Development

Precise Order‑Closing Delayed Tasks: Best Practices and Common Pitfalls

This article compares several ways to implement order‑closing delayed tasks—message‑queue delayed delivery, Redisson DelayQueue, Redis expiration listening, RabbitMQ dead‑letter queues, and time wheels—explaining their mechanisms, drawbacks, and recommending the most reliable solutions for production systems.

Backend ArchitectureMessage QueueRedis
0 likes · 7 min read
Precise Order‑Closing Delayed Tasks: Best Practices and Common Pitfalls
Tencent Cloud Middleware
Tencent Cloud Middleware
Apr 24, 2025 · Backend Development

How TDMQ RocketMQ Implements Distributed Rate Limiting for High‑Throughput Messaging

This article explains TDMQ RocketMQ's distributed rate‑limiting mechanism, covering conversion rules, fast‑fail behavior, token‑based implementation, counting periods, client best practices, elastic TPS options, code examples for different SDK versions, monitoring tips, and answers to common throttling questions.

BackendMessage QueueRocketMQ
0 likes · 15 min read
How TDMQ RocketMQ Implements Distributed Rate Limiting for High‑Throughput Messaging
Lobster Programming
Lobster Programming
Apr 17, 2025 · Backend Development

How Local Message Tables Solve Distributed Transaction Challenges

Using a local message table, developers can break down distributed transactions into local database operations and asynchronous MQ messages, ensuring eventual consistency, simplifying implementation, and handling retries, while balancing advantages like simplicity and compatibility against drawbacks such as added maintenance and potential queue dependencies.

Backend ArchitectureLocal Message TableMessage Queue
0 likes · 5 min read
How Local Message Tables Solve Distributed Transaction Challenges
Xuanwu Backend Tech Stack
Xuanwu Backend Tech Stack
Apr 14, 2025 · Backend Development

Mastering RabbitMQ Dead Letter Exchanges and Queues with Java Code

This article explains the concepts of RabbitMQ dead‑letter exchanges and queues, outlines why messages become dead letters, and provides complete Java code examples for configuring exchanges, publishing messages with TTL, and consuming both normal and dead‑letter queues.

Dead Letter QueueJavaMessage Queue
0 likes · 12 min read
Mastering RabbitMQ Dead Letter Exchanges and Queues with Java Code
Cognitive Technology Team
Cognitive Technology Team
Apr 12, 2025 · Backend Development

Implementation Principles of RocketMQ Distributed Transaction Messages

The article explains how RocketMQ implements distributed transaction messages using a two‑phase commit model to ensure data consistency across micro‑service subsystems, detailing the workflow from half‑message production, broker handling, local transaction execution, commit/rollback decisions, and periodic status checks.

Message QueueRocketMQbackend development
0 likes · 7 min read
Implementation Principles of RocketMQ Distributed Transaction Messages
Architecture and Beyond
Architecture and Beyond
Apr 12, 2025 · Backend Development

How to Keep Your AIGC Service Stable: Queueing and Rate‑Limiting Strategies

This article explains why AIGC services need queueing systems and rate‑limiting, describes the user‑facing behaviors of both mechanisms, outlines design goals, compares queue and limiter implementations, and provides practical guidance on selecting middleware, monitoring, and integrating them into a production workflow.

AIGCBackendMessage Queue
0 likes · 28 min read
How to Keep Your AIGC Service Stable: Queueing and Rate‑Limiting Strategies
macrozheng
macrozheng
Apr 11, 2025 · Backend Development

How to Guarantee Exactly‑Once Message Consumption in High‑Concurrency Systems

This article explains common causes of duplicate message consumption in high‑traffic systems and presents a three‑layer defense—producer idempotence, broker de‑duplication, and consumer idempotent design—plus monitoring and reconciliation strategies to achieve reliable exactly‑once processing.

KafkaMessage QueueRocketMQ
0 likes · 7 min read
How to Guarantee Exactly‑Once Message Consumption in High‑Concurrency Systems
Xuanwu Backend Tech Stack
Xuanwu Backend Tech Stack
Apr 11, 2025 · Backend Development

Master RabbitMQ Exchanges: Direct, Topic, Fanout, and Headers Explained

RabbitMQ uses exchanges to route messages from producers to queues, and this guide details the four main exchange types—Direct, Topic, Fanout, and Headers—explaining their routing rules, suitable scenarios, and practical examples to help developers choose the right pattern for reliable messaging.

ExchangeMessage Queuebackend development
0 likes · 8 min read
Master RabbitMQ Exchanges: Direct, Topic, Fanout, and Headers Explained
Java Captain
Java Captain
Apr 10, 2025 · Backend Development

Design and Implementation of Delayed Task Processing for Order Systems

This article explains various approaches to delayed task handling—such as database polling, JDK DelayQueue, Redis expiration listeners, Redisson delay queues, RocketMQ delayed messages, and RabbitMQ dead‑letter queues—evaluating their advantages, drawbacks, and best‑practice recommendations for reliable order‑expiration workflows.

Message QueueRedisSpring
0 likes · 17 min read
Design and Implementation of Delayed Task Processing for Order Systems
Sanyou's Java Diary
Sanyou's Java Diary
Apr 10, 2025 · Backend Development

Why RocketMQ Beats Kafka: Architecture Simplified and Features Amplified

This article explains how RocketMQ, a Chinese‑origin message queue, simplifies Kafka’s architecture while adding powerful features such as tag‑based filtering, transactional messaging, delayed and dead‑letter queues, and a unified commit‑log storage model, making delayed processing and high‑throughput scenarios easier to implement.

KafkaMessage QueueRocketMQ
0 likes · 10 min read
Why RocketMQ Beats Kafka: Architecture Simplified and Features Amplified
Xuanwu Backend Tech Stack
Xuanwu Backend Tech Stack
Apr 10, 2025 · Backend Development

Master RabbitMQ: Core Components and Architecture Explained

This article provides a comprehensive overview of RabbitMQ, an open-source AMQP-based message broker, detailing its core components—producers, exchanges, queues, consumers, and broker—along with auxiliary elements like bindings, connections, channels, virtual hosts, and key architectural features such as decoupling, flexible routing, reliability, and scalability.

AMQPMessage QueueMessaging Architecture
0 likes · 7 min read
Master RabbitMQ: Core Components and Architecture Explained
Tencent Cloud Middleware
Tencent Cloud Middleware
Apr 9, 2025 · Operations

How TDMQ Pulsar’s Cluster‑Level and Topic‑Partition Throttling Keeps Your Messaging System Stable

This article explains why high‑throughput producers and consumers can saturate CPU, memory, network and disk I/O in TDMQ Pulsar clusters, describes the built‑in cluster‑level distributed and topic‑partition rate‑limiting mechanisms, and provides practical guidance for configuration, monitoring, and troubleshooting.

Cluster ManagementMessage QueueTDMQ
0 likes · 12 min read
How TDMQ Pulsar’s Cluster‑Level and Topic‑Partition Throttling Keeps Your Messaging System Stable