独立站数据定向同步方法及其装置、设备、介质与流程

本申请涉及电商，尤其涉及一种独立站数据定向同步方法及其相应的装置、计算机设备、计算机可读存储介质。

背景技术：

1、在电商平台中，为了支持其中各个搭建在独立站上的在线店铺可以按需接入不同的功能，会设计一套插件系统。在线店铺的商家可以自行选用所需的插件，从而启用该插件对应的功能，然而插件系统中的插件都需要以相应在线店铺的数据为基础来提供对应的功能，这就需要将在线店铺的数据同步到该在线店铺商家选用插件的插件数据库。

2、传统技术中，通常将电商平台中所有在线店铺的数据全部分别同步到插件系统中各个插件的插件数据库，使得每个插件数据库都存有所有在线店铺的数据，这种实现方式，不仅存储成本极其高昂，而且因为存储大部分未选用相应插件的在线店铺的数据，从而导致数据查询和调用的速度极慢，此外，各个独立站对应的在线店铺的数据相互隔离，使得各在线店铺的数据只有自身在线店铺或其授权者可使用，在未经在线店铺选用相应的插件而将这些在线店铺的数据同步到该插件的插件数据库中，会存在安全风险。

3、鉴于传统做法的不足，本申请人长期从事相关领域的研究，为解决电商技术领域业内难题，故另辟蹊径。

技术实现思路

1、本申请的首要目的在于解决上述问题至少之一而提供一种独立站数据定向同步方法及其相应的装置、计算机设备、计算机程序产品。

2、为满足本申请的各个目的，本申请采用如下技术方案：

3、适应本申请的目的之一而提供的一种独立站数据定向同步方法，包括如下步骤：

4、响应独立站店铺的数据源变更事件，获取数据源变更事件对应的变更日志及其中的目标店铺标识；

5、根据所述目标店铺标识指定工作者线程池中的目标工作者线程，将目标店铺标识和所述变更日志分发给目标工作者线程；

6、启用所述目标工作者线程判断是否存在与所述目标店铺标识相关联的插件标识，当存在所述插件标识时，目标工作者线程构造出所述变更日志对应的待同步变更消息，将其写入到消息队列中关联插件标识的目标主题；

7、启用所述插件标识对应的插件开发者线程消费其订阅的所述目标主题中的所述待同步变更消息，使得关联插件标识的插件数据库与所述数据源实现数据同步。

8、另一方面，适应本申请的目的之一而提供的一种独立站数据定向同步装置，包括事件响应模块、线程分发模块、主题插入模块、消息消费模块，其中，事件响应模块，用于响应独立站店铺的数据源变更事件，获取数据源变更事件对应的变更日志及其中的目标店铺标识；线程分发模块，用于根据所述目标店铺标识指定工作者线程池中的目标工作者线程，将目标店铺标识和所述变更日志分发给目标工作者线程；主题插入模块，用于启用所述目标工作者线程判断是否存在与所述目标店铺标识相关联的插件标识，当存在所述插件标识时，目标工作者线程构造出所述变更日志对应的待同步变更消息，将其写入到消息队列中关联插件标识的目标主题；消息消费模块，用于启用所述插件标识对应的插件开发者线程消费其订阅的所述目标主题中的所述待同步变更消息，使得关联插件标识的插件数据库与所述数据源实现数据同步。

9、又一方面，适应本申请的目的之一而提供的一种计算机设备，包括中央处理器和存储器，所述中央处理器用于调用运行存储于所述存储器中的计算机程序以执行本申请所述的独立站数据定向同步方法的步骤。

10、又一方面，适应本申请的另一目的而提供的一种计算机程序产品，包括计算机程序/指令，该计算机程序/指令被处理器执行时实现本申请任意一种实施例中所述方法的步骤。

11、本申请的技术方案存在多方面优势，包括但不限于如下各方面：

12、本申请首先响应独立站店铺的数据源变更事件，获取相关的变更日志和目标店铺标识。然后，依据目标店铺标识指定工作者线程池中相应的目标工作者线程，向其分发变更日志和目标店铺标识，之后，目标工作者线程确定是否存在与目标店铺标识相关联的插件标识，如果存在，便构造变更日志对应的待同步变更消息并将其定向写入到消息队列中关联插件标识的目标主题。进一步，插件开发者线程从其订阅的目标主题中消费待同步变更消息，完成关联插件标识的插件数据库与数据源的数据同步。可见，能够定向同步独立站店铺的数据至与该独立站店铺相关联的插件数据库，确保了插件数据库中不会存放冗余的未关联独立站店铺的数据，确保了数据同步的准确性、实时性、一致性。同时，保障了各个独立站店铺的数据安全性，确保只有该独立站店铺相关联的插件数据库会存有该独立站店铺的数据。其次，通过使用工作线程池结合线程分发机制能够高效精准地处理大量独立站数据的定向同步需求，确保高吞吐量，以及响应的及时性。

技术特征：

1.一种独立站数据定向同步方法，其特征在于，包括如下步骤：

2.根据权利要求1所述的独立站数据定向同步方法，其特征在于，根据所述目标店铺标识指定工作者线程池中的目标工作者线程，包括如下步骤：

3.根据权利要求1所述的独立站数据定向同步方法，其特征在于，启用所述目标工作者线程判断是否存在与所述目标店铺标识相关联的插件标识，包括如下步骤：

4.根据权利要求1所述的独立站数据定向同步方法，其特征在于，根据所述目标店铺标识指定工作者线程池中的目标工作者线程，将目标店铺标识和所述变更日志分发给目标工作者线程之前，包括如下步骤：

5.根据权利要求4所述的独立站数据定向同步方法，其特征在于，响应消息队列中关联主题的消息插入事件之前，包括如下步骤：

6.根据权利要求4所述的独立站数据定向同步方法，其特征在于，将每个待同步变更消息写入到消息队列中关联该目标插件变更消息中的插件标识的目标主题之后，包括：

7.根据权利要求1所述的独立站数据定向同步方法，其特征在于，响应独立站店铺的数据源变更事件之前，包括如下步骤：

8.一种独立站数据定向同步装置，其特征在于，包括：

9.一种计算机设备，包括中央处理器和存储器，其特征在于，所述中央处理器用于调用运行存储于所述存储器中的计算机程序以执行如权利要求1至7中任意一项所述的方法的步骤。

10.一种计算机可读存储介质，其特征在于，其以计算机可读指令的形式存储有依据权利要求1至7中任意一项所述的方法所实现的计算机程序，该计算机程序被计算机调用运行时，执行相应的方法所包括的步骤。

技术总结
本申请涉及电商技术领域中一种独立站数据定向同步方法及其装置、设备、介质，所述方法包括：响应独立站店铺的数据源变更事件，获取数据源变更事件对应的变更日志及其中的目标店铺标识,根据目标店铺标识指定工作者线程池中的目标工作者线程，将目标店铺标识和变更日志分发给该线程，启用目标工作者线程判断是否存在与目标店铺标识相关联的插件标识，当存在时，构造出变更日志对应的待同步变更消息，将其写入到消息队列中关联插件标识的目标主题，启用插件标识对应的插件开发者线程消费其订阅的目标主题中的待同步变更消息，使得关联插件标识的插件数据库与数据源实现数据同步。本申请能够高效精准地处理大量独立站数据的定向同步需求，确保数据同步的准确性、实时性、一致性，以及独立站数据的安全性。

技术研发人员：连松洲
受保护的技术使用者：广州商耘网络科技有限公司
技术研发日：
技术公布日：2024/9/23