Introduction to rocketmq

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

RocketMQ message transaction

Half(Prepare) Message 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

๐Ÿ“š Demo of several message sending methods of Rocket MQ

1, Basic sample Knowledge foreshadowing 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 Start producer. 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

RocketMQ learning IX - Broker analysis

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 //producer list HashMap<String /* group name */, HashMap<Channel, ...

Added by sandrob57 on Thu, 03 Feb 2022 16:31:58 +0200

RocketMQ learning VII - Application of Netty

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

RocketMQ learning IV - message sending high availability design

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

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

How does RocketMQ Broker perceive abnormal downtime and normal offline of consumers by analyzing the fishing source code?

1, Foreword 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

Rocket introduction and stand-alone installation

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

RocketMQ - single machine and cluster installation

Stand alone installation Front work Hardware requirements: 64 bit Linux/Unix/Mac/Windows4G and above disk space Software requirements: 64 bit JDK above 1.8Maven 3.2.xGit Installation: 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