发明名称 网格计算系统、管理伺服器、处理伺服器、控制方法、控制程式、与记录媒体
摘要
申请公布号 申请公布日期 2011.01.01
申请号 TW094103746 申请日期 2005.02.04
申请人 万国商业机器公司 发明人 金子章弘
分类号 G06F9/50 主分类号 G06F9/50
代理机构 代理人 蔡玉玲 台北市大安区敦化南路2段218号5楼A区
主权项 一种包含复数个处理伺服器与一管理伺服器的系统,每一处理伺服器执行一或复数个指定之程式,系用以处理一所要求工作中之一或复数个步骤,该管理伺服器用以管理该复数个处理伺服器;该管理伺服器包含:一执行指示产生单元,系利用每一程式之一身份资讯以及该复数个程式之一执行次序,以产生一执行指示(execution direction);以及一输入资料发送单元,系用以发送该工作之输入资料予一处理伺服器,以执行欲先执行之一程式,其中该工作之输入资料系与该执行指示相关;以及每一处理伺服器系包含:一程式执行单元,系藉由所接收之输入资料而执行该指定之程式,以更新该输入资料;一处理伺服器选择单元,系根据与该输入资料相关联之该执行指示,选择一处理伺服器,以藉由更新的输入资料而执行欲后续执行之一程式;以及一输入资料传送单元,系用以发送与该执行指示相关之所更新之输入资料予被该处理伺服器选择单元所选择之处理伺服器。如请求项第1项所述之系统,其中该处理伺服器选择单元系询问该管理伺服器关于一处理伺服器之身份资讯,以藉由所更新的输入资料而执行欲后续执行之一程式,藉此根据所获得之确认资料选择一处理伺服器;以及该管理伺服器更包含:一处理伺服器资讯储存单元,系用以储存每一程式之确认资料,其中该确认资料系与执行该程式之一处理伺服器之确认资料相关;以及一询问回应单元,回应该处理伺服器选择单元所发出之一询问、该询问回应单元从该处理伺服器资讯储存单元取得一处理伺服器之身份资讯,对应于产生该询问之程式之身份资讯,以及发出一处理伺服器之确认资讯。如请求项第2项所述之系统,其中每一处理伺服器更包含一快取单元(caching unit),系用以快取一处理伺服器之确认资料,该处理伺服器为该处理伺服器选择单元回应于该询问回应单元之询问的所获得之结果,该处理伺服器之身份资讯与被该处理伺服器所执行之一程式之确认资料相关;以及当欲被执行之一程式之身份资讯被该快取单元所快取时,该处理伺服器选择单元选择对应该程式之一处理伺服器。如请求项第2项所述之系统,其中该程式执行单元为了接收该输入资料,发送一接收通知以表示该管理伺服器已接收该输入资料,而为了停止该程式之执行,该程式执行单元则发出一停止通知以表示该程式已经被停止执行;该处理伺服器资讯储存单元,根据该接收通知以及该停止通知储存一可执行资料,该可执行资料关于每一处理伺服器是否能够接收新的输入资料以及执行一程式;以及从执行产生该询问信号之一程式之复数个处理伺服器中,该询问回应单元根据该可执行资讯,选择一能够新接收输入资料以及执行该程式之处理伺服器,以发送该被选择之该处理伺服器之确认资料。如请求项第4项所述之系统,其中该管理伺服器更包含一程式启动单元,当供执行该询问回应单元接收一询问之程式之该复数个处理伺服器中,具有超过一预定比例的处理伺服器无法新接收输入资料与执行该程式,则该程式启动单元启动还未被启动之程式,该询问回应单元发送该处理伺服器之确认资料,该确认资料系关于哪个程式已被该程式启动单元所启动。如请求项第1项所述之系统,其中每一处理伺服器包含:一历史储存单元,系用以储存由该输入资料传送单元传送至该处理伺服器之该输入资料及该执行指示之历史;以及一错误发生决定单元,系用以决定该程式在被一发送目的地处理伺服器处理时是否发生任何错误,而该输入资料传送单元已发送该更新输入资料以及该执行指示至该发送目的地处理伺服器;以及因应该错误发生决定单元决定一错误已发生,该处理伺服器选择单元选择另一处理伺服器以执行后续程式;以及该输入资料传送单元从该历史储存单元获得该输入资料以及该执行指示,以发送该输入资料以及该执行指示给该处理伺服器选择单元所选择之该另一处理伺服器。如请求项第6项所述之系统,其中该程式执行单元,因应接收该输入资料,发送一接收通知,以表示该管理伺服器已接收该输入资料,而该程式执行单元,因应停止该程式之执行,发送一停止通知,以表示该程式已经被停止;该管理伺服器更包含一错误发生通知发送单元,当从任何处理伺服器接收该接收通知后,而在一预先决定处理时间内未接收该停止通知时,则该错误发生通知发送单元系发送一错误发生通知给已发送该输入资料给该处理伺服器之一发送源处理伺服器,以表示该程式执行中之有一错误发生;以及若该错误发生通知被接收时,该错误发生决定单元系决定在一发送目的地处理器上一程式执行期间错误是否发生,该输入资料传送单元发送已更新输入资料与该执行指示给该发送目的地处理器。如请求项第6项所述之系统,其中因应由一发送目的地处理伺服器接收该输入资料及执行指示,当新接收输入资料及决定该程式无法被执行,该程式执行单元发送一拒绝通知给已发送该输入资料与该执行指示之一发送源处理伺服器,以表示该输入资料之被拒绝接收;因应接收从该发送目的地处理伺服器发出之该拒绝通知,该发送源处理伺服器之该错误发生决定单元决定在该发送目的地处理伺服器之一程式执行时,发生一错误。如请求项第6项所述之系统,其中该管理伺服器更包含一删除指示单元,当该工作藉由被该复数个程式完成时,该删除指示单元系用以删除每一处理伺服器之历史储存区之该输入资料以及该执行指示。如请求项第6项所述之系统,其中每一处理伺服器之处理伺服器选择单元,从藉由更新的输入资料而启动一欲后续执行的程式之复数个处理伺服器中选择一处理伺服器,该处理伺服器与另一处理伺服器具有较高的通讯速度,而与其他处理伺服器具有较低的通讯速度。如请求项第1项所述之系统,其中每一处理伺服器更包含:一历史储存单元,系用以储存该处理伺服器之历史资料,该处理伺服器系被该程式执行单元藉由执行该程式而改变,该历史资料系关于能够回复到改变之前状态的资料;以及一改变回复单元,若在一发送目的地处理伺服器上一程式执行期间发生一错误,该输入资料传输单元已发送该已更新资料与该执行指示至该发送目的地处理伺服器,则该改变回复单元根据在该历史储存单元内之该历史资料,回复被该程式执行单元改变至原始状态之资料。如请求项第1项所述之系统,其中该管理伺服器更包含一程式启动单元系根据所产生之执行指令,侦测每一欲利用在该工作中作为一输入之输入指令在第二次所执行的程式,且该程式启动单元启动不同于该输入资料发送单元之发送目的地伺服器以外之任何该处理伺服内之被侦测之程式。如请求项第1项所述之系统,其中每一处理伺服器之程式执行单元系通知该管理伺服器关于执行先前之一程式之所需之总处理能力(throughput);以及当被该程式执行单元所通知之一程式之先前所需之总处理能力超过一已经启动该程式之一处理伺服器所处理之最大总处理能力,则该管理伺服器之该程式启动单元启动不同于该输入资料发送单元之发送目的地伺服器之任何处理伺服器上的程式。如请求项第1项所述之系统,其中该管理伺服器更包括一程式启动单元,系用以侦测每一欲利用在该工作中作为一输入之输入指令而执行的程式,而对于每一被侦测到的程式,当该欲藉由输入资料而执行之程式之先前所需之总处理能力超过一已经启动该程式之一处理伺服器所处理之最大总处理能力,则该程式启动单元启动任何不同于该输入资料发送单元之发送目的地伺服器以外之任何该处理伺服器内之被侦测之程式。如请求项第1项所述之系统,其中当在前次接收该输入资料以及该执行指示后一预定等待时间内,该程式执行单元系未接收输入资料及执行指示,则该程式执行单元停止被该处理伺服器执行之该程式。如请求项第1项所述之系统,其中该管理伺服器更包含一处理伺服器改变单元,当被用于执行该程式执行单元之一程式之计算资源使用率低于一预定参考使用率时,则该处理伺服器改变单元使得另一具有较低最大总工作能力的伺服器去执行该程式。如请求项第1项所述之系统,其中因应接收该发送目的地处理伺服器之该输入资料及该执行指示,该程式执行单元侦测到应该已根据该所接收之执行指示而被执行之一程式,则当该发送源处理伺服器能够执行该程式时,则该程式执行单元执行该被侦测的程式。如请求项第1项所述之系统,其中每一处理伺服器之该输入资料传送单元产生该更新输入资料之一数位签章或一执行资讯,以发送与该输入资料相关之该数位签章及被该数位签章涵盖之该执行指示;以及当该数位签章被正确地验证时,一处理伺服器之程式执行单元执行一程式。一种供管理复数个处理伺服器的管理伺服器,每一处理伺服器执行一或复数个指定之程式,系用以处理一所要求工作中之一或复数个步骤;每一处理伺服器系包含:一程式执行单元,系藉由所接收之输入资料而执行该指定之程式,以更新该输入资料;一处理伺服器选择单元,系根据与该输入资料相关联之该执行指示,选择一其他处理伺服器,以藉由所更新的输入资料而执行欲后续执行之一程式;以及一输入资料传送单元,系用以发送与该执行指示相关之所更新之输入资料予被该处理伺服器选择单元所选择之处理伺服器;以及该管理伺服器包含:一执行指示产生单元,系利用每一程式之一身份资讯以及该复数个程式之一执行次序,以产生一执行指示;以及一输入资料发送单元,系用以发送该工作之输入资料予一处理伺服器,以执行欲先执行之一程式,其中该工作之输入资料系与该执行指示相关。一种被一管埋伺服器所管理的处理伺服器,该处理伺服器系执行一或复数个指定之程式,系用以处理一所要求工作中之一或复数个步骤,该管理伺服器包含:一执行指示产生单元,系利用每一程式之一身份资讯以及该复数个程式之一执行次序,以产生一执行指示;以及一输入资料发送单元,系用以发送该工作之输入资料予一处理伺服器,以执行欲先执行之一程式,其中该工作之输入资料系与该执行指示相关;及该处理伺服器包含:一程式执行单元,系藉由所接收之输入资料而执行该指定之程式,以更新该输入资料;一处理伺服器选择单元,系根据与该输入资料相关联之该执行指示,选择另一处理伺服器,以藉由更新的输入资料而执行欲后续执行之一程式;以及一输入资料传送单元,系用以发送与该执行指示相关之所更新之输入资料予被该处理伺服器选择单元所选择之处理伺服器。一种控制一管理伺服器的控制方法,该管理伺服器管理复数个处理伺服器,每一处理伺服器执行一或复数个指定之程式,系用以处理一所要求工作中之一或复数个步骤,每一处理伺服器包含:一程式执行单元,系藉由所接收之输入资料而执行该指定之程式,以更新该输入资料;一处理伺服器选择单元,系根据与该输入资料相关联之该执行指示,选择另一处理伺服器,以藉由更新的输入资料而执行欲后续执行之一程式;以及一输入资料传送单元,系用以发送与该执行指示相关之所更新之输入资料予被该处理伺服器选择单元所选择之处理伺服器;及该控制方法包含:利用每一程式之一身份资讯以及该复数个程式之一执行次序,以产生一执行指示;以及发送该工作之输入资料予一处理伺服器,以执行欲先执行之一程式,其中该工作之输入资料系与该执行指示相关。一种控制一处理伺服器的控制方法,该处理伺服器系被一管理伺服器管理,每一处理伺服器执行一或复数个指定之程式,系用以处理一所要求工作中之一或复数个步骤;该管理伺服器包含:一执行指示产生单元,系利用每一程式之一身份资讯以及该复数个程式之一执行次序,以产生一执行指示;以及一输入资料发送单元,系用以发送该工作之输入资料予一处理伺服器,以执行欲先执行之一程式,其中该工作之输入资料系与该执行指示相关;该方法包含:藉由所接收之输入资料而执行该指定之程式,以更新该输入资料;根据与该输入资料相关联之该执行指示,选择另一处理伺服器,以藉由更新的输入资料而执行欲后续执行之一程式;以及发送与该执行指示相关之所更新之输入资料予被该处理伺服器选择单元所选择之处理伺服器。一种记录媒体,包含供使一电脑作为一管理伺服器之一控制程式,该管理伺服器系管理复数个处理伺服器,每一处理伺服器执行一或复数个指定之程式,系用以处理一所要求工作中之一或复数个步骤;每一处理伺服器包含:一程式执行单元,系藉由所接收之输入资料而执行该指定之程式,以更新该输入资料;一处理伺服器选择单元,系根据与该输入资料相关联之该执行指示,选择另一处理伺服器,以藉由更新的输入资料而执行欲后续执行之一程式;以及一输入资料传送单元,系用以发送与该执行指示相关之所更新之输入资料予被该处理伺服器选择单元所选择之处理伺服器;及该程式使该电脑作为:一执行指示产生单元,系利用每一程式之一身份资讯以及该复数个程式之一执行次序,以产生一执行指示(execution direction);以及一输入资料发送单元,系用以发送该工作之输入资料予一处理伺服器,以执行欲先执行之一程式,其中该工作之输入资料系与该执行指示相关。一种记录媒体,包含使一电脑作为一处理伺服器之一控制程式,该处理伺服器被一管理伺服器所管理,该处理伺服器系执行一或复数个指定之程式,系用以处理一所要求工作中之一或复数个步骤;该管理伺服器包含:一执行指示产生单元,系利用每一程式之一身份资讯以及该复数个程式之一执行次序,以产生一执行指示;以及一输入资料发送单元,系用以发送该工作之输入资料予一处理伺服器,以执行欲先执行之一程式,其中该工作之输入资料系与该执行指示相关;及该程式使该电脑执行下列功能:一程式执行单元,系藉由所接收之输入资料而执行该指定之程式,以更新该输入资料;一处理伺服器选择单元,系根据与该输入资料相关联之该执行指示,选择另一处理伺服器,以藉由更新的输入资料而执行欲后续执行之一程式;以及一输入资料传送单元,系用以发送与该执行指示相关之所更新之输入资料予被该处理伺服器选择单元所选择之处理伺服器。
地址 美国