SG-UAP_V3 0 0_使用手册_分册1 任务调度-集群部署手册

任务调度集群配置1. 任务调度集群概述1.1. 任务调度集群根据国家电网公司统一应用开发平台（以下简称SGUAP）典型设计，任务调度模块是SGUAP可选公共套件，任务调度的部署作为业务应用系统的平台模块同时发布。任务调度在部署时，默认的配置是集群模式，实现任务调度的集群部署仅需要所有集群节点连接同一数据源。任务调度以第三方插件Quartz作为任务调度主服务，任务调度的集群功能是由Quartz引擎提供，任务调度继承了Quartz引擎集群相关的所有特性。1.2. Quartz集群一个 Quartz 集群中的每个节点是一个独立的 Quartz 应用，它又管理着其他的节点。意思是你必须对每个节点分别启动或停止。不像许多应用服务器的集群，独立的 Quartz 节点并不与其它节点或是管理节点通信。(将来的 Quartz 版本将会设计成让节点能与其他节点直接通信，而不是借助于数据库。) 取而代之的是，Quartz 应用是通过数据库表来感知到另一应用的。Quartz使用的是随机算法来提供最低限度负载均衡的能力。集群中的每个调度引擎实例尝试触发所允许尽量快的速度触发已经部署的Job。所有调度引擎实例通过触发自己的Trigger来竞争(使用数据库锁)得到执行Job的权利。当某个Job的Trigger被触发时，别的调度引擎实例就不再试图触发这一Trigger了，直到下一次触发时间的到来。1.3. 任务恢复机制在任务定义中，配置任务的【是否自动恢复】属性后，当任务执行失败（指引擎故障或服务宕机等情况，并非业务逻辑执行异常或失败）后，集群中的其他调度引擎实例会在下一次调度引擎实例检测时接过这个任务重新执行，调度引擎实例检测周期默认为15s。1.4. 定义任务调度主服务：是指SG-UAP平台提供的任务调度（TaskDispatch, TD）模块，它主要提供的功能包括：任务定义，组件定义，任务监控以及任务统计。业务应用任务组件：是指由SG-UAP平台任务调度模块提供接口规范，由业务应用系统利用接口规范实现系统业务功能，从而封装成为供任务调度主服务调用的可执行的组件。本地类型组件：是指由业务应用系统开发的，利用任务调度提供的接口规范实现，供任务调度主服务本地调用的业务组件。远程类型组件：是指由业务应用系统开发的，利用任务调度提供的接口规范实现，供任务调度主服务远程调用的业务组件。UAP-Server：UAP服务端，为UAP客户端提供Bundle资源。UAP-Client：UAP客户端、UAP项目，提供应用配置，是应用Bundle运行的容器。2. 任务调度集群2.1. 任务调度典型集群图2.1 任务调度典型集群部署示例图任务调度典型集群配置是指SGUAP任务调度主服务跟随业务应用系统及业务应用业务组件同时发布到UAP客户端（UAP项目）中。业务应用以集群模式部署，任务调度会自动跟随业务系统发布为集群部署模式，并且任务调度的集群模式默认为负载均衡。2.2. 本地类型任务组件集群图2.2 任务调度本地类型任务组件集群部署示例图任务调度本地类型任务组件集群模式部署要求每个任务调度集群节点的任务调度主服务与业务应用任务组件必须同时发布到同一个UAP客户端（UAP项目）中，且每个任务调度集群节点连接同一数据源。图2.2中部署示例将业务应用系统与任务调度拆分成为不同的两个集群，目的是为了降低任务调度中大量调度任务对业务应用系统带来的压力。2.3. 远程类型任务组件集群图2.3 任务调度远程类型任务组件集群任务调度远程类型组件的部署可以将任务调度主服务、业务应用任务组件以及业务应用系统三者分开分别独立部署，任务调度主服务集群要求所有集群节点连接同一数据源。图2.3中的部署示例分别将业务应用系统、业务应用任务组件和任务调度主服务发布成为三个集群，任务调度集群通过远程调用的方式调用和执行业务应用任务组件集群中的任务组件，集群与集群间互不干扰，可靠性较高。3. 任务调度集群配置3.1. UAP典型应用集群配置UAP项目路径下：WebContentWEB-INFconfiguration除业务应用系统固有配置以外，部署任务调度集群节点时需要修改及确认的配置包括：config.ini，perties，perties和datasource.xml。(1) 确认每个集群节点datasource.xml配置或者Weblogic数据源配置中任务调度主服务所依赖的数据源为同一数据源。(2) 确认config.ini中配置的UAP服务端（UAP-Server）地址正常、可用。(3) 确认perties所配置的ISC地址正常、可用。(4) 如果使用的是远程类型的组件需要添加ISC权限验证白名单，在perties文件中ISC_EXCLUDEPAGES配置项添加/*/rest/taskcom/components/*,/*/rest/tasklocalcom/components/*。(5) 日志配置见附录。(6) 任务调度页面组件配置见SG-UAP_V*.*_使用手册_分册1.任务调度.doc。UAP项目路径下：WebContentWEB-INFrepositoryplatformmodulelistclient_include_perties除业务应用系统固有白名单外，需要添加任务调度主服务白名单，即：taskdispatch。3.2. 本地类型任务组件集群配置UAP项目路径下：WebContentWEB-INFconfiguration除业务应用组件包固有配置以外，部署任务调度本地类型集群节点时需要确认的配置包括：config.ini，perties和datasource.xml。(1) 确认每个节点datasource.xml配置或者Weblogic数据源配置中任务调度主服务所依赖的数据源为同一数据源。(2) 确认config.ini中配置的UAP服务端（UAP-Server）地址正常、可用。(3) 确认perties所配置的ISC地址正常、可用。(4) 日志配置见附录。(5) 任务调度页面组件配置见SG-UAP_V*.*_使用手册_分册1.任务调度.doc。UAP项目路径下：WebContentWEB-INFrepositoryplatformmodulelistclient_include_perties添加任务调度主服务白名单和业务应用任务组件包白名单， 即taskdispatch和。3.3. 远程类型任务组件集群配置远程类型任务组件集群包括任务调度主服务集群配置和业务组件集群配置。任务调度主服务集群配置：任务调度主服务UAP项目路径下：WebContentWEB-INFconfiguration(1) 配置config.ini中UAP服务端（UAP-Server）地址，保证该地址正常、可用。(2) 配置datasource.xml数据源或者Weblogic数据源，并保证每个集群节点所使用的数据源为同一数据源。(3) 配置perties中ISC地址等参数，保证该配置正常、可用。(4) 日志配置见附录。任务调度主服务UAP项目路径下：WebContentWEB-INFrepositoryplatformmodulelistclient_include_perties添加任务调度主服务白名单，即：taskdispatch。业务组件集群配置：业务组件UAP项目路径下：WebContentWEB-INFconfiguration(1) 配置config.ini中UAP服务端（UAP-Server）地址，保证该地址正常、可用。(2) 配置datasource.xml数据源或者Weblogic数据源。(3) 配置perties中ISC地址等参数，保证该配置正常、可用。(4) 配置perties中ISC权限白名单，修改 ISC_EXCLUDEPAGES配置项，添加/*/rest/taskcom/components/*,/*/rest/tasklocalcom/components/*。(5) 日志配置见附录。(6) 任务调度页面组件配置见SG-UAP_V*.*_使用手册_分册1.任务调度.doc。（注：组件注册的URI是集群提供的URI）附录1：Log4j日志配置日志文件位置:UAP项目路径下：WebContentWEB-INFperties#日志文件存储地址：#Windows: LOG_DIR=D:sguap-logclient#Linux: LOG_DIR= sguap-logclient#Appender：#平台日志-控制台log4j.appender.platform=org.apache.log4j.ConsoleAppenderlog4j.appender.platform.Target=System.outlog4j.appender.platform.layout=org.apache.log4j.PatternLayoutlog4j.appender.platform.layout.ConversionPattern=%dISO8601 Platform : %m%n#平台日志-文件log4j.appender.platform1=org.apache.log4j.RollingFileAppenderlog4j.appender.platform1.File=$LOG_DIR/trace.loglog4j.appender.platform1.MaxBackupIndex=100log4j.appender.platform1.MaxFileSize=5000000log4j.appender.platform1.layout=org.apache.log4j.PatternLayoutlog4j.appender.platform1.layout.ConversionPattern=%dISO8601 platform :%-5p %-x %Xuser %n %m%n#应用日志-控制台log4j.appender.thirdparty=org.apache.log4j.ConsoleAppenderlog4j.appender.thirdparty.Target=System.outlog4j.appender.thirdparty.layout=org.apache.log4j.PatternLayoutlog4j.appender.thirdparty.layout.ConversionPattern=%dISO8601 Thirds :%5p %c1:%L - %m%n#应用日志-文件log4j.appender.thirdparty1=org.apache.log4j.RollingFileAppenderlog4j.appender.thirdparty1.File=$LOG_DIR/trace.loglog4j.appender.thirdparty1.MaxBackupIndex=100log4j.appender.thirdparty1.MaxFileSize=5000000log4j.appender.thirdparty1.layout=org.apache.log4j.PatternLayoutlog4j.appender.thirdparty1.layout.ConversionPattern=%dISO8601 Thirds :%-5p %-x %Xuser %n %m%n#Log Levels(debug, info, warn, error, fatal).sgcc = .sgcc.uap.task = debug, .quartz = debug, .sgcc.uap.task = debug, .quartz = debug, platform1日志级别规则：log4j.logger. = , 例：PMS系统开启debug级别日志：.sgcc.pms = debug, .sgcc.pms = debug, thirdparty1附录2：Quartz引擎配置(可以在perties进行添加或修改)#=# Configure ThreadPool Quartz线程池#=org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPoolorg.quartz.threadPool.threadCount = 10org.quartz.threadPool.threadPriority = 5org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true#=# Configure JobStore Quartz任务存储#=#MySQL：com.sgcc.uap.task.persistence.UAPMySQLDelegate#Oracle：com.sgcc.uap.task.persistence.UAPOracleDelegate#PostgreSQL：com.sgcc.uap.task.persistence.UAPPostgreDelegate#达梦：com.sgcc.uap.task.persistence.UAPDmDelegate#金仓：com.sgcc.uap.task.persistence.UAPKingbaseDelegateorg.quartz.jobStore.driverDelegateClass = com.sgcc.uap.task.persistence.UAPOracleDelegateorg.quartz.jobStore.misfireThreshold = 60000#是否启用集群模式org.quartz.jobStore.isClustered = true