Freaks City

This guide walks through building a 3-master–3-slave RocketMQ cluster on CentOS 7, including NameServer setup, broker configuration, and the optional web console. Prerequisites JDK 8 or newer Maven 3.2+ Git Note: RocketMQ expects /usr/local/jdk by default. If your JDK lives elsewhere, update the startup scripts. Install RocketMQ Download wg ...

Message Queue Fundamentals A message queue (MQ) serves as a data structure for storing messages in a first-in-first-out manner. Key Functions of MQ Systems Decoupling Applications: Enables independent development and deployment of services Rapid System Updates: Facilitates quick modifications without system-wide impacts Traffic Management: Han ...

Standard Message Types RocketMQ supports three primary message sending modes, each balancing reliability and performance differently. Synchronous Sending: The producer blocks until it receives an acknowledgment from the broker. This ensures high reliability but incurs latency. Asynchronous Sending: The producer sends messages without waiting fo ...

Downloading RocketMQ 4.9.8 Download the release package from the official reppository: https://dist.apache.org/repos/dist/release/rocketmq/4.9.8/rocketmq-all-4.9.8-bin-release.zip Extract it to a local directory such as: D:\dev\env\rocketmq-4.9.8 Configuring ACL 1.0 for Access Control Official documentation: RocketMQ ACL Guide - ACL 1.0 is dep ...

Dependency Setup To begin, include the starter dependency in your Maven project: <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-spring-boot-starter</artifactId> <version>2.2.3</version> </dependency> This dependency triggers Spring Boot’s auto-configurati ...

Core Concepts Message tracing captures the complete lifecycle of a message, including: Producer send timestamp Broker storage details Consumer consumption events Timing metrics at each stage Configuration Broker Setup # Enable tracing in broker.conf traceTopicEnable=true Producer Implementation public class MessageProducer { private stat ...

Network Infrastructure Setup To ensure the NameServer, Broker, and Console components can communicate, establish a dedicated Docker bridge network first. docker network create rocketmq-net NameServer Containerization Dockerfile for NameServer Create a file named Dockerfile.namesrv. This configuration uses OpenJDK 8 and sets up the environment ...

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 ...