文章 2023-06-06 来自:开发者社区

RocketMQ 学习社区重磅上线!AI 互动,一秒了解 RocketMQ 功能源码

作者:RocketMQ学习社区RocketMQ 背景Apache RocketMQ 诞生至今,一直服务于 100% 阿里集团内部业务、阿里云以及开源社区数以万计的企业客户。历经十多年双十一严苛流量验证的 RocketMQ,承载了超过万亿级消息规模的洪峰压力。2021 年 Apache RocketMQ 更是进入全新 5.0 时代。立足于企业业务集成的核心场景,RocketMQ 在高可靠低延迟方面....

RocketMQ 学习社区重磅上线!AI 互动,一秒了解 RocketMQ 功能源码
文章 2023-05-31 来自:开发者社区

RocketMQ源码中,7种导致重复消费的坑!

消息发送异常时重复发送消费消息抛出异常消费者提交offset失败服务端持久化offset失败主从同步offset失败重平衡清理长时间消费的消息最后在众多关于MQ的面试八股文中有这么一道题,“如何保证MQ消息消费的幂等性”。为什么需要保证幂等性呢?是因为消息会重复消费。为什么消息会重复消费?明明已经消费了,为什么消息会被再次被消费呢?不同的MQ产生的原因可能不一样本文就以RocketMQ为例,来扒....

RocketMQ源码中,7种导致重复消费的坑!
问答 2023-05-30 来自:开发者社区

rocketmq删除过期文件的条件是怎样的 为什么配置了过了两天都没删除?在5.0源码里面没有搜道

rocketmq删除过期文件的条件是怎样的 为什么配置了过了两天都没删除?在5.0源码里面没有搜道fileReserverdTime字段

文章 2023-05-27 来自:开发者社区

RocketMQ-初体验RocketMQ(04)_使用RocketMQ Console源码搭建RocketMQ Console与基本使用

Github地址访问 rocketmq-externals选择rocketmq-console : 戳这里选择 release-rocketmq-console-1.0.0 分支IDEA中 部署下载成功后,将rocketmq-console项目导入idea,在idea中进行编译 , 等待maven自动下载好依赖的jar, 耗时稍微长点,如果还是有依赖包飘红,建议到本地仓库,删除后重新下载,Rei....

RocketMQ-初体验RocketMQ(04)_使用RocketMQ Console源码搭建RocketMQ Console与基本使用
问答 2023-05-23 来自:开发者社区

大佬,Apache RocketMQ源码中acl账号名密码长度需要大于6位,为什么要大于6位有解释?

大佬,Apache RocketMQ源码中acl账号名密码长度需要大于6位,为什么要大于6位有解释说明吗?

文章 2023-05-08 来自:开发者社区

RocketMQ源码本地搭建调试

1 GitHub源码git clone https://github.com/apache/rocketmq.git导入IDEA,可在命令行执行mvn compile一下,保证源码能够正确编译。本次我使用的master分支的版本-4.8.0。下面我们开始准备启动Namesrv。2 启动Namesrv到namesrv模块找到NamesrvStartup,启动main方法,报错如下:Please s....

RocketMQ源码本地搭建调试
问答 2023-05-01 来自:开发者社区

在Apache RocketMQ5.0的集群里面 这个rocketmq-exporter的源码是对的

在Apache RocketMQ5.0的集群里面 这个rocketmq-exporter的源码是对的 没有拼写错误 我调试了一下 从kvTable.getTable()里面拥有的的key就是"getTransferredTps" 其他版本不清楚这个地方是否有问题

文章 2023-04-30 来自:开发者社区

读完 RocketMQ 源码,我学会了如何优雅的创建线程

1. 创建单线程2. 单线程抽象类3. 线程池原理4. 线程池封装5. 线程名很重要6. 总结RocketMQ 是一款开源的分布式消息系统,基于高可用分布式集群技术,提供低延时、高可靠的消息发布与订阅服务。这篇文章,笔者整理了 RocketMQ 源码中创建线程的几点技巧,希望大家读完之后,能够有所收获。1. 创建单线程首先我们先温习下常用的创建单线程的两种方式:实现 Runnable 接口继承 ....

读完 RocketMQ 源码,我学会了如何优雅的创建线程
问答 2023-04-27 来自:开发者社区

使用rabbitMQ,结合admin一起使用,远程关闭server报错,源码中存在bug

环境信息 canal 1.1.5 问题描述 使用rabbitMQ,结合admin一起使用,远程关闭server报错,原因是在stop时,关闭rabbitMQ的channel时,connection已经被先关闭了 原提问者GitHub用户David0825

文章 2023-03-01 来自:开发者社区

《Apache RocketMQ 源码解析》电子版地址

《Apache RocketMQ 源码解析》为了让广大学习者和爱好者更好地了解及学习,特著作《Apache RocketMQ 源码解析》,以便广大受众更好地深入了解Apache RocketMQ。本书围绕Apache RocketMQ 源码进行多方面分析,包含RocketMQ ACL、RocketMQ 消息轨迹、RocketMQ 多副本之Leader 选主等,带你深入了解Apache Rocke....

《Apache RocketMQ 源码解析》电子版地址

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。