CN114116889A - 物料数据的同步方法、装置、计算机设备和存储介质 - Google Patents

Abstract

本申请涉及一种物料数据的同步方法、装置、计算机设备和存储介质。方法包括：在消息队列中读取预设数量的目标物料数据；消息队列中的各物料数据是由业务服务器存入至消息队列中的数据；对目标物料数据进行参数校验和过滤处理；在完成参数校验和过滤处理后，将处理后的目标物料数据向数据库进行同步，得到同步结果；响应于业务服务器发起的携带服务器标识的第一查询请求，根据服务器标识获取业务服务器对应的各物料数据的同步结果；将同步结果分别向业务服务器进行发送。可以实现多客户端稳定同步大批量数据。

Description

物料数据的同步方法、装置、计算机设备和存储介质

技术领域

本申请涉及网络通信技术领域，特别是涉及一种物料数据的同步方法、装置、计算机设备和存储介质。

背景技术

在信息时代，客户端与服务器的信息交互成为常态，随着网络技术的发展，数据量也在不断增长，因此多客户端的大批量数据同步已成为不可或缺的技术。

在传统技术中，一般有两种方式来实现服务器与客户端的数据同步。一种方法是由服务器主动向客户端请求同步数据，这个方法无法满足多客户端一起同步的需求，并且当客户端的IP地址不确定时，服务器将无法进行同步请求；另一种方法是客户端向服务器发送数据同步请求，但是当多个客户端一起向服务器发送大量的数据时，服务器会因为请求量过大而导致奔溃。

发明内容

基于此，有必要针对上述技术问题，提供一种能够实现多客户端稳定同步大批量数据的物料数据的同步方法、装置、计算机设备和存储介质。

一种物料数据的同步方法，所述方法包括：

在消息队列中读取预设数量的目标物料数据；所述消息队列中的各物料数据是由业务服务器存入至所述消息队列中的数据；

对所述目标物料数据进行参数校验和过滤处理；

在完成参数校验和过滤处理后，将处理后的所述目标物料数据向所述数据库进行同步，得到同步结果；

响应于所述业务服务器发起的携带服务器标识的第一查询请求，根据所述服务器标识获取所述业务服务器对应的各物料数据的同步结果；

将所述同步结果分别向所述业务服务器进行发送。

在其中一个实施例中，所述将处理后的所述目标物料数据向所述数据库进行同步之前，还包括：

根据所述目标物料数据获取目标物料数据对应的展示位信息；

根据所述展示位信息在所述数据库中进行检索，得到目标物料数据对应的展示位；

根据所述展示位检索展示位中的历史物料数据，从所述数据库中获取与所述目标物料数据对应的待同步物料数据；

所述将处理后的所述目标物料数据向所述数据库进行同步包括：

基于处理后的所述目标物料数据，对所述数据库中的待同步物料数据进行更新。

在其中一个实施例中，所述将所述同步结果分别向所述业务服务器进行发送之后，所述方法还包括：

当所述业务服务器在预设间隔时间后未收到所请求物料数据的同步结果而发起第二查询请求时，基于所述第二查询请求携带的服务器标识和物料标识，获取对应物料数据的同步结果；

其中，所述物料标识为所述未收到所请求物料数据的标识。

在其中一个实施例中，所述将处理后的所述目标物料数据向所述数据库进行同步之后，还包括：

对所述同步结果进行存储，以使在接收到所述业务服务发起查询请求时，获取存储的同步结果，并进行返回；

其中，所述同步结果包括同步成功，或同步失败和失败原因。

在其中一个实施例中，所述将处理后的所述目标物料数据向所述数据库进行同步，得到同步结果包括：

以事务的形式将处理后的所述目标物料数据向所述数据库进行同步；

当同步成功时，得到用于标识同步成功的同步结果；

当同步失败时，进行事务回滚，以将同步过程中对所述数据库中修改的数据进行恢复。

在其中一个实施例中，所述物料数据包括物料图片的网络存储地址；所述网络存储地址是所述业务服务器通过物料标识从文件服务器获取的针对所述物料图片的地址。

一种物料数据的同步装置，所述装置包括：

读取模块，用于在消息队列中读取预设数量的目标物料数据；所述消息队列中的各物料数据是由业务服务器存入至所述消息队列中的数据；

处理模块，用于对所述目标物料数据进行参数校验和过滤处理；

同步模块，用于在完成参数校验和过滤处理后，将处理后的所述目标物料数据向所述数据库进行同步，得到同步结果；

获取模块，用于响应于所述业务服务器发起的携带服务器标识的第一查询请求，根据所述服务器标识获取所述业务服务器对应的各物料数据的同步结果；

返回模块，用于将所述同步结果分别返回至对应的所述业务服务器。

在其中一个实施例中，所述装置还包括：

检索模块，用于根据所述目标物料数据获取目标物料数据对应的展示位信息；根据所述展示位信息在所述数据库中进行检索，得到目标物料数据对应的展示位；根据所述展示位检索展示位中的历史物料数据，从所述数据库中获取与所述目标物料数据对应的待同步物料数据；

所述同步模块，还用于基于处理后的所述目标物料数据，对所述数据库中的待同步物料数据进行更新。

在其中一个实施例中，所述获取模块，还用于当所述业务服务器在预设间隔时间后未收到所请求物料数据的同步结果而发起第二查询请求时，基于所述第二查询请求携带的服务器标识和物料标识，获取对应物料数据的同步结果；

其中，所述物料标识为所述未收到所请求物料数据的标识。

在其中一个实施例中，所述装置还包括：

储存模块，用于对所述同步结果进行存储，以使在接收到所述业务服务发起查询请求时，获取存储的同步结果，并进行返回；

其中，所述同步结果包括同步成功，或同步失败和失败原因。

在其中一个实施例中，所述同步模块，还用于以事务的形式将处理后的所述目标物料数据向所述数据库进行同步；

当同步成功时，得到用于标识同步成功的同步结果；

当同步失败时，进行事务回滚，以将同步过程中对所述数据库中修改的数据进行恢复。

一种计算机设备，包括存储器和处理器，所述存储器存储有计算机程序，所述计算机程序被所述处理器执行时，使得所述处理器执行上述物料数据的同步方法的步骤。

一种计算机可读存储介质，其上存储有计算机程序，所述计算机程序被处理器执行时，使得所述处理器执行上述物料数据的同步方法的步骤。

上述物料数据的同步方法、装置、计算机设备和存储介质，在消息队列中读取预设数量的目标物料数据；消息队列中的各物料数据是由业务服务器存入至消息队列中的数据；对目标物料数据进行参数校验和过滤处理；在完成参数校验和过滤处理后，将处理后的目标物料数据向数据库进行同步，得到同步结果；响应于业务服务器发起的携带服务器标识的第一查询请求，根据服务器标识获取业务服务器对应的各物料数据的同步结果；将同步结果分别向业务服务器进行发送。通过按照一定的处理速度读取预设数量的目标物料数据，可以控制对消息队列中数据的处理速度，防止因为处理请求量过多，导致系统奔溃，从而实现多客户端稳定同步大批量数据。

附图说明

图1为一个实施例中物料数据的同步方法的应用环境图；

图2为一个实施例中物料数据的同步方法的流程示意图；

图3为一个实施例中消息队列出入队的示意图；

图4为一个实施例中获取同步结果的示意图；

图5为一个实施例中物料数据的同步过程的示意图；

图6为一个实施例中获取展示位信息的流程示意图；

图7为一个实施例中获取展示位信息的示意图；

图8为一个实施例中物料数据的同步装置的结构框图；

图9为另一个实施例中物料数据的同步装置的结构框图；

图10为一个实施例中计算机设备的内部结构图。

具体实施方式

为了使本申请的目的、技术方案及优点更加清楚明白，以下结合附图及实施例，对本申请进行进一步详细说明。应当理解，此处描述的具体实施例仅仅用以解释本申请，并不用于限定本申请。

本申请提供的物料数据的同步方法，可以应用于如图1所示的应用环境中。在该应用环境中，包括业务服务器102和服务端业务服务器104。

服务端业务服务器104在消息队列中读取预设数量的目标物料数据；消息队列中的各物料数据是由业务服务器存入至消息队列中的数据；对目标物料数据进行参数校验和过滤处理；在完成参数校验和过滤处理后，将处理后的目标物料数据向数据库进行同步，得到同步结果；响应于业务服务器发起的携带服务器标识的第一查询请求，根据服务器标识获取业务服务器对应的各物料数据的同步结果；将同步结果分别向业务服务器进行发送。

其中，业务服务器102和服务端业务服务器104分别可以是独立的物理服务器，也可以是区块链系统中的服务节点，该区块链系统中的各服务节点之间形成组成点对点(P2P，Peer To Peer)网络，P2P协议是一个运行在传输控制协议(TCP，TransmissionControl Protocol)协议之上的应用层协议。

此外，业务服务器102和服务端业务服务器104还可以是多个物理服务器构成的服务器集群，可以是提供云服务、云数据库、云计算、云函数、云存储、网络服务、云通信、中间件服务、域名服务、安全服务、内容分发网络(Content Delivery Network，CDN)、以及大数据和人工智能平台等基础云计算服务的云服务器。

业务服务器102与服务端业务服务器104之间可以通过蓝牙、USB(UniversalSerial Bus，通用串行总线)或者网络等通讯连接方式进行连接，本申请在此不做限制。

在一个实施例中，如图2所示，提供了一种物料数据的同步方法，以该方法应用于图1中的服务端业务服务器为例进行说明，包括以下步骤：

S202，在消息队列中读取预设数量的目标物料数据；消息队列中的各物料数据是由业务服务器存入至消息队列中的数据。

其中，物料数据包括物料标识、物料价格、物料存量和图片的网络存储地址；网络存储地址是业务服务器通过物料标识从文件服务器获取的针对物料图片的地址，消息队列可以使用RabbitMQ、ActiveMQ和Kafka等消息系统。该业务服务器可以是客户端业务服务器。

在一个实施例中，如图3所示，业务服务器接收到同步请求后，将获取到的需要同步的物料数据转发至消息队列，服务端业务服务器会按照一定的处理速度消费消息，对消息进行处理实现数据同步。

其中，预设服务端业务服务器读取消息队列中的消息数量是为了控制消费消息的频率。服务端业务服务器对每次在消息队列中读取消息的个数进行设置，例如，服务端业务服务器可以每次在消息队列中读取2000个消息，完成这2000个消息的处理后，服务端业务服务器才会再次读取2000个消息队列中的消息。

S204，对目标物料数据进行参数校验和过滤处理。

其中，参数包括指物料的标识、价格和库存，服务端业务服务器的参数校验包括检验参数的格式是否符合数据库的格式要求；过滤处理包括过滤掉多余的参数和异常的参数。

S206，在完成参数校验和过滤处理后，将处理后的目标物料数据向数据库进行同步，得到同步结果。

在一个实施例中，服务端业务服务器以事务的形式将处理后的目标物料数据向数据库进行同步；当同步成功时，得到用于标识同步成功的同步结果；当同步失败时，进行事务回滚，以将同步过程中对数据库中修改的数据进行恢复。

其中，事务是指访问并可能更新数据库中各种数据项的一个程序执行单元。事务范围内的所有操作都具有一致性，即所有操作要么全部执行，要么全部不执行。例如，当目标物料数据与数据库同步成功时，提交事务，永久保存事务内的所有操作；当目标物料数据与数据库同步失败时，回滚事务，撤销事务范围内的所有操作，回滚后数据库数据没有任何改动。

S208，响应于业务服务器发起的携带服务器标识的第一查询请求，根据服务器标识获取业务服务器对应的各物料数据的同步结果。

在一个实施例中，当业务服务器在预设间隔时间后未收到所请求物料数据的同步结果而发起第二查询请求时，服务端业务服务器基于第二查询请求携带的服务器标识和物料标识，获取对应物料数据的同步结果；其中，所述物料标识为未收到所请求物料数据的标识。

例如，如图4所示，该图4中的查询请求可以是第一查询请求或第二查询请求，当该查询请求只携带服务器标识时，则该查询请求即为第一查询请求；当该查询请求携带了服务器标识和物料标识时，则该查询请求即为第二查询请求。因此，当查询请求为第一查询请求时，服务端业务服务器通过服务器标识获取同步结果；当查询请求为第二查询请求时，服务端业务服务器通过服务器标识和物料标识获取同步结果。获取到同步结果后，服务端业务服务器会修改数据库的同步结果返回状态，然后将同步结果返回给业务服务器。

在一个实施例中，S208之后，该方法还可以包括：服务端业务服务器对同步结果进行存储，以使在接收到业务服务发起查询请求时，获取存储的同步结果，并进行返回；其中，所述同步结果包括同步成功，或同步失败和失败原因。

在一个实施例中，服务端业务服务器会在接收到各物料数据并且等待一段时间后，才会收到业务服务器发送的第一查询请求，业务服务器可以预设发送物料数据后与发送第一查询请求之间的时间间隔。其中，预设的时间间隔可以是几秒钟、几分钟、或其他间隔时间。

S210，将同步结果分别向业务服务器进行发送。

在一个实施例中，服务端业务服务器发送完成后，会更新每个物料同步结果中的发送状态，将发送状态修改为已发送。当业务服务器再次发送第一查询请求时，发送状态为已发送的物料同步结果不会再次发送。

在一个实施例中，当业务服务器发送物料数据到消息队列后，业务服务器会将物料数据对应的发送状态字段更新为成功。当服务端业务服务器返回的同步结果为成功时，业务服务器会将物料数据对应的同步结果字段更新为成功，即数据同步完成。

在另一个实施例中，当服务端业务服务器返回的同步结果为失败时，业务服务器会将物料数据对应的同步结果字段和发送状态字段都修改为失败。业务服务器会根据失败原因对同步失败的物料数据进行更新，更新完毕后，再次发送该物料数据。

为了使本领域技术人员更加直观了解物料数据的同步方法，结合图5进行说明。客户端业务服务器接收到同步请求后，开始检索并保存需要同步的物料数据，客户端业务服务器通过物料标识从客户端文件服务器获取物料图片数据，并将其上传至服务端文件服务器；服务端文件服务器将物料图片数据进行储存后，会将图片的网络存储地址返回至客户端业务服务器，客户端业务服务器将所有获取到的需要同步的物料数据转发至消息队列。服务端业务服务器会消费消息队列中的消息，进行物料信息同步操作并且存储记录了同步结果的同步状态表。客户端业务服务器会发送查询请求，查询商品同步状态。接收到客户端业务服务器的查询请求后，服务端业务服务器会返回查询结果。

上述物料数据的同步方法中，在消息队列中读取预设数量的目标物料数据；消息队列中的各物料数据是由业务服务器存入至消息队列中的数据；对目标物料数据进行参数校验和过滤处理；在完成参数校验和过滤处理后，将处理后的目标物料数据向数据库进行同步，得到同步结果；响应于业务服务器发起的携带服务器标识的第一查询请求，根据服务器标识获取业务服务器对应的各物料数据的同步结果；将同步结果分别向业务服务器进行发送。通过按照一定的处理速度读取预设数量的目标物料数据，可以控制对消息队列中数据的处理速度，防止因为处理请求量过多，导致系统奔溃，从而实现多客户端稳定同步大批量数据。

在一个实施例中，如6所示，S206之前，该方法还包括：

S602，根据目标物料数据获取目标物料数据对应的展示位信息。

其中，该展示位信息也可以称为展厅信息。

在一个实施例中，如图7所示，服务端业务服务器会对展示位信息进行参数检验和过滤处理，保证展示位消息的准确性，之后再利用展示位信息在数据库中进行检索。

在一个实施例中，服务端业务服务器会根据目标物料数据确定该物料是否自动上架，当该物料需要自动上架时，服务端业务服务器会在物料数据同步完成后，自动上架该物料。

S604，根据展示位信息在数据库中进行检索，得到目标物料数据对应的展示位。

其中，展示位包括销售平台上的店铺，数据库可以根据店铺信息检索该店铺中所有的物料信息。

S606，根据展示位检索展示位中的历史物料数据，从数据库中获取与目标物料数据对应的待同步物料数据。

其中，基于处理后的所述目标物料数据，服务端业务服务器会对所述数据库中的待同步物料数据进行更新。

上述实施例中，根据目标物料数据获取目标物料数据对应的展示位信息；根据展示位信息在数据库中进行检索，得到目标物料数据对应的展示位；据展示位检索展示位中的历史物料数据，从数据库中获取与目标物料数据对应的待同步物料数据。通过根据目标物料数据获取目标物料数据对应的展示位信息，可以方便数据库对待同步物料数据的检索，提高同步效率。

应该理解的是，虽然图2、6的流程图中的各个步骤按照箭头的指示依次显示，但是这些步骤并不是必然按照箭头指示的顺序依次执行。除非本文中有明确的说明，这些步骤的执行并没有严格的顺序限制，这些步骤可以以其它的顺序执行。而且，图2、6中的至少一部分步骤可以包括多个步骤或者多个阶段，这些步骤或者阶段并不必然是在同一时刻执行完成，而是可以在不同的时刻执行，这些步骤或者阶段的执行顺序也不必然是依次进行，而是可以与其它步骤或者其它步骤中的步骤或者阶段的至少一部分轮流或者交替地执行。

在一个实施例中，如图8所示，提供了一种物料数据的同步装置，该装置可以采用软件模块或硬件模块，或者是二者的结合成为计算机设备的一部分，该装置具体包括：读取模块802、处理模块804、同步模块806、获取模块808和返回模块810，其中：

读取模块802，用于在消息队列中读取预设数量的目标物料数据；消息队列中的各物料数据是由业务服务器存入至消息队列中的数据；

处理模块804，用于对目标物料数据进行参数校验和过滤处理；

同步模块806，用于在完成参数校验和过滤处理后，将处理后的目标物料数据向数据库进行同步，得到同步结果；

获取模块808，用于响应于业务服务器发起的携带服务器标识的第一查询请求，根据服务器标识获取业务服务器对应的各物料数据的同步结果；

返回模块810，用于将同步结果分别返回至对应的业务服务器。

上述实施例中，通过在消息队列中读取预设数量的目标物料数据；消息队列中的各物料数据是由业务服务器存入至消息队列中的数据；对目标物料数据进行参数校验和过滤处理；在完成参数校验和过滤处理后，将处理后的目标物料数据向数据库进行同步，得到同步结果；响应于业务服务器发起的携带服务器标识的第一查询请求，根据服务器标识获取业务服务器对应的各物料数据的同步结果；将同步结果分别向业务服务器进行发送。通过按照一定的处理速度读取预设数量的目标物料数据，可以控制对消息队列中数据的处理速度，防止因为处理请求量过多，导致系统奔溃，从而实现多客户端稳定同步大批量数据。

在其中一个实施例中，如图9，装置还包括：

检索模块812，用于根据目标物料数据获取目标物料数据对应的展示位信息；根据展示位信息在数据库中进行检索，得到目标物料数据对应的展示位；根据展示位检索展示位中的历史物料数据，从数据库中获取与目标物料数据对应的待同步物料数据；

同步模块806，还用于基于处理后的目标物料数据，对数据库中的待同步物料数据进行更新。

在其中一个实施例中，获取模块808，还用于当业务服务器在预设间隔时间后未收到所请求物料数据的同步结果而发起第二查询请求时，基于第二查询请求携带的服务器标识和物料标识，获取对应物料数据的同步结果；

其中，所述物料标识为所述未收到所请求物料数据的标识。

在其中一个实施例中，装置还包括：

储存模块814，用于对同步结果进行存储，以使在接收到业务服务发起查询请求时，获取存储的同步结果，并进行返回；

其中，同步结果包括同步成功，或同步失败和失败原因。

在其中一个实施例中，同步模块806，还用于以事务的形式将处理后的目标物料数据向数据库进行同步；

当同步成功时，得到用于标识同步成功的同步结果；

当同步失败时，进行事务回滚，以将同步过程中对数据库中修改的数据进行恢复。

关于物料数据的同步装置的具体限定可以参见上文中对于物料数据的同步方法的限定，在此不再赘述。上述物料数据的同步装置中的各个模块可全部或部分通过软件、硬件及其组合来实现。上述各模块可以硬件形式内嵌于或独立于计算机设备中的处理器中，也可以以软件形式存储于计算机设备中的存储器中，以便于处理器调用执行以上各个模块对应的操作。

在一个实施例中，提供了一种计算机设备，该计算机设备可以是服务端业务服务器，其内部结构图可以如图10所示。该计算机设备包括通过系统总线连接的处理器、存储器和网络接口。其中，该计算机设备的处理器用于提供计算和控制能力。该计算机设备的存储器包括非易失性存储介质、内存储器。该非易失性存储介质存储有操作系统、计算机程序和数据库。该内存储器为非易失性存储介质中的操作系统和计算机程序的运行提供环境。该计算机设备的数据库用于存储物料数据。该计算机设备的网络接口用于与外部的业务服务器通过网络连接通信。该计算机程序被处理器执行时以实现一种物料数据的同步方法。

本领域技术人员可以理解，图10中示出的结构，仅仅是与本申请方案相关的部分结构的框图，并不构成对本申请方案所应用于其上的计算机设备的限定，具体的计算机设备可以包括比图中所示更多或更少的部件，或者组合某些部件，或者具有不同的部件布置。

在一个实施例中，还提供了一种计算机设备，包括存储器和处理器，存储器中存储有计算机程序，该处理器执行计算机程序时实现上述各方法实施例中的步骤。

在一个实施例中，提供了一种计算机可读存储介质，存储有计算机程序，该计算机程序被处理器执行时实现上述各方法实施例中的步骤。

在一个实施例中，提供了一种计算机程序产品或计算机程序，该计算机程序产品或计算机程序包括计算机指令，该计算机指令存储在计算机可读存储介质中。计算机设备的处理器从计算机可读存储介质读取该计算机指令，处理器执行该计算机指令，使得该计算机设备执行上述各方法实施例中的步骤。

本领域普通技术人员可以理解实现上述实施例方法中的全部或部分流程，是可以通过计算机程序来指令相关的硬件来完成，所述的计算机程序可存储于一非易失性计算机可读取存储介质中，该计算机程序在执行时，可包括如上述各方法的实施例的流程。其中，本申请所提供的各实施例中所使用的对存储器、存储、数据库或其它介质的任何引用，均可包括非易失性和易失性存储器中的至少一种。非易失性存储器可包括只读存储器(Read-Only Memory，ROM)、磁带、软盘、闪存或光存储器等。易失性存储器可包括随机存取存储器(Random Access Memory，RAM)或外部高速缓冲存储器。作为说明而非局限，RAM可以是多种形式，比如静态随机存取存储器(Static Random Access Memory，SRAM)或动态随机存取存储器(Dynamic Random Access Memory，DRAM)等。

以上实施例的各技术特征可以进行任意的组合，为使描述简洁，未对上述实施例中的各个技术特征所有可能的组合都进行描述，然而，只要这些技术特征的组合不存在矛盾，都应当认为是本说明书记载的范围。

以上所述实施例仅表达了本申请的几种实施方式，其描述较为具体和详细，但并不能因此而理解为对发明专利范围的限制。应当指出的是，对于本领域的普通技术人员来说，在不脱离本申请构思的前提下，还可以做出若干变形和改进，这些都属于本申请的保护范围。因此，本申请专利的保护范围应以所附权利要求为准。

Claims (10)

1.一种物料数据的同步方法，其特征在于，所述方法包括：

在消息队列中读取预设数量的目标物料数据；所述消息队列中的各物料数据是由业务服务器存入至所述消息队列中的数据；

对所述目标物料数据进行参数校验和过滤处理；

在完成参数校验和过滤处理后，将处理后的所述目标物料数据向所述数据库进行同步，得到同步结果；

响应于所述业务服务器发起的携带服务器标识的第一查询请求，根据所述服务器标识获取所述业务服务器对应的各物料数据的同步结果；

将所述同步结果分别向所述业务服务器进行发送。

2.根据权利要求1所述的方法，其特征在于，所述将处理后的所述目标物料数据向所述数据库进行同步之前，还包括：

根据所述目标物料数据获取目标物料数据对应的展示位信息；

根据所述展示位信息在所述数据库中进行检索，得到目标物料数据对应的展示位；

根据所述展示位检索展示位中的历史物料数据，从所述数据库中获取与所述目标物料数据对应的待同步物料数据；

所述将处理后的所述目标物料数据向所述数据库进行同步包括：

基于处理后的所述目标物料数据，对所述数据库中的待同步物料数据进行更新。

3.根据权利要求1所述的方法，其特征在于，所述将所述同步结果分别向所述业务服务器进行发送之后，所述方法还包括：

当所述业务服务器在预设间隔时间后未收到所请求物料数据的同步结果而发起第二查询请求时，基于所述第二查询请求携带的服务器标识和物料标识，获取对应物料数据的同步结果；

其中，所述物料标识为所述未收到所请求物料数据的标识。

4.根据权利要求1所述的方法，其特征在于，所述将处理后的所述目标物料数据向所述数据库进行同步之后，还包括：

对所述同步结果进行存储，以使在接收到所述业务服务发起查询请求时，获取存储的同步结果，并进行返回；

其中，所述同步结果包括同步成功，或同步失败和失败原因。

5.根据权利要求1所述的方法，其特征在于，所述将处理后的所述目标物料数据向所述数据库进行同步，得到同步结果包括：

以事务的形式将处理后的所述目标物料数据向所述数据库进行同步；

当同步成功时，得到用于标识同步成功的同步结果；

当同步失败时，进行事务回滚，以将同步过程中对所述数据库中修改的数据进行恢复。

6.根据权利要求1所述的方法，其特征在于，所述物料数据包括物料图片的网络存储地址；所述网络存储地址是所述业务服务器通过物料标识从文件服务器获取的针对所述物料图片的地址。

7.一种物料数据的同步装置，其特征在于，所述装置包括：

读取模块，用于在消息队列中读取预设数量的目标物料数据；所述消息队列中的各物料数据是由业务服务器存入至所述消息队列中的数据；

处理模块，用于对所述目标物料数据进行参数校验和过滤处理；

同步模块，用于在完成参数校验和过滤处理后，将处理后的所述目标物料数据向所述数据库进行同步，得到同步结果；

获取模块，用于响应于所述业务服务器发起的携带服务器标识的第一查询请求，根据所述服务器标识获取所述业务服务器对应的各物料数据的同步结果；

返回模块，用于将所述同步结果分别返回至对应的所述业务服务器。

8.根据权利要求1所述的方法，其特征在于，所述装置还包括：

检索模块，用于根据所述目标物料数据获取目标物料数据对应的展示位信息；根据所述展示位信息在所述数据库中进行检索，得到目标物料数据对应的展示位；根据所述展示位检索展示位中的历史物料数据，从所述数据库中获取与所述目标物料数据对应的待同步物料数据；

所述同步模块，还用于基于处理后的所述目标物料数据，对所述数据库中的待同步物料数据进行更新。

9.一种计算机设备，包括存储器和处理器，所述存储器存储有计算机程序，其特征在于，所述处理器执行所述计算机程序时实现权利要求1至6中任一项所述的方法的步骤。

10.一种计算机可读存储介质，存储有计算机程序，其特征在于，所述计算机程序被处理器执行时实现权利要求1至6中任一项所述的方法的步骤。

Images