业务节点控制方法、系统、设备及存储介质与流程

    专利2022-07-08  70


    本发明涉及数据处理技术领域,尤其涉及一种业务节点控制方法、系统、设备及存储介质。



    背景技术:

    在物流仓配系统中,有多个核心业务节点,例如创建物流单的业务节点、将物流单下发给服务商的业务节点、服务商接单的业务节点、确认发货的业务节点和更改库存的业务节点等。在物流仓配系统运作中,可能会由于系统故障或网络抖动而导致某一些业务节点执行失败。现有技术中,对于业务节点执行失败的情况,解决方案包括:通过定时任务的方式进行重试,即每隔一定预设间隔时间来进行业务节点的重试,然而现有的重试间隔时间如果设置得过短,会造成物流仓配系统的压力过大,如果设置得过长,则可能会导致业务节点执行失败的处理不及时,造成物流单业务流转速度过慢,影响消费者体验,也可能会造成业务节点执行失败的故障堆积而来不及处理。



    技术实现要素:

    针对现有技术中的问题,本发明的目的在于提供一种业务节点控制方法、系统、设备及存储介质,可以查询业务节点执行状态并且在接收到重放请求时重新执行业务节点,解决了现有技术中采用定时重试方法存在的缺陷。

    本发明实施例提供一种业务节点控制方法,包括如下步骤:

    接收到用户的业务节点信息查询请求;

    从业务节点数据库中查询所述业务节点信息查询请求所对应的业务节点信息,所述业务节点信息包括节点执行状态;

    接收到用户的第一业务节点重放请求;

    向业务系统的业务重放接口发送第二业务节点重放请求,所述业务系统配置为接收到所述第二业务节点重放请求时,控制所对应的业务节点重新执行业务脚本。

    在一些实施例中,所述业务节点数据库包括分布式搜索引擎。

    在一些实施例中,所述业务节点信息查询请求包括被查询的业务节点的节点类型;

    所述从业务节点数据库中查询所述业务节点信息查询请求所对应的业务节点信息,包括从业务节点数据库中查询所述被查询的业务节点的节点类型所对应的业务节点信息。

    在一些实施例中,所述业务节点信息查询请求还包括被查询的业务id;

    所述从业务节点数据库中查询所述业务节点信息查询请求所对应的业务节点信息,包括从业务节点数据库中查询所述被查询的业务节点的节点类型和所述业务id所对应的业务节点信息。

    在一些实施例中,所述第一业务节点重放请求和所述第二业务节点重放请求分别包括用户请求重放的业务节点的节点类型;

    所述业务系统配置为接收到所述第二业务节点重放请求时,根据用户请求重放的业务节点的节点类型,控制所对应的业务节点重新执行业务脚本。

    在一些实施例中,所述第一业务节点重放请求和所述第二业务节点重放请求还分别包括用户请求重放的业务id;

    所述业务系统配置为接收到所述第二业务节点重放请求时,根据用户请求重放的业务节点的节点类型,控制所对应的业务节点重新执行与所述业务id所对应的业务脚本。

    在一些实施例中,所述向业务系统的业务重放接口发送第二业务节点重放请求,包括如下步骤:

    远程调用所述业务系统的基于http协议的业务重放接口,向所述业务重放接口发送所述第二业务节点重放请求。

    在一些实施例中,基于ajax远程调用所述业务系统的业务重放接口。

    在一些实施例中,所述业务系统还配置为从各个业务节点获取业务节点信息,并存入所述业务节点数据库。

    在一些实施例中,所述业务系统配置为基于网络请求切面的方式从各个业务节点获取业务节点的接口请求参数、业务节点的节点执行状态和节点类型。

    在一些实施例中,所述从业务节点数据库中查询所述业务节点信息查询请求所对应的业务节点信息之后,还包括如下步骤:

    判断是否有节点执行状态为执行失败的业务节点;

    如果是,则向业务系统的业务重放接口发送第三业务节点重放请求,所述业务系统配置为接收到所述第三业务节点重放请求时,控制所对应的业务节点重新执行业务脚本。

    本发明实施例还提供一种业务节点控制系统,应用于所述的业务节点控制方法,所述系统包括:

    请求接收模块,用于接收用户的业务节点信息查询请求,以及接收用户的第一业务节点重放请求;

    信息查询模块,用于接收到用户的业务节点信息查询请求时,从业务节点数据库中查询所述业务节点信息查询请求所对应的业务节点信息,所述业务节点信息包括节点执行状态;

    节点重放模块,用于接收到用户的第一业务节点重放请求时,向业务系统的业务重放接口发送第二业务节点重放请求,所述业务系统配置为接收到所述第二业务节点重放请求时,控制所对应的业务节点重新执行业务脚本。

    本发明实施例还提供一种业务节点控制设备,包括:

    处理器;

    存储器,其中存储有所述处理器的可执行指令;

    其中,所述处理器配置为经由执行所述可执行指令来执行所述的业务节点控制方法的步骤。

    本发明实施例还提供一种计算机可读存储介质,用于存储程序,所述程序被处理器执行时实现所述的业务节点控制方法的步骤。

    应当理解的是,以上的一般描述和后文的细节描述仅是示例性和解释性的,并不能限制本公开。

    本发明的业务节点控制方法、系统、设备及存储介质具有如下有益效果:

    本发明可以查询业务节点执行状态,方便工作人员按需了解业务节点的执行情况,并且在接收到重放请求时重新执行业务节点,工作人员可以根据业务节点执行状态的查询情况,选择执行失败的业务节点进行重放,而无需等待预设间隔时间,并且不会造成业务系统过大的处理负担,解决了现有技术中采用定时重试方法存在的缺陷。本发明的业务节点控制方案不仅可以应用于物流仓配系统的业务节点控制中,也可以应用于其他类型的业务系统的业务节点控制中,例如其他服务行业的服务单管理系统等。

    附图说明

    通过阅读参照以下附图对非限制性实施例所作的详细描述,本发明的其它特征、目的和优点将会变得更明显。

    图1是本发明一实施例的业务节点控制方法的流程图;

    图2是本发明一实施例的业务系统的结构示意图;

    图3是本发明一实施例的自动请求业务节点重放的流程图;

    图4是本发明一实施例的业务节点控制系统的结构示意图;

    图5是本发明一实施例的业务节点控制系统与其他系统交互的示意图;

    图6是本发明一实施例的增加自动重放判断后的业务节点控制系统的结构示意图;

    图7是本发明一实施例的业务节点控制设备的结构示意图;

    图8是本发明一实施例的计算机可读存储介质的结构示意图。

    具体实施方式

    现在将参考附图更全面地描述示例实施方式。然而,示例实施方式能够以多种形式实施,且不应被理解为限于在此阐述的范例;相反,提供这些实施方式使得本公开将更加全面和完整,并将示例实施方式的构思全面地传达给本领域的技术人员。所描述的特征、结构或特性可以以任何合适的方式结合在一个或更多实施方式中。

    此外,附图仅为本公开的示意性图解,并非一定是按比例绘制。图中相同的附图标记表示相同或类似的部分,因而将省略对它们的重复描述。附图中所示的一些方框图是功能实体,不一定必须与物理或逻辑上独立的实体相对应。可以采用软件形式来实现这些功能实体,或在一个或多个硬件模块或集成电路中实现这些功能实体,或在不同网络和/或处理器装置和/或微控制器装置中实现这些功能实体。

    附图中所示的流程图仅是示例性说明,不是必须包括所有的步骤。例如,有的步骤还可以分解,而有的步骤可以合并或部分合并,因此,实际执行的顺序有可能根据实际情况改变。

    如图1所示,本发明实施例提供一种业务节点控制方法,包括如下步骤:

    s100:接收到用户的业务节点信息查询请求;

    s200:从业务节点数据库中查询所述业务节点信息查询请求所对应的业务节点信息,所述业务节点信息包括节点执行状态;

    s300:接收到用户的第一业务节点重放请求;

    s400:向业务系统的业务重放接口发送第二业务节点重放请求,所述业务系统配置为接收到所述第二业务节点重放请求时,控制所对应的业务节点重新执行业务脚本。

    在本发明中,业务节点重放,即指的是业务节点重新执行其业务脚本。本发明通过步骤s100和s200,在接收到用户的查询请求时,可以查询业务节点执行状态,方便用户按需了解业务节点的执行情况,并且通过步骤s300和s400,在接收到重放请求时重新执行业务节点,用户可以根据业务节点执行状态的查询情况,选择执行失败的业务节点进行重放,而无需等待预设间隔时间,并且不会造成业务系统过大的处理负担,解决了现有技术中采用定时重试方法存在的缺陷。

    本发明的业务节点控制方法可以应用于一电子设备中,该电子设备可以与业务节点数据库进行通信,以获取业务节点信息查询请求所对应的业务节点信息,也可以与业务系统的业务重放接口通信,以通过所述业务重放接口请求业务系统对指定的业务节点重放。该电子设备可以是服务器、笔记本、台式机等设备。

    如图2示出了业务系统的结构示意图。业务系统m200中包括多个业务节点m210,每个业务节点m210执行不同的业务脚本。业务系统m200提供一业务重放接口m220,供本发明的业务节点控制方法调用。

    所述步骤s100中,接收到用户的业务节点信息查询请求,可以是接收到用户通过用户端发送的业务节点信息查询请求,该用户端可以是用户使用的移动终端、笔记本电脑、台式机等终端设备。在另一种实施方式中,所述业务节点控制方法也可以应用于具有输入装置的电子设备中,所述步骤s100中,接收到用户的业务节点信息查询请求,也可以是所述电子设备通过输入装置直接接收到用户的业务节点信息查询请求。

    所述步骤s200,从业务节点数据库中查询所述业务节点信息查询请求所对应的业务节点信息之后,还可以进一步包括展示所述业务节点信息的步骤,以供用户查看。在该实施例中,用户指的是业务节点执行管理的工作人员。展示所述业务节点信息可以采用多种不同的方式。例如,在所述业务节点应用于具有显示装置的电子设备中时,可以直接在显示装置中显示被查询的业务节点信息。所述业务节点也可以将被查询的业务节点信息发送到用户端,该用户端可以是步骤s100中发送业务节点信息查询请求的终端,也可以是与被查询的业务节点有预设映射关系的指定用户终端。

    所述步骤s300中,接收到用户的第一业务节点重放请求,可以是接收到用户通过用户端发送的重放请求。在另一种实施方式中,所述业务节点控制方法也可以应用于具有输入装置的电子设备中,所述步骤s300中,接收到用户的第一业务节点重放请求,也可以是所述电子设备通过输入装置直接接收到用户的第一业务节点重放请求。

    下面以将本发明的业务节点控制方法应用于物流领域中为例进行说明,实现物流仓配系统的业务节点控制。但可以理解的是,本发明不限于此。本发明的业务节点控制方案不仅可以应用于物流仓配系统的业务节点控制中,也可以应用于其他类型的业务系统的业务节点控制中,例如其他服务行业的服务单管理系统等。

    在该实施例中,所述业务节点数据库可以采用分布式搜索引擎,例如elasticsearch引擎。elasticsearch引擎提供了一个分布式多用户能力的全文搜索引擎,具有实时搜索、稳定、可靠、快速和安装使用方便的特点。

    如图2所示,所述业务系统还配置为从各个业务节点获取业务节点信息,并存入所述业务节点数据库m300。具体地,所述业务节点信息至少包括业务节点的接口请求参数、业务节点的节点执行状态和节点类型。进一步地,在该实施例中,所述业务系统配置为基于网络请求切面的方式从各个业务节点获取业务节点的接口请求参数、业务节点的节点执行状态和节点类型。切面指的是可以通过预编译方式和运行期动态代理实现在不修改源代码的情况下给程序动态统一添加功能的一种技术,可以将日志记录、数据采集等代码从业务系统本身的逻辑代码中划分出来。此处所述业务系统基于网络请求切面的方式从各个业务节点获取业务节点的接口请求参数、业务节点的节点执行状态和节点类型,即将采集业务节点信息并存储到业务节点数据库中的代码部分以切面的形式添加到业务系统中,可以将此部分功能从业务系统中独立出来,可以使得多个动作共享该功能,并且不会对业务系统原有的逻辑产生影响。

    在该实施例中,所述业务节点信息查询请求包括被查询的业务节点的节点类型。在所述业务节点控制方法应用于物流领域时,所述业务系统指的是物流仓配系统,其中的业务节点类型可以有创建物流单的业务节点类型、将物流单下发给服务商的业务节点类型、服务商接单的业务节点类型、确认发货的业务节点类型和更改库存的业务节点类型等。

    在步骤s100中,接收到的业务节点信息查询请求中,可以定义nodetype(节点类型)枚举来区分不同的业务节点类型。所述步骤s200中,查询所述业务节点信息查询请求所对应的业务节点信息,包括查询所述业务节点信息查询请求中业务节点类型的业务节点信息。查询到业务节点信息后返回给用户时,可以使用一个布尔类型变量表示业务节点是否执行成功,即表示节点执行状态。

    在该实施例中,所述物流仓配系统可以同时处理多个业务,每个业务对应于一个唯一的物流单号,该物流单号可以作为标识此业务的业务id。在所述步骤s100中,接收到的所述业务节点信息查询请求还可以包括被查询的业务id,以实现针对于特定业务id的特定业务节点的执行状态查询。

    所述步骤s200中,从业务节点数据库中查询所述业务节点信息查询请求所对应的业务节点信息,包括从业务节点数据库中查询所述被查询的业务节点的节点类型和所述业务id所对应的业务节点信息,即所述被查询的业务节点的节点类型执行某一个具体的业务id所对应的业务是否成功的状态。例如,所述业务节点信息查询请求包括下发服务商节点类型和至少一个特定的物流单号a。则所述业务系统配置为控制下发服务商节点类型重新执行与该特定的物流单号a相对应的业务脚本,以重新执行该特定的物流单号a的下发服务商动作。因此,用户可以通过发送业务节点信息查询请求实现以业务id 业务节点类型 节点执行状态三个维度的业务节点信息查询。

    在另一种实施方式中,所述业务节点信息查询请求也可以只包括业务节点的类型。可以设置查询所述业务节点数据库中存储的预设时间范围内所有该业务节点的类型所对应的业务节点的所有业务的执行状态,并进行展示。

    在该实施例中,所述步骤s300中的第一业务节点重放请求和所述步骤s400中的所述第二业务节点重放请求分别包括用户请求重放的业务节点的节点类型。

    在本发明中,第一业务节点重放请求和第二业务节点重放请求中的“第一”和“第二”仅为表示发送方和接收方的不同。即,第一业务节点重放请求的发送方为用户,接收方为应用该业务节点控制方法的电子设备,第二业务节点的发送方为应用该业务节点控制方法的电子设备,接收方为业务系统。由于第二业务节点重放请求是根据第一业务节点重放请求生成的,因此,第一业务节点重放请求和第二业务节点重放请求中所指向的需要重放的业务节点类型是相同的。

    所述业务系统配置为接收到所述第二业务节点重放请求时,根据用户请求重放的业务节点的节点类型,控制所对应的业务节点重新执行业务脚本。例如,用户发送的第一业务节点重放请求是针对于服务商接单的业务节点类型的,则向业务系统发送的第二业务节点重放请求也是针对于服务商接单的业务节点类型的。所述业务系统接收到该第二业务节点重放请求之后,控制服务商节点的业务节点重新执行业务脚本,以实现重放功能。

    在该实施例中,在业务系统同时处理多个业务时,所述步骤s300中的第一业务节点重放请求和所述步骤s400中的所述第二业务节点重放请求还分别包括包括用户请求重放的业务id。同样地,每个业务对应于一个唯一的物流单号,该物流单号可以作为标识此业务的业务id。由于第二业务节点重放请求是根据第一业务节点重放请求生成的,因此,第一业务节点重放请求和第二业务节点重放请求中所指向的需要重放的业务id是相同的。

    所述业务系统配置为接收到所述第二业务节点重放请求时,根据用户请求重放的业务节点的节点类型,控制所对应的业务节点重新执行与所述业务id所对应的业务脚本。例如,接收到的所述第一业务节点重放请求包括确认发货业务节点类型和至少一个特定物流单号b,则将包括有确认发货业务节点类型和至少一个特定物流单号b的第二业务节点重放请求发送给业务系统。业务系统接收倒该第二业务节点重放请求后,控制确认发货业务节点重新执行特定物流单号b的确认发货动作,以实现业务节点重放。

    在该实施例中,所述业务系统的业务重放接口为基于http(hypertexttransferprotocol,超文本传输协议)协议的接口。所述步骤s400中,向业务系统的业务重放接口发送第二业务节点重放请求,包括:远程调用所述业务系统的基于http协议的业务重放接口,向所述业务重放接口发送所述第二业务节点重放请求。

    在该实施例中,所述步骤s400中,远程调用所述业务系统的业务重放接口时,基于ajax远程调用所述业务系统的业务重放接口。通过基于ajax方式远程调用http接口,可以在不刷新页面的情况下,通过ajax的方式与业务系统交换数据。

    因此,通过采用本发明的业务节点控制方法,在用户通过步骤s100和步骤s200查询到所需要了解的业务节点和业务id对应的节点执行状态之后,可以根据节点执行状态人工选择执行失败的业务节点,确定执行失败的部分或全部业务节点需要重放,然后通过步骤s300和步骤s400实现需要重放的业务节点的重放请求的发送。

    进一步地,在本发明中,通过步骤s100和步骤s200从业务节点数据库中获取到了业务节点信息之后,还可以根据业务节点信息中节点执行状态自动选择需要重放的业务节点,并且自动向业务系统发送业务节点重放请求,从而实现了整个节点查询和重放流程的自动化。具体地,如图3所示,所述步骤s200:从业务节点数据库中查询所述业务节点信息查询请求所对应的业务节点信息之后,还包括如下步骤:

    s500:判断是否有节点执行状态为执行失败的业务节点;

    s600:如果是,则向业务系统的业务重放接口发送第三业务节点重放请求,所述业务系统配置为接收到所述第三业务节点重放请求时,控制所对应的业务节点重新执行业务脚本;

    s700:如果不存在节点执行状态为执行失败的业务节点,则结束当前流程。

    此处第三业务节点重放请求指的在通过步骤s200查询到各个业务节点的业务执行状态之后,如果有执行失败的业务节点,则自动基于该执行失败的业务节点生成的业务节点重放请求,由该业务节点控制方法应用的电子设备发送至所述业务系统。所述第三业务节点重放请求中所包括的业务节点类型即为执行失败的业务节点的类型。

    进一步地,在判断有节点执行状态为执行失败的业务节点之后,还可以进一步获取执行失败的业务id。根据执行失败的业务节点的类型和对应的执行失败的业务id生成所述第三业务节点重放请求并发送至所述业务系统。所述业务系统配置为接收到所述第三业务节点重放请求时,控制所对应的业务节点重新执行与所述业务id相对应的业务脚本,以实现特定的业务id的特定业务节点重放。例如,通过步骤s200查询到物流单号c的更改库存节点执行失败,则生成包括该物流单号c和更改库存节点类型的第三业务节点重放请求,并发送给业务系统。业务系统接收倒该第三业务节点重放请求后,控制更改库存节点重新执行特定物流单号c的更改库存动作,以实现业务节点重放。

    如图4和图5所示,本发明实施例还提供一种业务节点控制系统m100,应用于所述的业务节点控制方法,所述系统包括:

    请求接收模块m110,用于接收用户的业务节点信息查询请求,以及接收用户的第一业务节点重放请求;

    信息查询模块m120,用于接收到用户的业务节点信息查询请求时,从业务节点数据库m300中查询所述业务节点信息查询请求所对应的业务节点信息,所述业务节点信息包括节点执行状态;

    节点重放模块m130,用于接收到用户的第一业务节点重放请求时,向业务系统m200的业务重放接口m220发送第二业务节点重放请求,所述业务系统m200配置为接收到所述第二业务节点重放请求时,控制所对应的业务节点m210重新执行业务脚本。

    本发明通过请求接收模块m110和信息查询模块m120,在接收到用户的查询请求时,可以查询业务节点执行状态,方便用户按需了解业务节点的执行情况,并且通过请求接收模块m110和节点重放模块m130,在接收到重放请求时重新执行业务节点,用户可以根据业务节点执行状态的查询情况,选择执行失败的业务节点进行重放,而无需等待预设间隔时间,并且不会造成业务系统m200过大的处理负担,解决了现有技术中采用定时重试方法存在的缺陷。

    如图5所示,本发明的业务节点控制系统m100可以应用于一电子设备中,该电子设备可以与业务节点数据库m300进行通信,以从业务节点数据库m300获取业务节点信息查询请求所对应的业务节点信息,也可以与业务系统m200的业务重放接口m220通信,以通过所述业务重放接口m220请求业务系统m200对指定的业务节点m210重放。该电子设备可以是服务器、笔记本、台式机等设备。

    所述请求接收模块m110用于与用户进行交互,交互的方式可以是所述请求接收模块m110从用户终端获取用户的请求,并且可以将查询到的业务节点信息发送给用户终端,也可以是通过所述业务节点控制系统所部属的电子设备本身具有的显示装置和输入装置与用户交互。具体地,所述请求接收模块m110接收用户的业务节点信息查询请求,可以是与用户终端通信,接收用户通过用户终端发送的业务节点信息查询请求,也可以是通过电子设备的显示屏显示可供用户选择查看的业务节点,并且通过输入装置(例如键盘、触摸屏、鼠标等)获取用户对需要查看的业务节点的选择。

    具体地,所述请求接收模块m110接收用户的第一业务节点重放请求,可以是与用户终端通信,接收用户通过用户终端发送的第一业务节点重放请求。例如,所述请求接收模块m110可以将所述信息查询模块m120查询到的业务节点信息发送至用户终端,用户终端显示各个业务节点的执行状态,用户可以直接在用户终端上选择需要重放的业务节点,所述用户终端根据用户的选择发送第一业务节点重放请求给所述请求接收模块m110。在另一种实施方式中,也可以是所述请求接收模块m110可以将所述信息查询模块m120查询到的业务节点信息显示在电子设备的显示装置中,用户可以通过输入装置选择需要重放的业务节点,从而发送第一业务节点重放请求。此外,用户也可以通过输入业务节点类型的编号、名称等方式来发送业务节点信息查询请求和第一业务节点重放请求。

    所述业务节点控制系统可以应用于物流领域,实现物流仓配系统的业务节点控制,也可以应用于其他服务行业的服务单管理系统中。在应用于物流领域时,所述业务节点信息查询请求和第一业务节点重放请求可以包括用户所指定的业务节点的类型,以实现特定业务节点的类型的业务节点信息查询和特定业务节点的类型的业务节点重放。所述业务节点信息查询请求和第一业务节点重放请求也可以包括用户所指定的业务id,在物流领域,业务id即为作为业务标识的物流单号。所述第二业务节点重放请求由于是根据第一业务节点重放请求生成的,因此其所包括的业务节点的类型和业务id与第一业务节点重放请求相同。

    所述业务节点信息查询请求包括被查询的业务节点的类型和业务id时,所述信息查询模块m120查询业务节点信息包括所述信息查询模块m120从业务节点数据库m300中查询所述被查询的业务节点的节点类型和所述业务id所对应的业务节点信息。所述业务节点数据库m300可以为分布式搜索引擎,例如elasticsearch引擎。

    所述第一业务节点重放请求包括业务节点的类型和业务id时,所述节点重放模块m130接收到用户的第一业务节点重放请求时,根据所述业务节点的类型和业务id生成第二业务节点重放请求,并发送至业务系统m200的业务重放接口m220。所述业务系统m200配置为接收到所述第二业务节点重放请求时,根据用户请求重放的业务节点的节点类型,控制所对应的业务节点m210重新执行与所述业务id所对应的业务脚本。所述业务系统m200的业务重放接口m220可以为基于http协议的接口。所述节点重放模块m130远程调用所述业务重放接口m220,可以是基于ajax方式远程调用http接口,但本发明不限于此。

    进一步地,在本发明中,通过请求接收模块m110和信息查询模块m12从业务节点数据库m300中获取到了业务节点信息之后,还可以根据业务节点信息中节点执行状态自动选择需要重放的业务节点,并且自动向业务系统m200发送业务节点重放请求,从而实现了整个节点查询和重放流程的自动化。具体地,如图6所示,所述业务节点控制系统还可以包括重放判断模块m140,所述重放判断模块m140用于在所述信息查询模块m120查询到业务节点的节点执行状态之后,判断是否有节点执行状态为执行失败的业务节点,如果是,则生成第三业务节点重放请求,所述第三业务节点重放请求包括该执行失败的业务节点的类型,如果不存在节点执行状态为执行失败的业务节点,则结束当前的判断流程。

    所述节点重放模块m130还用于在所述重放判断模块m140生成第三业务节点重放请求之后,向业务系统m200的业务重放接口m220发送第三业务节点重放请求,所述业务系统m200配置为接收到所述第三业务节点重放请求时,控制所对应的业务节点m210重新执行业务脚本。

    进一步地,在所述重放判断模块m140判断有节点执行状态为执行失败的业务节点之后,还可以进一步获取执行失败的业务id。根据执行失败的业务节点的类型和对应的执行失败的业务id生成所述第三业务节点重放请求,并由所述节点重放模块m130发送至所述业务系统m200。所述业务系统m200配置为接收到所述第三业务节点重放请求时,控制所对应的业务节点重新执行与所述业务id相对应的业务脚本,以实现特定的业务id的特定业务节点重放。

    本发明实施例还提供一种业务节点控制设备,包括处理器;存储器,其中存储有所述处理器的可执行指令;其中,所述处理器配置为经由执行所述可执行指令来执行所述的业务节点控制方法的步骤。

    所属技术领域的技术人员能够理解,本发明的各个方面可以实现为系统、方法或程序产品。因此,本发明的各个方面可以具体实现为以下形式,即:完全的硬件实施方式、完全的软件实施方式(包括固件、微代码等),或硬件和软件方面结合的实施方式,这里可以统称为“电路”、“模块”或“平台”。

    下面参照图7来描述根据本发明的这种实施方式的电子设备600。图7显示的电子设备600仅仅是一个示例,不应对本发明实施例的功能和使用范围带来任何限制。

    如图7所示,电子设备600以通用计算设备的形式表现。电子设备600的组件可以包括但不限于:至少一个处理单元610、至少一个存储单元620、连接不同系统组件(包括存储单元620和处理单元610)的总线630、显示单元640等。

    其中,所述存储单元存储有程序代码,所述程序代码可以被所述处理单元610执行,使得所述处理单元610执行本说明书上述业务节点控制方法部分中描述的根据本发明各种示例性实施方式的步骤。例如,所述处理单元610可以执行如图1中所示的步骤。

    所述存储单元620可以包括易失性存储单元形式的可读介质,例如随机存取存储单元(ram)6201和/或高速缓存存储单元6202,还可以进一步包括只读存储单元(rom)6203。

    所述存储单元620还可以包括具有一组(至少一个)程序模块6205的程序/实用工具6204,这样的程序模块6205包括但不限于:操作系统、一个或者多个应用程序、其它程序模块以及程序数据,这些示例中的每一个或某种组合中可能包括网络环境的实现。

    总线630可以为表示几类总线结构中的一种或多种,包括存储单元总线或者存储单元控制器、外围总线、图形加速端口、处理单元或者使用多种总线结构中的任意总线结构的局域总线。

    电子设备600也可以与一个或多个外部设备700(例如键盘、指向设备、蓝牙设备等)通信,还可与一个或者多个使得用户能与该电子设备600交互的设备通信,和/或与使得该电子设备600能与一个或多个其它计算设备进行通信的任何设备(例如路由器、调制解调器等等)通信。这种通信可以通过输入/输出(i/o)接口650进行。并且,电子设备600还可以通过网络适配器660与一个或者多个网络(例如局域网(lan),广域网(wan)和/或公共网络,例如因特网)通信。网络适配器660可以通过总线630与电子设备600的其它模块通信。应当明白,尽管图中未示出,可以结合电子设备600使用其它硬件和/或软件模块,包括但不限于:微代码、设备驱动器、冗余处理单元、外部磁盘驱动阵列、raid系统、磁带驱动器以及数据备份存储系统等。

    所述业务节点控制设备中,所述存储器中的程序被处理器执行时实现所述的业务节点控制方法的步骤,因此,所述计算机存储介质也可以获得上述业务节点控制方法的技术效果。

    本发明实施例还提供一种计算机可读存储介质,用于存储程序,所述程序被处理器执行时实现所述的业务节点控制方法的步骤。在一些可能的实施方式中,本发明的各个方面还可以实现为一种程序产品的形式,其包括程序代码,当所述程序产品在终端设备上执行时,所述程序代码用于使所述终端设备执行本说明书上述业务节点控制方法部分中描述的根据本发明各种示例性实施方式的步骤。

    参考图8所示,描述了根据本发明的实施方式的用于实现上述方法的程序产品800,其可以采用便携式紧凑盘只读存储器(cd-rom)并包括程序代码,并可以在终端设备,例如个人电脑上执行。然而,本发明的程序产品不限于此,在本文件中,可读存储介质可以是任何包含或存储程序的有形介质,该程序可以被指令执行系统、装置或者器件使用或者与其结合使用。

    所述程序产品可以采用一个或多个可读介质的任意组合。可读介质可以是可读信号介质或者可读存储介质。可读存储介质例如可以为但不限于电、磁、光、电磁、红外线、或半导体的系统、装置或器件,或者任意以上的组合。可读存储介质的更具体的例子(非穷举的列表)包括:具有一个或多个导线的电连接、便携式盘、硬盘、随机存取存储器(ram)、只读存储器(rom)、可擦式可编程只读存储器(eprom或闪存)、光纤、便携式紧凑盘只读存储器(cd-rom)、光存储器件、磁存储器件、或者上述的任意合适的组合。

    所述计算机可读存储介质可以包括在基带中或者作为载波一部分传播的数据信号,其中承载了可读程序代码。这种传播的数据信号可以采用多种形式,包括但不限于电磁信号、光信号或上述的任意合适的组合。可读存储介质还可以是可读存储介质以外的任何可读介质,该可读介质可以发送、传播或者传输用于由指令执行系统、装置或者器件使用或者与其结合使用的程序。可读存储介质上包含的程序代码可以用任何适当的介质传输,包括但不限于无线、有线、光缆、rf等等,或者上述的任意合适的组合。

    可以以一种或多种程序设计语言的任意组合来编写用于执行本发明操作的程序代码,所述程序设计语言包括面向对象的程序设计语言—诸如java、c 等,还包括常规的过程式程序设计语言—诸如“c”语言或类似的程序设计语言。程序代码可以完全地在用户计算设备上执行、部分地在用户设备上执行、作为一个独立的软件包执行、部分在用户计算设备上部分在远程计算设备上执行、或者完全在远程计算设备或服务器上执行。在涉及远程计算设备的情形中,远程计算设备可以通过任意种类的网络,包括局域网(lan)或广域网(wan),连接到用户计算设备,或者,可以连接到外部计算设备(例如利用因特网服务提供商来通过因特网连接)。

    所述计算机存储介质中的程序被处理器执行时实现所述的业务节点控制方法的步骤,因此,所述计算机存储介质也可以获得上述业务节点控制方法的技术效果。

    以上内容是结合具体的优选实施方式对本发明所作的进一步详细说明,不能认定本发明的具体实施只局限于这些说明。对于本发明所属技术领域的普通技术人员来说,在不脱离本发明构思的前提下,还可以做出若干简单推演或替换,都应当视为属于本发明的保护范围。


    技术特征:

    1.一种业务节点控制方法,其特征在于,所述方法包括:

    接收到用户的业务节点信息查询请求;

    从业务节点数据库中查询所述业务节点信息查询请求所对应的业务节点信息,所述业务节点信息包括节点执行状态;

    接收到用户的第一业务节点重放请求;

    向业务系统的业务重放接口发送第二业务节点重放请求,所述业务系统配置为接收到所述第二业务节点重放请求时,控制所对应的业务节点重新执行业务脚本。

    2.根据权利要求1所述的业务节点控制方法,其特征在于,所述业务节点数据库包括分布式搜索引擎。

    3.根据权利要求1所述的业务节点控制方法,其特征在于,所述业务节点信息查询请求包括被查询的业务节点的节点类型;

    所述从业务节点数据库中查询所述业务节点信息查询请求所对应的业务节点信息,包括从业务节点数据库中查询所述被查询的业务节点的节点类型所对应的业务节点信息。

    4.根据权利要求3所述的业务节点控制方法,其特征在于,所述业务节点信息查询请求还包括被查询的业务id;

    所述从业务节点数据库中查询所述业务节点信息查询请求所对应的业务节点信息,包括从业务节点数据库中查询所述被查询的业务节点的节点类型和所述业务id所对应的业务节点信息。

    5.根据权利要求1所述的业务节点控制方法,其特征在于,所述第一业务节点重放请求和所述第二业务节点重放请求分别包括用户请求重放的业务节点的节点类型;

    所述业务系统配置为接收到所述第二业务节点重放请求时,根据用户请求重放的业务节点的节点类型,控制所对应的业务节点重新执行业务脚本。

    6.根据权利要求5所述的业务节点控制方法,其特征在于,所述第一业务节点重放请求和所述第二业务节点重放请求还分别包括用户请求重放的业务id;

    所述业务系统配置为接收到所述第二业务节点重放请求时,根据用户请求重放的业务节点的节点类型,控制所对应的业务节点重新执行与所述业务id所对应的业务脚本。

    7.根据权利要求1所述的业务节点控制方法,其特征在于,所述向业务系统的业务重放接口发送第二业务节点重放请求,包括如下步骤:

    远程调用所述业务系统的基于http协议的业务重放接口,向所述业务重放接口发送所述第二业务节点重放请求。

    8.根据权利要求7所述的业务节点控制方法,其特征在于,基于ajax远程调用所述业务系统的业务重放接口。

    9.根据权利要求1所述的业务节点控制方法,其特征在于,所述业务系统还配置为从各个业务节点获取业务节点信息,并存入所述业务节点数据库。

    10.根据权利要求9所述的业务节点控制方法,其特征在于,所述业务系统配置为基于网络请求切面的方式从各个业务节点获取业务节点的接口请求参数、业务节点的节点执行状态和节点类型。

    11.根据权利要求1所述的业务节点控制方法,其特征在于,所述从业务节点数据库中查询所述业务节点信息查询请求所对应的业务节点信息之后,还包括如下步骤:

    判断是否有节点执行状态为执行失败的业务节点;

    如果是,则向业务系统的业务重放接口发送第三业务节点重放请求,所述业务系统配置为接收到所述第三业务节点重放请求时,控制所对应的业务节点重新执行业务脚本。

    12.一种业务节点控制系统,其特征在于,应用于权利要求1至11中任一项所述的业务节点控制方法,所述系统包括:

    请求接收模块,用于接收用户的业务节点信息查询请求,以及接收用户的第一业务节点重放请求;

    信息查询模块,用于接收到用户的业务节点信息查询请求时,从业务节点数据库中查询所述业务节点信息查询请求所对应的业务节点信息,所述业务节点信息包括节点执行状态;

    节点重放模块,用于接收到用户的第一业务节点重放请求时,向业务系统的业务重放接口发送第二业务节点重放请求,所述业务系统配置为接收到所述第二业务节点重放请求时,控制所对应的业务节点重新执行业务脚本。

    13.一种电子设备,其特征在于,所述电子设备包括:

    处理器;

    存储器,其上存储有计算机程序,所述计算机程序被所述处理器运行时执行根据权利要求1至11任一项所述的业务节点控制方法。

    14.一种计算机存储介质,其特征在于,存储有计算机程序,所述计算机程序被处理器运行时执行根据权利要求1至11任一项所述的业务节点控制方法。

    技术总结
    本发明提供了一种业务节点控制方法、系统、设备及存储介质,该方法包括:接收到用户的业务节点信息查询请求;从业务节点数据库中查询所述业务节点信息查询请求所对应的业务节点信息,所述业务节点信息包括节点执行状态;接收到用户的第一业务节点重放请求;向业务系统的业务重放接口发送第二业务节点重放请求,所述业务系统配置为接收到所述第二业务节点重放请求时,控制所对应的业务节点重新执行业务脚本。本发明可以查询业务节点执行状态并且在接收到重放请求时重新执行业务节点,解决了现有技术中采用定时重试方法存在的缺陷。

    技术研发人员:方聪
    受保护的技术使用者:上海寻梦信息技术有限公司
    技术研发日:2020.11.30
    技术公布日:2021.03.12

    转载请注明原文地址:https://wp.8miu.com/read-21978.html

    最新回复(0)