定时调度任务系统、方法、装置、服务器及可读存储介质与流程

计算;推算;计数设备的制造及其应用技术1.本发明涉及数据处理技术领域，具体涉及一种定时调度任务系统、方法、装置、服务器及可读存储介质。背景技术：2.定时调度服务在金融科技领域的重要地位不言而喻，如交易订单的定时关闭，交易数据的定时清分，清分数据的定时汇总上报等。定时调度服务作为一种非系统间交互调用的内部服务，在数据中心的调度服务不可用时，大部分业务场景只能等待调度服务的恢复，重新触发定时任务；对于要求处理时效性的业务可以通过业务接口的服务切换，或者业务数据库表的同步以保证业务的连续性。但是，由业务方进行服务切换增加了接入成本，业务接口也不能够真正实现服务解耦，无疑增加了业务操作的复杂性，仍然可能影响业务的连续性。技术实现要素：3.有鉴于此，本发明实施例提供了一种定时调度任务系统、方法、装置、服务器及可读存储介质，以解决数据中心的调度服务不可用时，定时调度任务按时触发的接入成本高、操作复杂的问题。4.根据第一方面，本发明实施例提供了一种定时调度任务系统，包括：本地数据服务器，用于拉取第一定时调度任务并触发所述第一定时调度任务；异地数据服务器，与所述本地数据服务器进行通信连接，所述异地数据服务器配置有第二定时调度任务，所述第二定时调度任务的配置与所述本地数据服务器的所述第一定时调度任务的配置一致；所述异地数据服务器用于当所述本地数据服务器故障时，拉取和触发与所述第一定时调度任务配置一致的所述第二定时调度任务。5.结合第一方面，在第一方面第一实施方式中，所述本地数据服务器包括：调度服务接口，与所述异地数据服务器通信连接，用于当本地数据服务器故障时，向所述异地数据服务器发送拉取指令，以使所述异地数据服务器基于所述拉取指令拉取所述第二定时调度任务。6.结合第一方面，在第一方面第二实施方式中，所述本地数据服务器包括：管理控制接口，与所述异地数据服务器通信连接，用于当本地数据服务器故障时，向所述异地数据服务器发送触发指令，以使所述异地数据服务器基于所述触发指令触发所述第二定时调度任务。7.结合第一方面，在第一方面第三实施方式中，所述本地数据服务器每隔预设时间向所述异地数据服务器发送状态参数，所述状态参数包括心跳数据。8.结合第一方面第三实施方式，在第一方面第四实施方式中，所述异地数据服务器基于所述状态参数确定所述本地数据服务器的运行是否发生故障。9.根据第二方面，本发明实施例提供了一种定时调度任务的执行方法，用于第一方面或第一方面任一实施方式所述的定时调度任务系统，所述方法包括如下步骤：获取本地数据服务器的工作状态，所述本地数据服务器用于拉取和触发第一定时调度任务；判断所述工作状态是否处于故障状态；当所述工作状态处于故障状态时，控制异地数据服务器拉取和触发与所述第一定时调度任务配置一致的第二定时调度任务。10.结合第二方面，在第二方面第一实施方式中，所述方法还包括：当所述本地数据服务器未处于所述故障状态时，所述本地数据服务器每隔预设时间向所述异地数据服务器发送状态参数，所述状态参数包括心跳数据；所述异地数据服务器接收所述状态参数，并基于所述状态参数确定是否拉取和触发所述第二定时调度任务。11.结合第二方面，在第二方面第二实施方式中，在判断所述工作状态是否处于故障状态之前，所述方法还包括：获取所述第一定时调度任务的运行状态；判断所述第一定时调度任务的运行状态是否处于开启状态；当所述第一定时调度任务的运行状态处于开启状态时，判断所述本地数据服务器的工作状态是否处于故障状态。12.结合第二方面第二实施方式，在第二方面第三实施方式中，所述方法还包括：当所述第一定时调度任务未开启时，控制所述异地数据服务器不执行所述第二定时调度任务的拉取操作和触发操作。13.根据第三方面，本发明实施例提供了一种定时调度任务的执行装置，用于第一方面或第一方面任一实施方式所述的定时调度任务系统，所述装置包括：获取模块，用于获取本地数据服务器执行第一定时调度任务的工作状态；判断模块，用于判断所述工作状态是否处于故障状态；启动模块，用于当所述工作状态处于故障状态时，控制异地数据服务器拉取和触发与所述第一定时调度任务配置一致的第二定时调度任务。14.根据第四方面，本发明实施例提供了一种服务器，包括：存储器和处理器，所述存储器和所述处理器之间互相通信连接，所述存储器中存储有计算机指令，所述处理器通过执行所述计算机指令，从而执行第二方面或第二方面任一实施方式所述的定时调度任务的执行方法。15.根据第五方面，本发明实施例提供了一种计算机可读存储介质，所述计算机可读存储介质存储有计算机指令，所述计算机指令用于使计算机执行第二方面或第二方面任一实施方式所述的定时调度任务的执行方法。16.本技术实施例采用的上述至少一个技术方案能够达到以下有益效果：17.本发明提供的定时调度任务系统、方法、装置、服务器及可读存储介质，通过本地数据服务器拉取第一定时调度任务并触发该第一定时调度任务，当本地数据服务器出现故障时，控制异地数据服务器拉取和触发第二定时调度任务，其中，异地数据服务器对第二定时调度任务的配置与本地数据服务器对第一定时调度任务的配置一致。由此，避免了本地数据服务器故障时对定时调度任务进行服务切换，从而降低了定时调度任务的操作复杂性，进而避免了接入成本的增加。通过对异地数据服务器的定时调度任务与本地数据服务器的定时调度任务进行一致性配置，保证了定时调度任务执行的连续性，进而保证了定时调度任务的执行时效性。附图说明18.为了更清楚地说明本发明具体实施方式或现有技术中的技术方案，下面将对具体实施方式或现有技术描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图是本发明的一些实施方式，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。19.图1是根据本发明实施例的定时调度任务系统的结构框图；20.图2是根据本发明实施例的定时调度任务系统的另一结构框图；21.图3是根据本发明实施例的定时调度任务系统的另一结构框图；22.图4是根据本发明实施例的定时调度任务的执行方法的流程图；23.图5是根据本发明实施例的定时调度任务的执行方法的另一流程图；24.图6是根据本发明实施例的定时调度任务的执行装置的结构框图；25.图7是本发明实施例提供的服务器的硬件结构示意图。具体实施方式26.为使本发明实施例的目的、技术方案和优点更加清楚，下面将结合本发明实施例中的附图，对本发明实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例是本发明一部分实施例，而不是全部的实施例。基于本发明中的实施例，本领域技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都属于本发明保护的范围。27.定时调度服务作为一种非系统间交互调用的内部服务，在数据中心的调度服务不可用时，大部分业务场景只能等待调度服务的恢复，重新触发定时任务；对于要求处理时效性的业务可以通过业务接口的服务切换，或者业务数据库表的同步以保证业务的连续性。但是，由业务方进行服务切换增加了接入成本，业务接口也不能够真正实现服务解耦，无疑增加了业务操作的复杂性，影响了业务的连续性。28.基于此，本发明技术方案通过设置异地数据服务器，并将异地数据服务器的定时调度任务与本地数据服务器的定时调度任务的配置一致，当本地数据服务器故障时，启动异地数据服务器，通过异地数据服务器拉取和触发定时调度任务，避免了服务切换，保证了定时调度任务执行的连续性和时效性。29.根据本发明实施例，提供了一种定时调度任务系统的实施例，如图1所示，该定时调度任务系统包括：本地数据服务器11和异地数据服务器12。其中，本地数据服务器11用于拉取第一定时调度任务并触发第一定时调度任务；异地数据服务器12与本地数据服务器11进行通信连接，异地数据服务器12的第二定时调度任务与本地数据服务器11的第一定时调度任务的配置一致。具体地，当定时调度任务系统中的本地数据服务器11故障时，控制异地数据服务器12启动第二定时调度任务的拉取和触发。30.本实施例提供的定时调度任务系统，当本地数据服务器出现故障时，启动异地数据服务器，避免了本地数据服务器故障时对定时调度任务进行服务切换，从而降低了定时调度任务的操作复杂性，进而避免了接入成本的增加。通过对异地数据服务器的定时调度任务与本地数据服务器的定时调度任务进行一致性配置，保证了定时调度任务执行的连续性，进而保证了定时调度任务的执行时效性。31.作为一个可选的实施方式，本地数据服务器每隔预设时间向异地数据服务器发送状态参数，异地数据服务器则可以根据本地数据服务器定时发送的状态参数确定本地数据服务器的运行状态是否发生故障。其中，状态参数可以为心跳数据，心跳数据为本地数据服务器定时通知异地数据服务器与其相关的运行状态的命令字，心跳数据可以按照一定的时间间隔进行发送，例如10秒、30秒、1分钟或5分钟等，本技术对此不作具体限定，本领域技术人员可以根据实际需要确定。32.作为一个可选的实施方式，如图2所示，本地数据服务器11可以包括调度服务接口111，该调度服务接口111与异地数据服务器12进行通信连接，当异地数据服务器12在一定时间间隔内并未接收到本地数据服务器11发送的心跳数据，即可判定本地数据服务器11发生故障，此时本地数据服务器可以向异地数据服务器发送拉取指令，异地数据服务器12则可以连接调度服务接口111，并基于该拉取指令拉取与正在本地数据服务器11上执行的与第一定时调度任务配置一致的第二定时调度任务，以便异地数据服务器12执行第二定时调度任务，实现了异地数据服务器继续执行被中断的第一定时调度任务，从而保证了定时调度任务的执行连续性以及时效性。33.作为一个可选的实施方式，如图3所示，本地数据服务器11也可以包括管理控制接口112。通过管理控制接口112与异地数据服务器12进行通信连接，当异地数据服务器12在一定时间间隔内并未接收到本地数据服务器11发送的心跳数据，即可判定本地数据服务器11发生故障，此时本地数据服务器可以向异地数据服务器发送触发指令，异地数据服务器12则可以连接管理控制接口112，并基于该触发指令触发与正在本地数据服务器11上执行的与第一定时调度任务配置一致的第二定时调度任务，以便异地数据服务器12执行第二定时调度任务，实现了异地数据服务器12能够继续执行被中断的第一定时调度任务，从而保证了定时调度任务的执行连续性以及时效性。34.需要说明的是，当本地数据服务器11处于正常工作状态时，异地数据服务器12仅与本地数据服务器11保持正常的通信连接即可，并不执行任何第二定时调度任务的拉取操作或触发操作，避免了额外操作的增加，降低了定时调度任务的操作复杂性。35.根据本发明实施例，提供了一种定时调度任务的执行方法的实施例，需要说明的是，在附图的流程图示出的步骤可以在诸如一组计算机可执行指令的计算机系统中执行，并且，虽然在流程图中示出了逻辑顺序，但是在某些情况下，可以以不同于此处的顺序执行所示出或描述的步骤。36.在本实施例中提供了一种定时调度任务的执行方法，可用于服务器，如服务器构成的计算机系统或平台等，图4是根据本发明实施例的定时调度任务的执行方法的流程图，如图4所示，该流程包括如下步骤：37.s21，获取本地数据服务器执行第一定时调度任务的工作状态。38.本地数据服务器用于拉取和触发第一定时调度任务，本地数据服务器可以将其执行第一定时调度任务的工作状态所对应的数据包实时上报至本地数据服务器对应的数据库。当本地数据服务器启动后，定时调度任务系统可以实时从数据库中调取本地数据服务器的工作状态对应的数据包。39.s22，判断工作状态是否处于故障状态。40.定时调度任务系统对其调取与本地数据服务器的工作状态对应的数据包进行识别和分析，以对本地数据服务器的工作状态进行实时检测，确定其工作状态是否处于故障状态。当其工作状态处于故障状态时，执行步骤s23，否则执行其他操作，其他操作可以是继续监测本地数据服务器的工作状态，也可以是控制异地数据服务器继续保持与本地数据服务器的连接关系，且控制异地数据服务器不执行任何拉取操作或触发操作，此处不作具体限定。41.s23，控制异地数据服务器拉取和触发与第一定时调度任务配置一致的第二定时调度任务。42.异地数据服务器的第二定时调度任务与本地数据服务器的第一定时调度任务的配置保持一致。当本地数据服务器执行第一定时调度任务的工作状态处于故障状态时，定时调度任务系统可以控制异地数据服务器启动第二定时调度任务的拉取任务和调度任务，其中，第一定时调度任务与第二定时调度任务的配置一致，由此实现了异地数据服务器继续执行本地数据服务器因故障而被迫停止的定时调度任务，无需等待本地数据服务器的恢复，也无需通过本地数据服务器进行服务切换。43.本发明提供的定时调度任务的执行方法，通过获取本地数据服务器的工作状态，当本地数据服务器的工作状态处于故障状态时，控制异地数据服务器拉取和触发与所述第一定时调度任务配置一致的第二定时调度任务，避免了本地数据服务器故障时对定时调度任务进行服务切换，从而降低了定时调度任务的操作复杂性，进而避免了接入成本的增加。通过对异地数据服务器的定时调度任务与本地数据服务器的定时调度任务进行一致性配置，保证了定时调度任务执行的连续性，进而保证了定时调度任务的执行时效性。44.在本实施例中提供了一种定时调度任务的执行方法，可用于服务器，如服务器构成的计算机系统或平台等，图5是根据本发明实施例的定时调度任务的执行方法的流程图，如图5所示，该流程包括如下步骤：45.s31，获取本地数据服务器执行第一定时调度任务的工作状态。详细说明参见上述实施例对应步骤s21的相关描述，此处不再赘述。46.s32，获取第一定时调度任务的运行状态。47.第一定时调度任务的运行状态为第一定时调度任务的当前运行状态。第一定时调度任务的运行状态可以通过检测本地数据服务器上的运行数据进行获取。当第一定时调度任务在本地数据服务器上开启运行时，本地数据服务器即可对其运行数据进行记录。48.s33，判断第一定时调度任务的运行状态是否处于开启状态。49.定时调度任务系统可以通过本地数据服务器上记录的第一定时调度任务的运行数据确定定时任务的运行状态。具体地，定时调度任务系统可以检测当前本地数据服务器上是否存在与第一定时调度任务对应的执行数据以确定第一定时调度任务的运行状态是否处于开启状态。当第一定时调度任务处于开启状态时，执行步骤s34，否则，执行步骤s36。50.s34，判断本地数据服务器的工作状态是否处于故障状态。51.当第一定时调度任务的运行状态处于开启状态时，表示本地数据服务器可以拉取和触发该第一定时调度任务。在本地数据服务器拉取和触发该第一定时调度任务后，定时调度任务系统可以对本地数据服务器执行第一定时调度任务的工作状态进行实时监测以确定其工作状态处于正常状态或故障状态。当工作状态处于故障状态时，执行步骤s35，否则，执行步骤s37。52.s35，控制异地数据服务器拉取和触发与第一定时调度任务配置一致的第二定时调度任务。详细说明参见上述实施例对应步骤23的相关描述，此处不再赘述。53.s36，控制异地数据服务器不执行定时调度任务的拉取操作和触发操作。54.当本地数据服务器未处于故障状态时，表示定时任务能够在本地数据服务器上进行正常执行。此时，定时调度任务系统仅控制异地数据服务器与本地数据服务器保持连接即可，异地数据服务器无需执行任何拉取操作或触发操作。当定时调度任务未开启时，表示该定时任务并未到达触发时间，无法确定该定时任务是否能够在本地数据服务器进行正常执行。此时，控制异地数据服务器与本地数据服务器保持连接即可，异地数据服务器亦无需执行任何拉取操作或触发操作。55.s37，控制本地数据服务器每隔预设时间向异地数据服务器发送状态参数，其中，状态参数包括心跳数据；异地数据服务器接收状态参数，并基于状态参数确定是否拉取和触发第二定时调度任务。56.本地数据服务器每隔预设时间向异地数据服务器发送状态参数，异地数据服务器则可以根据接收到的状态参数确定本地数据服务器的运行状态是否发生故障。其中，状态参数可以为心跳数据，心跳数据为本地数据服务器定时通知异地数据服务器与其相关的运行状态的命令字，心跳数据可以按照一定的时间间隔进行发送，例如10秒、30秒、1分钟或5分钟等，本技术对此不作具体限定，本领域技术人员可以根据实际需要确定。57.本发明提供的定时调度任务的执行方法，在判断本地数据服务器的运行状态是否处于故障状态之前，获取定时任务的运行状态，以确定定时任务是否开启，以确定本地数据服务器是否在执行定时任务时出现故障状态，进而保证了异地数据服务器的及时启动，保证了定时调度任务执行的连续性，进而保证了定时调度任务的执行时效性。58.在本实施例中还提供了一种定时调度任务的执行装置，该装置用于实现上述实施例及优选实施方式，已经进行过说明的不再赘述。如以下所使用的，术语“模块”可以实现预定功能的软件和/或硬件的组合。尽管以下实施例所描述的装置较佳地以软件来实现，但是硬件，或者软件和硬件的组合的实现也是可能并被构想的。59.本实施例提供一种定时调度任务的执行装置，用于上述实施例所述的定时调度任务系统，如图6所示，包括：60.获取模块41，用于获取本地数据服务器执行第一定时调度任务的工作状态。详细说明参见上述实施例对应的相关描述，此处不再赘述。61.判断模块42，用于判断工作状态是否处于故障状态。详细说明参见上述实施例对应的相关描述，此处不再赘述。62.启动模块43，用于当工作状态处于故障状态时，控制异地数据服务器拉取和触发与第一定时调度任务配置一致的第二定时调度任务。详细说明参见上述实施例对应的相关描述，此处不再赘述。63.本发明提供的定时调度任务的执行装置，通过获取本地数据服务器的工作状态，当本地数据服务器的工作状态处于故障状态时，控制异地数据服务器启动第二定时调度任务的拉取和触发，且第二定时调度任务与第一定时调度任务的配置一致，由此，避免了本地数据服务器故障时对定时调度任务进行服务切换，从而降低了定时调度任务的操作复杂性，进而避免了接入成本的增加。通过对异地数据服务器的定时调度任务与本地数据服务器的定时调度任务进行一致性配置，保证了定时调度任务执行的连续性，进而保证了定时调度任务的执行时效性。64.本实施例中的定时调度任务的执行装置是以功能单元的形式来呈现，这里的单元是指asic电路，执行一个或多个软件或固定程序的处理器和存储器，和/或其他可以提供上述功能的器件。65.上述各个模块更进一步的功能描述与上述对应实施例相同，在此不再赘述。66.本发明实施例还提供一种服务器，具有上述图6所示的定时调度任务的执行装置。67.请参阅图7，图7是本发明可选实施例提供的一种服务器的结构示意图，如图7所示，该服务器可以包括：至少一个处理器501，例如cpu(central processing unit，中央处理器)，至少一个通信接口503，存储器504，至少一个通信总线502。其中，通信总线502用于实现这些组件之间的连接通信。其中，通信接口503可以包括显示屏(display)、键盘(keyboard)，可选通信接口503还可以包括标准的有线接口、无线接口。存储器504可以是高速ram存储器(random access memory，易挥发性随机存取存储器)，也可以是非不稳定的存储器(non-volatile memory)，例如至少一个磁盘存储器。存储器504可选的还可以是至少一个位于远离前述处理器501的存储装置。其中处理器501可以结合图6所描述的装置，存储器504中存储应用程序，且处理器501调用存储器504中存储的程序代码，以用于执行上述任一方法步骤。68.其中，通信总线502可以是外设部件互连标准(peripheral component interconnect，简称pci)总线或扩展工业标准结构(extended industry standard architecture，简称eisa)总线等。通信总线502可以分为地址总线、数据总线、控制总线等。为便于表示，图7中仅用一条粗线表示，但并不表示仅有一根总线或一种类型的总线。69.其中，存储器504可以包括易失性存储器(英文：volatile memory)，例如随机存取存储器(英文：random-access memory，缩写：ram)；存储器也可以包括非易失性存储器(英文：non-volatile memory)，例如快闪存储器(英文：flash memory)，硬盘(英文：hard disk drive，缩写：hdd)或固态硬盘(英文：solid-state drive，缩写：ssd)；存储器504还可以包括上述种类的存储器组合。70.其中，处理器501可以是中央处理器(英文：central processing unit，缩写：cpu)，网络处理器(英文：network processor，缩写：np)或者cpu和np的组合。71.其中，处理器501还可以进一步包括硬件芯片。上述硬件芯片可以是专用集成电路(英文：application-specific integrated circuit，缩写：asic)，可编程逻辑器件(英文：programmable logic device，缩写：pld)或其组合。上述pld可以是复杂可编程逻辑器件(英文：complex programmable logic device，缩写：cpld)，现场可编程逻辑门阵列(英文：field-programmable gate array，缩写：fpga)，通用阵列逻辑(英文：generic array logic,缩写：gal)或其任意组合。72.可选地，存储器504还用于存储程序指令。处理器501可以调用程序指令，实现如本技术图4和5实施例中所示的定时调度任务的执行方法。73.本发明实施例还提供了一种非暂态计算机存储介质，所述计算机存储介质存储有计算机可执行指令，该计算机可执行指令可执行上述任意方法实施例中的定时调度任务的执行方法的处理方法。其中，所述存储介质可为磁碟、光盘、只读存储记忆体(read-only memory，rom)、随机存储记忆体(random access memory，ram)、快闪存储器(flash memory)、硬盘(hard disk drive，缩写：hdd)或固态硬盘(solid-state drive，ssd)等；所述存储介质还可以包括上述种类的存储器的组合。74.虽然结合附图描述了本发明的实施例，但是本领域技术人员可以在不脱离本发明的精神和范围的情况下做出各种修改和变型，这样的修改和变型均落入由所附权利要求所限定的范围之内。









图片声明：本站部分配图来自人工智能系统AI生成,觅知网授权图片,PxHere摄影无版权图库。本站只作为美观性配图使用,无任何非法侵犯第三方意图,一切解释权归图片著作权方,本站不承担任何责任。如有恶意碰瓷者,必当奉陪到底严惩不贷!




内容声明：本文中引用的各种信息及资料（包括但不限于文字、数据、图表及超链接等）均来源于该信息及资料的相关主体（包括但不限于公司、媒体、协会等机构）的官方网站或公开发表的信息。部分内容参考包括:(百度百科,百度知道,头条百科,中国民法典,刑法,牛津词典,新华词典,汉语词典,国家院校,科普平台)等数据,内容仅供参考使用,不准确地方联系删除处理！本站为非盈利性质站点,发布内容不收取任何费用也不接任何广告!




免责声明：我们致力于保护作者版权，注重分享，被刊用文章因无法核实真实出处，未能及时与作者取得联系，或有版权异议的，请联系管理员，我们会立即处理，本文部分文字与图片资源来自于网络，部分文章是来自自研大数据AI进行生成,内容摘自(百度百科,百度知道,头条百科,中国民法典,刑法,牛津词典,新华词典,汉语词典,国家院校,科普平台)等数据,内容仅供学习参考,不准确地方联系删除处理!的,若有来源标注错误或侵犯了您的合法权益，请立即通知我们，情况属实，我们会第一时间予以删除，并同时向您表示歉意,谢谢!