当前位置: 首页 > 网络应用技术

RocketMQ原理发送过程

时间:2023-03-07 18:21:22 网络应用技术

  RocketMQ源版本4.9.1

  每个角色描述:

  消息传递方法:同步,异步,单向

  新闻类型:普通消息(包括延迟消息),顺序消息(全局顺序和本地顺序),事务消息

  本文了解通过普通消息的演示发送消息的主要过程。

  让我们看看制片人发送的演示

  主要做一些事情:

  在开始时,主要的时机任务:

  注意:因为生产者和消费者的底层是通过MQClientInstance类来与经纪人服务进行通信,并且该消息是绘制的服务,而重负载余额服务的旨在针对消费者。因此,不会生效。

  在消息发送过程中,有两个核心步骤:

  进行以下操作:

  目的甚至是将消息发送到每个经纪人中的消息队列。

  负载平衡策略有两种类型:

  尽管故障延迟机制的负载平衡策略也具有避免故障经纪人的逻辑,但它只能在消息发送的试验场景上行动。

  实施逻辑如下:

  如果要避免多次发送消息的失败故障,则可以通过SendLecentFauletable配置打开故障延迟机制。

  总体过程如下:

  核心点:

  隔离时间是根据上一条消息发送的延迟时间确定的。延迟时间越长,相应的隔离时间越长。

  本文主要包括以下内容:

  通过阅读本文,您可以对RocketMQ消息发送过程有整体理解。您可以理解,通过负载平衡策略,它具有系统扩展和高可用性的特征。