Distributed Message Queue Cluster Setup with ZooKeeper and Kafka

Message Queue Fundamentals Understanding Message Queues A message represents data transmitted between applications. Messages can range from simple text strings to complex structures containing embedded objects. A Message Queue (MQ) serves as an asynchronous communication mechanism in software systems. It decouples communication between differen ...

Posted on Wed, 17 Jun 2026 16:15:00 +0000 by nickmagus

RabbitMQ: Rate Limiting, Message Expiration, and Monitoring Techniques

Consumer Rate Limiting In scenarios where RabbitMQ servers accumulate thousands of unprocessed messages, opening a consumer client may result in an overwhelming flood of messages that a single consumer cannot handle simultaneously. When dealing with large data volumes, rate limiting at the producer side is impractical since user behavior often ...

Posted on Mon, 15 Jun 2026 16:33:29 +0000 by hessian

RocketMQ Fundamentals: Installation, Messaging Patterns, and Core Features

Overview =========== MQ (Message Queue) is a mechanism for storing and distributing message data in a structured queue format. A queue, as a fundamental data structure, follows the First-In-First-Out (FIFO) principle. Purpose of Message Queues ============================ Application decoupling (essential for distributed systems) Facilitat ...

Posted on Mon, 11 May 2026 08:59:27 +0000 by MattMan

RabbitMQ Broker Deployment and Message Routing Patterns on Ubuntu

Core Installation and Service Configuration Execute the package manager to deploy the RabbitMQ server on Ubuntu: sudo apt update sudo apt install -y rabbitmq-server sudo systemctl enable --now rabbitmq-server Once the service is active, provision an administrative account and assign comprehensive access rights: sudo rabbitmqctl add_user sys_ad ...

Posted on Sun, 10 May 2026 02:57:49 +0000 by keithschm

Integrating RabbitMQ with Spring Boot Applications

Maven Dependencies and Configuration Add the following dependency to integrate RabbitMQ functionality: <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> <version>3.2.7</version> </dependency> Configure connection parameters in a ...

Posted on Thu, 07 May 2026 16:36:16 +0000 by dta