一种基于区块链的任务调度方法、设备及存储介质与流程

1.本技术涉及区块链技术领域，尤其涉及一种基于区块链的任务调度方法、设备及存储介质。


背景技术：

2.在集群系统中，执行服务中往往存在多个执行实例，当集群系统执行某项任务时需要判断由哪个执行实例来负责执行。现有的集群系统存在同一个任务被重复执行情况。
3.因此，如何确保集群系统的任务执行不重复成为亟待解决的技术问题。


技术实现要素：

4.本技术实施例提供了一种基于区块链的任务调度方法、设备及存储介质，用以解决如下技术问题：如何确保集群系统的任务执行不重复。
5.第一方面，本技术实施例提供了一种基于区块链的任务调度方法，其特征在于，方法包括：基于集群系统中调度服务提供的前端交互界面，确定执行服务对应的当前任务分配规则；其中，执行服务包括若干个执行实例；当前任务分配规则为轮询任务分配规则或权重匹配任务分配规则；在集群系统接收到待执行任务的执行请求的情况下，调度服务调用区块链中预存的执行服务对应的待交互智能合约，以确定当前任务分配规则的任务执行状态，并基于任务执行状态，确定待执行任务对应的待执行实例标识；基于待执行实例标识，调用对应的待执行实例以执行待执行任务，并将执行结果返回至调度服务。
6.在本技术的一种实现方式中，在基于集群系统中调度服务提供的前端交互界面，确定执行服务对应的当前任务分配规则之前，方法还包括：将当前任务分配规则对应的待交互智能合约部署于区块链，并确定待交互智能合约对应的唯一编号；在基于集群系统中调度服务提供的前端交互界面，确定执行服务对应的当前任务分配规则之后，方法还包括：调度服务将待交互智能合约的唯一编号记录于集群系统数据库中。
7.在本技术的一种实现方式中，调度服务调用区块链中预存的执行服务对应的待交互智能合约，以确定当前任务分配规则的任务执行状态，具体包括：调度服务读取集群系统数据库，以获取唯一编号，并基于唯一编号，识别出区块链中待交互智能合约；调用待交互智能合约；待交互智能合约确定其中存储的各执行实例的执行次数，为执行服务对应的当前任务分配规则的任务执行状态。
8.在本技术的一种实现方式中，基于任务执行状态，确定待执行任务对应的待执行实例标识，具体包括：待交互智能合约确定各执行实例的执行次数是否都为0，并在确定各执行实例的执行次数都为0的情况下，确定执行服务中的第一执行实例对应的执行实例标识为待执行实例标识；其中，第一执行实例为执行服务中的位置排列为第一个的执行实例；在确定各执行实例的执行次数存在任一执行实例的执行次数不为0的情况下，基于待交互智能合约的合约内容，确定待执行任务对应的待执行实例标识。
9.在本技术的一种实现方式中，基于待交互智能合约的合约内容，确定待执行任务
对应的待执行实例标识，具体包括：确定待交互智能合约对应的任务分配规则为轮询任务分配规则还是权重匹配任务分配规则；在待交互智能合约对应的任务分配规则为轮询任务分配规则的情况下，待交互智能合约基于各执行实例在执行服务中的位置排列，依次将执行服务中各执行实例的执行次数与第一执行实例的执行次数进行对比，确定是否存在与第一执行实例的执行次数不相同的执行实例；在确定不存在与第一执行实例的执行次数不相同的执行实例的情况下，确实第一执行实例的标识为待执行任务对应的待执行实例标识；在确定存在与第一执行实例的执行次数不相同的执行实例的情况下，确定执行服务中第一个与第一执行实例的执行次数不相同的执行实例的标识为待执行任务对应的待执行实例标识。
10.在本技术的一种实现方式中，方法还包括：在待交互智能合约对应的任务分配规则为权重匹配任务分配规则的情况下，确定各执行实例的执行次数是否均达到周期权重分配次数；在确定各执行实例的执行次数均达到周期权重分配次数的情况下，确定第一执行实例的标识为待执行任务对应的待执行实例标识；在确定各执行实例的执行次数未均达到周期权重分配次数的情况下，基于各执行实例在执行服务中的位置排列，确定第一个未达到周期权重分配次数的执行实例的标识为待执行任务对应的待执行实例标识。
11.在本技术的一种实现方式中，在将执行结果返回至调度服务之后，方法还包括：调度服务基于执行结果，确定待执行任务是否执行成功；以及，将执行结果上传至区块链。
12.在本技术的一种实现方式中，方法还包括：在确定待执行任务执行失败的情况下，调度服务将待执行实例标识发送至区块链以触发待交互智能合约进行执行重试；在执行重试次数达到预设阈值的情况下，生成告警信息发送到调度服务提供的前端交互界面。
13.第二方面，本技术实施例还提供了一种基于区块链的任务调度设备，其特征在于，设备包括：至少一个处理器；以及，与至少一个处理器通信连接的存储器；其中，存储器存储有可被至少一个处理器执行的指令，指令被至少一个处理器执行，以使至少一个处理器能够：基于集群系统中调度服务提供的前端交互界面，确定执行服务对应的当前任务分配规则；其中，执行服务包括若干个执行实例；当前任务分配规则为轮询任务分配规则或权重匹配任务分配规则；在集群系统接收到待执行任务的执行请求的情况下，调度服务调用区块链中预存的执行服务对应的待交互智能合约，以确定当前任务分配规则的任务执行状态，并基于任务执行状态，确定待执行任务对应的待执行实例标识；基于待执行实例标识，调用对应的待执行实例以执行待执行任务，并将执行结果返回至调度服务。
14.第三方面，本技术实施例还提供了一种基于区块链的任务调度的非易失性计算机存储介质，存储有计算机可执行指令，其特征在于，计算机可执行指令设置为：基于集群系统中调度服务提供的前端交互界面，确定执行服务对应的当前任务分配规则；其中，执行服务包括若干个执行实例；当前任务分配规则为轮询任务分配规则或权重匹配任务分配规则；在集群系统接收到待执行任务的执行请求的情况下，调度服务调用区块链中预存的执行服务对应的待交互智能合约，以确定当前任务分配规则的任务执行状态，并基于任务执行状态，确定待执行任务对应的待执行实例标识；基于待执行实例标识，调用对应的待执行实例以执行待执行任务，并将执行结果返回至调度服务。
15.本技术实施例提供的一种基于区块链的任务调度方法、设备及存储介质，通过调度服务与区块链进行交互，完成待执行任务的执行实例分配工作，使得每个任务只会被成
功执行一次，保证任务正确完成的同时，还避免了重复执行。另外，借助区块链不可篡改、数据共享的特性，保存了任务的执行详情。
附图说明
16.此处所说明的附图用来提供对本技术的进一步理解，构成本技术的一部分，本技术的示意性实施例及其说明用于解释本技术，并不构成对本技术的不当限定。在附图中：
17.图1为本技术实施例提供的一种基于区块链的任务调度方法流程图；
18.图2为本技术实施例提供的一种基于区块链的任务调度设备内部结构示意图。
具体实施方式
19.为使本技术的目的、技术方案和优点更加清楚，下面将结合本技术具体实施例及相应的附图对本技术技术方案进行清楚、完整地描述。显然，所描述的实施例仅是本技术一部分实施例，而不是全部的实施例。基于本技术中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都属于本技术保护的范围。
20.本技术实施例提供了一种基于区块链的任务调度方法、设备及存储介质，用以解决如下技术问题：如何确保集群系统的任务执行不重复。
21.下面通过附图对本技术实施例提出的技术方案进行详细的说明。
22.图1为本技术实施例提供的一种基于区块链的任务调度方法流程图。如图1所示，本技术实施例提供的一种基于区块链的任务调度方法，具体包括以下步骤：
23.步骤101、基于集群系统中调度服务提供的前端交互界面，确定执行服务对应的当前任务分配规则。
24.在本技术的一个实施例中，为确保集群系统的任务执行不重复，在基于集群系统中调度服务提供的前端交互界面，确定执行服务对应的当前任务分配规则之前，需要将当前任务分配规则对应的待交互智能合约部署于区块链，并确定待交互智能合约对应的唯一编号。
25.在本技术的一个实施例中，执行服务包括若干个执行实例，当前任务分配规则为轮询任务分配规则或权重匹配任务分配规则。
26.在本技术的一个实施例中，在基于集群系统中调度服务提供的前端交互界面，确定执行服务对应的当前任务分配规则之后，调度服务将待交互智能合约的唯一编号记录于集群系统数据库中。
27.步骤102、在集群系统接收到待执行任务的执行请求的情况下，调度服务调用区块链中预存的执行服务对应的待交互智能合约，以确定当前任务分配规则的任务执行状态，并基于任务执行状态，确定待执行任务对应的待执行实例标识。
28.在本技术的一个实施例中，在集群系统接收到待执行任务的执行请求的情况下，调度服务会读取集群系统数据库，以获取唯一编号，并基于唯一编号，识别出区块链中待交互智能合约。
29.进一步地，调用待交互智能合约；待交互智能合约确定其中存储的各执行实例的执行次数，为执行服务对应的当前任务分配规则的任务执行状态。
30.在本技术的一个实施例中，在确定当前任务分配规则的任务执行状态之后，待交
互智能合约确定各执行实例的执行次数是否都为0，并在确定各执行实例的执行次数都为0的情况下，确定执行服务中的第一执行实例对应的执行实例标识为待执行实例标识；其中，第一执行实例为执行服务中的位置排列为第一个的执行实例。
31.进一步地，在确定各执行实例的执行次数存在任一执行实例的执行次数不为0的情况下，基于待交互智能合约的合约内容，确定待执行任务对应的待执行实例标识。
32.在本技术的一个实施例中，基于待交互智能合约的合约内容，确定待执行任务对应的待执行实例标识，具体包括：确定待交互智能合约对应的任务分配规则为轮询任务分配规则还是权重匹配任务分配规则；在待交互智能合约对应的任务分配规则为轮询任务分配规则的情况下，待交互智能合约基于各执行实例在执行服务中的位置排列，依次将执行服务中各执行实例的执行次数与第一执行实例的执行次数进行对比，确定是否存在与第一执行实例的执行次数不相同的执行实例；在确定不存在与第一执行实例的执行次数不相同的执行实例的情况下，确实第一执行实例的标识为待执行任务对应的待执行实例标识；在确定存在与第一执行实例的执行次数不相同的执行实例的情况下，确定执行服务中第一个与第一执行实例的执行次数不相同的执行实例的标识为待执行任务对应的待执行实例标识。
33.在本技术的一个实施例中，方法还包括：在待交互智能合约对应的任务分配规则为权重匹配任务分配规则的情况下，确定各执行实例的执行次数是否均达到周期权重分配次数；在确定各执行实例的执行次数均达到周期权重分配次数的情况下，确定第一执行实例的标识为待执行任务对应的待执行实例标识；在确定各执行实例的执行次数未均达到周期权重分配次数的情况下，基于各执行实例在执行服务中的位置排列，确定第一个未达到周期权重分配次数的执行实例的标识为待执行任务对应的待执行实例标识。
34.例如：执行服务中包含三个执行实例：执行实例1、执行实例2、执行实例3，其对应的周期权重分配次数分别为1、2、7，如果在确定当前的执行实例1、执行实例2、执行实例3对应的周期权重分配次数已经分别是1、2、7了，则进入下一个任务分配周期，直接从执行实例1开始分配。如果当前的执行实例1、执行实例2、执行实例3对应的周期权重分配次数为1、1、0(即确定各执行实例的执行次数未均达到周期权重分配次数)，则根据执行实例的位置排列将当前的待执行任务分配给执行实例2执行。之后如果再有执行任务分配的话，由于执行实例2达到了其对应的周期权重分配次数2，则将任务分配给执行实例3执行，直到执行实例3的执行次数达到周期权重分配次数后，重新进入新的任务分配周期。
35.步骤103、基于待执行实例标识，调用对应的待执行实例以执行待执行任务，并将执行结果返回至调度服务。
36.在本技术的一个实施例中，在确定待执行任务对应的待执行实例标识之后，基于待执行实例标识，调用对应的待执行实例以执行待执行任务，并将执行结果返回至调度服务。在将执行结果返回至调度服务之后，调度服务基于执行结果，确定待执行任务是否执行成功；以及，将执行结果上传至区块链。
37.进一步地，在确定待执行任务执行失败的情况下，调度服务将待执行实例标识发送至区块链以触发待交互智能合约进行执行重试；在执行重试次数达到预设阈值的情况下，生成告警信息发送到调度服务提供的前端交互界面。
38.以上为本技术提出的方法实施例。基于同样的发明构思，本技术实施例还提供了
一种基于区块链的任务调度设备，其结构如图2所示。
39.图2为本技术实施例提供的一种基于区块链的任务调度设备内部结构示意图。如图2所示，设备包括：
40.至少一个处理器201；
41.以及，与至少一个处理器通信连接的存储器202；
42.其中，存储器202存储有可被至少一个处理器执行的指令，指令被至少一个处理器201执行，以使至少一个处理器201能够：
43.基于集群系统中调度服务提供的前端交互界面，确定执行服务对应的当前任务分配规则；其中，执行服务包括若干个执行实例；当前任务分配规则为轮询任务分配规则或权重匹配任务分配规则；
44.在集群系统接收到待执行任务的执行请求的情况下，调度服务调用区块链中预存的执行服务对应的待交互智能合约，以确定当前任务分配规则的任务执行状态，并基于任务执行状态，确定待执行任务对应的待执行实例标识；
45.基于待执行实例标识，调用对应的待执行实例以执行待执行任务，并将执行结果返回至调度服务。
46.本技术的一些实施例提供的对应于图1的一种基于区块链的任务调度的非易失性计算机存储介质，存储有计算机可执行指令，计算机可执行指令设置为：
47.基于集群系统中调度服务提供的前端交互界面，确定执行服务对应的当前任务分配规则；其中，执行服务包括若干个执行实例；当前任务分配规则为轮询任务分配规则或权重匹配任务分配规则；
48.在集群系统接收到待执行任务的执行请求的情况下，调度服务调用区块链中预存的执行服务对应的待交互智能合约，以确定当前任务分配规则的任务执行状态，并基于任务执行状态，确定待执行任务对应的待执行实例标识；
49.基于待执行实例标识，调用对应的待执行实例以执行待执行任务，并将执行结果返回至调度服务。
50.本技术中的各个实施例均采用递进的方式描述，各个实施例之间相同相似的部分互相参见即可，每个实施例重点说明的都是与其他实施例的不同之处。尤其，对于物联网设备和介质实施例而言，由于其基本相似于方法实施例，所以描述的比较简单，相关之处参见方法实施例的部分说明即可。
51.本技术实施例提供的系统和介质与方法是一一对应的，因此，系统和介质也具有与其对应的方法类似的有益技术效果，由于上面已经对方法的有益技术效果进行了详细说明，因此，这里不再赘述系统和介质的有益技术效果。
52.本领域内的技术人员应明白，本技术的实施例可提供为方法、系统、或计算机程序产品。因此，本技术可采用完全硬件实施例、完全软件实施例、或结合软件和硬件方面的实施例的形式。而且，本技术可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、cd-rom、光学存储器等)上实施的计算机程序产品的形式。
53.本技术是参照根据本技术实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流
程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器，使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。
54.这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中，使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品，该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。
55.这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上，使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理，从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。
56.在一个典型的配置中，计算设备包括一个或多个处理器(cpu)、输入/输出接口、网络接口和内存。
57.内存可能包括计算机可读介质中的非永久性存储器，随机存取存储器(ram)和/或非易失性内存等形式，如只读存储器(rom)或闪存(flash ram)。内存是计算机可读介质的示例。
58.计算机可读介质包括永久性和非永久性、可移动和非可移动媒体可以由任何方法或技术来实现信息存储。信息可以是计算机可读指令、数据结构、程序的模块或其他数据。计算机的存储介质的例子包括，但不限于相变内存(pram)、静态随机存取存储器(sram)、动态随机存取存储器(dram)、其他类型的随机存取存储器(ram)、只读存储器(rom)、电可擦除可编程只读存储器(eeprom)、快闪记忆体或其他内存技术、只读光盘只读存储器(cd-rom)、数字多功能光盘(dvd)或其他光学存储、磁盒式磁带，磁带磁磁盘存储或其他磁性存储设备或任何其他非传输介质，可用于存储可以被计算设备访问的信息。按照本文中的界定，计算机可读介质不包括暂存电脑可读媒体(transitory media)，如调制的数据信号和载波。
59.还需要说明的是，术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法、商品或者设备不仅包括那些要素，而且还包括没有明确列出的其他要素，或者是还包括为这种过程、方法、商品或者设备所固有的要素。在没有更多限制的情况下，由语句“包括一个
……”
限定的要素，并不排除在包括所述要素的过程、方法、商品或者设备中还存在另外的相同要素。
60.以上所述仅为本技术的实施例而已，并不用于限制本技术。对于本领域技术人员来说，本技术可以有各种更改和变化。凡在本技术的精神和原理之内所作的任何修改、等同替换、改进等，均应包含在本技术的权利要求范围之内。

技术特征：
1.一种基于区块链的任务调度方法，其特征在于，所述方法包括：基于集群系统中调度服务提供的前端交互界面，确定执行服务对应的当前任务分配规则；其中，所述执行服务包括若干个执行实例；所述当前任务分配规则为轮询任务分配规则或权重匹配任务分配规则；在所述集群系统接收到待执行任务的执行请求的情况下，所述调度服务调用区块链中预存的所述执行服务对应的待交互智能合约，以确定当前任务分配规则的任务执行状态，并基于所述任务执行状态，确定所述待执行任务对应的待执行实例标识；基于所述待执行实例标识，调用对应的待执行实例以执行所述待执行任务，并将执行结果返回至所述调度服务。2.根据权利要求1所述的一种基于区块链的任务调度方法，其特征在于，在基于集群系统中调度服务提供的前端交互界面，确定执行服务对应的当前任务分配规则之前，所述方法还包括：将所述当前任务分配规则对应的待交互智能合约部署于区块链，并确定所述待交互智能合约对应的唯一编号；在基于集群系统中调度服务提供的前端交互界面，确定执行服务对应的当前任务分配规则之后，所述方法还包括：所述调度服务将所述待交互智能合约的唯一编号记录于集群系统数据库中。3.根据权利要求2所述的一种基于区块链的任务调度方法，其特征在于，所述调度服务调用区块链中预存的所述执行服务对应的待交互智能合约，以确定当前任务分配规则的任务执行状态，具体包括：所述调度服务读取所述集群系统数据库，以获取所述唯一编号，并基于所述唯一编号，识别出所述区块链中待交互智能合约；调用所述待交互智能合约；所述待交互智能合约确定其中存储的各执行实例的执行次数，为所述执行服务对应的当前任务分配规则的任务执行状态。4.根据权利要求3所述的一种基于区块链的任务调度方法，其特征在于，基于所述任务执行状态，确定所述待执行任务对应的待执行实例标识，具体包括：所述待交互智能合约确定所述各执行实例的执行次数是否都为0，并在确定所述各执行实例的执行次数都为0的情况下，确定所述执行服务中的第一执行实例对应的执行实例标识为待执行实例标识；其中，所述第一执行实例为所述执行服务中的位置排列为第一个的执行实例；在确定所述各执行实例的执行次数存在任一执行实例的执行次数不为0的情况下，基于所述待交互智能合约的合约内容，确定所述待执行任务对应的待执行实例标识。5.根据权利要求4所述的一种基于区块链的任务调度方法，其特征在于，基于所述待交互智能合约的合约内容，确定所述待执行任务对应的待执行实例标识，具体包括：确定所述待交互智能合约对应的任务分配规则为轮询任务分配规则还是权重匹配任务分配规则；在所述待交互智能合约对应的任务分配规则为轮询任务分配规则的情况下，所述待交互智能合约基于各执行实例在所述执行服务中的位置排列，依次将所述执行服务中各执行
实例的执行次数与第一执行实例的执行次数进行对比，确定是否存在与第一执行实例的执行次数不相同的执行实例；在确定不存在与第一执行实例的执行次数不相同的执行实例的情况下，确实所述第一执行实例的标识为所述待执行任务对应的待执行实例标识；在确定存在与第一执行实例的执行次数不相同的执行实例的情况下，确定所述执行服务中第一个与第一执行实例的执行次数不相同的执行实例的标识为所述待执行任务对应的待执行实例标识。6.根据权利要求5所述的一种基于区块链的任务调度方法，其特征在于，所述方法还包括：在所述待交互智能合约对应的任务分配规则为权重匹配任务分配规则的情况下，确定所述各执行实例的执行次数是否均达到周期权重分配次数；在确定所述各执行实例的执行次数均达到周期权重分配次数的情况下，确定所述第一执行实例的标识为所述待执行任务对应的待执行实例标识；在确定所述各执行实例的执行次数未均达到周期权重分配次数的情况下，基于各执行实例在所述执行服务中的位置排列，确定第一个未达到周期权重分配次数的执行实例的标识为所述待执行任务对应的待执行实例标识。7.根据权利要求1所述的一种基于区块链的任务调度方法，其特征在于，在将执行结果返回至所述调度服务之后，所述方法还包括：所述调度服务基于所述执行结果，确定所述待执行任务是否执行成功；以及，将所述执行结果上传至区块链。8.根据权利要求7所述的一种基于区块链的任务调度方法，其特征在于，所述方法还包括：在确定所述待执行任务执行失败的情况下，所述调度服务将所述待执行实例标识发送至所述区块链以触发所述待交互智能合约进行执行重试；在执行重试次数达到预设阈值的情况下，生成告警信息发送到所述调度服务提供的前端交互界面。9.一种基于区块链的任务调度设备，其特征在于，所述设备包括：至少一个处理器；以及，与所述至少一个处理器通信连接的存储器；其中，所述存储器存储有可被所述至少一个处理器执行的指令，所述指令被所述至少一个处理器执行，以使所述至少一个处理器能够：基于集群系统中调度服务提供的前端交互界面，确定执行服务对应的当前任务分配规则；其中，所述执行服务包括若干个执行实例；所述当前任务分配规则为轮询任务分配规则或权重匹配任务分配规则；在所述集群系统接收到待执行任务的执行请求的情况下，所述调度服务调用区块链中预存的所述执行服务对应的待交互智能合约，以确定当前任务分配规则的任务执行状态，并基于所述任务执行状态，确定所述待执行任务对应的待执行实例标识；基于所述待执行实例标识，调用对应的待执行实例以执行所述待执行任务，并将执行结果返回至所述调度服务。
10.一种基于区块链的任务调度的非易失性计算机存储介质，存储有计算机可执行指令，其特征在于，所述计算机可执行指令设置为：基于集群系统中调度服务提供的前端交互界面，确定执行服务对应的当前任务分配规则；其中，所述执行服务包括若干个执行实例；所述当前任务分配规则为轮询任务分配规则或权重匹配任务分配规则；在所述集群系统接收到待执行任务的执行请求的情况下，所述调度服务调用区块链中预存的所述执行服务对应的待交互智能合约，以确定当前任务分配规则的任务执行状态，并基于所述任务执行状态，确定所述待执行任务对应的待执行实例标识；基于所述待执行实例标识，调用对应的待执行实例以执行所述待执行任务，并将执行结果返回至所述调度服务。

技术总结
本申请公开了一种基于区块链的任务调度方法、设备及存储介质。方法包括：基于集群系统中调度服务提供的前端交互界面，确定执行服务对应的当前任务分配规则；其中，执行服务包括若干个执行实例；当前任务分配规则为轮询任务分配规则或权重匹配任务分配规则；在集群系统接收到待执行任务的执行请求的情况下，调度服务调用区块链中预存的执行服务对应的待交互智能合约，以确定当前任务分配规则的任务执行状态，并基于任务执行状态，确定待执行任务对应的待执行实例标识；基于待执行实例标识，调用对应的待执行实例以执行待执行任务，并将执行结果返回至调度服务。本申请通过上述方法保证了集群系统的任务执行不重复。证了集群系统的任务执行不重复。证了集群系统的任务执行不重复。


技术研发人员：杨竹 肖雪 商广勇 李程 刘宁
受保护的技术使用者：浪潮工业互联网股份有限公司
技术研发日：2023.05.06
技术公布日：2023/8/14