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

RocketMQ特征 - 代理存储交易消息如何?

时间:2023-03-09 13:15:03 网络应用技术

  在经纪人中,通过方法执行事务消息的初始化。

  这是三个核心初始化变量

  事务消息主要是处理的服务。默认实现类还可以自行定义交易消息的实现类,并通过方法加载它。类定义如下。内部属性已注释。

  事务新闻返回调查监视设备

  事务消息检查服务,并启动一个线程,以检查是否需要检查超时时间的一半消息。

  初始化完成后,经纪人可以处理事务消息。

  经纪人存储交易消息实际上与普通新闻相同。但是,有两种特殊处理交易消息:

  中间:

  在存储交易新闻之前进行预处理,相应的方法为

  完成上述步骤后,将呼叫方法保存到中间。

  在成功存储Commitlog之后,该方法将通过该方法处理。

  这里的逻辑就是这样。当读取的消息类型是事务消息时,当前消息的站点值为0,而不是设置真实站点。这样,本网站将不会建立补充索引或消耗。