This article focuses on RocketMQ route management, service registration, and service discovery mechanisms. The design idea of message-oriented middleware is generally subscription and publishing mechanism...
RocketMQ provides a tag-based message filtering mechanism, but many of my friends have some questions during the use of RocketMQ. I inadvertently tagged the RocketMQ...
RocketMQ (HEREINAFTER referred to as MQ) is widely used as message middleware in transaction management, asynchronous decoupling, peak clipping, data synchronization and other application scenarios....
RocketMQ version 4.9.1 has some performance optimizations for brokers, and this batch of PR is mounted under ISSUE#2883. The following will be from the source...
RocketMQ Message Type "This is the 14th day of my participation in the 2022 First Update Challenge" Message type Common Message Order Message Delay Message...
NameServer is a lightweight naming service designed for RocketMQ. NameServer is simple, scalable, stateless, and non-communicating. The Rocketmq cluster works as shown below
In this article we will focus on how NameServer stores information about topic, broker, and cluster. Rocketmq-namesrv module basic introduction can be seen in its...
NameServer is a very simple Topic routing registry that acts like ZooKeeper in Dubbo and supports dynamic registration and discovery of brokers. There are two...
The project team used Alibaba RocketMQ to set different tag subscription relationships for the same consumer group, causing the problem of message loss. This paper...
NameServer is the brain of Rocketmq, designed to control multiple messaging servers and solve the single point of failure problem. 2. The NameServer to start...
Chapter 2 Installation and Startup of RocketMQ basic Concepts 1 Message A Message is a physical carrier of information transmitted by a Message system, and...
Chapter 3 How RocketMQ works 4. Message consumption Consumers can obtain messages from brokers in two ways: pull and push. The consumer group has two...
The RocketMQ source code is used to start NameServer and Broker for single deployment and send and receive messages. It is a simple QuickStart. After...
RocketMQ and the dual-master environment have been introduced in the last RocketMQ Field (1). QuickStartMaven configuration: POM.xml Producer: producer code eliminated
There are also many options for sending messages. Different modes have different system effects. Sending messages Synchronously Indicates that a Producer sends messages synchronously
Chapter 3 RocketMQ working principle 7, consumption idempotent 1 What is consumption idempotent 1 When there is a situation where consumers repeat consumption of a...
1 Message production process the Producer can write messages to a Queue in a Broker. The process is as follows: Before sending messages, the Producer...
Chapter 4 RocketMQ Application 7. Message Sending retry Mechanism 1 Indicates that Producer resends messages that fail to be sent, which is also known as...
Chapter 4 RocketMQ Application iv. Transaction Message 1 Problem Introduced here is A requirement scenario: ICBC user A transfers 10,000 yuan to CCB user B....