RocketMQ
RocketMQ基础使用
环境准备 1.软件准备: RocketMQ版本：4.5.1 2.环境要求 JDK 1.8.0 Linux64位系统(CentOS Linux release 7.9.2009) 源码安装需要安装Maven 3.2.x 4G+ free 磁盘空间 3.安装及启动 下载rocketmq wget htt
发布于 2024-08-19
RocketMQ介绍
RocketMQ的前世今生 RocketMQ在阿里内部叫做Metaq（最早名为Metamorphosis，中文意思"变形记"，是作家卡夫卡的中篇小说代表作，可见是为了致敬Kafka）。 RocketMQ是Metaq 3.0之后开源的版本。 Metaq在阿里巴巴集团内部、蚂蚁金服、菜鸟等各
发布于 2024-08-19
RocketMQ——基于CommitLog和ConsumeQueue的消息存储机制
RocketMQ的消息存储机制是基于CommitLog和ConsumeQueue的。消息首先会被追加到CommitLog中，然后根据消息的主题和队列ID被索引到对应的ConsumeQueue中，以便快速检索。 代码如下： DefaultMQProducer producer = new Defaul
发布于 2024-08-19
RocketMQ——事务消息支持
RocketMQ的事务消息支持是通过Half Message机制实现的。 详细步骤如下： 1. 发送方发送半消息（Half Message） 发送方首先发送一条半消息，消息状态为"待确认"。发送成功后，执行本地事务逻辑。 2. 本地事务执行 发送方根据半消息执行本地事务逻辑，可能是数据库操作、文件操
发布于 2024-08-19
RocketMQ——通过主从复制和消息冗余保证高可用性和容错
RocketMQ的高可用性和容错机制主要通过主从复制和消息冗余来实现： 主从复制：RocketMQ采用主从复制机制，每个Broker都有一个主节点和多个从节点。主节点负责消息的写入和同步，从节点负责消息的备份和故障转移。当主节点宕机时，从节点可以接管服务，确保消息的可靠性和高可用性。 消息冗余：Ro
发布于 2024-08-19