This article compares RabbitMQ, RocketMQ, and Kafka on throughput, latency, scalability, and reliability, outlining each system's core features and recommending suitable scenarios such as reliable messaging, high‑performance streaming, and large‑scale real‑time data processing.
This guide explains three ways to automatically cancel orders that remain unpaid for 30 minutes in a Spring Boot application, covering scheduled tasks, RabbitMQ delayed queues, and Redis key‑expiration events, with complete code examples and configuration details.
This article explains RabbitMQ's transaction mechanism, walks through the four-step process of opening, executing, committing, or rolling back a transaction, provides a complete Java example with Maven setup, and discusses performance impacts and when to prefer acknowledgments over transactions.
This guide shows how to use Canal to capture MySQL binlog changes, forward them through RabbitMQ, and process them in a SpringBoot application, providing a clean, decoupled way to record both new and old data for insert, update, and delete operations.
This guide walks through why a high‑traffic flash‑sale system needs a message queue, explains the three core benefits of async processing, decoupling and traffic‑shaping, and then details RabbitMQ installation, common work patterns, durability, idempotency, ordering, dead‑letter handling, high‑availability clustering and advanced features such as delayed and priority queues.
RabbitMQ supports transactional messaging to guarantee atomic delivery, using txSelect to start, txCommit to finalize, and txRollback to abort; this article explains the mechanism, outlines its advantages and performance drawbacks, and provides a complete Java example with step‑by‑step code walkthrough.
This article presents a comprehensive, end‑to‑end solution for preventing duplicate consumption in RabbitMQ by combining architecture design, routing strategies, idempotent controls, state machines, and ACK mechanisms, and details six concrete implementation options with code examples.
This guide explains why high availability is critical for RabbitMQ in micro‑service environments, compares cluster modes, provides step‑by‑step commands for building a resilient three‑node cluster, and covers monitoring, failover, performance tuning, and common pitfalls to ensure reliable message delivery.
This tutorial explains why HAProxy is essential for RabbitMQ clusters, walks through installing HAProxy on Ubuntu, configuring load‑balancing and health‑check parameters, integrating with Java applications, and validating automatic failover to ensure high availability and efficient resource utilization.
This guide explains why delayed messages are essential for distributed system stability, compares RabbitMQ's TTL+DLX and delayed‑message plugin, details RocketMQ's precise timing and delay‑level features, and offers custom Redis and time‑wheel solutions with practical Java code examples and deployment tips.
Facing frequent timeouts in the high‑traffic eLong red‑envelope API, we traced the root cause to a RabbitMQ SDK connection‑leak using Linux netstat, then resolved it by offloading the processing to a single‑threaded pool, eliminating blocking and avoiding the SDK bug.
This guide explains how RabbitMQ with MQTT provides lighter protocol overhead, built‑in QoS, reliable offline messaging and powerful topic routing, offering a more stable and scalable alternative to WebSocket for mobile, IoT and instant‑messaging scenarios, with full code examples for both front‑end and back‑end.
This article compiles detailed Java backend interview questions and answers, covering MySQL lock types, thread lifecycle states, garbage collection mechanisms, volatile semantics, RabbitMQ reliability, delayed queues, Zset usage, and practical coding examples.
This article walks through the design and implementation of a complete seckill (flash‑sale) system built on SpringBoot, MyBatis, MySQL, RabbitMQ and Redis, covering double MD5 password hashing, distributed sessions, unified exception handling, caching strategies, memory flags, pre‑decrement inventory, asynchronous order processing, oversell prevention, and rate limiting, with code snippets and UI screenshots.
This article provides an in‑depth, multi‑dimensional comparison of Apache Kafka, RabbitMQ, and Apache RocketMQ—covering design philosophy, performance, reliability, features, ecosystem, operations, and typical scenarios—to help you choose the right message middleware for your architecture.
This guide explains common use cases for delayed tasks, describes the two RabbitMQ delay‑queue methods (TTL + dead‑letter exchange and the rabbitmq‑delayed‑message‑exchange plugin), and provides step‑by‑step PHP code for configuring dead‑letter exchanges, queues, and timed message processing.
This guide explains how to use Spring's MDC to generate and propagate a traceId through HTTP requests, RabbitMQ messages, thread‑pool tasks, and XXL‑Job scheduled jobs, enabling unified log tracing without adding extra dependencies.
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.
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.
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.
This guide walks through implementing four fundamental RabbitMQ messaging patterns—simple queue, work queue, fanout (publish/subscribe), and direct routing—using Spring Boot, providing complete configuration, code samples, controller endpoints, testing commands, and production‑grade enhancements such as persistence, manual ACK, prefetch limits, dead‑letter handling, idempotency and monitoring.
This article outlines the key building blocks of a microservice architecture—including Nginx as the traffic entry, Spring Cloud Gateway, service registration, Redis caching, MySQL persistence, Elasticsearch, message queues, ELK logging, distributed scheduling, and object storage—providing practical guidance on design choices and high‑availability setups.
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.
This guide walks through setting up a Docker‑Compose environment, configuring Canal to capture MySQL binlog changes, integrating it with a SpringBoot client, and forwarding change events to RabbitMQ, providing complete code snippets and step‑by‑step instructions for real‑time data change tracking.
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.
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.
This article examines the core evaluation criteria for enterprise message queues and provides a detailed comparison of Kafka, RabbitMQ, and Pulsar—including performance, reliability, scalability, operational complexity, ecosystem maturity, and business fit—offering actionable guidance for selecting the optimal solution in cloud‑native environments.
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.
This guide walks you through installing and configuring Prometheus and Grafana, comparing Prometheus with Zabbix, adding exporters for system metrics, MySQL, RabbitMQ, Redis and TiDB, setting up dashboards, plugins, and email alerts to create a comprehensive monitoring solution.
This guide shows how to enable instant messaging using RabbitMQ's MQTT plugin, run the broker in Docker, test with MQTTX, create a web‑based chat with MQTT.js, and integrate MQTT into a Spring Boot application, all without writing custom backend code.
This article explores why high availability is critical for RabbitMQ in micro‑service environments, presents a full HA architecture diagram, compares cluster modes, details mirror‑queue and quorum‑queue configurations, walks through production‑grade setup steps, performance tuning, monitoring, network‑partition handling, failover procedures, and shares practical lessons learned.
This guide explains how to use the lightweight MQTT protocol with RabbitMQ, covering Docker setup, enabling the MQTT plugin, testing with MQTTX, creating a front‑end chat using MQTT.js, and integrating MQTT into a SpringBoot application for server‑side messaging, all without writing custom back‑end code.
This article explains RabbitMQ's system architecture, covering producers, brokers, consumers, exchanges, routing keys, bindings, queue storage, network protocols, and reliability features, using clear analogies and diagrams to illustrate core concepts.
This article provides a detailed, step‑by‑step analysis of RabbitMQ's classic queue storage architecture, covering directory layout, index and data file formats, write and read workflows, file compaction, and practical operational tips such as publisher confirms and manual acknowledgments to improve reliability and throughput.
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.
This article explores various techniques for implementing delayed tasks in Java, comparing Quartz database polling, JDK DelayQueue, Netty's HashedWheelTimer, Redis sorted sets, and RabbitMQ delayed queues, detailing their implementations, advantages, drawbacks, and practical code examples for handling order timeouts.
This article deeply examines Tencent Cloud TDMQ RabbitMQ Serverless's distributed rate‑limiting mechanism, covering its necessity, design principles, token‑based throttling architecture, implementation challenges, client‑side error handling, and practical guidelines for planning load and configuring alerts to ensure stable high‑throughput messaging.
This article explains the fundamentals, architectures, key concepts, advantages, and disadvantages of Kafka, RabbitMQ, RocketMQ, and ActiveMQ, and provides practical guidance on selecting the most suitable message queue for various application scenarios such as high‑throughput logging, financial transactions, or small‑scale services.
This guide walks you through installing software on CentOS using three primary methods—source/tarball compilation, RPM packages, and Yum—demonstrating each approach with real‑world examples such as Redis, RabbitMQ, and Nginx, and covering essential concepts, commands, and configuration steps.
This guide walks through creating a FastAPI application that both publishes and consumes messages via RabbitMQ, detailing the setup of a Pika client, asynchronous consumer, message handling, API routes, and deployment with uvicorn, complete with code snippets and testing instructions.
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.
RabbitMQ often suffers from duplicate message consumption due to network glitches, node failures, or ACK issues, but you can eliminate repeats by implementing idempotent processing, using caches or deduplication tables, and leveraging manual acknowledgments or the Message Deduplication plugin, as illustrated with Java examples.
This article explains why RabbitMQ is often selected as a message middleware, covering its reliability features, flexibility in routing, performance advantages, ecosystem support, and a concise comparison with Kafka and RocketMQ to help developers make an informed choice.
This guide walks through setting up RabbitMQ via Docker, configuring Celery with FastAPI, defining asynchronous tasks, launching workers, testing endpoints, and monitoring execution with Flower, providing a complete, step‑by‑step solution for background processing in Python web applications.
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.
This article explains RabbitMQ's transaction mechanism, outlines its basic workflow, core channel methods, provides a Java example, compares its advantages and disadvantages with the confirm mode, and offers guidance on choosing the appropriate approach for different scenarios.
This article explains what delayed queues are, details two RabbitMQ implementations using TTL with dead‑letter exchanges and the rabbitmq‑delayed‑message‑exchange plugin, provides full Java configuration and producer/consumer code examples, and outlines common use‑cases such as order timeout and refund processing.
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.
RabbitMQ, an Erlang‑based open‑source message broker implementing AMQP, uses producers, consumers, exchanges, queues, virtual hosts, connections, and channels to enable scalable, reliable asynchronous communication, with various exchange types and binding mechanisms that organize message routing in microservice architectures.
This article explains how to integrate Spring Cloud Bus with RabbitMQ (or Kafka) to automatically propagate configuration changes across multiple microservice instances, replacing manual /refresh calls with a message‑bus driven refresh workflow, and provides step‑by‑step implementation details.
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.
This article clarifies the distinct definitions, purposes, and usage scenarios of RabbitMQ's routing key and binding key, illustrating how they work together in message routing with examples for direct and topic exchanges, including code snippets for publishing and binding.
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.
This article explains why messages can be lost in RabbitMQ at the producer, broker, or consumer stages and provides concrete techniques—including confirm mode, transaction handling, persistence settings, manual acknowledgments, and retry mechanisms with dead‑letter queues—to ensure reliable delivery.
The article explains why using Redis expiration or RabbitMQ dead‑letter queues for delayed order‑cancellation tasks is unreliable, compares several approaches such as message‑queue delayed delivery, Redisson delay queues, and time wheels, and recommends robust solutions like RocketMQ or Pulsar for accurate timing.
This article compares Kafka, RocketMQ, and RabbitMQ, detailing their architectures, performance characteristics, strengths, and ideal use‑cases to help engineers select the most suitable message‑queue solution for high‑throughput, fault‑tolerant, and real‑time processing scenarios.
This article compares Kafka and RabbitMQ across design philosophy, performance, data model, delivery semantics, ecosystem, and typical use cases, helping readers choose the right messaging middleware for high‑throughput or reliable delivery scenarios.
This article explores why message queues can lose consistency, presents concrete solutions such as transactional two‑phase commits, persistence settings, replica configurations, unique IDs, idempotent designs, and dead‑letter queues, and shares ten practical lessons drawn from real‑world incidents.
This guide walks through analyzing RabbitMQ requirements, selecting self‑hosted servers, preparing CentOS nodes, installing Docker and Docker‑Compose, configuring RabbitMQ, deploying a three‑node high‑availability cluster, and validating its performance and memory usage.
This comprehensive guide explains the role of message queues in distributed systems, compares the architectures and core concepts of Kafka, Pulsar, RocketMQ, RabbitMQ, and NSQ, and provides practical criteria for selecting, configuring, and operating a message‑queue solution in high‑performance, high‑availability environments.
This comprehensive guide covers RabbitMQ fundamentals, installation on Windows, Linux, and Docker, configuration for durability and monitoring, Java integration examples, high‑availability architectures, clustering, and practical troubleshooting tips for building reliable distributed systems.
This article demonstrates how to send and receive messages as objects in Spring Boot 3 using RabbitMQ, covering custom message converters, object validation, idle‑event handling, and custom listener containers with complete code examples.
Message queues act as asynchronous communication bridges in distributed systems, and this article examines three leading solutions—Kafka, RabbitMQ, and RocketMQ—detailing their performance, scalability, reliability, strengths, drawbacks, and suitable use‑cases to guide developers in selecting the right technology.
This guide explains how to install the workerman/rabbitmq package, set up producer and consumer scripts for both Workerman and PHP‑FPM environments, and run asynchronous RabbitMQ messaging using detailed PHP code examples and configuration options.
This article compares seven practical approaches—DelayQueue, database polling, Redis queues, Redis key expiration callbacks, RabbitMQ delayed messages, scheduled task frameworks, and event‑stream processing—for automatically cancelling unpaid orders, outlining their suitable scenarios, code examples, advantages, disadvantages, and optimization tips.
This article examines seven practical approaches—including Java DelayQueue, database polling, Redis queues, key‑expiration callbacks, RabbitMQ delayed messages, scheduled‑task frameworks, and event‑stream processing—to automatically cancel unpaid orders, comparing their scenarios, advantages, drawbacks, and implementation tips for scalable systems.
This article explores ten classic use cases of message queues—from asynchronous processing and traffic shaping to distributed transactions, broadcasting, log aggregation, delayed tasks, data synchronization, and distributed scheduling—providing practical scenarios, detailed code examples, and deep analysis to help developers leverage MQ as a system lubricant.
This article examines why using Redis key‑space expiration notifications for delayed job execution is unreliable, compares common approaches such as message‑queue delayed delivery, RabbitMQ dead‑letter queues, time wheels, and Redisson DelayQueue, and provides practical recommendations for robust timeout handling in e‑commerce systems.
This tutorial walks you through installing Erlang, downloading the RabbitMQ server, starting it in detached mode, verifying its status, and troubleshooting common TCP‑listener errors on CentOS systems, providing all necessary commands and configuration details.
This guide walks through installing software on CentOS using source tarballs, RPM packages, and yum, covering terminology, step‑by‑step commands, and practical examples with Redis, RabbitMQ, and Nginx.
This article compares Kafka and RabbitMQ across design philosophy, performance, data models, delivery semantics, ecosystem, and typical use cases, helping developers choose the right messaging middleware for high‑throughput streaming or reliable task queues.
This article introduces RabbitMQ, explains its core features and messaging model, discusses why to use it for asynchronous, decoupled, and throttled processing, and provides step‑by‑step installation instructions for macOS, Windows, and CentOS along with Java code examples for configuring and using delayed messages via the rabbitmq_delayed_message_exchange plugin.
This guide walks you through installing Erlang, downloading and building RabbitMQ 3.0.4 from source on a Linux system, verifying the installations, starting the server in detached mode, checking its status, and troubleshooting common port‑conflict issues on CentOS 6.
This guide walks you through installing Erlang, downloading and extracting RabbitMQ 3.0.4, starting the server in detached mode, verifying its status, and troubleshooting common port‑conflict errors on CentOS 6, with complete command‑line examples.
This comprehensive guide compares five popular message queue systems—Kafka, Pulsar, RabbitMQ, RocketMQ, and NSQ—covering their architectures, core concepts, selection criteria, feature differences such as ordering, latency, durability, scaling, and operational considerations, to help engineers select the most suitable solution for their use cases.
This guide walks you through installing common backend services on CentOS—building Redis from source, deploying RabbitMQ via RPM, and adding Nginx with YUM—while explaining key concepts like tarballs, RPM metadata, and YUM repository configuration.
This tutorial walks through creating a remote procedure call (RPC) system with RabbitMQ in Java, covering client and server design, callback queues, correlation IDs, code examples, deployment steps, scalability benefits, and common pitfalls to avoid.
This article outlines a comprehensive backend design that abstracts WebSocket into a reusable communication service, details project structure, business processes, reliability mechanisms for RabbitMQ, message classification, API design, and a unified message format to enable plug‑and‑play real‑time messaging across various Java applications.
The article surveys major message‑queue systems—Kafka, Pulsar, RocketMQ, RabbitMQ, and NSQ—detailing their architectures, key features, selection criteria such as ordering, scalability and latency, performance benchmarks, operational considerations, and typical use cases, and advises which platform best fits high‑throughput, reliability, low‑latency, or lightweight Go‑centric scenarios.
A large table with tens of millions of rows caused 20‑second query times, but by decoupling reads through RabbitMQ and writing data asynchronously to Elasticsearch, query latency dropped to 500 ms, with Java code examples for both producer and consumer, sync handling, and migration tips.
The article chronicles the author’s evolution with message queues—from early experiments with ActiveMQ, through Redis and RabbitMQ, to MetaQ and RocketMQ—highlighting real‑world challenges, architectural decisions, scaling tactics, and practical insights for building robust asynchronous systems.
This article explains how message queues decouple and buffer tasks such as payment processing, inventory updates, and notifications in high‑traffic online stores, improving reliability, scalability, and fault tolerance through asynchronous communication.
This article outlines the design and implementation of a unified WebSocket communication service, covering background motivations, project goals, core architecture, message reliability mechanisms using RabbitMQ, message classification, API specifications, and unified message formats to enable efficient, decoupled real‑time messaging across backend applications.
The article explains why adopting a message‑queue improves microservice decoupling and responsibility boundaries, then details the design of a pluggable Base‑MQ component—including @MQEventListener, MQEvent base class, configuration, and MQClient interface—followed by concrete implementations for RocketMQ, Kafka, Redis and RabbitMQ, an example event flow, and guidance for extending the framework.
RabbitMQ is a lightweight, open‑source AMQP broker offering reliable, flexible routing, clustering, and multi‑protocol support; it can be installed via Homebrew, Windows installers, or source on CentOS, and, using the rabbitmq_delayed_message_exchange plugin, Spring Boot applications can configure custom exchanges, queues, and send delayed messages with an x‑delay header.
This article outlines the design of an internal WebSocket communication service that abstracts real‑time messaging, reduces code coupling, supports various business scenarios, ensures reliable delivery with RabbitMQ, defines unified APIs and message formats, and demonstrates a DDD‑based project structure for easy integration.
This guide explains what RabbitMQ is, walks through installing Erlang and RabbitMQ on a Linux system, shows how to start and verify the server, and provides troubleshooting tips for common startup errors such as port conflicts.
This article describes the background, objectives, core design, reliability mechanisms, message classification, API design, and unified calling approach of a company‑wide WebSocket abstraction layer that replaces polling, supports asynchronous communication, and ensures reliable message delivery using RabbitMQ and confirm mechanisms.
This tutorial explains how to configure, test, and dynamically modify the concurrency of RabbitMQ listeners in a Spring Boot application, covering dependency setup, YAML configuration, code examples, runtime adjustments, and best‑practice recommendations for optimal message processing.
This article presents a comprehensive design of a unified WebSocket communication service that abstracts messaging, improves reliability with RabbitMQ, replaces polling with push, and provides standardized APIs and message formats for backend developers to quickly integrate real‑time features.
This article details the design and implementation of a Java SpringBoot seckill system, covering its architecture, technology stack, double‑MD5 password encryption, distributed session management with Redis, unified exception handling, page and object caching, static page generation, memory‑flag plus Redis pre‑decrement and RabbitMQ asynchronous order processing, oversell prevention, and API rate limiting, accompanied by key code snippets.
This guide walks through preparing three CentOS 7 nodes, installing Erlang and RabbitMQ, configuring users and permissions, setting environment variables, enabling the management plugin, synchronizing erlang.cookie, joining nodes in RAM or disc mode, and verifying cluster status via the web UI.
This article explains RabbitMQ’s architecture, details its core components, walks through the five main messaging patterns with visual diagrams, provides complete Java code examples for each pattern, and discusses reliability mechanisms such as acknowledgments, persistence, and practical use‑case scenarios.
To prevent message loss in RabbitMQ systems, this guide explains the three-step message flow, introduces producer confirm mechanisms, demonstrates how to enable persistence for exchanges, queues and messages, outlines a database fallback strategy, and shows how to implement manual consumer acknowledgments for end‑to‑end reliability.
This guide explains RabbitMQ's core concepts, architecture, installation via 1Panel, configuration of the Webman RabbitMQ plugin, and demonstrates how to set up producers and consumers with code examples for reliable message handling.
This article explains the concept, use cases, and common implementations of delay queues—including JDK's DelayQueue, RabbitMQ plugins, and Redis ZSet—followed by a detailed guide to installing, configuring, and using the open‑source lmstfy project, and concludes with promotional information for ChatGPT‑related services.
This guide explains how to deploy RabbitMQ on Kubernetes and improve its performance through Helm installation, resource tuning, monitoring, scaling, security hardening, and advanced configuration techniques, providing practical code examples for each step.
This article explains the concept, working principle, common use cases, and various implementations of delay queues—including JDK's DelayQueue, RabbitMQ plugins, Redis sorted sets, and the Go‑based lmstfy project—along with installation, configuration, and sample client code.
This guide explains how to enable MQTT support in RabbitMQ, use MQTTBox and MQTT.js for instant messaging, and integrate MQTT into a SpringBoot application, providing step‑by‑step commands, code snippets, and configuration details for both front‑end and back‑end developers.
This article explains how to guarantee RabbitMQ message reliability—preventing loss and duplicate consumption—by covering producer‑consumer models, persistence, transaction and confirm mechanisms, consumer acknowledgments, troubleshooting steps, and compensation strategies such as retry queues and idempotent design.
