RocketMQ 发送事务消息原理分析和代码实现

发布于 2020-10-26

事务消息RocketMQ 提供了可靠性消息,也叫事务消息。下面分析一下其原理。事务消息的原理下面来看 RocketMQ 的事务消息是如何来发送“可靠消息”的,只需要以下三步:发送半消息(半消息不会发送给消费者)执行本地事务提交消息完成事务消息发送后,消费者就可以以正常的方式来消费数据。RocketM

0 条评论
105 热度

RocketMQ (三) 基本原理

发布于 2020-10-26

Topic 基本原理在Rocketmq集群中新建 Topic1在管理界面中新建主题Topic1,为了方便观察测试效果,这里把写队列和读队列的数量都设置成3。这样,在 broker-a 和 broker-b 上都创建了 Topic1 主题,并各创建了3写3读队列,共6写6读,如下图所示:你也可以修改T

0 条评论
96 热度

RocketMQ (二) 双主双从同步复制集群方案

发布于 2020-10-26

部署环境作为测试环境,我们使用两台虚拟机来部署双主双从环境,具体结构如下:整个集群由两个 name server 实例和四个 broker 实例组成name server:两台服务器分别启动两个name serverbroker A 主从:服务器1部署 broker A 主服务服务器2部署 brok

0 条评论
80 热度

RocketMQ (一) 安装

发布于 2020-10-26

文件下载jdk-8-u212rocketmq4.7-rocketconsole1.0.1安装安装配置 jdk81. 上传jdk压缩文件将文件jdk-8u212-linux-x64.tar.gz上传到 /root 目录2. 解压缩执行解压命令# 将jdk解压到 /usr/local/ 目录tar -x

0 条评论
78 热度