RocketMQ Client 启动异常解决 现象 rocketmq-common-4.9.3 版本作为客户端消费数据时，从MessageExt.getMsgId()获取消息ID时，会存在一个潜在的依赖冲突问题，最终导致方法执行失败，如下图： 从现象来看，Could not i... 2023-11-28
RocketMQ消息存储过程 讲完了消息的生产过程，接下来记录一下消息发送到Broker后如何存储和分发。 前言 首先看下RocketMQ Broker的消息存储目录结构，RocketMQ的消息存储在本地文件系统中，默认在当前用户主目录下的store目录中： ... 2023-11-15
Java 实现简单单机时间轮方案 时间轮的使用场景自不必多说，最近研究RocketMQ 5.0时，想简单写一个活跃下思路，遂写了下面的方案（没有参照任何代码，没有优化），主要做下记录。 package top.imyzt.learning.algorithm.time... 2023-11-13
RocketMQ消息生产基本流程 RocketMQ 相较于 RabbitMQ、Kafka 能够集成两者的不少优点（原生的延迟消息、支持事务消息、能够支撑较大流量），加之Java技术架构，所以已作为目前队列选型调研时的第一选择，本文主要以图解形式讲明白RocketMQ一... 2023-11-12
