CN1842078A - 网格服务容器 - Google Patents
网格服务容器 Download PDFInfo
- Publication number
- CN1842078A CN1842078A CN 200510059314 CN200510059314A CN1842078A CN 1842078 A CN1842078 A CN 1842078A CN 200510059314 CN200510059314 CN 200510059314 CN 200510059314 A CN200510059314 A CN 200510059314A CN 1842078 A CN1842078 A CN 1842078A
- Authority
- CN
- China
- Prior art keywords
- module
- service
- user
- resource
- batch job
- 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.)
- Granted
Links
- 238000012544 monitoring process Methods 0.000 claims abstract description 34
- 238000012545 processing Methods 0.000 claims abstract description 21
- 238000000034 method Methods 0.000 claims description 25
- 230000008569 process Effects 0.000 claims description 24
- 239000000344 soap Substances 0.000 claims description 15
- 230000003068 static effect Effects 0.000 claims description 8
- 230000007246 mechanism Effects 0.000 claims description 7
- 238000005516 engineering process Methods 0.000 claims description 6
- 238000012546 transfer Methods 0.000 claims description 4
- 238000013507 mapping Methods 0.000 claims description 3
- 230000006870 function Effects 0.000 description 19
- 238000010586 diagram Methods 0.000 description 8
- 238000005538 encapsulation Methods 0.000 description 6
- 238000012217 deletion Methods 0.000 description 5
- 230000037430 deletion Effects 0.000 description 5
- 239000011800 void material Substances 0.000 description 3
- 238000004364 calculation method Methods 0.000 description 2
- 239000008358 core component Substances 0.000 description 2
- 238000010200 validation analysis Methods 0.000 description 2
- 238000004458 analytical method Methods 0.000 description 1
- 238000013475 authorization Methods 0.000 description 1
- 230000005540 biological transmission Effects 0.000 description 1
- 230000008859 change Effects 0.000 description 1
- 239000002131 composite material Substances 0.000 description 1
- 230000006837 decompression Effects 0.000 description 1
- 238000011161 development Methods 0.000 description 1
- 239000012467 final product Substances 0.000 description 1
- 230000003993 interaction Effects 0.000 description 1
Images
Landscapes
- Management, Administration, Business Operations System, And Electronic Commerce (AREA)
- Stored Programmes (AREA)
Abstract
本发明公开了一种网格服务容器,它包括HTTP请求接收处理模块、服务运行管理模块,其特征在于:它还包括服务部署模块、批作业服务模块和资源监控模块。所述服务部署模块可将开发好的网格服务装载入网格服务容器内,使其可被用户调用,即部署;还可以将已部署好的服务从服务容器中删除,即反部署;还可以更新已部署的服务,即重部署。所述批作业服务模块可自动地将用户的批作业处理请求适配到相应的批作业处理系统中,并将作业的处理结果返回给用户。所述资源监控模块主要收集、管理系统资源信息,以及向用户提供系统资源信息。与传统的Globus Toolkit等网格服务容器相比,本发明提供了强大的服务部署功能,丰富的计算节点资源信息监控服务和基于服务的一体化批作业处理功能。
Description
技术领域
本发明涉及网格服务技术,更具体地说,涉及在网格服务系统内,为网格服务的部署、运行、管理以及网格资源监控提供支持的网格服务容器。
背景技术
近年来人们将Web服务技术引入到网格计算领域中,提出了网格服务体系结构,其中以GGF的开放网格服务体系结构(简称OGSA体系结构)为典型代表。在网格服务体系结构下,网格中的所有软件、硬件、计算、存储、网络和设备等各种资源都被抽象成服务的形式,通过服务屏蔽资源之间的差异,从而有效地屏蔽网格中资源的异构性,为资源的共享和协同提供了有效的支持。
WSRF规范明确了OGSA体系结构中服务的形式以及具体的接口定义,Web服务和相关的资源构成了WSRF框架下的资源。针对OGSA体系结构提出的服务网格的基本需求,WSRF规范分别对资源的生命周期管理、资源属性、通知机制、服务组和错误处理等进行了详细的定义。因此遵循OGSA和WSRF规范的网格系统必须支持服务和资源的基本特性、部署和运行管理等需求。网格服务容器是专门用于解决这一问题的核心组件,它是在网格服务体系结构下支持资源的服务化封装、服务部署和服务的运行管理等基本功能的基础中间件,同时网格服务容器还要对网格计算节点的资源信息进行监控,从而为整个网格系统的监控管理和高层的任务调度提供支持,它被部署在每一个需要进行服务交互的网格节点之上。其中,服务化封装是指网格中各种各样的软件、硬件和设备等资源服务化的过程,目前在网格领域中,采用Web服务作为资源封装的基本形式。服务部署是指将开发后的服务装载到网格服务容器中,使服务能够被用户调用的过程,广义的服务部署还包括服务的反部署,即将服务从网格服务容器中卸载的过程,以及服务的重部署,即更新已经部署的服务的过程。服务的运行管理是指网格服务容器协调各个功能组件接收用户的请求,调用各种资源处理请求,最终向用户返回处理结果的一整套功能。计算节点的资源信息监控是指网格服务容器能够收集本节点的有意义的资源信息,其中包括动态信息(如CPU当前的负载、内存当前可用空间等)和静态信息(如操作系统类型、版本、CPU的主频等)两种,服务容器提供访问接口,使得相应的用户能够方便地获取到这些信息。
网格界著名的开发源码的组织Globus在2003年推出了网格服务下的中间件Globus Toolkit 3,服务容器是该中间件的核心组件。在2004年,Globus又推出了支持WSRF规范的中间件Globus Toolkit 4 alpha,其中包括了将在Globus Toolkit 4正式版中使用的服务容器。Globus Toolkit 3服务容器和GlobusToolkit 4 alpha服务容器都是OGSA体系结构下的网格中间件,它们分别支持OGSI和WSRF规范,尽管支持的规范不同,但它们实现的基本功能非常类似,主要完成服务的运行管理功能。从服务容器的基本功能来分析,两者在服务的部署、传统批作业处理以及资源监控方面都很不完善。在Globus Toolkit中,服务开发人员在进行服务封装之后,只能通过烦琐的命令行来将服务部署到服务容器中,而且新部署的服务只能在服务容器重新启动之后才会生效,另外Globus Toolkit不提供远程用户的部署服务。Globus Toolkit尽管提供了部分系统资源的监控功能,但是监控的信息种类非常少,而且没有一个清晰的监控服务体系结构,同时也没有一个统一的访问监控信息的服务接口。此外,GlobusToolkit没有提供通过服务的方式对传统批作业处理进行支持的功能。
发明内容
为了解决传统的Globus Toolkit 3服务容器和Globus Toolkit 4 alpha服务容器在服务的部署、传统批作业处理以及资源监控方面的不完善,本发明的目的是提供一种支持OGSA体系结构和WSRF规范的、具有强大的服务部署功能、批作业处理功能和系统资源信息监控功能的网格服务容器。
为实现上述目的,本发明采用以下技术方案:一种网格服务容器,它包括HTTP请求接收处理模块、服务运行管理模块,其特征在于:它还包括服务部署模块、批作业服务模块和资源监控模块;所述服务部署模块可将开发好的网格服务装载入网格服务容器内,使其可被用户调用,即部署;还可以将已部署好的服务从服务容器中删除,即反部署;还可以更新已部署的服务,即重部署;所述批作业服务模块可自动地将用户的批作业处理请求适配到相应的批作业处理系统中,并将作业的处理结果返回给用户;所述资源监控模块主要收集、管理系统资源信息,以及向用户提供系统资源信息。
所述服务部署模块是针对GAR格式的文件的一系列操作过程,它包括本地文件夹监视接口、部署子模块、反部署子模块、重部署子模块和容器配置参数表;本地文件夹监视接口用于接收本地或远程的GAR文件,并将接收到的文件传输给部署子模块、反部署子模块和重部署子模块;部署子模块、反部署子模块和重部署子模块在ANT技术的基础之上,将GAR文件部署或反部署或重部署到网格服务容器内,在执行这些操作的过程中,容器的配置会动态进行更新;所述服务部署模块对接收的本地GAR文件实现自动部署;对接收到的远程GAR文件,基于FTP/SOAP附件实现远程部署。
所述批作业服务模块包括用户管理子模块、批作业管理器、BJDL解析器、批作业适配器和批作业系统;所述用户管理子模块提供用户信息的添加、编辑、删除,以及认证提交作业的用户的合法身份,用户的所有信息都存储在MySQL数据库中;所述批作业管理器通过BJDL解析器来解析用户的作业请求,调用批作业系统的适配器向相应的批作业系统提交用户作业;用户通过HTTP/SOAP、批作业管理器、适配器查询作业当前处理状态,获得作业的标准输出结果以及错误信息。
为了便于用户管理,将外部的不同用户映射到本地系统用户中,所述用户管理子模块具有四个接口:添加用户接口、修改密码接口、删除用户接口、验证用户合法性接口。
所述批作业适配器定义有6个标准接口:作业提交接口、查询作业状态接口、取消作业接口、获取标准输出接口、获取标准错误接口、获取文件输出接口。
所述系统资源监控模块主要包括提供者监控器和资源监控器;所述提供者监控器用于管理、监控各个信息提供者;各个信息提供者收集系统的资源信息,并将收集的系统资源信息提供给提供者监控器;提供者监控器生成资源属性与信息提供者映射表;所述提供者监控器通过推或拉的模式将系统资源信息传送给资源监控器,由资源监控器最终封装为WSRF服务;所述资源监控器提供有用于对资源信息进行查询的查询接口和提供动态信息的通知接口,用户可以利用WSRF的通知机制以异步的方式获得资源信息。
本发明北京航空航天大学网格服务容器为遵循OGSA/WSRF的服务网格平台提供了基础运行环境和必需的基础服务,解决了资源的服务化封装、服务部署、WSRF服务的运行管理、传统批作业的服务化处理以及系统资源监控等基础问题,为构建复杂的网格系统服务以及网格应用提供了基础支撑。与GlobusToolkit等其他的网格服务容器相比,本发明提供了强大的服务部署功能,丰富的计算节点资源信息监控服务和基于服务的一体化批作业处理功能。
附图说明
图1为本发明网格服务容器的结构示意图
图2为本发明服务部署模块结构示意图
图3为本发明服务部署模块部署网格服务的流程图
图4为本发明服务部署模块重部署网格服务的流程图
图5为本发明服务部署模块反部署网格服务的流程图
图6为本发明服务部署模块自动部署网格服务的流程图
图7为本发明服务部署模块基于FTP附件实现远程部署的流程图
图8为本发明服务部署模块基于SOAP附件实现远程部署的流程图
图9为本发明批作业服务模块的结构示意图
图10为本发明批作业管理器处理用户请求的总体流程图
图11为本发明批作业服务模块处理用户提交作业请求的流程图
图12为本发明批作业服务模块处理用户获取作业处理状态请求的流程图
图13为本发明批作业服务模块处理用户取消作业处理请求的流程图
图14为本发明批作业服务模块处理用户获取作业标准输出结果请求的处理流程图
图15为本发明批作业服务模块处理用户获取标准错误输出请求的处理流程图
图16为本发明系统资源监控模块结构示意图
图17为本发明系统资源监控模块中提供者监控器工作流程图
图18为本发明系统资源监控模块中资源监控器工作流程图
具体实施方式
为了解决传统的Globus Toolkit 3服务容器和Globus Toolkit 4 alpha服务容器在服务的部署、批作业处理以及资源监控方面的不完善,如图1所示,本发明提供的网格服务容器除了包括HTTP请求接收处理部分、服务运行管理部分外,还包括服务部署模块、批作业服务模块和资源监控模块。
图2为本发明网格服务容器中服务部署模块的结构示意图。网格服务系统中的各种资源经服务化封装后,通过服务部署模块接入到服务容器中,供用户以统一的方式使用。如图所示,本发明服务部署模块具有部署、反部署和重部署功能;另外,它不仅可以实现自动部署,还可以实现基于FTP/SOAP附件的远程部署。
服务的部署是指将开发好的网格服务装载入网格服务容器,使其可被用户调用的过程。服务部署模块除了具有部署服务的功能外,还需要提供将服务从服务容器中反部署的功能,以及提供更新已部署服务的重部署功能。本发明网格服务容器支持方便易用的拖放式部署、热部署以及多种方式的远程部署功能。拖放式部署是指用户只要将开发好的服务封装包GAR(Grid ARchive)文件用鼠标或其他工具复制到指定的文件夹中,服务就会自动部署到容器中;热部署是指服务在部署之后,无需重新启动,即可被用户调用;远程部署实际为一个Web服务,用户可以在远程通过调用Web服务的接口,利用SOAP附件技术或者FTP协议将服务封装包传送到服务容器,并进行部署。
通常,一个GAR文件包含了支持服务运行的若干个文件和配置信息,主要包括如下内容:
1.服务逻辑的执行程序,比如Java Class
2.服务的WSDL描述文件
3.针对服务容器所描述的服务配置信息WSDD(Web Service DeploymentDescriptor)文档
4.JNDI文件,描述服务所使用的WSRF资源的相关信息
5.描述服务访问控制和授权信息的安全配置文件
6.描述组合服务定义的BPEL文件
7.其他文件,比如描述说明性质的文档。
这些文件中只有1、2和3是必需的,它们均由服务的开发人员提供,利用Java中的Jar命令将所有的文件压缩为一个GAR文件,通过部署服务对GAR文件的操作完成服务的部署。
如图所示,本发明服务部署模块是针对GAR格式的文件的一系列操作过程,它包括本地文件夹监视接口、部署子模块、反部署子模块、重部署子模块和容器配置参数表。本地文件夹监视接口用于接收本地或远程的GAR文件,并将接收到的文件传输给部署子模块、反部署子模块和重部署子模块;部署子模块、反部署子模块和重部署子模块在ANT技术的基础之上,将GAR文件部署或反部署或重部署到网格服务容器内,在执行这些操作的过程中,容器的配置会动态进行更新,以此实现了热部署的功能。
通过对特定文件夹的监视,支持方便的拖放式部署;同时还为远程用户提供了Web服务方式的远程部署服务,用户可以通过FTP或者SOAP附件将GAR包传输到目标服务容器。
图3为部署子模块工作流程图。如图所示,部署子模块执行以下操作:
1、开始;
2、查看GAR文件是否存在?如果不存在,部署子模块就结束操作;
3、如果GAR文件存在,判断ANT环境是否可用?如果不可用,部署子模块就结束操作;
4、如果ANT环境可用,就利用ANT工具将GAR文件部署到网格服务容器中;具体工作包括解压缩GAR文件、装载Java Class执行文件、解析WSDD配置文档并将配置信息装载到服务容器中、复制WSDL文件、解析JNDI配置文档;
5、结束此次操作。
图4为重部署子模块工作流程图。如图所示,重部署模块执行以下操作:
1、反部署指定的GAR文件;
2、部署指定的GAR文件;
3、结束此次操作。
图5为反部署子模块工作流程图。如图所示,反部署模块执行以下操作:
1、判断ANT环境是否可用?如果不可用,反部署模块就结束操作;
2、如果ANT环境可用,就调用ANT工具将部署时,装载到服务容器中的所有配置信息、程序文件删除;
3、结束此次操作。
本发明服务部署模块可以自动地将开发好的网格服务部署、反部署或重部署到网格服务容器中,具体操作如图6所示:
1、检查是否部署目录下的文件都已经被检查过,如果没有转到第2步;否则,转到第5步;
2、查看部署目录中下一个GAR文件;
3、根据信息记录,判断该GAR文件所包含的服务是否已经部署过?如果没有被部署,把该GAR文件信息加入信息记录中,并执行调用Ant工具进行服务部署,然后转到第1步;否则,转入步骤4;
4、检查GAR文件自上次部署之后,是否被更新过;如果更新过,调用Ant工具进行重部署操作,更新信息记录,然后转入第1步;否则转入第1步;
5、查找信息记录中记录的GAR文件,哪些已经被删除了,然后将对应的服务反部署;
6、工作线程挂起10秒钟,转到步骤1。
本发明服务部署模块不仅可以自动地将开发好的网格服务部署、反部署或重部署到网格服务容器中,还可以基于FTP/SOAP协议实现对网格服务的远程部署。
图7为基于FTP方式的远程部署工作流程图。如图所示,本发明服务部署模块基于FTP方式通过执行以下操作将封装好的网格服务远程部署到网格服务容器中:
1、从FTP服务器上下载GAR文件;
2、调用本地部署机制部署GAR文件;
3、结束此次操作。
图8为基于SOAP附件方式的远程部署工作流程图。如图所示,本发明服务部署模块基于SOAP附件通过执行以下操作将封装好的网格服务远程部署到网格服务容器中:
1、通过SOAP附件传输GAR文件;
2、调用本地部署机制部署GAR文件;
3、结束此次操作。
图9为本发明批作业服务模块结构示意图。网格计算来源于传统的高性能计算,在传统的高性能计算中,批作业是一种常被使用的作业类型,因此诞生了很多批作业处理系统,比较著名的有Unix/Linux下的FORK、PBS(PortableBatch System)和LSF(Load Sharing Facility)等。尽管网格服务体系结构已经被越来越多的人所认可,但是不可否认的是,批作业系统仍然广泛地存在。本发明网格服务容器提供了基于Web服务的批作业提交、监控和获取结果接口。在服务器端,批作业服务能够自动地将用户的请求适配到相应的批作业处理系统中,作业的处理结果最终通过SOAP消息返回给用户。
如图所示,本发明批作业服务模块包括用户管理子模块、批作业管理器、BJDL解析器、适配器和批作业系统。批作业管理器通过BJDL解析器来解析用户的作业请求,用户管理模块用于认证提交作业的用户的合法身份,然后批作业管理器调用批作业系统的适配器向相应的批作业系统提交用户作业。用户通过HTTP/SOAP可以查询作业当前处理状态,当作业完成时,可以获得作业的标准输出结果以及错误信息,其具体工作流程如图10所示。
在图9所示的体系结构下,如果要增加一种新的批作业系统,只需要根据规定好的接口为该批作业系统实现相应的适配器。由该适配器负责与实际的批作业系统进行交互。实际上,各个批作业系统的适配器都实现作业提交、结果获取和状态查询等标准接口,这样批作业系统就能很容易地接入到批作业服务中,从而保证了系统的可扩展性。
图11为本发明批作业服务模块处理用户提交作业请求的流程图。
1、BJDL解析器解析BJDL文件;
2、如果该文件非法,则返回出错信息,结束此次操作;
3、否则,由用户管理模块检查用户身份是否合法;如果用户身份非法,则返回出错信息,结束此次操作;
4、否则,把BJDL中的作业脚本内容序列化为本地文件;
5、根据作业类型,调用相应的适配器处理作业;
6、把作业相关信息作为历史信息写入数据库;
7、返回作业全局ID;
8、结束此次操作。
图12为本发明批作业服务模块处理用户获取作业处理状态请求的流程图。
1、由用户管理模块检查用户身份是否合法;如果用户身份非法,则返回出错信息,执行步骤6;
2、否则,查询作业信息数据库,获取该作业的相关信息;
3、判断作业是否完成或出错,如果完成,执行步骤5;否则,执行步骤4;
4、调用相应的适配器查询作业状态;
5、返回作业状态;
6、结束此次操作。
图13为本发明批作业服务模块处理用户取消作业处理请求的流程图。
1、由用户管理模块检查用户身份是否合法;如果用户身份非法,则执行步骤3;
2、否则,调用相应的适配器取消指定作业;
3、此次操作结束。
图14为本发明批作业服务模块处理用户获取作业标准输出结果请求的处理流程图。
1、由用户管理模块检查用户身份是否合法;如果用户身份非法,则返回出错信息,执行步骤6;
2、否则,查询作业信息数据库,获取该作业的相关信息;
3、判断作业是否完成或出错?如果完成,执行步骤4;否则,返回出错信息,执行步骤6;
4、调用相应的适配器获取标准输出;
5、返回标准输出;
6、结束此次操作。
图15为本发明批作业服务模块处理用户获取标准错误输出请求的处理流程图。
1、由用户管理模块检查用户身份是否合法;如果用户身份非法,则返回出错信息,执行步骤6;
2、否则,查询作业信息数据库,获取该作业的相关信息;
3、判断作业是否完成或出错?如果完成,执行步骤4;否则,返回出错消息,执行步骤6;
4、调用相应的适配器获取标准错误;
5、返回标准错误;
6、结束此次操作。
用户管理模块实现了简单的用户管理,外部的不同用户映射到本地的一个系统用户中即可。用户管理模块提供用户信息的添加、编辑、删除,以及用户身份的确认,用户的所有信息都存储在MySQL数据库中。该模块主要提供如下四个接口,接口的具体实现为对数据库的操作。
1、添加用户接口:public void addUser(String userName,String passWord,String email,String description);
2、修改密码接口:public void changePassword(String userName,StringnewPassWord);
3、删除用户接口:public void removeUser(String userName);
4、验证用户合法性接口:public boolean validateUser(String userName,String pass Word);
针对各种批作业处理系统的操作方式的差异,批作业适配器定义了一套标准的操作接口,如果要接入一种批作业处理系统,必需针对该批作业系统实现相应的批作业适配器,我们定义了如下6个标准接口:
1、作业提交:public String submit(String globalID,String workPath,String[]args);
2、查询作业状态:public String getJobStatus(String globalID,StringworkPath,String localID);
3、取消作业:public boolean cancel(String globalID,String workPath,StringlocalID);
4、获取标准输出:public String getStdOutput(String globalID,StringworkPath,String localID);
5、获取标准错误:public String getStdError(String globalID,String workPath,String localID);
6、获取文件输出:public int getOutput(String workPath,String url,String[]fileNames);
批作业管理器根据批作业的类型,调用相应的批作业适配器,完成图11-图15所描述的功能。
BJDL语言是基于XML的批作业描述语言,BJDL解析器本质上就是通过XML解析器解析BJDL描述的过程,我们采用了Sun的XML解析器实现BJDL解析器中的解析功能。
图16为本发明系统资源监控模块结构示意图。如图所示,系统资源监控模块主要包括提供者监控器和资源监控器。每一项被监控的系统资源信息都体现为WSRF中的一个资源属性,图16中的资源属性列表是所有资源属性的一个集合,也代表了该资源监控模块能对哪些资源进行监控;订阅主题列表是指其它模块对哪些资源属性进行了订阅。从而可以通过通知接口把资源信息的变化反馈给订阅者。提供者监控器用于管理、监控各个信息提供者,各个信息提供者收集系统的资源信息,信息提供者将收集的系统资源信息提供给提供者监控器,监控器生成资源属性与信息提供者映射表,同时,将系统资源信息以推或拉的模式传送给资源监控器,由资源监控器最终封装为WSRF服务。资源监控器除了提供对资源信息的查询接口外,针对动态信息还提供了通知接口,用户可以利用WSRF的通知机制以异步的方式获得资源信息。
系统的资源信息是由各种信息提供者收集的,根据采集的信息类型不同,可以分静态资源信息(如操作系统类型和机器类型)提供者及动态资源信息(如CPU负载)的提供者。信息提供者由提供者监控器按照配置文件的规定进行统一的管理,如信息提供者的初始化、控制信息推送的时间间隔和终止服务等。
图17为提供者监控器的处理流程图。如图所示,提供者监控器主要执行以下操作:
1、分析提供者的配置文件;
2、判断是否存在下一个提供者?如果不存在,就结束此次操作;
3、如果存在,判断该提供者采集的信息类型是否包含在资源模版中?如果存在,就加载该提供者,创建一个提供者对象,并返回至步骤2;如果不存在,就将该提供者加入到未加载数组中,并标记该提供者未载入,返回至步骤2。
图18为资源监控器的处理流程图。如图所示,资源监控器主要执行以下操作:
1、获取资源模版;
2、分析资源属性模版中的资源属性;如果是静态资源属性,就加入静态资源属性类表;如果是动态资源属性,就加入动态资源属性类表;
3、对提供者监控器进行初始化;
4、遍历静态提供者对象,查询静态资源属性;
5、将静态资源属性汇报给信息服务,信息服务是网格中信息提供者和信息请求者的中介机构,它通过对资源信息的发现,存储和管理等把相互分离的信息请求者和信息提供者联系起来,方便用户对资源的使用;
6、启动动态信息提供者;
7、结束。
上述网格服务容器资源监控模块功能封装成Web服务,用户通过SOAP消息在远程获取某个服务容器所在节点的系统资源信息。不仅如此,系统资源监控服务还提供了动态资源信息的推送功能,用户可以使用WSRF的通知机制,以异步的方式得到动态资源的实时信息。
本发明北京航空航天大学网格服务容器为遵循OGSA/WSRF的服务网格平台提供了基础运行环境和必需的基础服务,解决了资源的服务化封装、服务部署、WSRF服务的运行管理、传统批作业的服务化处理以及系统资源监控等基础问题,为构建复杂的网格系统服务以及网格应用提供了基础支撑。与GlobusToolkit等其他的网格服务容器相比,本发明提供了强大的服务部署功能,丰富的计算节点资源信息监控服务和基于服务的一体化批作业处理功能。
Claims (8)
1、一种网格服务容器,它包括HTTP请求接收处理模块、服务运行管理模块,其特征在于:它还包括服务部署模块、批作业服务模块和资源监控模块;
所述服务部署模块可将开发好的网格服务装载入网格服务容器内,使其可被用户调用,即部署;还可以将已部署好的服务从服务容器中删除,即反部署;还可以更新已部署的服务,即重部署;
所述批作业服务模块可自动地将用户的批作业处理请求适配到相应的批作业处理系统中,并将作业的处理结果返回给用户;
所述资源监控模块主要收集、管理系统资源信息,以及向用户提供系统资源信息,为用户提供访问系统资源信息的服务接口。
2、根据权利要求1所述的网格服务容器,其特征在于:所述服务部署模块是针对GAR格式的文件的一系列操作过程,它包括本地文件夹监视接口、部署子模块、反部署子模块、重部署子模块和容器配置参数表;本地文件夹监视接口用于接收本地或远程的GAR文件,并将接收到的文件传输给部署子模块、反部署子模块和重部署子模块;部署子模块、反部署子模块和重部署子模块在ANT技术的基础之上,将GAR文件部署或反部署或重部署到网格服务容器内,在执行这些操作的过程中,容器的配置会动态进行更新;
所述服务部署模块对接收的本地GAR文件实现自动部署;对接收到的远程GAR文件,基于FTP/SOAP附件实现远程部署。
3、根据权利要求1或2所述的网格服务容器,其特征在于:所述批作业服务模块包括用户管理子模块、批作业管理器、BJDL解析器、批作业适配器和批作业系统;
所述用户管理子模块提供用户信息的添加、编辑、删除,以及认证提交作业的用户的合法身份,用户的所有信息都存储在MySQL数据库中;
所述批作业管理器通过BJDL解析器来解析用户的作业请求,调用批作业系统的适配器向相应的批作业系统提交用户作业;用户通过HTTP/SOAP、批作业管理器、适配器查询作业当前处理状态,获得作业的标准输出结果以及错误信息。
4、根据权利要求3所述的网格服务容器,其特征在于:为了便于用户管理,将外部的不同用户映射到本地系统用户中,所述用户管理子模块具有四个接口:添加用户接口、修改密码接口、删除用户接口、验证用户合法性接口。
5、根据权利要求4所述的网格服务容器,其特征在于:批作业适配器定义有6个标准接口:作业提交接口、查询作业状态接口、取消作业接口、获取标准输出接口、获取标准错误接口、获取文件输出接口。
6、根据权利要求1或2或3所述的网格服务容器,其特征在于:所述系统资源监控模块主要包括提供者监控器和资源监控器;
所述提供者监控器用于管理、监控各个信息提供者;各个信息提供者收集系统的资源信息,并将收集的系统资源信息提供给提供者监控器;提供者监控器生成资源属性与信息提供者映射表;
所述提供者监控器通过推或拉的模式将系统资源信息传送给资源监控器,由资源监控器最终封装为WSRF服务;
所述资源监控器提供有用于对资源信息进行查询的查询接口和提供动态信息的通知接口,用户可以利用WSRF的通知机制以异步的方式获得资源信息。
7、根据权利要求6所述的网格服务容器,其特征在于:所述系统资源监控模块内还包括有资源属性列表和订阅主题列表;
所述资源属性列表内包括了所有被监控的系统资源信息;所述订阅主题列表是指其它模块对哪些资源属性进行了订阅;
所述系统资源监控器通过所述通知接口把资源信息的变化反馈给订阅者。
8、根据权利要求6所述的网格服务容器,其特征在于:所述信息提供者分静态资源信息提供者和动态资源信息提供者;信息提供者由所述提供者监控器按照配置文件的规定进行统一的管理。
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN200510059314XA CN1842078B (zh) | 2005-03-28 | 2005-03-28 | 网格服务系统 |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN200510059314XA CN1842078B (zh) | 2005-03-28 | 2005-03-28 | 网格服务系统 |
Publications (2)
Publication Number | Publication Date |
---|---|
CN1842078A true CN1842078A (zh) | 2006-10-04 |
CN1842078B CN1842078B (zh) | 2010-08-11 |
Family
ID=37030921
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN200510059314XA Expired - Fee Related CN1842078B (zh) | 2005-03-28 | 2005-03-28 | 网格服务系统 |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN1842078B (zh) |
Cited By (8)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN102255938A (zh) * | 2011-03-22 | 2011-11-23 | 苏州阔地网络科技有限公司 | 一种文件处理同步通知方法、系统及服务器 |
CN102279754A (zh) * | 2011-09-19 | 2011-12-14 | 山东中创软件工程股份有限公司 | 一种业务处理执行语言流程部署方法 |
CN102681825A (zh) * | 2011-03-09 | 2012-09-19 | 北京航空航天大学 | 服务运行容器管理系统和方法 |
CN104950757A (zh) * | 2015-06-12 | 2015-09-30 | 北京奇虎科技有限公司 | 监控容器的方法及系统 |
CN105959138A (zh) * | 2016-04-29 | 2016-09-21 | 深圳前海大数点科技有限公司 | 基于云计算的微服务动态部署的系统及方法 |
CN111277422A (zh) * | 2018-12-04 | 2020-06-12 | 中国电信股份有限公司 | 微服务的处理方法、装置、系统和计算机可读存储介质 |
CN111552496A (zh) * | 2020-05-07 | 2020-08-18 | 上海道客网络科技有限公司 | 一种基于添加临时容器实现无缝升级边车的系统与方法 |
CN115134231A (zh) * | 2021-03-17 | 2022-09-30 | 北京搜狗科技发展有限公司 | 一种通信方法、装置和用于通信的装置 |
Family Cites Families (1)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN100502389C (zh) * | 2004-06-28 | 2009-06-17 | 上海理工大学 | 一种基于ogsa规范的网格计算过程表示系统及其实现方法 |
-
2005
- 2005-03-28 CN CN200510059314XA patent/CN1842078B/zh not_active Expired - Fee Related
Cited By (12)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN102681825A (zh) * | 2011-03-09 | 2012-09-19 | 北京航空航天大学 | 服务运行容器管理系统和方法 |
CN102255938A (zh) * | 2011-03-22 | 2011-11-23 | 苏州阔地网络科技有限公司 | 一种文件处理同步通知方法、系统及服务器 |
CN102279754A (zh) * | 2011-09-19 | 2011-12-14 | 山东中创软件工程股份有限公司 | 一种业务处理执行语言流程部署方法 |
CN104950757A (zh) * | 2015-06-12 | 2015-09-30 | 北京奇虎科技有限公司 | 监控容器的方法及系统 |
CN104950757B (zh) * | 2015-06-12 | 2018-03-16 | 北京奇虎科技有限公司 | 监控容器的方法及系统 |
CN105959138A (zh) * | 2016-04-29 | 2016-09-21 | 深圳前海大数点科技有限公司 | 基于云计算的微服务动态部署的系统及方法 |
CN105959138B (zh) * | 2016-04-29 | 2019-05-17 | 深圳大数点科技有限公司 | 基于云计算的微服务动态部署的系统及方法 |
CN111277422A (zh) * | 2018-12-04 | 2020-06-12 | 中国电信股份有限公司 | 微服务的处理方法、装置、系统和计算机可读存储介质 |
CN111277422B (zh) * | 2018-12-04 | 2023-04-07 | 中国电信股份有限公司 | 微服务的处理方法、装置、系统和计算机可读存储介质 |
CN111552496A (zh) * | 2020-05-07 | 2020-08-18 | 上海道客网络科技有限公司 | 一种基于添加临时容器实现无缝升级边车的系统与方法 |
CN115134231A (zh) * | 2021-03-17 | 2022-09-30 | 北京搜狗科技发展有限公司 | 一种通信方法、装置和用于通信的装置 |
CN115134231B (zh) * | 2021-03-17 | 2024-03-08 | 北京搜狗科技发展有限公司 | 一种通信方法、装置和用于通信的装置 |
Also Published As
Publication number | Publication date |
---|---|
CN1842078B (zh) | 2010-08-11 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
CN100337235C (zh) | 访问数据库的方法及装置 | |
CN1645330A (zh) | 用于应用程序分布式管理的启用网格的虚拟机的方法和系统 | |
CN1577322A (zh) | 管理数据处理系统中的应用文件的方法和装置 | |
CN101042649A (zh) | 一种配置信息处理方法及装置以及平台系统 | |
CN1956394A (zh) | 进行网络设备业务配置的方法及装置 | |
CN101038559A (zh) | 批量任务调度引擎及调度方法 | |
CN100341281C (zh) | 一种在网络系统中实现任务管理的方法 | |
CN1906580A (zh) | 对于具有可移动对象的启用网格的虚拟机的方法和系统 | |
CN1942860A (zh) | 在分布式网络体系结构中建模和动态部署服务的系统和方法 | |
CN1967485A (zh) | 一种实现j2ee应用的方法及系统 | |
CN1968283A (zh) | 一种网络管理的系统和方法 | |
CN1940951A (zh) | 安全漏洞信息聚合 | |
CN1564129A (zh) | 一种构件的封装和一致性访问的方法 | |
CN1682186A (zh) | 技术无关的信息管理 | |
CN1298503A (zh) | 分布式系统中的动态查找服务 | |
CN1756257A (zh) | 大型网络中主机性能采集代理 | |
CN1859194A (zh) | 终端设备管理方法及其系统、以及终端设备 | |
CN1842078A (zh) | 网格服务容器 | |
CN1924803A (zh) | 处理不同模态的数据的装置和方法 | |
CN1156755C (zh) | 应用程序·服务·提供方法和系统 | |
CN1677932A (zh) | 网络管理配置方法及其装置 | |
CN1259623C (zh) | 基于j2ee的五层体系结构构建方法 | |
CN1946198A (zh) | 核心开通平台系统 | |
CN1885266A (zh) | 用于协作处理的系统,设备及方法 | |
CN1866283A (zh) | 实现规则系统触发的系统及方法 |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
C06 | Publication | ||
PB01 | Publication | ||
C10 | Entry into substantive examination | ||
SE01 | Entry into force of request for substantive examination | ||
C14 | Grant of patent or utility model | ||
GR01 | Patent grant | ||
C17 | Cessation of patent right | ||
CF01 | Termination of patent right due to non-payment of annual fee |
Granted publication date: 20100811 Termination date: 20130328 |