CN108123987A - 从云计算系统中确定主调度器的方法及装置 - Google Patents
从云计算系统中确定主调度器的方法及装置 Download PDFInfo
- Publication number
- CN108123987A CN108123987A CN201611089191.9A CN201611089191A CN108123987A CN 108123987 A CN108123987 A CN 108123987A CN 201611089191 A CN201611089191 A CN 201611089191A CN 108123987 A CN108123987 A CN 108123987A
- Authority
- CN
- China
- Prior art keywords
- scheduler
- computing system
- cloud computing
- vote information
- moderator
- 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
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
- H04L41/30—Decision processes by autonomous network management units using voting and bidding
-
- 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/465—Distributed object oriented systems
-
- 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/50—Allocation of resources, e.g. of the central processing unit [CPU]
- G06F9/5005—Allocation of resources, e.g. of the central processing unit [CPU] to service a request
- G06F9/5027—Allocation of resources, e.g. of the central processing unit [CPU] to service a request the resource being a machine, e.g. CPUs, Servers, Terminals
- G06F9/5038—Allocation of resources, e.g. of the central processing unit [CPU] to service a request the resource being a machine, e.g. CPUs, Servers, Terminals considering the execution order of a plurality of tasks, e.g. taking priority or time dependency constraints into consideration
-
- 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/50—Allocation of resources, e.g. of the central processing unit [CPU]
- G06F9/5005—Allocation of resources, e.g. of the central processing unit [CPU] to service a request
- G06F9/5027—Allocation of resources, e.g. of the central processing unit [CPU] to service a request the resource being a machine, e.g. CPUs, Servers, Terminals
- G06F9/505—Allocation of resources, e.g. of the central processing unit [CPU] to service a request the resource being a machine, e.g. CPUs, Servers, Terminals considering the load
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L65/00—Network arrangements, protocols or services for supporting real-time applications in data packet communication
- H04L65/40—Support for services or applications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/10—Protocols in which an application is distributed across nodes in the network
- H04L67/1001—Protocols in which an application is distributed across nodes in the network for accessing one among a plurality of replicated servers
- H04L67/1004—Server selection for load balancing
- H04L67/1008—Server selection for load balancing based on parameters of servers, e.g. available memory or workload
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/50—Network services
- H04L67/60—Scheduling or organising the servicing of application requests, e.g. requests for application data transmissions using the analysis and optimisation of the required network resources
Landscapes
- Engineering & Computer Science (AREA)
- Signal Processing (AREA)
- Computer Networks & Wireless Communication (AREA)
- Software Systems (AREA)
- Theoretical Computer Science (AREA)
- General Engineering & Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Physics & Mathematics (AREA)
- Computer Hardware Design (AREA)
- Multimedia (AREA)
- Computer And Data Communications (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
- Management, Administration, Business Operations System, And Electronic Commerce (AREA)
Abstract
本申请公开了一种从云计算系统中确定主调度器的方法及装置,所述云计算系统至少包括仲裁器和多个调度器,每个调度器对应一种调度策略,其中,所述方法包括:所述仲裁器接收至少一个调度器发送的投票信息,所述投票信息为所述调度器根据所述云计算系统的当前负载状况以及预设的负载状况与投票信息的对应关系所生成的;所述仲裁器根据所述至少一个调度器发送的投票信息,从所述多个调度器中确定主调度器,以使得所述主调度器按照所对应的调度策略对所述云计算系统中的计算资源进行调度,其中,所述主调度器所对应的所述调度策略与所述云计算系统的当前负载状况相匹配;采用本发明的方法及装置,可避免不同调度器间所分配计算资源的冲突。
Description
技术领域
本发明涉及云计算技术领域,尤其涉及一种从云计算系统中确定主调度器的方法及装置。
背景技术
随着互联网的飞速发展,云计算应运而生;所谓云计算是一种计算模式,如图1所示,整个云计算系统主要由客户端、调度器和资源池组成;其中,调度器可接收客户端的请求,且根据客户端的请求,调度资源池中的计算资源给客户端使用。
目前,在图1所示的云计算系统中通常为单调度器,也就是一个云计算系统中只有一个调度器;但是随着云计算系统所承载业务的类型越来越多,云计算系统中的调度器也逐渐由单调度器演变为多调度器;其中,在多调度器的云计算系统中,每个调度器对应一种调度策略,负责一种类型的业务;比如,一云计算系统承载三种类型的业务,分别为搜索引擎、视频监控以及大数据;那么,如图2所示,整个云计算系统中,可有三个调度器,分别为搜索引擎调度器、视频监控调度器以及大数据调度器;相应的,搜索引擎调度器对应搜索引擎的调度策略,负责管理搜索引擎客户端的业务,即搜索引擎调度器接收搜索引擎客户端的业务请求,且调度资源池中的计算资源给搜索引擎客户端;同理,视频监控调度器对应视频监控调度策略,负责视频监控客户端的业务,大数据调度器对应大数据的调度策略,负责大数据客户端的业务,在此不再赘述。
由于在实际应用中,在多调度器的云计算系统中,不同调度器间是各自独立的,且不同调度器是共用资源池中的计算资源的,因此采用上述方法,可能会造成不同调度器所分配计算资源的冲突,仍沿用图2所示的举例,比如,搜索引擎调度器在接收到搜索引擎客户端的业务请求时,分配资源池中的计算资源M给搜索引擎客户端;而由于搜索引擎调度器与大数据调度器彼此间是相互独立的,可能会出现,在大数据服务器接收到大数据客户端的业务请求时,也分配资源池中的计算资源M给大数据客户端,从而会造成所分配计算资源的冲突。
发明内容
本发明实施例提供一种从云计算系统中确定主调度器的方法及装置,以避免不同调度器间所分配计算资源的冲突。
第一方面,提供一种从云计算系统中确定主调度器的方法,云计算系统至少包括仲裁器和多个调度器,每个调度器对应一种调度策略,方法包括:仲裁器接收至少一个调度器发送的投票信息,投票信息为调度器根据云计算系统的当前负载状况以及预设的负载状况与投票信息的对应关系所生成的;所述投票信息为当前调度器为所述多个调度器中至少一个调度器的投票信息,所述投票信息可具体为被投票调度器的标识,或,被投票调度器的评分;仲裁器根据至少一个调度器发送的投票信息,从所述多个调度器中确定主调度器,以使得主调度器按照所对应的调度策略对云计算系统中的计算资源进行调度,其中,主调度器所对应的所述调度策略与云计算系统的当前负载状况相匹配。
结合第一方面,在第一种可能的实现方式中,仲裁器根据至少一个调度器发送的投票信息,从多个调度器中选择一调度器作为主调度器,包括:仲裁器根据至少一个调度器发送的投票信息,确定每个调度器的投票得分;仲裁器从多个调度器中,确定投票得分满足预设条件的调度器为所述主调度器。由于在本发明实施例中,可选择满足预设条件的调度器为主调度器,而主调度器可根据其对应的调度策略对整个云计算系统进行调度,那么用户可通过设置不同的预设条件,进而选择不同的调度器作为主调度器,从而在本发明实施例中,可实现用户根据需求灵活地选择主调度器。
结合第一方面的第一种可能实现方式,在第二种可能的实现方式中,预先为不同调度器设置不同的优先级,仲裁器根据至少一个调度器发送的投票信息,确定每个调度器的投票得分,包括:仲裁器根据每个调度器的优先级,为每个调度器的投票信息设置不同的权重;仲裁器根据每个调度器所获得的投票信息以及每个投票信息的权重,确定每个调度器的投票得分。采用上述方法,可划分不同调度器的优先级,从而使得优先级高的调度器所占投票得分的比重较大,进而使得统计投票得分的方式更加实用。
结合第一方面的第一种可能实现方式,在第三种可能的实现方式中,仲裁器根据至少一个调度器发送的投票信息,确定每个调度器的投票得分,包括:针对一调度器,仲裁器确定当前调度器是否为其它调度器投票,其它调度器为云计算系统中,除当前调度器外的剩余调度器;仲裁器在确定当前调度器为其它调度器投票时,统计当前调度器的投票得分,否则,确定当前调度器的投票得分为零。采用上述方法,可避免优先级高的调度器总是被当选为主调度器。
结合第一方面的第一种可能实现方式,在第四种可能的实现方式中,仲裁器根据至少一个调度器发送的投票信息,确定每个调度器的投票得分,包括:所述仲裁器直接统计每个调度器的投票得分。采用上述方式,可快速地确定每个调度器的得分。
结合第一方面,第一方面的第一种可能实现方式、第二种可能实现方式、第三种可能实现方式或第四种可能实现方式,方法还包括:仲裁器接收辅调度器发送的重新选举请求,辅调度器为云计算系统中,除主调度器外的其它调度器,重新选举请求为辅调度器在当前主调度器对云计算系统中计算资源的调度不满足预设条件时所发送的;仲裁器在发送重新选举请求的辅调度器的比例满足预设条件时,向所有调度器发送重新选举指令,以使得所有调度器根据当前云计算系统的负载状况,重新进行投票。采用上述方法,可在云计算系统的当前负载状况与主调度器不匹配时,重新选择主调度器,从而使得所选择的主调度器总是与云计算系统的负载状况相匹配。
第二方面,提供一种从云计算系统中确定主调度器的方法,云计算系统至少包括仲裁器和多个调度器,每个调度器对应一种调度策略,方法包括:调度器确定云计算系统的当前负载状况;调度器根据云计算系统的当前负载状况以及预设的负载状况与投票信息的对应关系,确定投票信息,其中,在云计算系统的当前负载状况下,多个调度器的投票信息所确定的投票结果对应的调度器为与当前负载状况所匹配的调度器;调度器发送投票信息至仲裁器,以使得仲裁器根据投票信息,确定主调度器,主调度器用于按照对应的调度策略对云计算系统中的计算资源进行调度。采用上述方法,每个调度器可选择与当前负载状况相匹配的调度器,并为相匹配的调度器上报投票信息,从而使得仲裁器所选择的主调度器与整个云计算系统的负载状况相匹配。
结合第二方面,在第二方面的第一种可能实现方式中,方法还包括:调度器周期性采集云计算系统的负载状况;调度器在当前云计算系统的负载状况不满足预设条件时,上报重新投票信息至仲裁器,以使得仲裁器根据重新投票信息,触发云计算系统中的所有调度器重新发送投票信息。采用上述方法,可在云计算系统的当前负载状况与主调度器不匹配时,重新选择主调度器,从而使得所选择的主调度器总是与云计算系统的负载状况相匹配。
第三方面,提供一种从云计算系统中确定主调度器的装置,云计算系统至少包括多个调度器,每个调度器对应一种调度策略,装置包括:接收单元,用于接收至少一个调度器发送的投票信息,投票信息为调度器根据云计算系统的当前负载状况以及预设的负载状况与投票信息的对应关系所生成的;所述投票信息为当前调度器为所述多个调度器中至少一个调度器的投票信息,所述投票信息可具体为当前调度器所投票调度器的标识,或,当前调度器为投票调度器的评分;选择单元,用于根据至少一个调度器发送的投票信息,从所述多个调度器中确定主调度器,以使得主调度器按照所对应的调度策略对云计算系统中的计算资源进行调度,其中,所述主调度器所对应的所述调度策略与所述云计算系统的当前负载状况相匹配。结合第三方面,在第三方面的第一种可能实现方式中,选择单元,具体用于:根据至少一个调度器发送的投票信息,确定每个调度器的投票得分;从多个调度器中,确定投票得分满足预设条件的调度器为所述主调度器。由于在本发明实施例中,可选择满足预设条件的调度器为主调度器,而主调度器可根据其对应的调度策略对整个云计算系统进行调度,那么用户可通过设置不同的预设条件,进而选择不同的调度器作为主调度器,从而在本发明实施例中,可实现用户根据需求,灵活的选择主调度器。
结合第三方面的第一种可能实现方式中,在第三方面的第二种可能实现方式中,预先为不同调度器设置不同的优先级,选择单元,在根据至少一个调度器发送的投票信息,确定每个调度器的投票得分时,具体用于:根据每个调度器的优先级,为每个调度器的投票信息设置不同的权重;根据每个调度器所获得的投票信息以及每个投票信息的权重,确定每个调度器的投票得分。采用上述方法,可划分不同调度器的优先级,从而使得优先级高的调度器所占投票得分的比重较大,进而使得统计投票得分的方式更加实用。第三方面的第一种可能实现方式中,在第三方面的第三种可能实现方式中,选择单元,在根据至少一个调度器发送的投票信息,确定每个调度器的投票得分时,具体用于:针对一调度器,确定当前调度器是否为其它调度器投票,其它调度器为云计算系统中,除当前调度器外的剩余调度器;在确定当前调度器为其它调度器投票时,统计当前调度器的投票得分,否则,确定当前调度器的投票得分为零。在本发明实施例中,可避免优先级高的调度器总是被当选为主调度器。
结合第三方面的第一种可能实现方式,在第四种可能的实现方式中,仲裁器根据至少一个调度器发送的投票信息,确定每个调度器的投票得分,包括:所述仲裁器直接统计每个调度器的投票得分;采用上述方式,可快速的确定每个调度器的得分。
结合第三方面,第三方面的第一种可能实现方式、第二种可能实现方式、第三种可能实现方式或第四种可能实现方式,装置还包括,重新选择单元,具体用于:接收辅调度器发送的重新选举请求,辅调度器为云计算系统中,除主调度器外的其它调度器,重新选举请求为辅调度器在当前主调度器对云计算系统中计算资源的调度不满足预设条件时所发送的;在发送重新选举请求的辅调度器的比例满足预设条件时,向所有调度器发送重新选举指令,以使得所有调度器根据当前云计算系统的负载状况,重新进行投票。在本发明实施例中,可在云计算系统的当前负载状况与主调度器不匹配时,重新选择主调度器,从而使得所选择的主调度器总是与云计算系统的负载状况相匹配。
第四方面,提供一种从云计算系统中确定主调度器的装置,云计算系统至少包括仲裁器,装置包括:负载确定单元,用于确定云计算系统的当前负载状况;投票信息确定单元,用于根据云计算系统的当前负载状况以及预设的负载状况与投票信息的对应关系,确定投票信息,其中,在云计算系统的当前负载状况下,投票信息所确定的投票结果对应的调度器为与当前负载状况所匹配的调度器;发送单元,用于发送投票信息至仲裁器,以使得仲裁器根据投票信息,确定主调度器,主调度器用于按照对应的调度策略对云计算系统中的计算资源进行调度。在本发明实施例中,每个调度器可选择与当前负载状况相匹配的调度器,并为相匹配的调度器上报投票信息,从而使得仲裁器所选择的主调度器与整个云计算系统的负载状况相匹配。
结合第四方面,在第四方面的第一种可能实现方式中,装置还包括:采集单元,用于周期性采集云计算系统的负载状况;上报单元,用于在当前云计算系统的负载状况不满足预设条件时,上报重新投票信息至仲裁器,以使得仲裁器根据重新投票信息,触发云计算系统中的所有调度器重新发送投票信息。在本发明实施例中,可在云计算系统的当前负载状况与主调度器不匹配时,重新选择主调度器,从而使得所选择的主调度器总是与云计算系统的负载状况相匹配。
第五方面,提供一种云计算系统,云计算系统包括仲裁器以及调度器;其中,调度器,用于确定云计算系统的当前负载状况,以及根据云计算系统的当前负载状况、预设的负载状况与投票信息的对应关系,确定投票信息以及发送投票信息至仲裁器;仲裁器,用于接收至少一个调度器发送的投票信息,以及根据至少一个调度器发送的投票信息,从多个调度器中选择一调度器作为主调度器,以使得主调度器按照所对应的调度策略对云计算系统中的计算资源进行调度,其中,所述主调度器所对应的所述调度策略与所述云计算系统的当前负载状况相匹配。第三方面、第四方面以及第五方面及各自的实现方式中更为具体的实现方法可与前述方面或实现方式相互参考。
由上可见,在本发明实施例中,首先调度器确定整个云计算系统的当前负载状况,然后,根据当前负载状况确定投票信息。仲裁器根据多个调度器各自的投票信息,从云计算系统的多个调度器中,选择与当前负载状况相匹配的调度器,作为主调度器,而主调度器将按照其所对应的调度策略对云计算系统中的计算资源进行调度。由此,通过仲裁器决策出主调度器,而整个云计算系统中除主调度外的辅调度器将不再对计算资源进行调度,从而可保证在需要调度器调度的时候整个云计算系统只有一个调度器在进行调度工作,进而可避免不同调度器间对计算资源的调度冲突问题。
由于根据各个调度器的投票信息是根据当前系统的负载状况而产生的,所选出的调度器能够适应当前系统的负载状况,从而提高了主调度器的针对性,增强了云计算系统的调度性能。
此外,由于主调度器是根据各个调度器投票产生的,仲裁器仅需根据投票信息即可确定主调度器,而无需根据各个调度器的特性来进行选择,从而实现了仲裁器与各个调度器之间的解耦和,仲裁器对不同的多种调度器进行统一调度,且调度器可以灵活的进行变更和增减,提高了系统的灵活性。
附图说明
为了更清楚地说明本发明实施例或现有技术中的技术方案,下面将对实施例或现有技术描述中所需要使用的附图作一简单地介绍,显而易见地,下面描述中的附图是本发明的一些实施例,对于本领域普通技术人员来讲,还可以根据这些附图获得其他的附图。
图1为本发明实施例所提供的云计算系统的一示意图;
图2为本发明实施例所提供的云计算系统的另一示意图;
图3为本发明实施例所提供的云计算系统的一示意图;
图4为本发明实施例所提供的确定云计算系统中主调度器的方法一示意图;
图5为本发明实施例所提供的云计算系统的一示意图;
图6为本发明实施例所提供的云计算系统的一示意图;
图7为本发明实施例所提供的云计算系统的一示意图;
图8为本发明实施例所提供的确定云计算系统中主调度器的装置的一示意图;
图9为本发明实施例所提供的确定云计算系统中主调度器的装置的一示意图;
图10为本发明实施例所提供的云计算系统的一示意图;
图11为本发明实施例所提供的仲裁器的一示意图;
图12为本发明实施例所提供的调度器的一示意图。
具体实施方式
下面将结合本发明实施例中的附图,对本发明实施例中的技术方案进行清楚、完整地描述,显然,所描述的实施例仅仅是本发明一部分实施例,并不是全部的实施例。
本发明提供一种从云计算系统中确定主调度器的方法及装置,如图1所示,该方法及装置的应用场景如下:
随着互联网的飞速发展,云计算应运而生;所谓云计算是一种计算模式,如图1所示,整个云计算系统主要由客户端、调度器和资源池组成;其中,调度器可接收客户端的请求,且根据客户端的请求,调度资源池中的计算资源给客户端使用。
目前,在图1所示的云计算系统中通常为单调度器,也就是一个云计算系统中只有一个调度器;但是随着云计算系统所承载业务的类型越来越多,云计算系统中的调度器也逐渐由单调度器演变为多调度器;其中,在多调度器的云计算系统中,每个调度器对应一种调度策略,用于对云计算系统中的计算资源进行调度。
由于在实际应用中,在多调度器的云计算系统中,不同调度器间是独立进行工作的,即不同调度器是独自对云计算系统中的计算资源进行调度的,因此,采用上述方法,可能会造成不同调度器所调度计算资源的冲突。
实施例一
基于上述应用场景,本发明提供一种从云计算系统中确定主调度器的方法,其中,该方法的核心思想为:首先确定整个云计算系统的当前负载状况,然后,从云计算系统的多个调度器中,选择与当前负载状况相匹配的调度器,作为主调度器,而主调度器将按照其所对应的调度策略对云计算系统中的计算资源进行调度,而整个云计算系统中除主调度外的辅调度器将不再对计算资源进行调度,从而可保证在每个时刻,整个云计算系统只有一个调度器在进行调度工作,进而可避免不同调度器间对调度资源的冲突问题。
本发明首先提供一种云计算系统,如图3所示,该系统至少包括仲裁器、多个调度器以及资源池:
其中,资源池用于提供计算资源;每个调度器对应一种调度策略,用于按照其对应的调度策略,对资源池中的计算资源进行调度;仲裁器用于从多个调度器中,选择一调度器,作为主调度器;其中,被选为主调度的调度器,将按照其对应的调度策略对资源池中的计算资源进行调度,而未被选择为主调度器的调度器称为辅调度器,将停止对资源池中的计算资源进行调度;比如,整个云计算系统包括三个调度器,分别为调度器A、调度器B以及调度器C,其中,调度器A对应调度策略A,调度器B对应调度策略B,调度器C对应调度策略C;而此时,如果仲裁器将调度器A选为主调度器,那么调度器B和调度器C将为辅调度器,而在整个云计算系统中,调度器A将按照其对应的调度策略A对资源池中的计算资源进行调度,而调度器B以及调度器C将作为辅调度器,停止对资源池中的计算资源进行调度。
利用图3所示的云计算系统,如图4所示,本发明所提供的调度方法,具体如下:
步骤S41:调度器获取整个云计算系统中资源池的当前负载状况;
资源池的当前负载状况,是指当前资源池中各个服务器的各类资源的负载情况,当前负载状况可以体现为一些具体的参数,当参数满足特定条件(例如满足特定的阈值)时则认为资源池的负载状况处于某一特定的负载状况中;也可以通过监测资源池中是否出现了特定的触发事件,从而使得资源池满足某一负载状况的条件。在具体的实施例中,负载状况可以通过指资源池中所有服务器的资源总体负载状况,例如某一种或者多种资源在资源池中所有服务器的负载量的总量、或者占总资源量的比值的平均值或者加权平均值(可用以衡量资源的负载情况或者衡量某类资源是否为主要消耗的资源);或者当前资源池中某一种或多种资源的负载量与其他资源负载量的差值(常用来衡量资源负载的均衡性)、等来衡量。在另一些具体的实施例中,负载状况也可以通过服务器中部分服务器是否触发特定的条件来进行判定是否为预设的某种负载状况,例如某些服务器的资源负载大于特定的阈值(可用以判断资源池中服务器的均衡负载情况),或者某些服务器的某类资源占用超过了特定的阈值(可用于判断资源池中服务器的资源种类分配的均衡性)等。
资源池负载状况的获取,可以通过调度器主动进行采集,也可以通过其他云计算系统中的功能性节点采集后发送给调度器。资源负载状况的采集或者检测可以通过现有技术实践,例如根据各个服务器主动上报的资源负载信息进行确定,或者通过管理节点在任务分配时进行计算确定,或者通过监控服务器之间的数据流量进行估计等。
步骤S42:调度器根据云计算系统的当前负载状况以及预设的负载状况与投票信息的对应关系,确定投票信息;
在本发明实施例中,每个调度器内所预设的负载状况与投票信息的对应关系,可相同也可不同,相关技术人员,可根据需求,自行设置负载状况与投票信息的对应关系。
在本发明实施例中,所述投票信息为当前调度器为所述多个调度器中至少一个调度器的投票信息,所述投票信息可具体为被投票调度器的标识,或,被投票调度器的评分;比如,在本发明实施例中,所预设的负载状况与投票信息的对应关系为“负载1—调度器1,负载2—调度器2,以及负载3—调度器3”,那么,在云计算系统的当前负载为1时,当前调度器所匹配出的调度器为为“调度器1”,而“调度器1”具体为被投票调度器的标识,再如,所预设的负载状况与投票信息的对应关系为“负载1—调度器1评5分,负载2—调度器2评6分,负载3—调度器3评10分”,那么在整个云计算系统的当前负载为负载1时,调度器所匹配出的投票信息为“调度器1评5分”“而调度器1评5分”具体为被投票调度器的评分。
步骤S43:调度器上报投票信息至仲裁器;
步骤S44:仲裁器根据每个调度器的投票信息,从多个调度器中确定主调度器,其余调度器作为辅调度器,其中,主调度器将按照其对应的调度策略对资源池中的计算资源进行调度,而辅调度器将停止对资源池中的计算资源进行调度。
在本发明实施例中,可具体采用下述方法,从多个调度器中选择主调度器:
首先所述仲裁器根据每个调度器的投票信息,确定每个调度器的投票得分,然后,从多个调度器中,确定投票得分满足预设条件的调度器作为主调度器,而关于主调度器得分所满足的预设条件本领域技术人员可自行设置,比如可将预设条件设置为将得分最高的调度器作为主调度器,也可将预设条件设置为将得分最低的调度器作为主调度器,亦可将投票条件设置为将投票得分在一定区间的调度器作为主调度器,在此不再赘述。
在本发明实施例中,将以“预设条件为得分最高的调度器为主调度器”为例,详细介绍“选择主调度器”的过程:
第一种方式:这种方式可具体对应于投票信息为被投票调度器的标识,具体为:人工预先为每个调度器设置不同的优先级,然后,仲裁器在接收到每个调度器的投票信息后,根据发送投票信息的调度器的优先级为每个投票信息设置不同的权重;然后,根据每个调度器所获得的投票信息以及每个投票信息的权重,确定每个调度器的投票得分;最后,从多个调度器中,选择投票得分最高的调度器为主调度器;
比如,如图5所示,整个云计算系统,包括调度器A、B、C三个调度器,而预先将调度器A的优先级设置为高,调度器B的优先级设置为中,调度器C的优先级为低,且设置调度器A的投票权重为3,调度器B的投票权重为2,调度器C的投票权重为1;且调度器A投票给调度器B,调度器B投票给调度器C,而调度器C投票给调度器B,那么仲裁器在接收到上述每个调度器的投票信息后,将计算每个调度器的投票得分;其中,经计算可得出:调度器A的投票得分为0;调度器B的投票得分为:3*1+1*1=4;调度器C的投票得分为:2*1=2;可见,上述三个调度器中,调度器B的得分最高,因此仲裁器选择调度器B为主调度器。
第二种方式,这种方式可对应于投票信息为被投票调度器的评分,具体为:仲裁器直接统计每个调度器的评分,比如,仍沿用上述举例,整个云计算系统,包括调度器A、B、C三个调度器,那么,调度器A的投票信息为“调度器B评5分”,调度器B的投票信息为“调度器C评3分”,“调度器C的投票信息为”调度器C评6分”,那么,可统计调度器B的投票得分为5分,调度器C的投票得分为8分=5分+3分,而调度器A的投票得分为0分。
第二种方式:这种方式可对应投票信息为被投票调度器的标识和被投票调度器的评分两种情况,具体为:每个调度器向仲裁器至少发送两个投票信息,其中一个投票信息为自己,表明当前调度器要参与选举,另一个投票为其它调度器,所述其它调度器为所述云计算系统中,除当前调度器外的剩余调度器;
而仲裁器在接收到调度器的投票信息后,首先判断当前调度器是否为其它调度器投票,如果为其它调度器投票,统计当前调度器的投票得分,否则,确定当前调度器的得分为零;
关于如何统计调度器的投票得分,可具体采用上述第一种方式所公开的方式,也可采用第二种普通的相加方式;
采用上述方式,在某一调度器只为自身投票时,仲裁器将该调度器的投票得分判为零,从而可避免某调度器只为自身投票的情况。
由上可见,在本发明实施例中,首先确定整个云计算系统的当前负载状况,然后,从云计算系统的多个调度器中,选择与当前负载状况相匹配的调度器,作为主调度器,而主调度器将按照其所对应的调度策略对云计算系统中的计算资源进行调度,而整个云计算系统中除主调度外的辅调度器将不再对计算资源进行调度,从而可保证在每个时刻,整个云计算系统只有一个调度器在进行调度工作,进而可避免不同调度器间对计算资源的调度冲突问题。
实施例二
在本发明实施例中,当采用实施例一所公开的方法,在整个云计算系统中选择出主调度器后,主调度器将按照其对应的调度策略对资源池中的计算资源进行调度;而未被选择为主调度器的辅调度器将实时监控整个云计算系统的负载状况,当负载状况不满足自身预设的条件时,向仲裁器上报重新投票信息;而仲裁器在发送重新投票信息的调度器的比例满足预设条件时,向所有调度器发送重新选举指令,而调度器将采用实施例一所公开的方式,重新发送投票信息,而仲裁器将重新选举出主调度器,从而使得所选举出的主调度器与云计算系统的当前负载状况相匹配。
实施例三
下面将以整个云计算系统,包括三个调度器、一个仲裁器和一个资源池为例,详细介绍,本发明的过程:
首先,如图6所示,在实际应用中,资源池可具体由多个服务器组成,每个服务器提供一定的计算资源,而上述三个调度器可具体为LB(Load Balanc,负载均衡)调度器、LC(Load Consolidation,负载整合)调度器以及HE(Hotspot Elimination,热点消除)调度器;其中,LB调度器所对应的调度策略为LB调度策略,LC调度器所对应的调度策略为LC调度策略,HE调度器所对应的调度策略为HE调度策略;
而上述LB调度策略,可具体为在对服务器进行业务分配时,尽量保证资源池中每个服务器的负载均衡;
LC调度策略,可具体为当资源池中的一服务器的负载低于预设最低值时,将该服务器的业务迁移到资源池中的其它服务器上,同时将该服务器下电;
HE调度策略,可具体为当资源池中某一服务器的负载超过预设最高值时,将该服务器的部分业务迁移到资源池中的其它服务器上,从而降低当前服务器的负载。
在本发明实施例中,假设预先将HE调度器的优先级设置为高,将LB调度器的优先级设置为中,将LC调度器的优先级设置为低,而将高优先级HE调度器的投票信息的权重设置为3,将中优先级LB调度器的投票信息的权重设置为2,将低先级LC调度器的投票信息的权重设置为1;
在本发明实施例中,本领域技术人员,可自行设置每个调度器内部的投票策略;假设,在本发明实施例中,HE、LB和LC调度器的投票策略,各自如下:
HE调度器的投票策略:云计算系统的当前负载大于Th时,为HE投票;
云计算系统的当前负载小于T1时,为LC投票;
云计算系统的当前负载大于等于T1,小于等于Th时,为LB投票;
LB调度器的投票策略:云计算系统的当前负载小于T1时,为LC投票;
云计算系统的当前负载大于等于T1时,为LB投票;
LC调度器的投票策略:当云计算系统的当前负载小于T1时,并持续m分钟时,为LC投票;
而当云计算系统的当前负载大于等于T1时,不进行任何投票;
在本发明实施例中,假设整个云计算系统的当前负载状况小于T1,且持续了m分钟,那么通过上述投票策略,可确定HE调度器的投票信息为“为LC投票”,LB调度器的投票信息为“为LC投票”,LC调度器的投票信息为“为LC投票”;
那么仲裁器在接收到上述上述各个调度器的投票信息时,可确定LC调度器的投票得分为6=3*1+2*1+1*1,而HE和LB调度器的投票得分均为0;此时仲裁器将LC调度器选为主调度器,HE和LB调度器为辅调度器,此时,LC调度器将按照上述LC调度策略对资源池中的计算资源进行调度,而HE和LB调度器将停止调度工作。
而在将LC调度器选为主调度器后,LC和LB调度器将实时监测云计算系统中当前负载的状况,而当云计算系统的当前负载不满足条件时,比如(当前负载大于Th时),LB和LC调度器可向仲裁器发送重新选举的请求,而仲裁器在发送重新选举调度器的比例大于一定值时,触发所有调度器重新进行选举;比如,当发送重新选举调度器的比例占所述云系统中所有调度器的60%时,即重新进行选举。
由上可见,在本发明实施例中,采用上述方法,可保证在每个时刻,整个云计算系统中仅有一个调度器进行工作,从而可避免不同调度器间的调度冲突问题。
实施例四
本发明实施例,如图7所示,将以整个云计算系统包括三个调度器、一个仲裁器和一个资源池,且三个调度器分别为科学计算调度器、存储云调度器和Web服务调度器为例,详细介绍本发明的过程:
其中,科学计算调度器用于为科学计算业务,调度计算资源,其对应的调度策略为为科学计算业务提供充足的CPU资源,其对应的优先级为5;存储云调度器用于为存储云业务,调度计算资源,其对应的调度策略为尽量均衡磁盘输入输出和磁盘容量,减少碎片,其对应的优先级为3;Web服务调度器用于对Web业务,调度计算资源,其对应的调度策略为为当前业务提供充足的CPU和网络资源,其对应的优先级为7;
在本发明实施例中,上述三个调度器可分别采集云计算系统的当前负载状况,所述云计算系统的当前负载可具体包括云计算系统的磁盘负载以及网络负载;
在本发明实施例中,上述三个调度器的调度策略可分别如下:
科学计算调度器:第一,为自己投票;第二,当资源池中的剩余磁盘资源高于Rs时,为存储云调度器投票,否则,为Web服务调度器投票;
存储云调度器:第一,为自己投票;第二,当资源池中的剩余剩网络资源低于Rw时,为Web服务调度器投票,否则,为科学计算调度器投票。
Web服务调度器:第一,为自已投票;第二,当资源池中的剩余网络资源高于Rs时,为存储云调度器投票,否则,为科学计算调度器投票。
首先,需要说明的是,在本发明实施例中,每个调度器可投两票,一票投自己,表明当前调度器参与选举,另一票,投给与当前负载状况相匹配的其它调度器。
在本发明实施例中,以云计算系统的当前负载状况下,云计算系统中的剩磁盘资源高于Rs,剩余网络资源低于Rw为例,详细介绍本发明的过程:
具体的,对应于上述每个调度器的投票策略,对于科学计算调度器的投票信息可具体为:为自己,即为科学计算调度器投票,为存储云调度器投票;而对于存储云调度器的投票信息可具体为:为自己投票,即为存储云调度器投票,为Web服务调度器投票;对于Web服务调度器的投票信息可具体为:为自己投票,即为Web服务调度器投票,为存储云调度器投票。
而所述仲裁器接收到每个调度器的投票信息时,仲裁器可具体首先判断当前调度器是否为自身投票,如果为自身投票,确定当前调度器有参选资格,否则,确定当前调度器无参选资格,不再统计当前调度器的得分;然后,再判断每个调度器是否为其它调度器投票,如果当前调度器为其它调度器投票,统计当前调度器的得分,否则,确定当前调度器的得分为零;采用上述方式,可避免优先级高的调度器仅为自身投票,而不为其它调度器投票,进而避免优先级高的调度器总被选举为主调度器。
在本发明实施例中,仍沿用上述举例,仲裁器可看到上述三个调度器均为自身投票,均有参选资源,且均为其它调度器进行投票,可正常统计每个调度器的得分。具体通过沿用实施例一中的计算方式,可得到科学计算调度器的投票得分为:5*1=5分;存储云调度器的投票得分为:5*1+3*1+7*1=15分;Web服务调度器的投票得分为:3*1+7*1=10分;
在本发明实施例中,如果选择得分最高的调度器为主调度器,可看出,在本发明实施例中,将选举存储云调度器为主调度器,而科学计算调度器和Web服务调度器为辅调度器;而存储云调度器将按照其对应的调度策略,对资源池中的计算资源进行调度,而作为辅调度器的科学计算调度器和Web服务调度器可实时监控当前资源池的负载状况,所述负载状况包括磁盘资源状况和网络资源状况;而每个调度器一旦发现资源池的当前负载状况不满足自身的条件时,将向仲裁器发送重新选举的请求,而仲裁器在发送重新选举请求的调度器达到一定比例时,触发所有调度器重新进行选举。
由上可见,在本发明实施例中,采用上述方法,可保证在每个时刻,整个云计算系统中仅有一个调度器进行工作,从而可避免不同调度器间的调度冲突问题。
实施例五
与上述构思相同,本发明还提供一种从云计算系统中确定主调度器的装置,如图8所示,所述装置包括:
接收单元81,用于接收至少一个调度器发送的投票信息,所述投票信息为所述调度器根据所述云计算系统的当前负载状况以及预设的负载状况与投票信息的对应关系所生成的;
选择单元82,用于根据所述至少一个调度器发送的投票信息,从所述多个调度器中确定主调度器,以使得所述主调度器按照所对应的调度策略对所述云计算系统中的计算资源进行调度,其中,所述主调度器所对应的所述调度策略与所述云计算系统的当前负载状况相匹配。
可选的,选择单元,具体用于根据所述至少一个调度器发送的投票信息,确定每个调度器的投票得分;从所述多个调度器中,确定投票得分满足预设条件的调度器为所述主调度器。
可选的,预先为不同调度器设置不同的优先级,所述选择单元,在根据所述至少一个调度器发送的投票信息,确定每个调度器的投票得分时,具体用于:根据每个调度器的优先级,为每个调度器的投票信息设置不同的权重;根据每个调度器所获得的投票信息以及每个投票信息的权重,确定每个调度器的投票得分。
可选的,所述选择单元,在根据所述至少一个调度器发送的投票信息,确定每个调度器的投票得分时,具体用于:针对一调度器,确定当前调度器是否为其它调度器投票,所述其它调度器为所述云计算系统中,除当前调度器外的剩余调度器;在确定当前调度器为其它调度器投票时,统计当前调度器的投票得分,否则,确定当前调度器的投票得分为零。
可选的,所述装置还包括,重新选择单元,具体用于:接收辅调度器发送的重新选举请求,所述辅调度器为所述云计算系统中,除所述主调度器外的其它调度器,所述重新选举请求为所述辅调度器在当前主调度器对云计算系统中计算资源的调度不满足预设条件时所发送的;在所述发送重新选举请求的辅调度器的比例满足预设条件时,向所有调度器发送重新选举指令,以使得所有调度器根据当前云计算系统的负载状况,重新进行投票。
由上可见,在本发明实施例中,首先确定整个云计算系统的当前负载状况,然后,从云计算系统的多个调度器中,选择与当前负载状况相匹配的调度器,作为主调度器,而主调度器将按照其所对应的调度策略对云计算系统中的计算资源进行调度,而整个云计算系统中除主调度外的辅调度器将不再对计算资源进行调度,从而可保证在每个时刻,整个云计算系统只有一个调度器在进行调度工作,进而可避免不同调度器间对计算资源的调度冲突问题。
实施例六
与上述构思相同,本发明还提供一种从云计算系统中确定主调度器的装置,如图9所示,所述装置包括:
负载确定单元91,用于确定所述云计算系统的当前负载状况;
投票信息确定单元92,用于根据所述云计算系统的当前负载状况以及预设的负载状况与投票信息的对应关系,确定投票信息,其中,在所述云计算系统的当前负载状况下,所述投票信息所确定的投票结果对应的调度器为与当前负载状况所匹配的调度器;
发送单元93,用于发送所述投票信息至仲裁器,以使得所述仲裁器根据所述投票信息,确定主调度器,所述主调度器用于按照对应的调度策略对所述云计算系统中的计算资源进行调度。
可选的,所述装置还包括:采集单元,用于周期性采集云计算系统的负载状况;上报单元,用于在当前云计算系统的负载状况不满足预设条件时,上报重新投票信息至所述仲裁器,以使得所述仲裁器根据所述重新投票信息,触发所述云计算系统中的所有调度器重新发送投票信息。
由上可见,在本发明实施例中,首先确定整个云计算系统的当前负载状况,然后,从云计算系统的多个调度器中,选择与当前负载状况相匹配的调度器,作为主调度器,而主调度器将按照其所对应的调度策略对云计算系统中的计算资源进行调度,而整个云计算系统中除主调度外的辅调度器将不再对计算资源进行调度,从而可保证在每个时刻,整个云计算系统只有一个调度器在进行调度工作,进而可避免不同调度器间对计算资源的调度冲突问题。
实施例七
与上述构思相同,本发明还提供一种云计算系统,如图10所示,所述云计算系统包括一仲裁器101以及多个调度器102;
其中,调度器102,用于确定所述云计算系统的当前负载状况,以及根据所述云计算系统的当前负载状况、预设的负载状况与投票信息的对应关系,确定投票信息以及发送所述投票信息至所述仲裁器;
仲裁器101,用于接收至少一个调度器发送的投票信息,以及根据所述至少一个调度器发送的投票信息,从多个调度器中选择一调度器作为主调度器,以使得所述主调度器按照所对应的调度策略对所述云计算系统中的计算资源进行调度,其中,所述主调度器所对应的所述调度策略与所述云计算系统的当前负载状况相匹配。
由上可见,在本发明实施例中,首先确定整个云计算系统的当前负载状况,然后,从云计算系统的多个调度器中,选择与当前负载状况相匹配的调度器,作为主调度器,而主调度器将按照其所对应的调度策略对云计算系统中的计算资源进行调度,而整个云计算系统中除主调度外的辅调度器将不再对计算资源进行调度,从而可保证在每个时刻,整个云计算系统只有一个调度器在进行调度工作,进而可避免不同调度器间对计算资源的调度冲突问题。
实施例八
与上述构思相同,本发明还提供一种仲裁器,如图11所示,所述仲裁器至少包括存储器111和处理器112;
存储器111,用于存储程序和指令;
处理器112,用于通过调用存储器中存储的程序和指令,执行:
接收至少一个调度器发送的投票信息,所述投票信息为所述调度器根据所述云计算系统的当前负载状况以及预设的负载状况与投票信息的对应关系所生成的;
根据所述至少一个调度器发送的投票信息,从多个调度器中确定主调度器,以使得所述主调度器按照所对应的调度策略对所述云计算系统中的计算资源进行调度,其中,所述主调度器所对应的所述调度策略与所述云计算系统的当前负载状况相匹配。
与上述构思相同,如图12所示,本发明还提供一种调度器,所述调度器至少包括存储器121和处理器122;
存储器121,用于存储程序和指令;
处理器122,用于通过调用存储器中存储的程序和指令,执行:
确定所述云计算系统的当前负载状况;
根据所述云计算系统的当前负载状况以及预设的负载状况与投票信息的对应关系,确定投票信息,其中,在所述云计算系统的当前负载状况下,所述多个调度器的投票信息所确定的调度器为与当前负载状况所匹配的调度器;
发送所述投票信息至仲裁器,以使得所述仲裁器根据所述投票信息,确定主调度器,所述主调度器用于按照对应的调度策略对所述云计算系统中的计算资源进行调度。
其中,总线架构可以包括任意数量的互联的总线和桥,具体由处理器代表的一个或多个处理器和存储器代表的存储器的各种电路链接在一起。总线架构还可以将诸如外围设备、稳压器和功率管理电路等之类的各种其他电路链接在一起,这些都是本领域所公知的,因此,本文不再对其进行进一步描述。总线接口提供接口。处理器负责管理总线架构和通常的处理,存储器可以存储处理器在执行操作时所使用的数据。
由上可见,在本发明实施例中,首先确定整个云计算系统的当前负载状况,然后,从云计算系统的多个调度器中,选择与当前负载状况相匹配的调度器,作为主调度器,而主调度器将按照其所对应的调度策略对云计算系统中的计算资源进行调度,而整个云计算系统中除主调度外的辅调度器将不再对计算资源进行调度,从而可保证在每个时刻,整个云计算系统只有一个调度器在进行调度工作,进而可避免不同调度器间对计算资源的调度冲突问题。
本领域内的技术人员应明白,本发明的实施例可提供为方法、系统、或计算机程序产品。因此,本发明可采用完全硬件实施例、完全软件实施例、或结合软件和硬件方面的实施例的形式。而且,本发明可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、CD-ROM、光学存储器等)上实施的计算机程序产品的形式。
本发明是参照根据本发明实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器,使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。
这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中,使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品,该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。
这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上,使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理,从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。
尽管已描述了本发明的优选实施例,但本领域内的技术人员一旦得知了基本创造性概念,则可对这些实施例作出另外的变更和修改。所以,所附权利要求意欲解释为包括优选实施例以及落入本发明范围的所有变更和修改。
显然,本领域的技术人员可以对本发明实施例进行各种改动和变型而不脱离本发明实施例的精神和范围。这样,倘若本发明实施例的这些修改和变型属于本发明权利要求及其等同技术的范围之内,则本发明也意图包含这些改动和变型在内。
Claims (15)
1.一种从云计算系统中确定主调度器的方法,其特征在于,所述云计算系统至少包括仲裁器和多个调度器,每个调度器对应一种调度策略,所述方法包括:
所述仲裁器接收至少一个调度器发送的投票信息,所述投票信息为所述调度器根据所述云计算系统的当前负载状况以及预设的负载状况与投票信息的对应关系所生成的;
所述仲裁器根据所述至少一个调度器发送的投票信息,从所述多个调度器中确定主调度器,以使得所述主调度器按照所对应的调度策略对所述云计算系统中的计算资源进行调度,其中,所述主调度器所对应的所述调度策略与所述云计算系统的当前负载状况相匹配。
2.根据权利要求1所述的方法,其特征在于,所述仲裁器根据所述至少一个调度器发送的投票信息,从所述多个调度器中确定主调度器,包括:
所述仲裁器根据所述至少一个调度器发送的投票信息,确定每个调度器的投票得分;
所述仲裁器从所述多个调度器中,确定投票得分满足预设条件的调度器为所述主调度器。
3.根据权利要求2所述方法,其特征在于,预先为不同调度器设置不同的优先级,所述仲裁器根据所述至少一个调度器发送的投票信息,确定每个调度器的投票得分,包括:
所述仲裁器根据每个调度器的优先级,为每个调度器的投票信息设置不同的权重;
所述仲裁器根据每个调度器所获得的投票信息以及每个投票信息的权重,确定每个调度器的投票得分。
4.根据权利要求2所述的方法,其特征在于,所述仲裁器根据所述至少一个调度器发送的投票信息,确定每个调度器的投票得分,包括:
针对一调度器,所述仲裁器确定当前调度器是否为其它调度器投票,所述其它调度器为所述云计算系统中,除当前调度器外的剩余调度器;
所述仲裁器在确定当前调度器为其它调度器投票时,统计当前调度器的投票得分,否则,确定当前调度器的投票得分为零。
5.根据权利要求1至4任一项所述的方法,其特征在于,所述方法还包括:
所述仲裁器接收辅调度器发送的重新选举请求,所述辅调度器为所述云计算系统中,除所述主调度器外的其它调度器,所述重新选举请求为所述辅调度器在当前主调度器对云计算系统中计算资源的调度不满足预设条件时所发送的;
所述仲裁器在所述发送重新选举请求的辅调度器的比例满足预设条件时,向所有调度器发送重新选举指令,以使得所有调度器根据当前云计算系统的负载状况,重新进行投票。
6.一种从云计算系统中确定主调度器的方法,其特征在于,所述云计算系统至少包括仲裁器和多个调度器,每个调度器对应一种调度策略,所述方法包括:
所述调度器确定所述云计算系统的当前负载状况;
所述调度器根据所述云计算系统的当前负载状况以及预设的负载状况与投票信息的对应关系,确定投票信息,其中,在所述云计算系统的当前负载状况下,所述多个调度器的投票信息所确定的调度器为与当前负载状况所匹配的调度器;
所述调度器发送所述投票信息至仲裁器,以使得所述仲裁器根据所述投票信息,确定主调度器,所述主调度器用于按照对应的调度策略对所述云计算系统中的计算资源进行调度。
7.根据权利要求6所述的方法,其特征在于,所述方法还包括:
所述调度器周期性采集云计算系统的负载状况;
所述调度器在当前云计算系统的负载状况不满足预设条件时,上报重新投票信息至所述仲裁器,以使得所述仲裁器根据所述重新投票信息,触发所述云计算系统中的所有调度器重新发送投票信息。
8.一种从云计算系统中确定主调度器的装置,其特征在于,所述云计算系统至少包括多个调度器,每个调度器对应一种调度策略,所述装置包括:
接收单元,用于接收至少一个调度器发送的投票信息,所述投票信息为所述调度器根据所述云计算系统的当前负载状况以及预设的负载状况与投票信息的对应关系所生成的;
选择单元,用于根据所述至少一个调度器发送的投票信息,从所述多个调度器中确定主调度器,以使得所述主调度器按照所对应的调度策略对所述云计算系统中的计算资源进行调度,其中,所述主调度器所对应的所述调度策略与所述云计算系统的当前负载状况相匹配。
9.根据权利要求8所述的装置,其特征在于,所述选择单元,具体用于
根据所述至少一个调度器发送的投票信息,确定每个调度器的投票得分;
从所述多个调度器中,确定投票得分满足预设条件的调度器为所述主调度器。
10.根据权利要求9所述的装置,其特征在于,预先为不同调度器设置不同的优先级,所述选择单元,在根据所述至少一个调度器发送的投票信息,确定每个调度器的投票得分时,具体用于:
根据每个调度器的优先级,为每个调度器的投票信息设置不同的权重;
根据每个调度器所获得的投票信息以及每个投票信息的权重,确定每个调度器的投票得分。
11.根据权利要求9所述的装置,其特征在于,所述选择单元,在根据所述至少一个调度器发送的投票信息,确定每个调度器的投票得分时,具体用于:
针对一调度器,确定当前调度器是否为其它调度器投票,所述其它调度器为所述云计算系统中,除当前调度器外的剩余调度器;
在确定当前调度器为其它调度器投票时,统计当前调度器的投票得分,否则,确定当前调度器的投票得分为零。
12.根据权利要求8至11任一项所述的装置,其特征在于,所述装置还包括,重新选择单元,具体用于:
接收辅调度器发送的重新选举请求,所述辅调度器为所述云计算系统中,除所述主调度器外的其它调度器,所述重新选举请求为所述辅调度器在当前主调度器对云计算系统中计算资源的调度不满足预设条件时所发送的;
在所述发送重新选举请求的辅调度器的比例满足预设条件时,向所有调度器发送重新选举指令,以使得所有调度器根据当前云计算系统的负载状况,重新进行投票。
13.一种从云计算系统中确定主调度器的装置,其特征在于,所述云计算系统至少包括仲裁器,所述装置包括:
负载确定单元,用于确定所述云计算系统的当前负载状况;
投票信息确定单元,用于根据所述云计算系统的当前负载状况以及预设的负载状况与投票信息的对应关系,确定投票信息,其中,在所述云计算系统的当前负载状况下,所述投票信息所确定的投票结果对应的调度器为与当前负载状况所匹配的调度器;
发送单元,用于发送所述投票信息至仲裁器,以使得所述仲裁器根据所述投票信息,确定主调度器,所述主调度器用于按照对应的调度策略对所述云计算系统中的计算资源进行调度。
14.根据权利要求13所述的装置,其特征在于,所述装置还包括:
采集单元,用于周期性采集云计算系统的负载状况;
上报单元,用于在当前云计算系统的负载状况不满足预设条件时,上报重新投票信息至所述仲裁器,以使得所述仲裁器根据所述重新投票信息,触发所述云计算系统中的所有调度器重新发送投票信息。
15.一种云计算系统,其特征在于,所述云计算系统包括仲裁器以及调度器;
其中,所述调度器,用于确定所述云计算系统的当前负载状况,以及根据所述云计算系统的当前负载状况、预设的负载状况与投票信息的对应关系,确定投票信息以及发送所述投票信息至所述仲裁器;
所述仲裁器,用于接收至少一个调度器发送的投票信息,以及根据所述至少一个调度器发送的投票信息,从多个调度器中选择一调度器作为主调度器,以使得所述主调度器按照所对应的调度策略对所述云计算系统中的计算资源进行调度,其中,所述主调度器所对应的所述调度策略与所述云计算系统的当前负载状况相匹配。
Priority Applications (4)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201611089191.9A CN108123987A (zh) | 2016-11-30 | 2016-11-30 | 从云计算系统中确定主调度器的方法及装置 |
PCT/CN2017/092854 WO2018099090A1 (zh) | 2016-11-30 | 2017-07-13 | 从云计算系统中确定主调度器的方法及装置 |
EP17877361.0A EP3541048A4 (en) | 2016-11-30 | 2017-07-13 | METHOD AND DEVICE FOR DETERMINING THE MAIN SCHEDULER OF A CLOUD COMPUTER SYSTEM |
US16/425,680 US20190280945A1 (en) | 2016-11-30 | 2019-05-29 | Method and apparatus for determining primary scheduler from cloud computing system |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201611089191.9A CN108123987A (zh) | 2016-11-30 | 2016-11-30 | 从云计算系统中确定主调度器的方法及装置 |
Publications (1)
Publication Number | Publication Date |
---|---|
CN108123987A true CN108123987A (zh) | 2018-06-05 |
Family
ID=62226476
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN201611089191.9A Pending CN108123987A (zh) | 2016-11-30 | 2016-11-30 | 从云计算系统中确定主调度器的方法及装置 |
Country Status (4)
Country | Link |
---|---|
US (1) | US20190280945A1 (zh) |
EP (1) | EP3541048A4 (zh) |
CN (1) | CN108123987A (zh) |
WO (1) | WO2018099090A1 (zh) |
Cited By (3)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN108770014A (zh) * | 2018-07-10 | 2018-11-06 | 广东工业大学 | 网络服务器的计算评估方法、系统、装置及可读存储介质 |
CN109917705A (zh) * | 2019-02-25 | 2019-06-21 | 弗徕威智能机器人科技(上海)有限公司 | 一种多任务调度方法 |
CN110737521A (zh) * | 2019-10-14 | 2020-01-31 | 中国人民解放军32039部队 | 基于任务调度中心的容灾方法和装置 |
Families Citing this family (2)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
US11609811B2 (en) * | 2020-08-27 | 2023-03-21 | Microsoft Technology Licensing, Llc | Automatic root cause analysis and prediction for a large dynamic process execution system |
CN112527512B (zh) * | 2020-12-31 | 2023-11-21 | 河南信大网御科技有限公司 | 一种增强型拟态构造系统 |
Citations (6)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN102387173A (zh) * | 2010-09-01 | 2012-03-21 | 中国移动通信集团公司 | 一种MapReduce系统及其调度任务的方法和装置 |
US20150324231A1 (en) * | 2009-10-26 | 2015-11-12 | Microsoft Technology Licensing, Llc | Opportunistically scheduling and adjusting time slices |
CN105634784A (zh) * | 2014-11-06 | 2016-06-01 | 阿里巴巴集团控股有限公司 | 控制数据分发方法、装置及系统 |
CN105743995A (zh) * | 2016-04-05 | 2016-07-06 | 北京轻元科技有限公司 | 一种可移植高可用部署和管理容器集群的系统和方法 |
CN105791371A (zh) * | 2014-12-22 | 2016-07-20 | 中国科学院上海高等研究院 | 一种云存储服务系统及方法 |
CN106155780A (zh) * | 2015-04-02 | 2016-11-23 | 阿里巴巴集团控股有限公司 | 一种基于时间的节点选举方法及装置 |
Family Cites Families (8)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
KR101436339B1 (ko) * | 2010-09-15 | 2014-09-01 | 엠파이어 테크놀로지 디벨롭먼트 엘엘씨 | 클라우드 컴퓨팅 환경에서의 태스크 할당 |
CN103297499B (zh) * | 2013-04-19 | 2017-02-08 | 无锡成电科大科技发展有限公司 | 一种基于云平台的调度方法及系统 |
KR101941282B1 (ko) * | 2013-07-16 | 2019-01-23 | 한국전자통신연구원 | 가상 데스크톱 서비스 제공 방법 및 장치 |
US9658874B2 (en) * | 2014-06-18 | 2017-05-23 | International Business Machines Corporation | Selecting optimal hypervisor platforms that satisfy application workload requirements |
CN104657221B (zh) * | 2015-03-12 | 2019-03-22 | 广东石油化工学院 | 一种云计算中基于任务分类的多队列错峰调度模型及方法 |
US9697045B2 (en) * | 2015-03-24 | 2017-07-04 | International Business Machines Corporation | Selecting resource allocation policies and resolving resource conflicts |
US10333853B1 (en) * | 2016-03-30 | 2019-06-25 | Amazon Technologies, Inc. | Unified quality of service (QoS) for label switching traffic |
US10552228B2 (en) * | 2016-06-20 | 2020-02-04 | Vmware, Inc. | Distributed hierarchical scheduler |
-
2016
- 2016-11-30 CN CN201611089191.9A patent/CN108123987A/zh active Pending
-
2017
- 2017-07-13 WO PCT/CN2017/092854 patent/WO2018099090A1/zh unknown
- 2017-07-13 EP EP17877361.0A patent/EP3541048A4/en not_active Withdrawn
-
2019
- 2019-05-29 US US16/425,680 patent/US20190280945A1/en not_active Abandoned
Patent Citations (6)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
US20150324231A1 (en) * | 2009-10-26 | 2015-11-12 | Microsoft Technology Licensing, Llc | Opportunistically scheduling and adjusting time slices |
CN102387173A (zh) * | 2010-09-01 | 2012-03-21 | 中国移动通信集团公司 | 一种MapReduce系统及其调度任务的方法和装置 |
CN105634784A (zh) * | 2014-11-06 | 2016-06-01 | 阿里巴巴集团控股有限公司 | 控制数据分发方法、装置及系统 |
CN105791371A (zh) * | 2014-12-22 | 2016-07-20 | 中国科学院上海高等研究院 | 一种云存储服务系统及方法 |
CN106155780A (zh) * | 2015-04-02 | 2016-11-23 | 阿里巴巴集团控股有限公司 | 一种基于时间的节点选举方法及装置 |
CN105743995A (zh) * | 2016-04-05 | 2016-07-06 | 北京轻元科技有限公司 | 一种可移植高可用部署和管理容器集群的系统和方法 |
Cited By (5)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN108770014A (zh) * | 2018-07-10 | 2018-11-06 | 广东工业大学 | 网络服务器的计算评估方法、系统、装置及可读存储介质 |
CN108770014B (zh) * | 2018-07-10 | 2022-03-25 | 广东工业大学 | 网络服务器的计算评估方法、系统、装置及可读存储介质 |
CN109917705A (zh) * | 2019-02-25 | 2019-06-21 | 弗徕威智能机器人科技(上海)有限公司 | 一种多任务调度方法 |
CN109917705B (zh) * | 2019-02-25 | 2021-10-22 | 弗徕威智能机器人科技(上海)有限公司 | 一种多任务调度方法 |
CN110737521A (zh) * | 2019-10-14 | 2020-01-31 | 中国人民解放军32039部队 | 基于任务调度中心的容灾方法和装置 |
Also Published As
Publication number | Publication date |
---|---|
EP3541048A1 (en) | 2019-09-18 |
EP3541048A4 (en) | 2019-11-20 |
US20190280945A1 (en) | 2019-09-12 |
WO2018099090A1 (zh) | 2018-06-07 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
CN108123987A (zh) | 从云计算系统中确定主调度器的方法及装置 | |
CN101084680B (zh) | 在电信服务和/或网络管理平台中管理资源的方法、相应平台及其计算机程序产品 | |
CN106817499B (zh) | 一种话务资源调度方法及预测调度装置 | |
CN110290189A (zh) | 一种容器集群管理方法、装置及系统 | |
US20150262111A1 (en) | Apparatus and method for efficient task allocation in crowdsourcing | |
CN111311129A (zh) | 配电网配调值班任务自动分工方法、系统及计算机设备 | |
CN107968802A (zh) | 一种资源调度的方法、装置和过滤式调度器 | |
CN113627792B (zh) | 无人车的调度管理方法、装置、设备、存储介质及程序 | |
CN106330987A (zh) | 动态负荷均衡方法 | |
WO2017171123A1 (ko) | 수요관리사업자의 경제성 dr 입찰을 위한 최적 분산자원 선택 및 구성 방법 | |
CN107302564A (zh) | 事件信息处理方法、装置、计算机设备和存储介质 | |
CN115543577B (zh) | 基于协变量的Kubernetes资源调度优化方法、存储介质及设备 | |
CN111860853B (zh) | 在线预测系统、设备、方法及电子设备 | |
CN107145975A (zh) | 光传输设备备件数量的预测方法 | |
CN111461539A (zh) | 配电网配调工作任务难度定级方法、系统及计算机设备 | |
CN117350640A (zh) | 一种项目进度管理方法与系统 | |
CN113283778A (zh) | 一种基于安全性评价的分层汇聚联邦学习方法 | |
Gupta et al. | Multievent crisis management using noncooperative multistep games | |
de Larrea et al. | Simulating New York city hospital load balancing during covid-19 | |
JP2010086219A (ja) | 遠隔の機械を保守するための情報処理装置、プログラム、および方法 | |
CN113344392A (zh) | 一种企业项目综合管理方法及系统 | |
Lin | Solving a location, allocation, and capacity planning problem with dynamic demand and response time service level | |
CN106708624A (zh) | 一种多工作域计算资源的自适应调整方法 | |
CN109245949A (zh) | 一种信息处理方法及装置 | |
Çapar et al. | Alternative metrics to measure EMS system performance |
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 | ||
AD01 | Patent right deemed abandoned |
Effective date of abandoning: 20211231 |
|
AD01 | Patent right deemed abandoned |