RocketMQ
十六、RocketMQ5.0版本消费负载均衡
根据消费者类型的不同，消费者负载均衡策略分为以下两种模式： 1. 消息粒度负载均衡：RocketMQ5.x版本的PushConsumer和SimpleConsumer默认负载策略 2. 队列粒度负载均衡：PullConsumer默认负载策略 ### 消息粒度负载均衡 消息粒度负载均衡策略中，同一消费 ......
十五、RocketMQ4.x消费者负载均衡策略
### 一、AllocateMessageQueueAveragely AllocateMessageQueueAveragely就是默认的负载均衡策略，在上个例子已经演示了，可以在[这里](https://www.cnblogs.com/shigongp/p/17575805.html)查看。先分 ......
好烦呀为什么rocketmq监听打印的日志没有traceId啊
在使用springboot整合rocketmq使用方便使用注解即可实现消费，十分简洁。随之而来的是问题怎么追踪，一个链路的日志能看到是多么美好的事情。搜寻很久没有找到解决方案，于是自己搞吧！ 大前提：已经在使用spring-cloud-starter-sleuth，日志格式已经含有traceId、s ......
RocketMQ关键技术整理
form https://gitee.com/apache/rocketmq/tree/master/docs/cn 技术架构 RocketMQ架构上主要分为四部分，如上图所示： Producer：消息发布的角色，支持分布式集群方式部署。Producer通过MQ的负载均衡模块选择相应的Broker集 ......
RocketMQ 生产端与消费端
参考： en_oc：https://www.cnblogs.com/enoc/p/rocketmq-so-no-roku.html 田守枝（rebalance）：https://cloud.tencent.com/developer/article/1554950 官方文档：https://rock ......
RocketMQ 5.0 无状态实时性消费详解
RocketMQ 5.0 版本引入了 Proxy 模块、无状态 pop 消费机制和 gRPC 协议等创新功能，同时还推出了一种全新的客户端类型：SimpleConsumer。 ......
从互联网到云时代，Apache RocketMQ 是如何演进的？
RocketMQ 学习社区重磅上线！AI 互动，一秒了解 RocketMQ 功能源码。RocketMQ 学习社区是国内首个基于AIGC提供的知识服务社区，旨在成为 RocketMQ 学习路上的“贴身小二”。 ......
关于使用RocketMQ搭建多Master多Slave模式（同步）集群时遇到的问题
搭建多Master多Slave模式（同步）集群时的java.lang.NullPointerException异常 一、运行环境等基本描述（问题产生原因是权限问题，即权限不够导致无法启动broker，甚至broker线程无法通过jps命令查出。下面阐述分析思路） 1.1）操作系统：Linux 虚拟机 ......
【活动】30 秒上云体验，一键体验 RocketMQ 六大生产环境
立足于企业业务集成的核心场景，RocketMQ 在高可靠低延迟方面重点优化，构建了全新的低延迟存储引擎和多场景容灾解决方案；面向业务集成过程中链路逻辑的多样性，RocketMQ 提供了丰富的业务消息类型，这些特性的积累使得 RocketMQ 成为金融级业务消息的首选方案。 ......
RocketMQ安装部署
## 1.下载安装包解压 ## 2.环境配置 - 系统变量  ## 3.修改配置 - conf/broker.con ......
CVE-2023-33246 RocketMQ 远程命令执行漏洞分析
2023年5月23日， Rocketmq 爆出 CVE-2023-33246 RCE高危漏洞。 在一定条件下， 攻击者可以利用该漏洞通过更新配置功能以RocketMQ运行的系统用户身份执行命令 。 漏洞利用与复现 攻击者成功RCE需要满足以下条件 Rocketmq 版本 < 5.1.1 或 < 4. ......
RocketMQ on openEuler 提供高性能消息队列的稳定性解决方案
RocketMQ on openEuler 提供高性能消息队列的稳定性解决方案 openEuler2023-06-27openEuler RocketMQ on openEuler，是一种将 RocketMQ 消息中间件通过容器化的方式部署在 openEuler 操作系统上运行，借助 openEul ......
2023-07-16：讲一讲Kafka与RocketMQ中零拷贝技术的运用？
2023-07-16：讲一讲Kafka与RocketMQ中零拷贝技术的运用？ 答案2023-07-16： **什么是零拷贝?** 零拷贝(英语: Zero-copy) 技术是指计算机执行操作时，CPU不需要先将数据从某处内存复制到另一个特定区域。这种技术通常用于通过网络传输文件时节省CPU周期和内存 ......
2023-07-14：讲一讲Kafka与RocketMQ中存储设计的异同？
2023-07-14：讲一讲Kafka与RocketMQ中存储设计的异同？ 答案2023-07-14：  **在Kafka中，文件的布局采 ......
Rocketmq-背景
## 背景 消息队列（Message Queue，MQ）的三大特性：**异步、解耦、削峰** 在很多场景下，我们的业务是没有那么强的实时性的。 比如登录成功后发送短信，我们不必在登录的逻辑里实时的去调用发送短信，而是可以先“记下来”我们等下需要发送短信，然后快速的给出响应。 串行的登录+发送短信逻辑 ......
rocketMQ日常维护
1.查看topicsh mqadmin topicList -n 192.168.1.104:9876 2.删除topicsh mqadmin deleteTopic -c HOSTNAME -n 192.168.1.104:9876 -t mytest 3.创建topicsh mqadmin up ......
2023-07-12：RocketMQ如何做到消息不丢失？
2023-07-12：RocketMQ如何做到消息不丢失？ 答案2023-07-12： RocketMQ通过刷盘机制、消息拉取机制和ACK机制等多种方式来确保消息投递的可靠性，防止消息丢失。 1.刷盘机制 RocketMQ中的消息分为内存消息和磁盘消息，内存消息在Broker内存中进行读写，磁盘消息 ......
揭开 RocketMQ 事务消息的神秘面纱
事务消息是 RocketMQ 的高级特性之一，相信很多同学都对于其实现机制很好奇。 这篇文章，笔者会从**应用场景**、**功能原理**、**实战例子**、**实现细节**四个模块慢慢为你揭开事务消息的神秘面纱。  下载 Apache RocketMQ ......
一、 RocketMQ介绍
### 一、为什么选择RocketMQ 在阿里孕育 RocketMQ 的雏形时期，将其用于异步通信、搜索、社交网络活动流、数据管道，贸易流程中。随着阿里的贸易业务吞吐量的上升，源自阿里的消息传递集群的压力也变得紧迫。 根据阿里的研究，随着队列和虚拟主题使用的增加，ActiveMQ IO模块达到了一个 ......
rocketmq安装部署
1.下载wget https://archive.apache.org/dist/rocketmq/4.9.4/rocketmq-all-4.9.4-bin-release.zip 2.解压安装[root@host135 soft]# mv rocketmq-all-4.9.4-bin-releas ......
RocketMq5.0 任意延迟时间 TimerMessageStore 源码解析
#### TimerMessageStore 简略介绍 - 延迟队列 `rmq_sys_wheel_timer` - 指定时间的延迟消息。会先投递到 `rmq_sys_wheel_timer` 队列中 - 然后由 `TimerMessageStore` 消费队列数据，将数据消费到 `timerWhe ......
windows配置RocketMQ并测试发送消息
https://github.com/alibaba/spring-cloud-alibaba/wiki/RocketMQ 下载rocketmq-all-4.9.5-bin-release 保险起见配置一个RocketMQ路径的环境变量(反正我配置了，配置方法见最下面参考博客的第二个) 解压，进入解 ......
rocketmq-console基本使用
# rocketmq-console基本使用 作用：rocketmq-console是rocketmq的一款可视化工具，提供了mq的使用详情等功能。 ## 一、安装部署 > 下载rocketmq组件 **rocketmq**：[下载地址](https://rocketmq.apache.org/zh ......
聊聊 RocketMQ 主从复制
提到主从复制，我们可能立马会联想到 MySQL 的主从复制。 MySQL 主从复制是 MySQL 高可用机制之一，数据可以从数据库服务器主节点复制到一个或多个从节点。 这篇文章，我们聊聊 RocketMQ 的主从复制，希望你读完之后，能够理解主从复制的精髓。 ![](https://img2023. ......
rocketmq 随笔
sudo docker run -itd --name ubuntu2204-rocketmq \ -v /home/cl/docker/ubuntu2204-rocketmq:/home \ --restart always \ -p 9876:9876 \ -p 10911:10911 \ -p ......