Official address: https://rocketmq.apache.org/ Installation package download address: https://archive.apache.org/dist/rocketmq/
1, Introduction to rocketmq
RcoketMQ is a message oriented middleware with low latency, high reliability, scalability and ease of use. It has the following characteristics:
Support publish / subscribe (Pub/Sub) a ...
Added by gwledig on Thu, 10 Mar 2022 04:48:50 +0200
Semi message is a special message type. Messages in this state cannot be consumed by consumers for the time being. When a transaction message is successfully delivered to the Broker, but the Broker does not receive the secondary confirmation sent by the Producer, the transaction message is in the "temporarily unavail ...
Added by nyfael on Fri, 11 Feb 2022 12:52:50 +0200
1, Basic sample
The steps of message sending are briefly listed as follows:
Create a message producer and specify the producer group name
Contact the Broker manager nameserver first. You need to specify the nameserver address
Create a message object and specify the Topic, Tag and message body
send messag ...
Added by compound_eye on Thu, 03 Feb 2022 20:17:58 +0200
1, Data cached by BrokerBroker mainly caches routing information, including producer table, consumer table, consumerGroup table and topic table. This information is managed in producer manager, ConsumerManager, SubscriptionGroupManager and TopicConfigManager.ProducerManager
HashMap<String /* group name */, HashMap<Channel, ...
Added by sandrob57 on Thu, 03 Feb 2022 16:31:58 +0200
1, Remoting communication mechanism in RocketMQRocketMQ message queue cluster mainly includes NameServe, Broker(Master/Slave), Producer and consumer. The basic communication process is as follows:Register yourself with NameServer after the Broker is started; Then regularly report Topic routing information to NameServer every 30s;When sending a ...
Added by axnoran on Mon, 31 Jan 2022 17:16:10 +0200
We know that RocketMQ's NameServer is not strongly consistent, but ultimately consistent, that is, the client periodically obtains Broker information. If the Broker fails for a period of time, the client can't immediately sense it. How can RocketMQ achieve high availability of message sending? It can be expanded from the following three aspects ...
Added by optiplex on Sun, 30 Jan 2022 01:38:53 +0200
RocketMQ simple basic usage (III)
In the last article, I demonstrated how to get started with RocketMQ. Next, I'll learn more about how to use RocketMQ through some simple examples.
1, General message
RocketMQ provides three ways to send ordinary messages: reliable synchronous sending, reliable asynchronous sending and one-way sendi ...
Added by fordiman on Mon, 17 Jan 2022 05:34:32 +0200
When studying the consumption timeout of RocketMQ Consumer, which leads to repeated consumption, I suddenly thought of a thing: how does the Broker perceive the abnormal downtime and offline of the Consumer/Producer? And how can the remaining consumers quickly redo the load?, Originally, after sorting out the source code of Broker ...
Added by viperdk on Tue, 04 Jan 2022 03:36:25 +0200
1. Introduction to MQ
1. MQ purpose
1. Current limiting and peak clipping
mq can temporarily store the excessive requests of the system so that the system can process them slowly later, so as to avoid the loss of requests or the collapse of the system.
2. Asynchronous decoupling
The synchronous call between services is changed to MQ asynchronou ...
Added by 28rain on Mon, 03 Jan 2022 20:55:34 +0200
Stand alone installation
64 bit Linux/Unix/Mac/Windows4G and above disk space
64 bit JDK above 1.8Maven 3.2.xGit
1. Download the installation package
4.9. 2 download address
2. Upload the downloaded package to Linux
It can be uploaded through rz command. For ot ...
Added by HhAaZzEeYy on Wed, 29 Dec 2021 23:47:59 +0200