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