RocketMQ

2024/5/28 2:26:30

RocketMQ(一)

作用 1. 限流削峰 2. 异步解耦 组成 Producer:消息的发送者,生产者;举例:发件人 Consumer:消息接收者,消费者;举例:收件人 Broker:暂存和传输消息的通道&#xff1…

Apache RocketMQ知识点表格总结及示例

RocketMQ的使用大概还是四五年前的时候,最近几年参与的项目基本上都是使用的RabbitMQ,就我个人来说,我也更喜欢使用RabbitMQ,不过消息队列的功能都差不多,大同小异。原理也类似。我喜欢使用RabbitMQ,是因为RabbitMQ安装…

RocketMQ 消息重复消费

现象 触发消息后,在1s内收到了两次消息消费的日志。 消息消费日志重复,reconsumeTimes0,主机实例也不同,说明是同一条消息被消费了两次 分析 生产者发送消息的时候使用了重试机制,发送消息后由于网络原因没有收到MQ…

架构师系列-消息中间件(九)- RocketMQ 进阶(三)-消费端消息保障

5.2 消费端保障 5.2.1 注意幂等性 应用程序在使用RocketMQ进行消息消费时必须支持幂等消费,即同一个消息被消费多次和消费一次的结果一样,这一点在使用RoketMQ或者分析RocketMQ源代码之前再怎么强调也不为过。 “至少一次送达”的消息交付策略&#xff…

第十二章-Broker-同步刷盘(一)

12.1 刷盘 CommitLog.handleDiskFlush public void handleDiskFlush(AppendMessageResult result, PutMessageResult putMessageResult, MessageExt messageExt) {// 同步刷盘if (FlushDiskType.SYNC_FLUSH this.defaultMessageStore.getMessageStoreConfig().getFlushDiskT…

第十二章-Broker-同步刷盘(一)

12.1 刷盘 CommitLog.handleDiskFlush public void handleDiskFlush(AppendMessageResult result, PutMessageResult putMessageResult, MessageExt messageExt) {// 同步刷盘if (FlushDiskType.SYNC_FLUSH this.defaultMessageStore.getMessageStoreConfig().getFlushDiskT…

RocketMQ 消息重复消费

现象 触发消息后,在1s内收到了两次消息消费的日志。 消息消费日志重复,reconsumeTimes0,主机实例也不同,说明是同一条消息被消费了两次 分析 生产者发送消息的时候使用了重试机制,发送消息后由于网络原因没有收到MQ…

【RocketMQ知识点总结-1】

文章目录 RocketMQ介绍RocketMQ架构:NameServer:BrokerProducerTopic(主题):Queue(队列):Message(消息): RocketMQ的工作流程RocketMQ的使用场景异步消息传递…

Apache RocketMQ知识点表格总结及示例

RocketMQ的使用大概还是四五年前的时候,最近几年参与的项目基本上都是使用的RabbitMQ,就我个人来说,我也更喜欢使用RabbitMQ,不过消息队列的功能都差不多,大同小异。原理也类似。我喜欢使用RabbitMQ,是因为RabbitMQ安装…

我们在顺序消息和事务消息方面的实践

文章目录 导读第一部分: 基本介绍1. 领域模型概述1.1 消息生产1.2 消息存储1.3 消息消费 2. 消息传输模型介绍3. 普通消息的可靠性3.1 发送端怎么保证可靠性3.1.1 ACK机制 3.2 存储端怎么保证消息可靠性3.2.1 单机的刷盘机制3.2.2 主从同步 3.3 消费端怎么保证可靠性3.3.1 ACK3…

rocketmq集群搭建

1准备机器 rocketmq1 192.168.88.21 rocketmq2 192.168.88.22 下载rockermq网址:下载 | RocketMQ (apache.org) 下载java 1.8.0及以上版本 ​ 2m-2s-async 2主2从异步复制 2m-noslave 2主无从 2m-2s-sync 2主2从同步复制 本次实验采用 2主2从异步…

15. RocketMQ面试题汇总

Java全栈面试题汇总目录-CSDN博客 1. RocketMQ是什么? RocketMQ是阿里开源的分布式消息中间件。具有高性能、低延时和高可靠等特性。主要用来提升性能、系统解耦、流量削峰等。 2. RocketMQ有什么特点? 1. 灵活可扩展性 RocketMQ天然支持集群&#…

RocketMQ:高性能、可靠的消息中间件

引言: 在当今的分布式系统中,消息中间件扮演着至关重要的角色。它们作为不同服务之间的桥梁,负责解耦、异步通信和流量削峰等功能。RocketMQ,作为一款高性能、可靠、易扩展的消息中间件,受到了广大开发者的青睐。 一…

阿里云RocketMQ消费MQTT消息

业务背景: 项目中涉及的消息队列既有RocketMQ,又有MQTT,均为阿里云提供(阿里云有专门的“微消息队列 MQTT 版”模块,但博主公司消息队列的实例都在“消息队列 RocketMQ 版”模块下,只是实例不同&#xff0c…

什么是Topic

什么是topic 标识消息分类: RocketMQ的主题用于对消息进行分类和组织。通过为不同类型的消息分配不同的主题,可以使消息更具可读性和可管理性。 独立的消息队列:每个主题都有自己的消息队列,用于存储该主题下的消息。每个队列都可以并行地接收和处理消息…

Centos 7 安装 RocketMQ 5.14(保姆级)

1.yum 安装 upunzip yum install -y unzip 2.创建文件夹存放RocketMQ, 安装之前需要安装JDK mkdir -p /opt/tools/rocketmq 3.下载 RocketMQ 上传到 /opt/tools/rocketmq RocketMQ 官网下载地址 4.切换目录、解压 cd /opt/tools/rocketmq unzip rocketmq-a…