一种基于RocketMQ的数据同步方法
    2.
    发明公开

    公开(公告)号:CN117056422A

    公开(公告)日:2023-11-14

    申请号:CN202310939208.9

    申请日:2023-07-28

    Abstract: 本发明公开了一种基于RocketMQ的数据同步方法,旨在克服现有技术中数据同步的误差大和易故障的问题,它包括:获取更新数据、更新数据的数据标识、当前线程编号以及当前可用的CPU核心数,运算得到数据发布组件对象的队列索引;创建数据发布组件对象;将更新数据存放至数据发布组件对象中;运算得到消息中间件的消息队列索引;对存放有更新数据的数据发布组件对象执行自旋等待流程;将数据发布组件对象中的更新数据发布至消息中间件中;下游系统订阅消息中间件中的更新数据。

Patent Agency Ranking