Tag: RocketMQ

Install rocketmq DLedger high availability cluster

Architecture Description: RocketMQ Dledger cluster architecture Most versions before RocketMQ 4.5 are deployed using the Master-Slave architecture, which can ensure that data is not lost to a certain extent and ensures a certain degree of availability. But the flaws of that method are obvious. The biggest problem is that after the Master Broker hangs up, […]

[RocketMQ Series 13] RocketMQ’s cluster core concept of consumption retry & dead letter queue & emergence and processing of idempotent messages

Hello, I am Fei Ge (wei158556), a coder. Thank you for reading this article. Welcome to connect three times with one click. 1. Python basics column, covering all basic knowledge in one place. If you buy it for 9.9 yuan, you will not suffer a loss or be cheated. Python from beginner to proficient 2. […]

[RocketMQ Cluster] Build RocketMQ dual master dual slave cluster on Linux

In today’s big data era, the message queue system has become one of the important components for building highly available, scalable and reliable distributed applications. As an open source distributed messaging middleware, Apache RocketMQ is popular for its high throughput, low latency and reliability. In order to meet the needs of large-scale applications, building a […]

Installation of rocketmq in centos7

Original link: http://www.duozhi.online/2023/10/20/Installation of rocketmq in centos7/ 1. Node information 192.168.0.208 192.168.0.209 hosts configuration on ansible [root@MES-203 ~]# cat /etc/ansible/hosts [rockq] 192.168.0.208 ansible_ssh_user=root ansible_ssh_pass=admin 192.168.0.209 ansible_ssh_user=root ansible_ssh_pass=admin For firewall and time synchronization, please refer to redis, which has already been done when building redis. 2. Install jdk [root@MES-203 ~]# ansible rockq -m shell -a “yum […]

Message queue RocketMQ message repeated consumption problem (causes and solutions)

Table of Contents 1. Reasons for repeated consumption 2. Solve 2.1 Database insertion method 2.2 Using Bloom filters 2.2.1 Add hutool dependencies 2.2.2 Test producer 2.2.2 Test consumers 1. Reasons for repeated consumption In BROADCASTING (broadcasting) mode, all registered consumers will consume, and these consumers are usually microservices deployed in the cluster, so that multiple […]

[RocketMQ Series 5] Message Example-Implementation of Sequential Messages & Delayed Messages & Broadcast Messages

1. Preface In the previous article, we introduced the implementation of simple messages. This article will mainly introduce the implementation of sequential messages. Sequential messages are divided into local sequential messages and global sequential messages. Sequential messages mean that when consumers consume messages, they consume them in the order in which the producers send them. […]