CN113190364A - 远程调用管理方法、装置、计算机设备及可读存储介质 - Google Patents
远程调用管理方法、装置、计算机设备及可读存储介质 Download PDFInfo
- Publication number
- CN113190364A CN113190364A CN202110484348.2A CN202110484348A CN113190364A CN 113190364 A CN113190364 A CN 113190364A CN 202110484348 A CN202110484348 A CN 202110484348A CN 113190364 A CN113190364 A CN 113190364A
- Authority
- CN
- China
- Prior art keywords
- cluster
- service
- abnormal
- task
- information
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
- 238000007726 management method Methods 0.000 title claims abstract description 45
- 230000002159 abnormal effect Effects 0.000 claims abstract description 147
- 238000000034 method Methods 0.000 claims abstract description 37
- 238000004590 computer program Methods 0.000 claims description 11
- 230000005856 abnormality Effects 0.000 claims description 10
- 238000012544 monitoring process Methods 0.000 claims description 9
- 230000006854 communication Effects 0.000 claims description 6
- 238000004891 communication Methods 0.000 claims description 6
- 230000000903 blocking effect Effects 0.000 abstract description 5
- 230000008569 process Effects 0.000 description 13
- 238000012545 processing Methods 0.000 description 9
- 238000010586 diagram Methods 0.000 description 4
- 230000000694 effects Effects 0.000 description 3
- 238000007689 inspection Methods 0.000 description 3
- 230000002547 anomalous effect Effects 0.000 description 2
- 238000004422 calculation algorithm Methods 0.000 description 2
- 238000004364 calculation method Methods 0.000 description 2
- 229940004975 interceptor Drugs 0.000 description 2
- 230000003287 optical effect Effects 0.000 description 2
- 230000003068 static effect Effects 0.000 description 2
- 238000013475 authorization Methods 0.000 description 1
- 230000007175 bidirectional communication Effects 0.000 description 1
- 230000005540 biological transmission Effects 0.000 description 1
- 230000001413 cellular effect Effects 0.000 description 1
- 238000010276 construction Methods 0.000 description 1
- 238000013500 data storage Methods 0.000 description 1
- 238000001514 detection method Methods 0.000 description 1
- 238000005516 engineering process Methods 0.000 description 1
- 239000000835 fiber Substances 0.000 description 1
- 238000001914 filtration Methods 0.000 description 1
- 230000006870 function Effects 0.000 description 1
- 230000007246 mechanism Effects 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
- 238000012795 verification Methods 0.000 description 1
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/54—Interprogram communication
- G06F9/547—Remote procedure calls [RPC]; Web services
Landscapes
- Engineering & Computer Science (AREA)
- Software Systems (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Debugging And Monitoring (AREA)
Abstract
本发明涉及云服务的云计算领域，公开了一种远程调用管理方法、装置、计算机设备及可读存储介质，包括：获取至少具有一个服务集群的服务系统，与所述服务集群之间建立连接；根据所述状态信息识别出现异常的服务集群，并将所述服务集群设为异常集群；将所述异常集群中的任务信息转发至所述服务系统中其他的服务集群，用于执行所述任务信息以获得反馈信息。本发明还涉及区块链技术，信息可存储于区块链节点中。本发明避免了将任务信息路由至异常集群，导致任务信息无法得到处理造成服务系统线程阻塞的问题发生，保证了服务系统接收到的任务信息均能得到反馈信息，进而保证了所述服务系统的稳定性。
Description
技术领域
本发明涉及云服务的云计算技术领域，尤其涉及一种远程调用管理方法、装置、计算机设备及可读存储介质。
背景技术
现有业内关于rpc调用的协议非常多，比如http/https、dubbo、redis、file等等，大多数普通正常情况下一个rpc请求调用，如果不出什么异常状况的话，都能正常的拿到rpc的结果。
然而，发明人意识到，如果在复杂的多服务集群环境，而且服务集群与服务集群之间的网络、数据都是相互隔离的，那么一旦某个服务集群出现异常，将服务系统仍然会持续的将任务信息路由至异常集群，导致任务信息无法得到处理造成服务系统线程阻塞的问题发生；同时，由于异常集群中的任务信息得不到处理，还会导致服务系统无法将服务系统将接收到的任务信息完全处理得到反馈信息，影响了所述服务系统的稳定性。
发明内容
本发明的目的是提供一种远程调用管理方法、装置、计算机设备及可读存储介质，用于解决现有技术存在的持续将任务信息路由至异常集群导致任务信息无法得到处理，以及异常集群中的任务信息得不到处理导致服务系统无法将接收到的任务信息完全处理的问题。
为实现上述目的，本发明提供一种远程调用管理方法，包括：
获取至少具有一个服务集群的服务系统，与所述服务集群之间建立连接；
在所述服务集群的任务服务器中构建增强模块，用于生成反映所述任务服务器运行状态的状态信息；其中，所述服务集群为至少由一个任务服务器按照预置的业务逻辑构建而成；
根据所述状态信息识别出现异常的服务集群，并将所述服务集群设为异常集群；
将所述异常集群中的任务信息转发至所述服务系统中其他的服务集群，用于执行所述任务信息以获得反馈信息。
上述方案中，所述在所述服务集群的任务服务器中构建增强模块的步骤，包括：
获取增强文件，将所述增强文件配置在所述服务集群的任务服务器中；
运行所述增强文件，用以检测所述任务服务器的执行状态；
获取所述服务集群中各所述任务服务器的执行状态并汇总形成执行集，判断所述执行集中是否具有内容为异常的执行状态；
若是，则生成内容为正常的状态信息，用于反映所述服务集群处于正常的状态；
若否，则生成内容为异常的状态信息，用于反映所述服务集群处于出现异常的状态，将所述内容为异常的执行状态的服务器编号记载在所述状态信息中。
上述方案中，所述根据所述状态信息识别出现异常的服务集群，并将所述服务集群设为异常集群的步骤，包括：
向服务集群发送检查请求，并判断所述服务集群是否根据所述检查请求发送状态信息；
若是，则判定所述服务集群为正常；
若否，则判定所述服务集群出现异常，并将所述服务集群设为异常集群。
上述方案中，所述根据所述状态信息识别出现异常的服务集群，并将所述服务集群设为异常集群的步骤，包括：
构建监听拦截模块；
运行所述监听拦截模块过滤所述服务集群生成的状态信息，用以识别出内容为异常的状态信息，并将所述状态信息所对应的服务集群设为异常集群。
上述方案中，所述将所述异常集群中的任务信息转发至所述服务系统中其他的服务集群的步骤，包括：
获取所述异常集群的任务类型，及识别所述异常集群中出现异常的任务服务器并将所述任务服务器设为异常服务器，提取所述异常服务器接收到的任务信息；
将所述服务系统中任务类型与所述异常集群一致的服务集群设为备选集群，将工作状态符合预置调用规则的备选集群设为转发集群，其中，所述工作状态反映了服务集群的运行状态和工作强度；
将所述转发集群中与所述异常服务器对应的任务服务器作为目标服务器，将所述任务信息发送至所述目标服务器并调用所述任务服务器执行所述任务信息得到反馈信息。
上述方案中，所述将工作状态符合预置调用规则的备选集群设为转发集群的步骤，包括：
获取所述备选集群的工作状态并提取所述工作状态中的运行状态信息，判断是否具有内容为正常的运行状态信息；若是，则将内容为正常的运行状态信息所对应的备选集群设为第一集群；
获取所述第一集群的工作状态并提取所述工作状态中的工作强度信息，判断是否具有内容为空闲的工作强度信息；若是，则将内容为空闲的工作强度信息所对应的第一集群设为转发集群并结束。
上述方案中，所述将所述异常集群中的任务信息转发至所述服务系统中其他的服务集群之后，所述方法还包括：
将所述异常集群的集群编号发送至控制端；
所述将所述异常集群的集群编号发送至控制端之后，所述方法还包括：
将所述集群编号上传至区块链中。
为实现上述目的，本发明还提供一种远程调用管理装置，包括：
通信模块，用于获取至少具有一个服务集群的服务系统，与所述服务集群之间建立连接；
状态生成模块，用于在所述服务集群的任务服务器中构建增强模块，用于生成反映所述任务服务器运行状态的状态信息；其中，所述服务集群为至少由一个任务服务器按照预置的业务逻辑构建而成；
异常识别模块，用于根据所述状态信息识别出现异常的服务集群，并将所述服务集群设为异常集群；
转发执行模块，用于将所述异常集群中的任务信息转发至所述服务系统中其他的服务集群，用于执行所述任务信息以获得反馈信息。
为实现上述目的，本发明还提供一种计算机设备，其包括存储器、处理器以及存储在存储器上并可在处理器上运行的计算机程序，所述计算机设备的处理器执行所述计算机程序时实现上述远程调用管理方法的步骤。
为实现上述目的，本发明还提供一种计算机可读存储介质，所述可读存储介质上存储有计算机程序，所述可读存储介质存储的所述计算机程序被处理器执行时实现上述远程调用管理方法的步骤。
本发明提供的远程调用管理方法、装置、计算机设备及可读存储介质，通过识别出现异常的服务集群并将所述服务集群的方式，将服务系统中的异常部分准确识别出来，以避免将任务信息路由至异常集群，导致任务信息无法得到处理造成服务系统线程阻塞的问题发生。通过将所述异常集群中的任务信息转发至所述服务系统中其他的服务集群，使所述其他的服务集群执行所述任务信息以获得反馈信息，以保证服务系统接收到的任务信息均能得到反馈信息，进而保证了所述服务系统的稳定性。
附图说明
图1为本发明远程调用管理方法实施例一的流程图；
图2为本发明远程调用管理方法实施例二中远程调用管理方法的环境应用示意图；
图3是本发明远程调用管理方法实施例二中远程调用管理方法的具体方法流程图；
图4为本发明远程调用管理装置实施例三的程序模块示意图；
图5为本发明计算机设备实施例四中计算机设备的硬件结构示意图。
具体实施方式
为了使本发明的目的、技术方案及优点更加清楚明白，以下结合附图及实施例，对本发明进行进一步详细说明。应当理解，此处所描述的具体实施例仅用以解释本发明，并不用于限定本发明。基于本发明中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都属于本发明保护的范围。
本发明提供的远程调用管理方法、装置、计算机设备及可读存储介质，适用于云服务的云计算技术领域，为提供一种基于通信模块、异常识别模块、转发执行模块的远程调用管理方法。本发明通过获取至少具有一个服务集群的服务系统，与所述服务集群之间建立连接；根据所述状态信息识别出现异常的服务集群，并将所述服务集群设为异常集群；将所述异常集群中的任务信息转发至所述服务系统中其他的服务集群，用于执行所述任务信息以获得反馈信息。
实施例一：
请参阅图1，本实施例的一种远程调用管理方法，应用在具有程序的服务器中，包括：
S101：获取至少具有一个服务集群的服务系统，与所述服务集群之间建立连接；
S102：在所述服务集群的任务服务器中构建增强模块，用于生成反映所述任务服务器运行状态的状态信息；其中，所述服务集群为至少由一个任务服务器按照预置的业务逻辑构建而成；
S103：根据所述状态信息识别出现异常的服务集群，并将所述服务集群设为异常集群；
S104：将所述异常集群中的任务信息转发至所述服务系统中其他的服务集群，用于执行所述任务信息以获得反馈信息。
在示例性的实施例中，通过zookeeper与所述服务集群之间建立连接，其中，所述zookeeper是一种分布式文件系统，用于将服务集群的服务注册在预置的路径上，所述路径规则为{service}/{version}/{ip:port},例如：将“HelloWorldService”部署到两台机器，那么zookeeper上就会创建两条目录：分别为
/HelloWorldService/1.0.0/100.19.20.01:16888，/HelloWorldService/1.0.0/100.19.20.02:16888。
服务集群中各任务服务器是否出现异常，进而准确的检测服务系统中各任务服务器是否能够正常工作；其中，判定任务服务器异常的标准是：无法处理接收到的任务信息，并无法生成作为下一位次任务服务器的输入数据的任务信息。
通过识别出现异常的服务集群并将所述服务集群的方式，将服务系统中的异常部分准确识别出来，以避免将任务信息路由至异常集群，导致任务信息无法得到处理造成服务系统线程阻塞的问题发生。
通过将所述异常集群中的任务信息转发至所述服务系统中其他的服务集群，使所述其他的服务集群执行所述任务信息以获得反馈信息，以保证服务系统接收到的任务信息均能得到反馈信息，进而保证了所述服务系统的稳定性。其中，所述任务信息为通过调用服务集群中的任务服务器，用以生成指定的任务信息或反馈结果的请求信息，于本实施例中，所述任务信息为RPC(Remote Procedure Call)，即：远程过程调用，用于表达一个节点(客户端/任务服务器)请求另一节点(任务服务器)提供服务。其为基于http/https、或dubbo、或redis、或file通信协议所制成的请求协议。
实施例二：
本实施例为上述实施例一的一种具体应用场景，通过本实施例，能够更加清楚、具体地阐述本发明所提供的方法。
下面，以在运行有远程调用管理方法的服务器中，根据所述状态信息识别出现异常的服务集群，并将所述服务集群设为异常集群，并将所述异常集群中的任务信息转发至所述服务系统中其他的服务集群为例，来对本实施例提供的方法进行具体说明。需要说明的是，本实施例只是示例性的，并不限制本发明实施例所保护的范围。
图2示意性示出了根据本申请实施例二的远程调用管理方法的环境应用示意图。
在示例性的实施例中，远程调用管理方法所在的调用服务器2通过网络分别连接服务系统3和控制端4；所述服务器2可以通过一个或多个网络提供服务，网络可以包括各种网络设备，例如路由器，交换机，多路复用器，集线器，调制解调器，网桥，中继器，防火墙，代理设备和/或等等。网络可以包括物理链路，例如同轴电缆链路，双绞线电缆链路，光纤链路，它们的组合和/或类似物。网络可以包括无线链路，例如蜂窝链路，卫星链路，Wi-Fi链路和/或类似物；所述服务系统3至少具有一个服务集群31，所述服务集群31至少具有一个任务服务器311；所述控制端4可为智能手机、平板电脑、笔记本电脑、台式电脑等计算机设备。
图3是本发明一个实施例提供的一种远程调用管理方法的具体方法流程图，该方法具体包括步骤S201至S205。
S201：获取至少具有一个服务集群的服务系统，与所述服务集群之间建立连接。
本步骤中，通过zookeeper与所述服务集群之间建立连接，其中，所述zookeeper是一种分布式文件系统，用于将服务集群的服务注册在预置的路径上，所述路径规则为{service}/{version}/{ip:port},例如：将“HelloWorldService”部署到两台机器，那么zookeeper上就会创建两条目录：分别为
/HelloWorldService/1.0.0/100.19.20.01:16888，/HelloWorldService/1.0.0/100.19.20.02:16888。
示例性地，获得服务系统M，其包括服务集群S1，服务集群S2，服务集群S3，服务集群S1和服务集群S2分别包括任务服务器A、任务服务器B、任务服务器C；服务集群S3包括任务服务器A、任务服务器B和任务服务器D。
S202：在所述服务集群的任务服务器中构建增强模块，用于生成反映所述任务服务器运行状态的状态信息；其中，所述服务集群为至少由一个任务服务器按照预置的业务逻辑构建而成。
为准确的检测服务系统中各任务服务器是否能够正常工作，本步骤通过在所述服务集群的任务服务器中构建增强模块，用以检测服务集群中各任务服务器是否出现异常；其中，判定任务服务器异常的标准是：无法处理接收到的任务信息，并无法生成作为下一位次任务服务器的输入数据的任务信息。
于本实施例中，通过将增强文件配置在服务集群的任务服务器中，通过运行所述增强文件实现在所述任务服务器中构建增强模块的技术效果。
需要说明的是，可采用enhance.jar数据包作为所述增强文件，其中包含还有在任务服务器在接收到任务信息时，检测所述任务服务器对所述任务信息的处理过程和处理结果；及判断所述任务服务器是否运行正常；若是，则生成内容为正常的状j态信息；若否，则生成内容为异常的状态信息，并将任务服务器编号记载在所述状态信息中的计算机代码。
示例性地，基于上述举例，服务集群S1和S2的业务逻辑是：任务服务器A在接收到任务信息p之后生成任务信息a，并将所述任务信息a发送至任务服务器B，任务服务器B处理任务信息a得到任务信息b并将所述任务信息b发送至任务处理器C，任务处理器C处理所述任务信息b得到反馈信息c；而服务集群S3的业务逻辑是：任务服务器A在接收到任务信息q之后生成任务信息a，并将所述任务信息a发送至任务服务器B，任务服务器B处理任务信息a得到任务信息b并将所述任务信息b发送至任务处理器D，任务处理器D处理所述任务信息b得到反馈信息d。
在一个优选的实施例中，所述在所述服务集群的任务服务器中构建增强模块的步骤，包括：
S21：获取增强文件，将所述增强文件配置在所述服务集群的任务服务器中。
本步骤中，通过将所述增强文件载入在所述服务集群的配置中心中，并将其配置在所述服务集群的各个任务服务器上。
S22：运行所述增强文件，用以检测所述任务服务器的执行状态。
本步骤中，通过运行所述配置中心中的增强文件，实现构建各所述任务服务器的增强模块的技术效果，其中，所述增强模块用于实时检测任务服务器的执行状态是否出现异常，所述执行状态包括正常和异常。
S23：获取所述服务集群中各所述任务服务器的执行状态并汇总形成执行集，判断所述执行集中是否具有内容为异常的执行状态。
S24：若是，则生成内容为正常的状态信息，用于反映所述服务集群处于正常的状态。
S25：若否，则生成内容为异常的状态信息，用于反映所述服务集群处于出现异常的状态，将所述内容为异常的执行状态的服务器编号记载在所述状态信息中。
示例性地，分别在服务集群S1、服务集群S2和服务集群S3的任务服务器A，任务服务器B，任务服务器C中构建增强模块，该增强模块的作用是检测任务服务器A，任务服务器B，任务服务器C是否出现异常，例如：宕机、掉线、挂机等情况。如果服务集群S1中的任务服务器C出现了异常，如：掉线，那么就生成内容为异常的状态信息，并将所述任务服务器C的服务器编号FW-S1-C记载在状态信息中。
S203：根据所述状态信息识别出现异常的服务集群，并将所述服务集群设为异常集群。
为避免任务信息路由至出现异常的服务集群，导致服务系统中无法被处理的任务信息过多，造成服务系统的线程阻塞的问题，本步骤通过识别出现异常的服务集群并将所述服务集群的方式，将服务系统中的异常部分准确识别出来，以避免将任务信息路由至异常集群，导致任务信息无法得到处理造成服务系统线程阻塞的问题发生。
在一个优选的实施例中，所述根据所述状态信息识别出现异常的服务集群，并将所述服务集群设为异常集群的步骤，包括：
S3-01：向服务集群发送检查请求，并判断所述服务集群是否根据所述检查请求发送状态信息；
S3-02：若是，则判定所述服务集群为正常；
S3-03：若否，则判定所述服务集群出现异常，并将所述服务集群设为异常集群。
具体地，调用zookeeper向服务集群发送检查请求，所述检查请求通过在zookeeper与服务集群之间构建Socket长连接，并在所述Socket长连接中实时或持续的发送请求信号实现的；其中，所述socket是指套接字，用于对网络中不同主机上的应用进程之间进行双向通信的端点的抽象；所述长连接是在所述zookeeper与服务集群之间的整个连接过程中，执调用一个Socket对象，实现长期保持Socket的连接的技术效果。若所述服务集群根据所述检查请求通过所述Socket长连接发送了状态信息，则说明所述服务集群处于正常工作状态；若所述服务集群未根据所述检查请求通过所述Socket长连接发送状态信息，则说明所述服务集群出现了异常，并将所述服务集群设为异常集群。
在一个优选的实施例中，所述根据所述状态信息识别出现异常的服务集群，并将所述服务集群设为异常集群的步骤，包括：
S3-11：构建监听拦截模块。
S3-12：运行所述监听拦截模块过滤所述服务集群生成的状态信息，用以识别出内容为异常的状态信息，并将所述状态信息所对应的服务集群设为异常集群。
于本实施例中，无需通过构建Socket长连接，而仅需通过构建Spring MVC-拦截器作为监听拦截模块，即可识别出服务集群生成的状态信息中内容为异常的状态信息，节省了服务系统的算力负担。
需要说明的是，Spring MVC中的拦截器(Interceptor)类似于Servlet中的过滤器(Filter)，它主要用于拦截用户请求并作相应的处理。例如通过拦截器可以进行权限验证、记录请求信息的日志、判断用户是否登录等。
示例性地，基于上述举例，假设服务集群S1出现了异常，比如：服务集群S1中的任务服务器B向任务服务器C发送任务信息b时，由于任务服务器C出现了掉线情况，导致任务服务器C无法处理其接收到任务信息b。
S204：将所述异常集群中的任务信息转发至所述服务系统中其他的服务集群，用于执行所述任务信息以获得反馈信息。
为保证服务系统接收到的任务信息均能够得到反馈信息，以确保服务系统的稳定性，本步骤通过将所述异常集群中的任务信息转发至所述服务系统中其他的服务集群，使所述其他的服务集群执行所述任务信息以获得反馈信息，以保证服务系统接收到的任务信息均能得到反馈信息，进而保证了所述服务系统的稳定性。其中，所述任务信息为通过调用服务集群中的任务服务器，用以生成指定的任务信息或反馈结果的请求信息，于本实施例中，所述任务信息为RPC(Remote Procedure Call)，即：远程过程调用，用于表达一个节点(客户端/任务服务器)请求另一节点(任务服务器)提供服务。其为基于http/https、或dubbo、或redis、或file通信协议所制成的请求协议。
示例性地，由于服务集群S1和服务集群S2之间的任务类型是一致的，因此，将服务集群S1中的任务信息b转发至服务集群S2中，服务集群S2能够执行所述任务信息b用以获得反馈信息c。
在一个优选的实施例中，所述将所述异常集群中的任务信息转发至所述服务系统中其他的服务集群的步骤，包括：
S41：获取所述异常集群的任务类型，及识别所述异常集群中出现异常的任务服务器并将所述任务服务器设为异常服务器，提取所述异常服务器接收到的任务信息。
本步骤中，从所述异常集群的配置中心中获取任务类型，所述任务类型反映了所述异常集群的提供服务的类型及内容。
具体地，所述识别所述异常集群中出现异常的任务服务器并将所述任务服务器设为异常服务器的步骤，包括：
提取所述状态信息中的服务器编号，将所述服务器编号对应的任务服务器设为异常服务器，其中，所述服务器编号对应于出现异常的任务服务器。
示例性地，基于上述举例，服务集群S1中的任务服务器B向任务服务器C发送任务信息b时，由于任务服务器C出现了掉线情况，导致任务服务器C无法处理其接收到任务信息b，获取该任务服务器C的编号：FW-S1-C。
S42：将所述服务系统中任务类型与所述异常集群一致的服务集群设为备选集群，将工作状态符合预置调用规则的备选集群设为转发集群，其中，所述工作状态反映了服务集群的运行状态和工作强度。
本步骤中，所述工作状态包括服务集群的运行状态信息和工作强度信息，其中，运行状态信息包括：正常和异常；工作强度信息包括：繁忙、普通、空闲。进一步地，所述繁忙是指处理任务信息的数据高于高强度阈值的情况，所述空闲是指处理任务信息的数据量低于低强度阈值的情况，所述普通是指处理任务信息的数据量介于高强度阈值和低强度阈值之间的情况。所述任务类型描述了服务集群执行的任务类别及内容。
由于备选集群是用于执行异常集群未完成的任务信息的，因此只有任务类型与所述异常集群一致的服务集群才有资格作为备选集群。
优选的，所述调用规则是：
选择运行状态信息为正常，且工作强度信息为空闲的服务集群为转发集群；
若不具有工作强度信息为空闲的服务集群，则选择工作强度信息为普通的服务集群为转发集群；
若不具有工作强度信息为空闲和普通的服务集群，则将所述任务信息暂存在预置的缓存模块中。
进一步地，所述将工作状态符合预置调用规则的备选集群设为转发集群的步骤，包括：
S42-1：获取所述备选集群的工作状态并提取所述工作状态中的运行状态信息，判断是否具有内容为正常的运行状态信息；
S42-2：若是，则将内容为正常的运行状态信息所对应的备选集群设为第一集群；
S42-3：若否，则将所述任务信息保存在预置的缓存模块中，在经过预置的缓冲时间段后，再次执行S42-1；
S42-4：获取所述第一集群的工作状态并提取所述工作状态中的工作强度信息，判断是否具有内容为空闲的工作强度信息；
S42-5：若是，则将内容为空闲的工作强度信息所对应的第一集群设为转发集群并结束；
S42-6：若否，则判断是否具有内容为普通的工作强度信息；
S42-7：若是，则将内容为普通的工作强度信息所对应的第一集群设为转发集群并结束；
S42-8：若否，则将所述任务信息保存在预置的缓存模块中，在经过预置的缓冲时间段后，再次执行S42-1。
S43：将所述转发集群中与所述异常服务器对应的任务服务器作为目标服务器，将所述任务信息发送至所述目标服务器并调用所述任务服务器执行所述任务信息得到反馈信息。
示例性地，基于上述举例，假设服务集群S2的工作状态为正常、空闲，那么将服务服务集群S2设为转发集群，并将任务信息b发送至服务集群S2；又由于服务集群S1的任务服务器C出现了掉线的情况，那么就把服务集群S2的任务服务器C作为目标服务器，通过服务集群S2的任务服务器C执行所述任务信息b以得到反馈信息c。
综上，如果将异常集群接收到的任务信息，即位于首位的任务服务器所接收到的任务信息转发至转发集群，转发集群将重新处理所述任务信息，使得异常集群中未出现异常的任务服务器生成的任务信息直接被舍弃掉，导致转发集群与异常集群之间出现计算重复，进而提升了服务系统的算力消耗，降低了反馈信息的生成效率。而本技术方案通过识别所述异常服务器所接收到任务信息，并将该任务信息路由至其他服务集群中，使得获得所述反馈信息的过程中不再出现重复处理任务信息的问题发生，节省了服务系统算力，提高了反馈信息的运算效率。
S205：将所述异常集群的集群编号发送至控制端。
为准确的识别出出现异常的服务集群，本步骤通过将所述异常集群的集群编号发送至控制端，以便于控制端及时准确的对发生异常的服务集群进行排查。
示例性地，将所述服务集群S1的集群编号FW-S1发送至控制端，以便于控制端有针对性地解决出现异常的服务集群。进一步地，还可将服务集群S1中异常服务器的服务器编号FW-S1-C发送至控制端，以进一步的对出现异常的服务器进行定位的技术效果。
优选的，所述将所述异常集群的集群编号发送至控制端之后，所述方法还包括：
将所述集群编号上传至区块链中。
需要说明的是，基于集群编号得到对应的摘要信息，具体来说，摘要信息由集群编号进行散列处理得到，比如利用sha256s算法处理得到。将摘要信息上传至区块链可保证其安全性和对用户的公正透明性。用户设备可以从区块链中下载得该摘要信息，以便查证集群编号是否被篡改。本示例所指区块链是分布式数据存储、点对点传输、共识机制、加密算法等计算机技术的新型应用模式。区块链(Blockchain)，本质上是一个去中心化的数据库，是一串使用密码学方法相关联产生的数据块，每一个数据块中包含了一批次网络交易的信息，用于验证其信息的有效性(防伪)和生成下一个区块。区块链可以包括区块链底层平台、平台产品服务层以及应用服务层等。
实施例三：
请参阅图4，本实施例的一种远程调用管理装置1，包括：
通信模块11，用于获取至少具有一个服务集群的服务系统，与所述服务集群之间建立连接；
状态生成模块12，用于在所述服务集群的任务服务器中构建增强模块，用于生成反映所述任务服务器运行状态的状态信息；其中，所述服务集群为至少由一个任务服务器按照预置的业务逻辑构建而成；
异常识别模块13，用于根据所述状态信息识别出现异常的服务集群，并将所述服务集群设为异常集群；
转发执行模块14，用于将所述异常集群中的任务信息转发至所述服务系统中其他的服务集群，用于执行所述任务信息以获得反馈信息。
可选的，所述远程调用管理装置1还包括：
异常输出模块15，用于将所述异常集群的集群编号发送至控制端。
可选的，所述状态生成模块12还包括：
增强配置单元121，用于获取增强文件，将所述增强文件配置在所述服务集群的任务服务器中；
检测运行单元122，用于运行所述增强文件，用以检测所述任务服务器的执行状态；
汇总判断单元123，用于获取所述服务集群中各所述任务服务器的执行状态并汇总形成执行集，判断所述执行集中是否具有内容为异常的执行状态；
正常状态单元124，用于生成内容为正常的状态信息，用于反映所述服务集群处于正常的状态；
异常状态单元125，用于生成内容为异常的状态信息，用于反映所述服务集群处于出现异常的状态，将所述内容为异常的执行状态的服务器编号记载在所述状态信息中。
可选的，所述异常识别模块13还包括：
检查反馈单元131，用于向服务集群发送检查请求，并判断所述服务集群是否根据所述检查请求发送状态信息；
正常判定单元132，用于判定所述服务集群为正常；
异常判定单元133，用于判定所述服务集群出现异常，并将所述服务集群设为异常集群。
可选的，所述异常识别模块13还包括：
模块构建单元134，用于构建监听拦截模块；
过滤识别单元135，用于运行所述监听拦截模块过滤所述服务集群生成的状态信息，用以识别出内容为异常的状态信息，并将所述状态信息所对应的服务集群设为异常集群。
可选的，所述转发执行模块14还包括：
类型识别单元141，用于获取所述异常集群的任务类型，及识别所述异常集群中出现异常的任务服务器并将所述任务服务器设为异常服务器，提取所述异常服务器接收到的任务信息。
转发识别单元142，用于将所述服务系统中任务类型与所述异常集群一致的服务集群设为备选集群，将工作状态符合预置调用规则的备选集群设为转发集群，其中，所述工作状态反映了服务集群的运行状态和工作强度。
目标识别单元143，用于将所述转发集群中与所述异常服务器对应的任务服务器作为目标服务器，将所述任务信息发送至所述目标服务器并调用所述任务服务器执行所述任务信息得到反馈信息。
本技术方案应用在云服务的云计算领域，尤其应用在集群计算的场景中，通过获取至少具有一个服务集群的服务系统，与所述服务集群之间建立连接；根据所述状态信息识别出现异常的服务集群，并将所述服务集群设为异常集群；将所述异常集群中的任务信息转发至所述服务系统中其他的服务集群，用于执行所述任务信息以获得反馈信息。
实施例四：
为实现上述目的，本发明还提供一种计算机设备5，实施例三的远程调用管理装置的组成部分可分散于不同的计算机设备中，计算机设备5可以是执行程序的智能手机、平板电脑、笔记本电脑、台式计算机、机架式服务器、刀片式服务器、塔式服务器或机柜式服务器(包括独立的服务器，或者多个应用服务器所组成的服务器集群)等。本实施例的计算机设备至少包括但不限于：可通过系统总线相互通信连接的存储器51、处理器52，如图5所示。需要指出的是，图5仅示出了具有组件-的计算机设备，但是应理解的是，并不要求实施所有示出的组件，可以替代的实施更多或者更少的组件。
本实施例中，存储器51(即可读存储介质)包括闪存、硬盘、多媒体卡、卡型存储器(例如，SD或DX存储器等)、随机访问存储器(RAM)、静态随机访问存储器(SRAM)、只读存储器(ROM)、电可擦除可编程只读存储器(EEPROM)、可编程只读存储器(PROM)、磁性存储器、磁盘、光盘等。在一些实施例中，存储器51可以是计算机设备的内部存储单元，例如该计算机设备的硬盘或内存。在另一些实施例中，存储器51也可以是计算机设备的外部存储设备，例如该计算机设备上配备的插接式硬盘，智能存储卡(Smart Media Card,SMC)，安全数字(Secure Digital,SD)卡，闪存卡(Flash Card)等。当然，存储器51还可以既包括计算机设备的内部存储单元也包括其外部存储设备。本实施例中，存储器51通常用于存储安装于计算机设备的操作系统和各类应用软件，例如实施例三的远程调用管理装置的程序代码等。此外，存储器51还可以用于暂时地存储已经输出或者将要输出的各类数据。
处理器52在一些实施例中可以是中央处理器(Central Processing Unit，CPU)、控制器、微控制器、微处理器、或其他数据处理芯片。该处理器52通常用于控制计算机设备的总体操作。本实施例中，处理器52用于运行存储器51中存储的程序代码或者处理数据，例如运行远程调用管理装置，以实现实施例一和实施例二的远程调用管理方法。
实施例五：
为实现上述目的，本发明还提供一种计算机可读存储介质，如闪存、硬盘、多媒体卡、卡型存储器(例如，SD或DX存储器等)、随机访问存储器(RAM)、静态随机访问存储器(SRAM)、只读存储器(ROM)、电可擦除可编程只读存储器(EEPROM)、可编程只读存储器(PROM)、磁性存储器、磁盘、光盘、服务器、App应用商城等等，其上存储有计算机程序，程序被处理器52执行时实现相应功能。本实施例的计算机可读存储介质用于存储实现所述远程调用管理方法的计算机程序，被处理器52执行时实现实施例一和实施例二的远程调用管理方法。
上述本发明实施例序号仅仅为了描述，不代表实施例的优劣。
通过以上的实施方式的描述，本领域的技术人员可以清楚地了解到上述实施例方法可借助软件加必需的通用硬件平台的方式来实现，当然也可以通过硬件，但很多情况下前者是更佳的实施方式。
以上仅为本发明的优选实施例，并非因此限制本发明的专利范围，凡是利用本发明说明书及附图内容所作的等效结构或等效流程变换，或直接或间接运用在其他相关的技术领域，均同理包括在本发明的专利保护范围内。
Claims (10)
1.一种远程调用管理方法，其特征在于，包括：
获取至少具有一个服务集群的服务系统，与所述服务集群之间建立连接；
在所述服务集群的任务服务器中构建增强模块，用于生成反映所述任务服务器运行状态的状态信息；其中，所述服务集群为至少由一个任务服务器按照预置的业务逻辑构建而成；
根据所述状态信息识别出现异常的服务集群，并将所述服务集群设为异常集群；
将所述异常集群中的任务信息转发至所述服务系统中其他的服务集群，用于执行所述任务信息以获得反馈信息。
2.根据权利要求1所述的远程调用管理方法，其特征在于，所述在所述服务集群的任务服务器中构建增强模块的步骤，包括：
获取增强文件，将所述增强文件配置在所述服务集群的任务服务器中；
运行所述增强文件，用以检测所述任务服务器的执行状态；
获取所述服务集群中各所述任务服务器的执行状态并汇总形成执行集，判断所述执行集中是否具有内容为异常的执行状态；
若是，则生成内容为正常的状态信息，用于反映所述服务集群处于正常的状态；
若否，则生成内容为异常的状态信息，用于反映所述服务集群处于出现异常的状态，将所述内容为异常的执行状态的服务器编号记载在所述状态信息中。
3.根据权利要求1所述的远程调用管理方法，其特征在于，所述根据所述状态信息识别出现异常的服务集群，并将所述服务集群设为异常集群的步骤，包括：
向服务集群发送检查请求，并判断所述服务集群是否根据所述检查请求发送状态信息；
若是，则判定所述服务集群为正常；
若否，则判定所述服务集群出现异常，并将所述服务集群设为异常集群。
4.根据权利要求1所述的远程调用管理方法，其特征在于，所述根据所述状态信息识别出现异常的服务集群，并将所述服务集群设为异常集群的步骤，包括：
构建监听拦截模块；
运行所述监听拦截模块过滤所述服务集群生成的状态信息，用以识别出内容为异常的状态信息，并将所述状态信息所对应的服务集群设为异常集群。
5.根据权利要求1所述的远程调用管理方法，其特征在于，所述将所述异常集群中的任务信息转发至所述服务系统中其他的服务集群的步骤，包括：
获取所述异常集群的任务类型，及识别所述异常集群中出现异常的任务服务器并将所述任务服务器设为异常服务器，提取所述异常服务器接收到的任务信息；
将所述服务系统中任务类型与所述异常集群一致的服务集群设为备选集群，将工作状态符合预置调用规则的备选集群设为转发集群，其中，所述工作状态反映了服务集群的运行状态和工作强度；
将所述转发集群中与所述异常服务器对应的任务服务器作为目标服务器，将所述任务信息发送至所述目标服务器并调用所述任务服务器执行所述任务信息得到反馈信息。
6.根据权利要求5所述的远程调用管理方法，其特征在于，所述将工作状态符合预置调用规则的备选集群设为转发集群的步骤，包括：
获取所述备选集群的工作状态并提取所述工作状态中的运行状态信息，判断是否具有内容为正常的运行状态信息；若是，则将内容为正常的运行状态信息所对应的备选集群设为第一集群；
获取所述第一集群的工作状态并提取所述工作状态中的工作强度信息，判断是否具有内容为空闲的工作强度信息；若是，则将内容为空闲的工作强度信息所对应的第一集群设为转发集群并结束。
7.根据权利要求1所述的远程调用管理方法，其特征在于，所述将所述异常集群中的任务信息转发至所述服务系统中其他的服务集群之后，所述方法还包括：
将所述异常集群的集群编号发送至控制端；
所述将所述异常集群的集群编号发送至控制端之后，所述方法还包括：
将所述集群编号上传至区块链中。
8.一种远程调用管理装置，其特征在于，包括：
通信模块，用于获取至少具有一个服务集群的服务系统，与所述服务集群之间建立连接；
状态生成模块，用于在所述服务集群的任务服务器中构建增强模块，用于生成反映所述任务服务器运行状态的状态信息；其中，所述服务集群为至少由一个任务服务器按照预置的业务逻辑构建而成；
异常识别模块，用于根据所述状态信息识别出现异常的服务集群，并将所述服务集群设为异常集群；
转发执行模块，用于将所述异常集群中的任务信息转发至所述服务系统中其他的服务集群，用于执行所述任务信息以获得反馈信息。
9.一种计算机设备，其包括存储器、处理器以及存储在存储器上并可在处理器上运行的计算机程序，其特征在于，所述计算机设备的处理器执行所述计算机程序时实现权利要求1至7任一项所述远程调用管理方法的步骤。
10.一种计算机可读存储介质，所述可读存储介质上存储有计算机程序，其特征在于，所述可读存储介质存储的所述计算机程序被处理器执行时实现权利要求1至7任一项所述远程调用管理方法的步骤。
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110484348.2A CN113190364A (zh) | 2021-04-30 | 2021-04-30 | 远程调用管理方法、装置、计算机设备及可读存储介质 |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110484348.2A CN113190364A (zh) | 2021-04-30 | 2021-04-30 | 远程调用管理方法、装置、计算机设备及可读存储介质 |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN113190364A true CN113190364A (zh) | 2021-07-30 |
Family
ID=76983697
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202110484348.2A Pending CN113190364A (zh) | 2021-04-30 | 2021-04-30 | 远程调用管理方法、装置、计算机设备及可读存储介质 |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN113190364A (zh) |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113778695A (zh) * | 2021-11-12 | 2021-12-10 | 深圳华锐金融技术股份有限公司 | 跨应用生命周期的内存快照管理方法、装置、设备及介质 |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN103312541A (zh) * | 2013-05-28 | 2013-09-18 | 浪潮电子信息产业股份有限公司 | 一种高可用互备集群的管理方法 |
| CN107959705A (zh) * | 2016-10-18 | 2018-04-24 | 阿里巴巴集团控股有限公司 | 流式计算任务的分配方法和控制服务器 |
| CN110287053A (zh) * | 2019-06-27 | 2019-09-27 | 四川新网银行股份有限公司 | 分布式系统异常统一处理的方法 |
| CN112463451A (zh) * | 2020-12-02 | 2021-03-09 | 中国工商银行股份有限公司 | 缓存灾备集群切换方法及软负载均衡集群装置 |
| CN112463535A (zh) * | 2020-11-27 | 2021-03-09 | 中国工商银行股份有限公司 | 多集群异常处理方法及装置 |
-
2021
- 2021-04-30 CN CN202110484348.2A patent/CN113190364A/zh active Pending
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN103312541A (zh) * | 2013-05-28 | 2013-09-18 | 浪潮电子信息产业股份有限公司 | 一种高可用互备集群的管理方法 |
| CN107959705A (zh) * | 2016-10-18 | 2018-04-24 | 阿里巴巴集团控股有限公司 | 流式计算任务的分配方法和控制服务器 |
| CN110287053A (zh) * | 2019-06-27 | 2019-09-27 | 四川新网银行股份有限公司 | 分布式系统异常统一处理的方法 |
| CN112463535A (zh) * | 2020-11-27 | 2021-03-09 | 中国工商银行股份有限公司 | 多集群异常处理方法及装置 |
| CN112463451A (zh) * | 2020-12-02 | 2021-03-09 | 中国工商银行股份有限公司 | 缓存灾备集群切换方法及软负载均衡集群装置 |
Non-Patent Citations (1)
| Title |
|---|
| 吕德超: "游戏业务受理系统中定时任务子系统的设计与实现", 《中国优秀博硕士学位论文全文数据库（硕士）信息科技辑（月刊）》士）信息科技辑（月刊）》 * |
Cited By (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113778695A (zh) * | 2021-11-12 | 2021-12-10 | 深圳华锐金融技术股份有限公司 | 跨应用生命周期的内存快照管理方法、装置、设备及介质 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US10609079B2 (en) | Application of advanced cybersecurity threat mitigation to rogue devices, privilege escalation, and risk-based vulnerability and patch management | |
| US20210092150A1 (en) | Advanced cybersecurity threat mitigation using behavioral and deep analytics | |
| US10742647B2 (en) | Contextual and risk-based multi-factor authentication | |
| US20180219894A1 (en) | User and entity behavioral analysis using an advanced cyber decision platform | |
| US11539663B2 (en) | System and method for midserver facilitation of long-haul transport of telemetry for cloud-based services | |
| CN109558366B (zh) | 一种基于多处理器架构的防火墙 | |
| CN105743610B (zh) | 用于多网络分组操作的数据完整性的技术 | |
| CN111641563B (zh) | 基于分布式场景的流量自适应方法与系统 | |
| US20200167342A1 (en) | System for Secure Software Defined Networking Based on Block-Chain and Method Thereof | |
| CN112055017B (zh) | 单一账号多应用统一登录方法、装置及计算机设备 | |
| CN111585805B (zh) | 平滑发布升级方法、装置、计算机系统及可读存储介质 | |
| US20230300018A1 (en) | Autonomous server agents | |
| US20220060510A1 (en) | System and method for aggregating and securing managed detection and response connection interfaces between multiple networked sources | |
| WO2020232195A1 (en) | Method for midserver facilitation of long-haul transport of telemetry for cloud-based services | |
| WO2020224100A1 (zh) | 区块链配置文件的处理装置、系统、方法及存储介质 | |
| CN110661853A (zh) | 一种数据代理方法、装置、计算机设备及可读存储介质 | |
| WO2019018829A1 (en) | MITIGATING IMPROVED CYBERSECURITY THREATS USING DEEP AND BEHAVIORAL ANALYTICS | |
| CN113190364A (zh) | 远程调用管理方法、装置、计算机设备及可读存储介质 | |
| CN112087475B (zh) | 一种云平台组件应用的消息推送方法、装置及消息服务器 | |
| CN111586022A (zh) | 防火墙开墙验证方法、电子装置、计算机设备及存储介质 | |
| CN114020678B (zh) | 服务器串行控制台重定向方法、装置、系统以及电子设备 | |
| US20240154945A1 (en) | System and method for third party service integration into a browser client application | |
| US20230168816A1 (en) | Systems, methods and computer readable media for software defined storage security protection | |
| CN114567678B (zh) | 一种云安全服务的资源调用方法、装置及电子设备 | |
| CN114780327A (zh) | 一种服务器监控方法、资产管理方法和pcie卡 |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| RJ01 | Rejection of invention patent application after publication | ||
| RJ01 | Rejection of invention patent application after publication |
Application publication date: 20210730 |