目录 1、MQ作用 2、MQ产品对比 3、RocketMQ基本概念 4、RocketMQ系统框架 4.1.Producer 4.2.Consumer 4.3.Name Server 4.4.Broker 5、RocketMQ工作流...
文章目录 4. MQTT控制包详解 4.3 PUBLISH——发布消息 4.3.1 固定报文头 4.3.2 可变报文头 4.3.3 负载 4.3.4 行动 4.4 PUBACK 4.5 PUBREC 4.6 PUBRE...
目录 1、消息消费高可用 2、消息发送高可用 3、消息主从复制 RocketMQ分布式集群是通过Master和Slave的配合达到高可用性的。 Master和Slave的区别:在Bro...
目录 1、各角色介绍 2、集群搭建介绍 2.1 集群特点 2.2 单Master模式 2.3 多Master模式 2.4 多Master多Slave模式(异步) 2.4 多Master多Slave模式(同...
目录 1、基础整合 1.1.POM 1.2.yaml配置 1.3.Producer代码 1.4.Consumer代码 1.5.代码测试 1.6.topic与tag的指定 2、六大消息类型代码实现 2.1.基本...
目录 1、消费类型 1)拉取式消费 2)推送式消费 3)对比 2、消费模式 1)广播模式 2)集群模式(默认) 3)消息进度保存 3、消息负载均衡(Rebalance...
目录 1、消息生产 1.1 消息的生产过程 1.2 Queue选择算法 2、消息储存 2.1 存储介质 2.2 消息的存储和发送 2.3 消息存储结构 2.4 刷盘机制 1、...
1、顺序消息的重试 对于顺序消息,当消费者消费消息失败后,消息队列 RocketMQ 会自动不断进行消息重试(每次间隔时间为 1 秒),这时,应用会出现消息消费...
目录 1、事务场景 2、解决思路 3、事务消息概念 4、事务消息实现 4.1 代码说明: 4.2 完整代码 1、事务场景 场景:工行用户A向建行用户B转账1万元; ...
文章目录 Spring cloud config配置中心 步骤 三个业务模块的配置,传到git仓库 搭建配置中心 配置中心的客户端 Rabbitmq消息中间件 搭建Rabbitmq...