This article explains the ABA concurrency issue in distributed systems and presents three practical solutions—using Redis locks, implementing optimistic locking with version fields, and leveraging ordered message queues—to ensure data consistency under concurrent updates.
This article explains RocketMQ's advanced features—transactional messaging, ordered messaging, SQL‑based filtering, delayed messaging, and global high‑availability—detailing their principles, implementation steps, practical demos, and how they solve consistency challenges in large‑scale e‑commerce systems.
This tutorial walks through practical implementations of RocketMQ transaction, ordered, filtered, and delayed messages using native Java code and Spring Boot, explaining the underlying concepts, showing complete code examples, and highlighting how to configure producers, consumers, and listeners for reliable distributed messaging.
RocketMQ consumers initialize by validating configuration, creating subscription data, establishing a client instance, loading offsets, and starting services before registering with the client factory, after which they can receive messages via push (default low‑latency) or pull modes, support ordered processing, and handle acknowledgments with configurable retries and dead‑letter handling.
This article explains how to achieve high‑throughput, high‑availability ordered messaging in RocketMQ by using multi‑partition designs, routing strategies, and consumer locking mechanisms to guarantee local order while handling scaling, failures, and consumer concurrency.
