RocketMQ
【Alibaba中间件技术系列】「RocketMQ技术专题」让我们一起实践一下RocketMQ服务及其控制台安装指南
[推荐超值课程：点击获取](https://www.sanzhishu.top/) * 64位操作系统，生产环境建议Linux/Unix/MacOS（Windows操作系统安装说明详见 Windows操作系统安装教程） * 64位JDK 1.8+ * 4G+的可用磁盘 > unzip rocketm ......
【Alibaba中间件技术系列】「RocketMQ技术专题」让我们一起探索一下DefaultMQPullConsumer的实现原理及源码分析
[推荐超值课程：点击获取](https://www.sanzhishu.top/) ### 前提介绍 在RocketMQ中一般有两种获取消息的方式，一个是拉(pull，消费者主动去broker拉取)，一个是推(push，主动推送给消费者)，在上一章节中已经介绍到了相关的Push操作，接下来的章节会介 ......
RocketMQ
## 市面上MQ的简单对比 | 指标 | RabbitMQ | RocketMQ | Kafka | | | | | | | 单机吞吐量 | 1w量级 | 10w量级 | 10w量级 | | 开发语言 | Erlang | Java | Java和Scala | | 消息延迟 | 微秒 | 毫秒 | ......
【Alibaba中间件技术系列】「RocketMQ技术专题」让我们一起实践RocketMQ的服务搭建及配置操作
[推荐超值课程：点击获取](https://www.sanzhishu.top/) RocketMQ是一款分布式、队列模型的消息中间件，具有以下特点 * 1、能够保证严格的消息顺序 * 2、提供丰富的消息拉取模式 * 3、高效的订阅者水平扩展能力 * 4、实时的消息订阅机制 * 5、亿级消息堆积能力 ......
【Alibaba中间件技术系列】「RocketMQ技术专题」让我们一起探索一下DefaultMQPushConsumer的实现原理及源码分析
[推荐超值课程：点击获取](https://www.sanzhishu.top/) RocketMQ开源是使用文件作为持久化工具，阿里内部未开源的性能会更高，使用oceanBase作为持久化工具。 在RocketMQ1.x和2.x使用zookeeper管理集群，3.x开始使用nameserver代替 ......
【名师代练】带你玩转 RocketMQ，角逐「RocketMQ 首席评测官」
Apache RocketMQ 联合创始人、阿里云资深技术专家、阿里云消息产品线负责人——隆基带你玩转 RocketMQ。手把手视频教学，一键部署六大场景。 ......
《高级程序员 面试攻略 》RocketMQ 如何保证顺序性
RocketMQ 提供了一种称为顺序消息的机制来确保消息的顺序性。下面是一些关键的方法和概念： 1. 顺序消息：顺序消息是指在发送和消费过程中，消息按照特定的顺序进行处理。RocketMQ 通过将消息发送到同一个消息队列（Message Queue）来实现顺序消息。每个消息队列都有一个全局唯一的标识 ......
docker 安装rocketMQ和新版控制台
## docker 安装rocketMQ和新版控制台 参考文章：https://www.cnblogs.com/d1012181765/p/15603378.html ### 1.拉取镜像 ``` #拉取镜像 docker pull rocketmqinc/rocketmq ``` ### 2.创建 ......
RocketMQ源码阅读
 > RocketMQ中的领域概念，RTFM！！！！ > # 作为一个MQ的设计者，如何路由用户的消息  > **应一些小伙伴们的私信，希望可以介绍一下RocketMQ的基础，那么我们现在就从0开始，进入RocketMQ的基础学习及概念介绍，为学习和使用RocketMQ打好基础！** RocketMQ是一款快速地、可靠地 ......
【Alibaba中间件技术系列】「RocketMQ技术专题」帮你梳理RocketMQ相关的消费问题以及原理分析总结
[推荐超值课程：点击获取](https://www.sanzhishu.top/) ### 消息重复消费的问题 消息重复消费是各个MQ都会发生的常见问题之一，在一些比较敏感的场景下，重复消费会造成比较严重的后果，比如重复扣款等。 ### 消息重复消费场景及解决办法 > 在什么情况下会发生Rocket ......
【Alibaba中间件技术系列】「RocketMQ技术专题」帮你梳理RocketMQ或Kafka的选择理由以及二者PK
[推荐超值课程：点击获取](https://www.sanzhishu.top/) ### 前提背景 大家都知道，市面上有许多开源的MQ，例如，RocketMQ、Kafka、RabbitMQ等等，现在Pulsar也开始发光，今天我们谈谈笔者最常用的RocketMQ和Kafka，想必大家早就知道二者之 ......
【RocketMQ】消息的发送
RocketMQ是通过`DefaultMQProducer`进行消息发送的，它实现了`MQProducer`接口，`MQProducer`接口中定义了消息发送的方法，方法主要分为三大类： 1. `send`同步进行消息发送，向Broker发送消息之后等待响应结果； 2. `send`异步进行消息发送 ......
RocketMQ顺序消息
>RocketMQ 4.9.4 ### 基本原理 **目前4.9.x版本中，广播模式((MessageModel.BROADCASTING))下不支持顺序消费消息，因此只讨论集群模式(MessageModel.CLUSTERING)。没试过最新的5.x版本支不支持。** RocketMQ的topic ......
RocketMQ
使用的版本是 4.9.4，下载地址：https://rocketmq.apache.org/zh/release-notes/2022/03/04/4.9.4/。 Apache RocketMQ 使用的是 异步通信 方式和 发布与订阅 的消息传输模型。 使用 MQ 的好处： - 流量削峰：防止流量突 ......
Centos安装rocketmq
一、创建文件夹 进入我们创建好的文件夹中： //创建文件加 mkdir rockmq //进入文件夹 cd rockmq 二、下载安装包 下载自己所需的版本，我这里是rocketmq4.4.0 //下载安装包 wget https://archive.apache.org/dist/rocketmq ......
【分布式技术专题】RocketMQ延迟消息实现原理和源码分析
[推荐超值课程：点击获取](https://www.sanzhishu.top/) ### 痛点背景 #### 业务场景 > 假设有这么一个需求，用户下单后如果30分钟未支付，则该订单需要被关闭。你会怎么做？ #### 之前方案 > **最简单的做法，可以服务端启动个定时器，隔个几秒扫描数据库中待支 ......
RocketMQ Linux单机测试：简易快速部署指南及Dashboard控制台部署
[TOC](目录) ## 简介 请注意，本博客仅供初期测试时快速部署之用，以节省时间避免不必要的问题。如需在生产环境部署，请参考其他可靠的博客指南。 >本文链接: >[https://www.cnblogs.com/dks-/p/17613697.html](https://www.cnblogs. ......
RocketMQ - 顺序消息/事务消息/延迟消息
顺序消息 生产端顺序生产 消费端顺序消费 一般都是局部顺序消息。生产端根据 shardingkey 对队列数量取模，把同一个 shardingkey 的消息发送到同一个队列 而消费端也要确保消费这个队列时是一个线程消费的 首先是 consumer 中注册的 Listener 来指定是顺序消息消费还是 ......
聊聊 RocketMQ 名字服务
NameServer 是专为 RocketMQ 设计的**轻量级名字服务**，它的源码非常精简，八个类 ，少于1000行代码。  这篇文章， 笔者会从**基础概念**、**Broker发送心跳包 ......
Apache RocketMQ 远程代码执行漏洞（CVE-2023-33246）
RocketMQ 5.1.0及以下版本，在一定条件下，存在远程命令执行风险。RocketMQ的NameServer、Broker、Controller等多个组件外网泄露，缺乏权限验证，攻击者可以利用该漏洞利用更新配置功能以RocketMQ运行的系统用户身份执行命令。 此外，攻击者可以通过伪造 Roc... ......
RocketMQ 在业务消息场景的优势详解
RocketMQ 5.0 是消息事件流一体的实时数据处理平台，是业务消息领域的事实标准，很多互联网公司在业务消息场景会使用 RocketMQ。 ......
Windows启动RocketMQ
新增环境变量 新增环境变量ROCKETMQ_HOME 解压文件放置的目录，注意这个目录的下一级是有bin文件夹的，而不是还有一级rocketmq目录 启动mqnameserver服务 start mqnamesrv.cmd ## 指定ip start mqnamesrv.cmd -n 1 ......
RocketMq消费原理及源码解析
消费原理概览 先简单说下常见的rocketMq的部署方式，上图中broker为真正计算和存储消息的地方，而nameServer负责维护broker地 图中右侧consume message部分即是本文重点描述的部分，主要分为ConsumerGroup和Consumer，consumerGroup可以 ......
Apache RocketMQ 远程代码执行漏洞（CVE-2023-37582）
Apache RocketMQ是一款低延迟、高并发、高可用、高可靠的分布式消息中间件。CVE-2023-37582 中，由于对 CVE-2023-33246 修复不完善，导致在Apache RocketMQ NameServer 存在未授权访问的情况下，攻击者可构造恶意请求以RocketMQ运行的系... ......
RocketMQ学习
rabbitMQ（ons）特性 0拷贝 顺序写盘 随机读 延迟消息 事务消息 顺序消息 （rabbit没有这个） 基于netty nio框架 NameServer代替Zookeeper，寻址方式，更轻量级。 集群架构无单点，扩展性强。 消息重试机制，消息查询（rabbit不支持重试） 社区活跃、成熟 ......
Topic太多，RocketMQ炸了！
网上博客常说，kafka的topic数量过多会影响kafka，而RocketMQ不会受到topic数量影响。 但是，果真如此吗？ 最近排查一个问题，发现RocketMQ稳定性同样受到topic数量影响！！ 好了，一起来回顾下这次问题排查吧，最佳实践和引申思考放在最后，千万不要错过。 1、问题描述 我 ......
从互联网到云时代，Apache RocketMQ 是如何演进的？
*作者：隆基* 2022 年，RocketMQ 5.0 的正式版发布。相对于 4.0 版本而言，架构走向云原生化，并且覆盖了更多业务场景。 ## 消息队列演进史 操作系统、数据库、中间件是基础软件的三驾马车，而消息队列属于最经典的中间件之一，已经有 30 多年的历史。消息队列的发展主要经历了以下几个 ......
在同一个Java进程中连接多个RocketMQ集群
RocketMQ使用场景： 作为消费者：用户应用 --> MQ集群A --> 权益应用 消息内容:客户开户/销户相关消息 作为生产者：权益应用 --> MQ集群B --> 信贷应用 消息内容:卡券事件消息 问题现象： 一个Java进程要连接多个RocketMQ集群时，作为消费者功能无法正常使用，作为 ......
二十、RocketMQ5.x消费重试
消费重试指的是，消费者在消费某条消息失败后，Apache RocketMQ 服务端会根据重试策略重新消费该消息，超过一次定数后若还未消费成功，则该消息将不再继续重试，直接被发送到死信队列中。Apache RocketMQ 的消费重试主要解决的是业务处理逻辑失败导致的消费完整性问题，是一种为业务兜底的 ......