In the cluster consumption mode, after message consumption fails, the Broker redelivers the message through message retry. The Broker will retry automatically only if the...
Compared to the current popular distributed architecture, it brings a number of benefits, such as support for high concurrency, high availability clustering. It also presents...
Theoretically, RocketMQ should only need CommitLog files to run, so why maintain ConsumeQueue? ConsumeQueue is a consumption queue, introduced to increase consumption
This article focuses on upgrading a RocketMQ cluster from its original master-slave synchronization to a master-slave switch. This article first introduces the core configuration properties...
TOC preface This article uses version 4.3.0 as the standard to deploy a Single RocketMQ instance under Linux, requiring a JAVA environment to be configured....
A complex distributed system must consider using MQ to solve the problem of communication decoupling. More and more open source MQ is available on the...
This section describes the Rebalance process. Before we introduce the Consumer consumption message flow, let's introduce the process of Rebalance, which involves starting a Consumer....
RocketMQ- Architecture design 1 Technical architecture The RocketMQ architecture is divided into four parts, as shown in the preceding figure: Producer: distributes messages and supports...
In the previous article, we learned about the message retry mechanism in RocketMQ and how retry messages are processed at both Producer and Consumer. RocketMQ...
Step 1 Start the registry. Step 2 Start server 3. Start the console administration system to check whether the server is registered with the registry....
RocketMQ uses transaction messages to solve distributed transactions. A transaction, as you probably know, is a logical set of operations. The units that make up...
The main purpose of this series is to introduce the MQadmin management tools. Common mqADMIN management commands and the mqADMIN command execution process are introduced...
The producer sends the transaction message, assuming that the transaction message Topic is topic1-trans. The first Topic that the Broker gets to change the message...
Rocketmq image download 2. Start MQNAMesRV Use Dockerps to check whether the MQNAMesRV container is started successfully (running) 3. Where is the mqBroker created profile...
RocketMq processes deployed on the server are commonly referred to as brokers. Brokers receive messages from Producer, persist them locally, and then push them to...
RocketMQ is a pure Java message queue framework developed by Alibaba. There are other Java message queue frameworks such as Kafka, Rabbitmq, etc. There are...
RocketMQ uses long polling, which combines the advantages of both push and pull modes. Here is a brief introduction to long polling and further analysis...
[PCBUSY_CLEAN_QUEUE]broker busy' is an error log output by the client. A look at the call stack reveals that the start() method of the brokerFastFailure member...
This is a readme document based mainly on the RocketMQ source code, which summarizes the main processes and key points, and analyzes the source code...
2, remember to modify the JVM parameters when starting, otherwise the local cluster will instantly explode when starting, a single Broker memory is 8GB, you...