This article explains the concept of RabbitMQ dead‑letter queues, the three conditions that turn a message into a dead letter, how to configure DLX and routing keys in Spring Boot, common pitfalls, a classic order‑timeout use case, and typical interview follow‑up questions.
This article demonstrates how Spring Cloud Stream provides a unified programming model that decouples business logic from the underlying message broker, allowing a single codebase to work with RocketMQ, Kafka, or RabbitMQ by only changing configuration, and walks through project structure, implementation, conditional routing, MQ switching, testing, and common pitfalls.
This tutorial explains why microservices need a message queue, outlines RocketMQ’s core concepts, shows how to set up RocketMQ with Docker Compose, integrates it into Spring Boot projects with detailed producer and consumer code, provides testing steps, and lists common pitfalls and solutions.
The article explains why delayed messaging is a common requirement in modern applications, compares the native dead‑letter‑queue TTL method with the RabbitMQ x‑delayed‑message plugin, and provides step‑by‑step SpringBoot integration, configuration, producer/consumer code, testing instructions, and practical cautions.
Since March 2026, WeChat’s official iLink Bot API enables personal accounts to legally receive and send messages, and this article explains the protocol’s features, compares it with older reverse‑engineering methods, and provides a step‑by‑step guide to using the JiLink Java SDK, including code samples and pitfalls.
Facing explosive growth, the game‑service platform 悠悠有品 rebuilt its architecture on Alibaba Cloud, using RocketMQ for core transaction messaging and Kafka for data synchronization, achieving elastic scaling, high availability, cost reduction, and reliable high‑concurrency processing across its trading and analytics pipelines.
The article details how the "Qinbao" parenting app, serving over ten million daily active users and massive photo/video uploads, tackled high‑concurrency writes, instant cross‑device notifications, and distributed transaction consistency by migrating to Alibaba Cloud RocketMQ 5.x Serverless, achieving millisecond latency, elastic scaling, and near‑perfect reliability.
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.
Facing massive traffic spikes from viral marketing events, the leading tea brand Guming transformed its digital foundation by adopting a cloud‑native micro‑service architecture, leveraging Alibaba Cloud MSE and RocketMQ Serverless to achieve elastic scaling, cost savings, strong consistency, and full‑stack observability for stable, high‑speed operations.
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.
Facing limited visibility, routing, and security in traditional MQ-based financial systems, a company evaluated its needs for identity control, routing, auditing, low latency, scalability, ordering, and replay, and chose Apache Pulsar for its multi‑cluster, compute‑storage separation, pluggable authentication, rich API, and functions, outlining practical experiences and solutions.
The article reviews the eleven Apache projects graduating to top-level status in 2025, explaining how each—ranging from big‑data shuffle services and unified data processing to dev‑ops analytics, web frameworks, and messaging platforms—addresses specific infrastructure challenges and why they merit inclusion in modern technology stacks.
The Guangzhou AI‑native application salon gathered over 140 tech professionals to share deep technical insights on AgentScope Java, the HiMarket AI platform, Serverless‑based AgentRun, LoongSuite observability, and RocketMQ‑driven A2A communication, concluding with a hands‑on workshop for building intelligent agents.
This guide explains why modern distributed enterprises need a reliable, high‑throughput messaging system, outlines core concepts, design principles, technology selection, architecture components, best‑practice implementation steps, and provides concrete Kafka producer and consumer code examples.
This guide explains Chrome's multi‑process architecture, the roles of each extension script (manifest, popup, background, content, injected), and how they communicate via chrome.runtime, chrome.tabs, and window.postMessage, with practical code examples and diagrams.
The article explains how RocketMQ 5.x’s storage‑compute decoupling and POP consumption model require a new gRPC client, and how Tencent Cloud’s virtual‑queue solution provides full compatibility for legacy Remoting SDKs by abstracting queues and transparently converting consumption modes, eliminating client‑side rebalance and preserving order guarantees.
The article shares eye‑opening ByteDance campus salary data, breaks down salary tiers, and then provides detailed interview preparation covering design patterns, HashMap concurrency pitfalls, MySQL indexing rules, query optimization, handling large JSON fields, stock‑decrement bottlenecks, RabbitMQ vs RocketMQ differences, and distributed‑transaction strategies.
This article analyzes the current bottlenecks of Bilibili's private messaging service, explains the technical challenges of massive data volume and traffic spikes, and presents a comprehensive multi‑layer architecture upgrade—including cache strategies, BFF refactoring, database sharding, and consistency mechanisms—to ensure scalability and reliability.
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 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 guide walks you through adding MQTT dependencies, configuring connection parameters, creating a unified MqttConfig class, defining a messaging gateway, implementing service and controller layers, and applying advanced production settings such as SSL/TLS, multi‑topic subscriptions, QoS choices, clustering, health checks, and performance tuning for Spring Boot applications.
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.
This guide walks you through the core Kafka commands for starting and stopping the service, creating, listing, describing, and deleting topics, as well as producing and consuming messages, while explaining key parameters such as Zookeeper, partitions, and replication factors.
This article examines Grok 4’s impressive 45% HLE score—nearly double Gemini 2.5 Pro—explaining its significance in AI evaluation, and then delves into the technical challenges of implementing reliable read‑receipt mechanisms for group messages, covering data storage and acknowledgment strategies.
This article provides a comprehensive analysis of Apache Pulsar's Producer component, detailing its message-sending workflow, key design principles, configuration parameters, and practical performance tuning techniques to improve throughput, reduce latency, and lower resource consumption in large‑scale cloud‑native messaging systems.
This guide presents ten essential operations tools—including Zabbix, Prometheus, MySQL, Redis, Ansible, Jenkins, Docker, Kubernetes, LVS, and Kafka—covering monitoring, databases, automation, containerization, and load balancing, to help engineers shift from reactive firefighting to proactive, efficient system management.
This guide walks through the problem of server‑initiated push in a Spring Boot project, explains why WebSocket is needed over HTTP, and provides step‑by‑step Maven setup, configuration classes, controller code, a test HTML page, and troubleshooting tips for proper initialization.
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 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.
This article explains how to integrate the Ably real‑time messaging service into a PHP project using Composer, covering installation, basic usage such as publishing messages, retrieving history, and checking channel status, and demonstrates the benefits of simplified development and global data synchronization.
This article explains how to solve real‑time data synchronization challenges by integrating the Ably PHP library via Composer, covering installation, basic usage examples such as publishing messages, retrieving history, and checking channel status, all with clear code snippets.
This article explains how to integrate the Ably real‑time messaging platform into a PHP project using Composer, covering installation, basic usage such as publishing messages, retrieving history, and checking channel status, and demonstrates how it simplifies global real‑time data synchronization.
The article recaps Zhihu's Cloud Native Innovation Forum where experts from AutoMQ, OceanBase, and Flashcat shared practical solutions on streaming data ingestion, unified database architectures, and AI‑driven observability, highlighting real‑world deployments, performance optimizations, and cost‑saving strategies.
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 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.
This article explains Apache Pulsar’s fast‑growing adoption, its compute‑storage separation architecture, BookKeeper‑based persistence, multi‑tenant support, flexible subscription models, and fault‑tolerant design, providing a comprehensive overview for developers interested in modern distributed messaging middleware.
This tutorial explains the STOMP protocol, its frame structure, and how Spring Boot 3 integrates STOMP over WebSocket, providing step‑by‑step code examples for enabling STOMP, sending and receiving messages, handling headers, asynchronous processing, exception handling, and simple publish‑subscribe without a controller.
This article examines the trade‑offs of sending messages before, during, or after database persistence in order‑creation workflows, explores transaction‑message patterns, half‑message checks, and message‑table strategies, and offers practical guidance for building reliable backend messaging systems.
The article outlines a comprehensive microservice architecture by describing essential backend components such as Nginx as the traffic entry, Spring Cloud Gateway, service registries like Nacos, Redis caching and distributed locks, MySQL persistence, Elasticsearch, message queues, ELK logging, distributed schedulers, and object storage solutions, while also noting related tooling and best‑practice considerations.
To simplify RocketMQ usage, I designed an internal SDK that abstracts complex client configurations, offering single‑call ordered message sending, per‑message consumption, unified result handling, and enforced consistent subscription settings, thereby reducing developer effort and preventing common integration errors.
This article systematically outlines the requirements, evolution stages, functional and non‑functional specifications, and component design of a scalable, high‑availability enterprise notification platform that supports multi‑channel push (email, SMS, chat, WeChat, DingTalk, etc.) through a microservice‑based architecture.
This article dissects WeChat's early message‑sending and receiving architecture, explaining how the system meets real‑time delivery and no‑loss guarantees through a multi‑stage server pipeline, push notifications, and a sequence‑based acknowledgment mechanism, illustrated with concrete flow diagrams and numeric examples.
An in‑depth look at WeChat’s early messaging system reveals how its backend architecture—comprising ConnectSvr, SendSvr, PushSvr, and a sequence‑based loss‑prevention mechanism—ensured near‑real‑time delivery and prevented message loss, even under weak network conditions.
Message Queues (MQ) are essential for scalable, decoupled systems, offering asynchronous communication, reliability, buffering, and high availability; this guide explains MQ fundamentals, characteristics, architectures like point-to-point and publish/subscribe, core components, design considerations, and reviews popular solutions such as RabbitMQ, Kafka, ActiveMQ, RocketMQ, and Pulsar.
This article analyzes the challenges of tightly coupled message‑business code, duplicated service implementations, and intermittent message loss, then details the design of the X‑Pigeon centralized messaging platform—including its three‑element model, lifecycle states, rate‑limiting strategies, and template system—to achieve scalable, reliable communication across microservices.
This article provides an in‑depth introduction to RocketMQ, covering its evolution, core components, message domain model, key characteristics such as ordered delivery and deduplication, and typical use cases like traffic shaping, asynchronous decoupling, and distributed transaction messaging.
The article describes the background, pain points, and detailed design of the Xinge messaging platform, including decoupling of messages, lifecycle management, rate‑limiting strategies, template usage, and future enhancements to provide a unified, reliable backend service for business notifications.
The article outlines Apache RocketMQ's evolution from a traditional message queue to a cloud‑native, serverless‑ready unified engine that handles messaging, events, and streams, detailing its architectural milestones, edge‑cloud integration, and the new serverless‑focused features introduced in version 5.0.
This guide demonstrates how to use Python's ItChat library to programmatically send text, image, and video messages to multiple WeChat contacts, including code examples, setup instructions, and troubleshooting tips for Windows environments.
This article compares RabbitMQ and Apache Kafka across dimensions such as message ordering, routing, timing, retention, fault handling, scalability, and consumer complexity, and provides practical guidance on when to choose each platform for backend architectures.
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.
This article examines the false empty response issue caused by long‑polling coupling in RocketMQ 5.0 SimpleConsumer, analyzes existing approaches, and presents an adaptive, stateless proxy solution that decouples client and broker polls, adds notification, and includes metrics and configuration guidance.
By applying a six‑step growth formula—motivation, product thinking, problem definition, solving, derivative thinking, data validation, and summarizing—the author transformed Alibaba’s ACCS long‑connection messaging service, cutting latency by 40%, eliminating cold‑start delays, and dramatically reducing user complaints while aligning technical work with business goals and social responsibility.
MQTT is a lightweight, publish/subscribe messaging protocol ideal for IoT and mobile environments, offering low bandwidth usage, reliability, and TLS/SSL security, and the article provides a detailed PHP example demonstrating connection, subscription, publishing, message processing, and graceful disconnection.
This tutorial explains how to deploy a single‑node Pulsar cluster with Docker, configure the Java client in a Spring Boot application, and create producers and consumers with detailed code examples and parameter explanations.
This article presents a detailed curriculum for backend development, covering fundamental concepts and practical topics such as database design and optimization, popular frameworks like Spring and Hibernate, microservice architecture, message middleware (Redis, RabbitMQ, Kafka), common data structures, concurrency, JVM internals, and related interview questions.
This guide explains how to integrate PHP with WeChat Work by registering a corporate account, creating an application, obtaining credentials, using PHP’s HTTP requests to acquire access tokens, and sending messages or retrieving user data, including a complete code example.
This article examines various order timeout handling techniques in e‑commerce, detailing JDK’s DelayQueue, RabbitMQ delayed messages, RocketMQ timer‑wheel, Redis expiration listeners, and distributed batch processing with SchedulerX, comparing their advantages, drawbacks, and suitability for different latency and scale requirements.
This article explains how Apache Pulsar combines messaging, storage, and lightweight function computing into a cloud‑native streaming platform, detailing its architecture, storage‑compute separation, tiered storage, pluggable protocols, reliability guarantees, and rich ecosystem compared with traditional queues and Kafka.
The article explains Baidu's need for low‑cost, high‑latency full‑user notifications, analyzes existing IM architecture limitations, introduces a public mailbox read‑expansion approach, compares three push strategies, and details the design, management, caching, tiered release, advantages, drawbacks, and real‑world applications of this solution.
This article explains how to configure Spring Boot 2.7.10 for AMQP‑based RabbitMQ and Apache Kafka messaging, covering property settings, connection factories, template customization, sending and receiving messages, listener containers, retry mechanisms, and stream processing with code examples.
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.
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.
Since launching a systematic stability‑governance program in August 2022, Xianyu’s messaging system has employed gray releases, dedicated monitoring, daily automated regression, dependency reviews and drills, resulting in near‑zero online incidents within six months and demonstrating that continuous, context‑specific measures and vigilant change management are essential for reliable C2C transactions.
This article presents a complete technical design template for a CRM user reach module, detailing project overview, requirements, design goals, architecture choices, detailed process, algorithms, data models, interfaces, risk assessment, testing strategies, and deployment steps to ensure scalability, reliability, and observability.
The 2022 Vivo developer conference showcased a series of technical breakthroughs—including a custom wepy‑chameleon compiler for frontend upgrades, low‑code platforms for backend and game development, a real‑time computing platform built on Flink, advanced graph scheduling, cloud‑native container strategies, monitoring enhancements, database automation, and large‑scale messaging middleware—highlighting Vivo's comprehensive push toward efficiency and innovation across its internet services.
This article provides a comprehensive overview of RocketMQ messaging concepts—including synchronous, asynchronous and one‑way sending, ordered and delayed messages, transaction handling, batch processing, tag/SQL filtering, retry mechanisms, and dead‑letter queue management—accompanied by Java code examples for each scenario.
This article compares standard service interfaces and standard messaging, explains their characteristics, and shows how to choose the appropriate approach for different scenarios such as content moderation, points systems, open platforms, monitoring, and task execution pipelines.
RocketMQ 5.0 introduces a brand‑new unified API built on gRPC, refines client types, adds four message categories, pre‑fetches topic routes, embeds a telemetry channel, and provides OpenTelemetry‑based tracing and metrics, all while offering a cloud‑native SDK repository for developers.
This article details the challenges of scaling RabbitMQ, the evaluation of RocketMQ versus Pulsar, the design of a new messaging middleware platform with high availability, performance, and rich features, and the step‑by‑step migration strategy that enabled seamless, low‑cost transition for massive business traffic.
This article analyzes a real‑world Kafka outage caused by killing a broker process, explains why partitions with a replication factor of one lose their leader, and walks through the internal Zookeeper‑based failover mechanism and leader‑election logic that Kafka uses to recover from such failures.
The article explains fundamental concepts, common use cases, and selection criteria for four popular message‑queue platforms—Kafka, RabbitMQ, Pulsar, and RocketMQ—detailing each system’s architecture, strengths, and drawbacks so readers can match workload, scalability, ordering, latency, and operational needs to the most suitable middleware.
This article introduces RabbitMQ as an open‑source AMQP‑based message broker written in Erlang, outlines its major advantages and drawbacks, and explains core concepts such as producers, exchanges, queues, and consumers for backend developers.
To address RabbitMQ’s scalability, reliability, and feature limitations, Vivo’s middleware team evaluated RocketMQ and Pulsar, selected RocketMQ, and built a next‑generation message middleware platform with an AMQP‑proxy gateway, metadata services, and high‑availability mechanisms, enabling seamless, high‑throughput migration and richer messaging capabilities.
This article explains the fundamental components and mechanisms of RabbitMQ, RocketMQ, and Kafka—including exchanges, TTL, confirm and return listeners, consumer ACK/NACK, dead‑letter queues, delay and ordered messages, transactional flows, high‑availability setups, load balancing, partitioning, leader election, offset handling, and practical solutions to common messaging challenges.
This article provides an in‑depth technical guide to three major message‑queue systems—RabbitMQ, RocketMQ, and Kafka—covering their core components, exchange and routing mechanisms, durability features, consumer acknowledgment, dead‑letter handling, load balancing, and practical strategies for reliability, ordering, and scaling in distributed backend applications.
Facing scaling, high‑availability, and feature limitations of RabbitMQ, the vivo middleware team evaluated RocketMQ and Pulsar, chose RocketMQ, and detailed a seamless migration strategy—including a message gateway, metadata mapping, high‑performance push, consumption controls, and operational benefits that boosted TPS and reduced resource usage.
This article provides a comprehensive overview of Kafka’s core components—including brokers, topics, partitions, producers, and consumers—explaining their roles, log structures, replication mechanisms, and the system’s architecture, supplemented with practical visual illustrative diagrams.
This article provides an extensive overview of backend architectural concepts, covering microservices fundamentals, gateway design, service registration, configuration management, observability pillars, tracing standards, logging practices, metric collection, service mesh implementations, and a detailed comparison of modern message queue technologies.
This article provides an in‑depth overview of modern backend architecture, covering microservice fundamentals, design principles, gateway patterns, service registration, configuration management, observability pillars, service mesh options, and a detailed comparison of popular message‑queue technologies.
The Apache Pulsar 2.10.0 release introduces automatic cluster failover, lazy‑loading producers, new TableView support, enhanced broker interceptors, enriched client authentication, Etcd metadata storage, and numerous bug fixes, offering developers and operators a more flexible and performant messaging platform.
This article explains how large hotel‑booking platforms such as Airbnb, Booking.com and OYO use a micro‑services architecture, load balancers, master‑slave databases, caching, message queues, Elasticsearch, Cassandra and Hadoop to deliver seamless hotel management, search, booking and view‑booking services at massive scale.
This article provides an in‑depth overview of modern backend architecture, covering microservice fundamentals, service mesh concepts, observability pillars, messaging queue choices, and practical design considerations such as service registration, configuration centers, and security mechanisms.
This article surveys various delayed‑queue solutions—including Kafka pause/resume, RocketMQ delay levels, Redis/Redisson zset timers, Youzan's custom design, Netty's HashedWheelTimer, and a Kafka‑based time‑wheel—analyzing their architectures, pros and cons, and offering practical implementation guidance.
This article examines the problem of data inconsistency when writing to both a database and a cache, outlines four typical dual‑write strategies, analyzes their drawbacks in high‑concurrency scenarios, and recommends the most reliable approach—writing to the database first followed by cache deletion with retry mechanisms.
This article presents a comprehensive design of an order state machine for transaction systems, addressing multi‑state, multi‑type, multi‑scenario complexities through vertical business isolation, horizontal logic reuse, state pattern, template methods, validators, plugins, and consistency mechanisms between database updates and messaging.
This article provides an in‑depth overview of Kafka, covering why messaging systems are needed, core concepts, cluster architecture, performance optimizations such as sequential disk writes and zero‑copy, resource planning, deployment steps, configuration details, operational tools, and advanced topics like custom partitioners and time‑wheel scheduling.
This article explains why traditional delay solutions like Redis expiration, database polling, or JVM DelayQueue are inefficient, then demonstrates step‑by‑step how to configure RabbitMQ’s delayed‑queue plugin, create exchanges, queues, and bindings in Spring Boot, and send and consume delayed messages with code examples.
This article details how the Beike instant‑messaging system was analyzed, bottlenecks identified, and a series of backend optimizations—including business isolation, increased concurrency, computation reduction, and Redis connection‑pool redesign—were applied to boost 300‑person group‑chat throughput from 15 QPS to over 320 QPS, achieving more than a twenty‑fold performance gain.
This article explains the fundamentals of event‑driven architecture, outlines when it should be used, describes common patterns such as event notification, state transfer, event sourcing, and CQRS, and provides a detailed example of applying these concepts in a content‑platform microservice system with code snippets and deployment considerations.
The article explains enterprise integration as the essential practice of connecting applications, data, and devices across distributed, cloud‑native environments, covering its evolution, key challenges, and core techniques such as messaging, application connectors, data flow platforms, integration patterns, and APIs.
The iQIYI Basic Data Platform unifies internal data exchange standards, integrates massive multi‑business data, and implements high‑availability solutions for ID services, messaging, HBase storage, and read‑write scaling, showcasing practical engineering approaches to big‑data reliability and performance.
This guide explains how to achieve 99.999999% reliability in RabbitMQ message delivery by using publisher confirms, persisting exchanges/queues/messages, storing outbound messages in a database, and switching consumers to manual acknowledgments to prevent loss in extreme failure scenarios.
This tutorial walks you through installing the itchat Python library, logging into WeChat, searching friends, sending messages, registering message handlers for text, images and recordings, storing media files, and capturing withdrawn messages, all with clear code examples and screenshots.
This article explains why message acknowledgment is crucial in Apache Pulsar, describes the four ack modes, shows which subscription types support each mode, and details the internal implementation, batching, negative ack handling, and unacknowledged‑message processing for reliable broker‑consumer communication.
This article provides a comprehensive overview of RabbitMQ, covering the AMQP protocol fundamentals, key components such as connections, channels, exchanges, queues, and bindings, as well as message structures, various messaging patterns, consumption models, financial‑grade features, and a detailed feature comparison.
This article walks through installing the itchat Python library, logging into WeChat, sending messages, registering message handlers for text, images, and recordings, and storing chat data, providing a complete tutorial for building a simple WeChat automation script.
This article examines RocketMQ's routing registration process, identifies its two main shortcomings—delayed failure detection and NameServer inconsistency—and explores how network partitions can cause prolonged data inconsistency, uneven message distribution, and partitioned consumption, while discussing the architectural trade‑offs behind these design choices.
This article explains how to set up Spring Boot and RabbitMQ message confirmation, covering environment preparation, publisher and consumer callback implementations, acknowledgment methods, testing procedures, and practical pitfalls such as missed acknowledgments, infinite redelivery loops, and duplicate consumption.
The Xianyu instant‑messaging system evolved from a 2014 MVP to a robust, multi‑version architecture—adding distributed storage, hybrid sync, ACK‑based delivery, and feature‑driven monitoring—to handle billions of messages, improve stability, and boost user satisfaction, cutting technical complaints by half.
