Freaks City

RocketMQ provides two distinct consumption models: clustering and broadcasting, each suited to different architectural requirements. Core Behavioral Differences Clustering mode: Messages from a topic are distributed across consumers within the same group—each message is processed by exactly one instance. This enables horizontal scaling and fa ...

Transactional Messaging Core Concepts Transactional messaging in RocketMQ implements the local transaction table pattern from distributed systems, substituting message middleware for database operations while handling status verification automatically. Unlike Apache Kafka's transaction implementation focused on Exactly-Once semantics for stream ...

1. Prerequisites in Alibaba Cloud Before integration, provision a commercial RocketMQ instance and create the flolowing resources: Standard topic and consumer group for plain messages. Dedicated delay topic and cosnumer group for scheduled/delay messages. 2. Project Structure The example follows a typical Spring Boot project layout; configura ...

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