Tag: Message Queue
26 articles
RocketMQ Terminology and Message Model Quick Reference
RocketMQ core terminology and message model quick reference: Producer, Broker, Consumer, Consumer Group, cluster consumption, broadcast consumption, ordered messages, Tag and Queue.
RocketMQ Java API: Sync/Async Producer
Complete RocketMQ Java API tutorial, sync/async message producer (Producer), pull consumer (PullConsumer) and push consumer (PushConsumer) code examples.
RocketMQ Consumption Modes: Push vs Pull, Long Polling, O...
Deep dive into RocketMQ consumption modes: Push vs Pull comparison, long polling mechanism, consumption backlog handling and Offset management optimization. This article analyzes principles and pra...
RocketMQ 4.5.1 on JDK9+: Startup Troubleshooting Guide
Complete solution for RocketMQ 4.5.1 startup issues on JDK9+, script modifications (GC parameters, CLASSPATH, java.ext.dirs) and environment configuration. This article analyzes principles and prac...
RocketMQ Core Architecture: NameServer/Broker/Producer
RocketMQ (formerly MetaQ) technical evolution history and core architecture deep dive, NameServer, Broker, Producer, Consumer roles and deployment topology. This article analyzes principles and pra...
RocketMQ Core Features: Ordering/Filtering/Transaction/Ti...
Deep dive into RocketMQ core features: ordered consumption, Broker-side filtering, transaction messages, scheduled timing messages, consumption retry, flow control mechanism and dead letter queue. ...
RabbitMQ Message Reliability: Publisher Confirms, mandato...
Deep dive into RabbitMQ message reliability, Publisher Confirms mechanism, mandatory Return routing failure callback, message persistence and consumer idempotency practice. This article analyzes pr...
Spring Boot 2.4.1 Integration with RabbitMQ: DirectExchange
Complete Spring Boot integration with RabbitMQ tutorial, DirectExchange configuration, @RabbitListener message listener and Controller HTTP trigger delivery example.
Spring AMQP Integration with RabbitMQ: XML Configuration
Complete Spring AMQP integration with RabbitMQ tutorial, XML configuration to declare queues/exchanges/bindings, RabbitTemplate message sending/receiving and common troubleshooting. This article an...
Spring AMQP RabbitMQ JavaConfig Annotation Configuration
Spring AMQP JavaConfig annotation configuration to integrate RabbitMQ, ConnectionFactory, RabbitTemplate, Queue Bean configuration and message sending/receiving examples.
RabbitMQ Topic Exchange: Wildcard Matching
Deep dive into RabbitMQ Topic exchange, * and # wildcard rules, RoutingKey format specifications and Java producer/consumer code examples. This article analyzes principles and practices to help rea...
RabbitMQ Fanout Pub/Sub Java: Push/Pull Mode, ACK and Bin...
RabbitMQ fanout broadcast mode Java tutorial, deep dive into Push vs Pull implementation, applicable scenarios and ACK confirmation mechanism. This article analyzes principles and practices to help...
RabbitMQ Direct Exchange Routing: RoutingKey Exact Match
RabbitMQ Direct exchange routing mode details, RoutingKey exact match rules, queue multi-binding for log-level consumption and Java code examples. This article analyzes principles and practices to ...
RabbitMQ Connection/Channel Workflow Details
Deep dive into RabbitMQ Connection and Channel mechanism, AMQP frame structure packet capture analysis, and common issues and solutions under high concurrency. This article analyzes principles and ...
RabbitMQ Work Queue and Fanout Pub/Sub Patterns
RabbitMQ Work Queue task queue load balancing practice and fanout publish-subscribe mode, including manual ACK, QoS flow control and temporary queue usage guide. This article analyzes principles an...
RabbitMQ Installation and Container Quick Start: Erlang, RPM
RabbitMQ production environment RPM installation tutorial, including Erlang compatibility configuration, Docker Compose quick start, common management commands and troubleshooting. This article ana...
RabbitMQ Producer/Consumer Workflow: Connection/Channel, ...
Complete producer and consumer workflow analysis for RabbitMQ, including Connection/Channel mechanism, default exchange behavior, message acknowledgment mechanism and common troubleshooting. This a...
RabbitMQ Architecture and Exchange Routing Details
RabbitMQ architecture analysis and detailed explanation of four Exchange routing modes: fanout broadcast, direct exact, topic wildcard, headers multi-condition matching. This article analyzes princ...
RabbitMQ Message Persistence and Queue Index: .idx/.rdq, ...
Deep dive into RabbitMQ message persistence mechanism: queue index (.idx) + msg_store (.rdq) + ETS mapping + garbage collection/merge strategy, including four queue states alpha/beta/gamma/delta de...
RabbitMQ JMS Mode: Queue/Topic, 6 Message Types, Object M...
Java systems doing async decoupling and event-driven need unified understanding of JMS message model, object model and message types. JMS is a standard API (like JDBC), key is Queue/Topic semantics...
JMS Queue/Topic Cluster: Avoiding Duplicate Consumption
JMS Topic broadcasts in application cluster, causing same business to be repeatedly consumed by multiple nodes. Use ActiveMQ Virtual Topic (or JMS 2.0 Shared Subscription) to implement inter-group ...
MQ Application: Cache Warm-up, Rate Limiting, Redis Lua, ...
E-commerce seckill/ticket-grabbing scenarios with instantaneous traffic peaks, high read/write concurrency. Use pre-static + rate limiting queuing; write path uses Redis Lua atomic pre-deduction + ...
Build MQ Prototype with BlockingQueue: Producer-Consumer Gap
Implement a minimal runnable message model with queue buffering and async decoupling using Java concurrency. BlockingQueue can explain MQ core interactions, but lacks persistence, ACK, retry, clust...
MQ Selection: RabbitMQ vs RocketMQ vs Kafka
Coexisting with traditional IBM MQ, need open source, operatable, scalable, consistency/reliability. RabbitMQ suits 'reliability-first business decoupling', RocketMQ suits 'transaction/order/delay ...
Distributed Communication: SOA/Dubbo, OpenFeign, Retry vs MQ
After distributed service splitting, inter-service communication evolved from synchronous calls to async decoupling, with retry, idempotency, and reliability patterns for message-driven architectures.
MySQL Distributed Transactions: TCC, Message Queue & Saga...
Distributed transaction patterns mainly include TCC, message queue, and Saga. TCC divides traditional 2PC into three business-controllable steps, message queue achieves eventual consistency, Saga s...