登录社区云，与社区用户共同成长
邀请您加入社区
RocketMQ：介绍、架构与组件、顺序消息/事务消息工作流程、核心功能、限制、优缺点、应用场景、与其他主流消息队列对比、使用示例
三剑客组合：RocketMQ 事务消息 + 本地消息表 + XXL-Job 对账，实现分布式事务 高并发
本文探讨了分布式定时任务调度方案的演进与选择。从单体时代的Spring @Scheduled注解，到分布式环境下面临的高可用、幂等性等挑战，再到引入XXL-Job等专业中间件带来的新问题。重点分析了RocketMQ定时消息这一创新方案，通过消息投递时间替代传统调度器，实现了架构简化、高可用和自动负载均衡。文章详细比较了不同方案的优劣势：RocketMQ适合相对时间触发的简单任务，专业调度器则更适合
SpringBoot与RocketMQ整合，实现分布式场景下的订单超时自动取消功能
本机不能连接到本机的nameserver上，但是其他的节点可以，错误如下com.alibaba.rocketmq.remoting.exception.RemotingConnectException: connect to <rocketmq-nameserver1 :9876> failed仔细观察是本机的broker-a.properties文件里的namesrvAddr=rocketmq-
RocketMQ ACL 配置与安全访问摘要 Apache RocketMQ 的 ACL（访问控制列表）机制为分布式消息系统提供关键的安全保障。本文详解如何通过 身份认证+权限授权 构建安全的消息环境： 核心功能 基于 AccessKey/SecretKey 的用户认证 细粒度控制 Topic/Group 的读写权限（PUB/SUB/DENY） IP 白名单限制访问来源 配置流程 启用 broke
本文介绍了如何使用Apache RocketMQ实现基础的生产者-消费者Demo。首先讲解了RocketMQ作为分布式消息中间件的作用和应用场景，如电商系统中的异步处理。接着详细说明了环境准备工作，包括JDK安装和RocketMQ服务的两种启动方式（直接下载或Docker）。然后指导读者创建Maven项目并添加RocketMQ客户端依赖。文章采用循序渐进的方式，帮助开发者快速上手RocketMQ的
RocketMQ消息过滤技术解析：Tag与SQL92过滤机制 摘要：本文深入解析Apache RocketMQ的消息过滤机制，重点介绍Tag过滤和SQL92表达式过滤两种方式。通过Spring Boot实战示例，演示了如何利用Tag实现简单高效的消息分类，以及如何通过SQL92表达式进行复杂条件过滤。文章详细讲解了消息过滤的必要性、原理及实现方法，并提供了完整的代码示例，帮助开发者掌握Rocket
分布式中间件是现代分布式系统中不可或缺的组件之一，它扮演着连接和协调各个节点的桥梁角色。本文介绍了分布式中间件的核心原理和RocketMQ的最佳实践，希望读者可以通过本文更好地理解和应用分布式中间件。当然，分布式系统是一个复杂的领域，本文只是简单介绍了其中的一部分，读者还需要深入学习和实践。
众所周知RocketMQ消息队列一直是由阿里云作为此技术的天花板，消息队列RocketMQ版（原名开放消息服务，简称ONS）是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式消息中间件。今天小编就给大家分享一份号称是阿里云大佬分享的《RocketMQ分布式消息中间件手册》希望能对正在学习这个技术的小伙伴有到帮助!
【代码】RocketMQ学习笔记：秒杀+分布式锁 Redis RocketMQ SpringBoot。
vLLM是伯克利开源的高效大模型推理框架，通过PagedAttention分页机制和连续批处理技术显著提升推理性能，支持主流大模型在端侧和云端部署。该框架安装简便，提供Python SDK和REST API，核心API包括LLM类（推理引擎）和SamplingParams（采样控制）。实战案例展示了如何构建求职咨询对话系统和批量岗位描述生成工具，适用于应届生导航网站等场景。vLLM通过优化显存管理
我是从github上fork后下载到本地。使用idea启动nameSrv和broker。注意使用spring-boot 3.x版本后，jdk必须要17以上。所以本地需要安装jdk17。rocketMq我用的是最新的4.X版本4.9.8。版本信息是如何选择的呢？看rocketMq官网。新增application.yml文件。启动就可以看到如下，正常的生产和消费。使用spring-boot的初始化。创
本文介绍了分布式消息队列RocketMQ的核心概念与架构。RocketMQ由阿里巴巴开源，具备高吞吐、低延迟、高可用等特点，广泛应用于电商、金融等领域。文章解析了其四大核心组件：NameServer（注册中心）、Broker（消息服务器）、Producer（生产者）和Consumer（消费者），并详细说明了Topic、MessageQueue、Tag等核心概念。通过Mermaid架构图展示了Roc
项目技术栈聚支付服务端基于Spring Boot构建，采用Spring Cloud Alibaba微服务架构。业务数据持久化采用MySQL，数据缓存采用Redis，采用RocketMQ的事务消息机制完成部分场景下的分布式事务控制，采用第三方云平台完成文件上传与分布式存储。
【代码】docker挂载rocketmq(5.0)
本人安装环境：JDK1.8、RocketMQ 5.2.0 、RocketMQ-Dashboard 1.0.0 、Maven3.6.3（JDK和Maven安装教程省略，相信查看此文章的小伙伴已经非常熟悉了）
快速安装RocketMQ- Dashboard,附带官网下载地址,附带安装包可直接下载
RocketMQ控制台（RocketMQConsole）是解决消息队列监控和排查问题的利器，提供部署指南与实用功能详解。文章首先介绍控制台安装步骤，包括环境准备、下载构建和启动服务。重点讲解控制台核心功能：实时监控Broker/Topic状态、查看消息TPS、管理消费者组、查询消息轨迹（支持重发）、处理死信队列等。特别指出消费者客户端ID生成机制及Docker环境下的注意事项。通过该控制台，开发者
解决：在 rocketmq-dashboard\frontend 建一个build文件夹，然后再target目录下，建一个classes文件夹,classes下再建一个public文件夹。**起因：**访问rocketmq-externals项目的git地址，下载了源码，在目录中并没有找到rocketmq-console文件夹。git下面文档提示rocketMQ的仪表板转移到了新的项目中，点击。打
【代码】CentOS 7 搭建RocketMQ 4.6.0 双主双从集群，并使用Docker方式部署rocketmq-console-ng可视化管理控制台。
本文详细介绍了如何安装和配置 Apache RocketMQ，以及如何使用 RocketMQ Dashboard 进行可视化管理。
eventbus是分布式业务消息分发总线组件，支持广播及时消息、延时消息等（即发布/订阅模式）。组件通过屏蔽底层不同种类的消息引擎，并提供统一的接口调用，可发送及时消息和延时消息，同时可订阅及时消息或延时消息等。当我们的应用引入eventbus组件时可降低系统耦合度。目前可选择基于Redis、RabbitMQ、RocketMQ等任意一种做底层的消息引擎，其他消息引擎中间件将被陆续支持。注意：它不属
（3）控制台操作：登录 RocketMQ 控制台（如 RocketMQ-Console），找到目标 Topic 和消费组，在「消费进度」模块中，手动将偏移量重置为「最大偏移量」。RocketMQ 中新建消费组时，若未指定消费位置，默认从 Topic 的最小偏移量（Offset） 开始消费，即。（2）命令行调整：若消费组已创建，可通过 RocketMQ 命令行工具。在RocketMQ管控台，手动将消
RocketMQ提供有控制台及一系列控制台命令，用于管理员对主题，集群，broker等信息的管理；
这里订阅组指的是使用rocketmq的客户端（比如java，cpp，go，python等）进行消费时候使用的group，多个consumer可以使用同一个group进行消费，也可以使用不同的group消费。集群：整个RocketMq的集群情况，包括分片，编号，地址，版本，消息生产和消息消费的TPS等，这个在做性能测试的时候可以作为数据指标。消费详情和topic详情有点类似，不同的是topic详情展
RocketMQ Dashboard 报错：org.apache.rocketmq.remoting.execption.connect to [rmqnamesrv:9876] failed
为了保障项目组件库的质量，我们急需实施UI自动化测试。虽然之前的单元测试已经确保了API的质量，但它们无法验证视觉效果是否达到预期。经过对比各种UI自动化工具，我们选择了Playwright，以补充单元测试无法覆盖的范围，尤其是在渲染截图对比等方面。
现如今的互联网应用大都是采用分布式系统架构设计的，所以消息队列已经逐渐成为企业的应用系统内部通信的核心手段，它具有低耦合可靠投递广播流量控制最终一致性等一系列功能。当前使用较多的消息队列有 RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、MetaMQ 等，而部分数据库如 Redis、MySQL 以及 phxsql ，如果硬搞的话，其实也可实现消息队列的功能。可能有人
HA主从同步的核心类图如图所示：1、初始RocketMQ HAHAService：主从同步核心实现类。1）AtomicInteger connectionCount：Master维护的连接数。（Slave的个数）。2）List connectionList：具体连接信息。3）AcceptSocketService acceptSocketService：服务端接收连接线程实...
报错背景今天在Mac上安装了rocketmq 4.7.1的最新版本，程序调用的时候，出现了报错信息如下：Caused by: org.apache.rocketmq.client.exception.MQBrokerException: CODE: 14DESC: service not available now, maybe disk full, CL:0.92 CQ:0.92 INDEX:0
在分布式服务架构中，任何中间件或者应用都不允许单点存在，服务发现机制是必备的。服务实例有多个，且数量是动态变化的。注册中心会提供服务管理能力，服务调用方在注册中心获取服务提供者的信息，从而进行远程调用。接下来介绍一下RocketMQ的整体架构设计、集群管理。
对于分布式消息中间件而言，当不同的消息存储在不同的Broker上，生产者和消费者对于Broker的选取，路由选择会面临以下几个问题：1、生产者发一条消息，应该发到哪个Broker？消费者接收消息，从哪个Broker获取消息？2、如果Broker增加或者减少了，客户端怎么知道？3、一个新的生产者或者消费者加入，如何感知？所以，只要是跟分布式服务调用的场景，都需要一个注册中心，在RocketMQ当然也
注册中心namesrv概述在一个分布式服务系统里面注册中心是不可或缺的，因为它维护这服务的状态，防止分布式系统出现单点故障，提供高可用。假使不使用注册中心，服务发现，那么就需要在客户端配置每个服务端的信息，那么在服务端横向扩容的时候就显得很生硬，服务发现功能主要是为了让服务自动注册，让客户端能够自动感知到服务端的状态信息，从而使用一定的策略权衡调用服务。rocketmq注册中心网上普遍存在如下两个
摘要：随着AI应用快速发展，企业面临长耗时任务、高成本算力资源及流量波动等挑战。RocketMQ推出LiteTopic解决方案，支持百万级轻量Topic自动化管理，通过异步通信解决多Agent协作阻塞问题，保障会话连续性，并实现高效算力调度。该方案已在阿里云及多个AI产品中验证，显著提升资源利用率和系统稳定性。未来RocketMQ将持续优化AI场景支持，推动行业生态合作。（150字）
RocketMQ报错No route info of this topic解决方案
总结经验：碰到这种首先看网络是否ok，因为我是老项目能用，新项目不能用都在一个环境。最后能定位到就是代码问题了，那9成9就是某个包冲突了。找到它，干掉它就可以了。最近公司在做架构升级，对于RocketMq也做了升级，升级后启动项目直接报错send request to <xxxx:9876> failed。2. 继续走发现是调用服务端的问题，问题出现在netty通信上。首先声明：我这个问题不是网络
rocketmq
——rocketmq
联系我们（工作时间：8:30-22:00）
400-660-0108 kefu@csdn.net
深开鸿 技术专区
OpenTiny社区
2048 AI社区
HarmonyOS开发者社区
松山湖开发者村综合服务平台
DAMO开发者矩阵
魔乐社区
永洪数据分析社区
量化交易与投资社区
EazyDevelop社区
北京朝阳AI社区
