Our logic for this module is mainly through the use of these test classes to debug analysis mainly MappedFileQueue, MappedFile, CommitLog, MessageStore, ConsumeQueue, I
Recall that we demonstrated the Spring Cloud version of RocketMQ's sequential messages above: Sequential messages are divided into partitioned sequential messages and global sequential messages....
"This is the 17th day of my participation in the First Challenge 2022. For details: First Challenge 2022." RocketMQ consumption retry mechanism Analysis Today we...
From the application examples in the previous two articles, we already have an idea of what the architecture of RocketMQ looks like. Figure: Mainly following...
The main purpose of this series is to introduce the principles and usage of RocketMq Producer. In this series, we will introduce the initiation process...
The following example, again based on the Spring Cloud Stream programming model and combined with the implementation of Spring Cloud Alibaba RocketMQ, demonstrates the use...
In the most abstract sense, the master/slave synchronization process can be divided into three steps: The master starts the slave starts the M/S data synchronization...
The RocketMQv4.9.1 source code analysis -HA Master/Slave read/write processing to answer the Master related questions, this article around the Slave related issues continue to look...
Half messages are the first phase of a RocketMQ transaction and can consist of two parts: producer -> Broker sends half messages. The Broker processes...
This article focuses on best practices for online production environments with RocketMQ's observability tools. RocketMQ leads the industry in its visibility capabilities, with features such...
The rocketMQ-Spring consumer attribute configuration provides only a few fixed attributes for code configuration. If we want to modify the value of other attributes, what...
In normal Java project development, logging is a long way to record some key nodes in the project operation process and collect business data. SLF4J...
On January 11, 2022, the second Cloud Native Programming Challenge will have the final defense meeting, with 9 teams and 16 cloud native developers participating...
In the RocketMQ configuration, there is a configuration item 'maxMessageSize' that changes the size limits for sending and receiving messages, and here is a way...
Because the project needs to use distributed transactions, in order to solve this problem, we investigated some distributed transaction frameworks, hoping that developers can solve...
The logic of timeout cancellation is often encountered in e-commerce related services. It is very stable and convenient to implement it by using the delayed...
This paper first introduces RocksDB's implementation of LSM tree, then summarizes the design idea of LSM tree, also compares the storage design idea of Elasticsearch...