RocketMQ源版本4.9.1
每个角色描述:
消息传递方法:同步,异步,单向
新闻类型:普通消息(包括延迟消息),顺序消息(全局顺序和本地顺序),事务消息
本文了解通过普通消息的演示发送消息的主要过程。
让我们看看制片人发送的演示
主要做一些事情:
在开始时,主要的时机任务:
注意:因为生产者和消费者的底层是通过MQClientInstance类来与经纪人服务进行通信,并且该消息是绘制的服务,而重负载余额服务的旨在针对消费者。因此,不会生效。
在消息发送过程中,有两个核心步骤:
进行以下操作:
目的甚至是将消息发送到每个经纪人中的消息队列。
负载平衡策略有两种类型:
尽管故障延迟机制的负载平衡策略也具有避免故障经纪人的逻辑,但它只能在消息发送的试验场景上行动。
实施逻辑如下:
如果要避免多次发送消息的失败故障,则可以通过SendLecentFauletable配置打开故障延迟机制。
总体过程如下:
核心点:
隔离时间是根据上一条消息发送的延迟时间确定的。延迟时间越长,相应的隔离时间越长。
本文主要包括以下内容:
通过阅读本文,您可以对RocketMQ消息发送过程有整体理解。您可以理解,通过负载平衡策略,它具有系统扩展和高可用性的特征。