`

我的步骤执行容器StepFramework

    博客分类:
  • Java
 
阅读更多

读者可以在eclipse中导入附件的项目,执行main.java体验"步骤执行容器"的效果(温馨提示,stepframework依赖了dom4j,在附件中的dependence目录含有该lib)。

 

问题背景与实现简述

 

通常情况下,一项任务可以分为多个步骤,每个步骤之下又能分为几个子步骤。最简单的实现方法就是:使用一个主类调用几个步骤方法去完成任务;每个步骤方法执行的时候,能够读取的参数都是同一配置文件下的所有参数。然而,到了后期,任务的需求变得越来越灵活和复杂,前面实现方法就存在以下缺点了:

 

1 不能做到某些步骤的配置式替换、去掉或者添加;

2 当步骤越来越多的时候,参数命名容易冲突,通常需要添加足够的前缀。况且一个步骤能到其他所有的步骤的参数,也不太合理。

3 参数在步骤间传递的是个设计难题。通常来说,在多个方法或者类之间传递某个值,要么需要使用一个static变量、threadlocal之类的全局变量来维护,要么在方法中传递参数。前者会一定程度上增加维护的难度(需要清楚某个参数何时放进去,何时拿出来,需要知道全局变量里面究竟会有哪些参数),而后者会让代码看起来好臃肿(参数太多了)而且耦合性较强。

4 当步骤的数量庞大起来的时候,让人很难理清其中的执行的顺序和逻辑。

 

例如做一个增量补丁制作工具,刚开始按照 ”SVN-DIFF-->SVN下载-->全量编译SRC-->增量编译SRC-->复制文件-->整合sql执行脚本文件“的思路做了一个简单的工具。后面发现,有时候需要SVN下载后停顿一下,以便手工删除某些文件;整合sql执行脚本文件针对不同的项目需要替换;后面有人提议希望能够直接只指定某几个步骤,而不是每次都从头到尾执行,太浪费时间了,例如只需要执行整合sql脚本等等。这时候,原来简单的一个主类调用多个步骤方法的程序很难使用。

 

重构:采用配置文件、责任链模式、聚合模式解决以上问题

 

1 使用step.xml配置文件描述所有的步骤组件、步骤参数和要执行的步骤顺序。

 

通过配置该文件,可以灵活地替换、去掉或者添加组件。同时,该文件,能够非常清晰地描述整个任务的执行的过程。

 

	<main>add,multiply,divideAndSubtractionStepSuite</main>
	<all-step>
		<step name="add" class="test.Add" params-ref="add"/>
		<step name="multiply" class="test.Multiply" params-ref="multiply"/>
		<step name="divideAndSubtractionStepSuite" class="test.TryStepSuit" 
			params-ref="divideAndSubtractionStepSuite"
		/>
	</all-step>

看了这个文件,即使我不说明,都大概能猜到该程序要依次运行add,multiply,divideAndSubtractionStepSuite这三个步骤,步骤对应的类和参数在<step/>中得到进一步的描述。

 

细节1

divideAndSubtractionStepSuite

 这个步骤其实集合了除法步骤和减法步骤,融合为一步骤(具体参见附件或实例代码)。这个特性是为了满足可读性的要求。例如一个增量编译,包含了下载增量文件,编译,COPY文件三个子步骤,融合为一个名为compileDiff的步骤,显然好读,更易理解。

 

细节2 

配置文件没有考虑StepSuite的配置项,只有step配置项。

 

stepframwork将包含多个step和stepSuite组件的集合称为stepSuite。目前对StepSuite下的各个组件共用一个参数集合,因为考虑到一个StepSuite,大多数情况下是不应该存在重复参数的,而且,我认为一个StepSuite作为一个namespace已经足够了,细化到Step似乎有些多余。万一如果一个StepSuite下真存在重复组件和重复参数名,实际上很可能应该将一个StepSuite分拆为两个。另一方面,考虑到如果要使每个StepSuite组件下的所有Step单独使用自己的参数集合,配置将变得复杂,后面的人维护起来也麻烦。stepframwork并不是不能实现每个Step对应一个参数集合,而是为了维护和易学,stepframework做了一个“不完美”的选择, 因此配置文件中没有类似

<stepSuite name="divideAndSub">

 <step step-ref="divide"/>

 <step step-ref="sub"/>

</stepSuite>

的配置。但是可以通过写一个TestSuite的子类实现同等效果,也很简单。

例如:

 

package test;

import stepframework.StepSuite;

public class TryStepSuit extends StepSuite{
	
	public TryStepSuit(){
		this.addStep(new Divide()).addStep(new Sub());
	}
}

 

 

 

2 每个步骤组件关联一个参数集合,当参数集合中查找不到想要的参数,则使用责任链在前面步骤组件关联的参数集合中查找参数。

 

这样设计是因为通常情况下,后面执行的步骤需要前面步骤的某些参数,而责任链能非常优雅的实现这一点。责任链还提供其他两个好处:

 a)免去了重用前面的某个步骤组件时需要在参数名前面添加前缀的问题,因为即使重名,责任链保证首先会读到该组件实例关联的参数。

 b)利用责任链,可以把前一步骤的执行结果,传递到下一个步骤。

 

此外,每个步骤组件关系的参数集合,都是由stepframework自动注入到具体的步骤组件对象中,无需步骤组件开发人员处理。

 

题外话:在现在使用责任链来实现参数的动态查找之前,我是这样设计的,一个步骤组件关联一个参数集合,该集合包含了该步骤所需的所有参数,但是这些参数与其他步骤的参数有不少重复。对于一个有代码洁癖的程序原来说,这是不能容忍的事情,苦思一番之后,灵感乍现,javascript原型链不就是解决我这个问题的最佳实践吗?于是,责任链的实现诞生了。

 

	<all-params>
		<params name="add">
			<param name="left" value="10"/>
			<param name="right" value="20"/>
			<param name="result" value=""/>
		</params>
		
		<params name="multiply">
			<param name="multi_num" value="3"/>
		</params>
		<params name="divideAndSubtractionStepSuite">
			<param name="div_num" value="2"/>
			<param name="sub_num" value="3"/>
		</params>
	</all-params>

 

package stepframework;
import java.util.Map;


public class Params {
	private Map<String,String> map;
	private Params parent;

	public Params(Map<String, String> map, Params parent) {
		super();
		this.map = map;
		this.parent = parent;
	}
	
	public void put(String paramName, String paramValue){
		map.put(paramName, paramValue);
	}
	//责任链查找
	public String get(String paramName){
		String paramValue = map.get(paramName);
		if(null != paramValue){
			return paramValue;
		}else if(null != parent){
			return parent.get(paramName);
		}else{
			return "";
		}
	}
	
}

 

3 对于步骤集合(StepSuite)和单一步骤(Step),使用了聚合模式,统一作为一个IStep的实现,容器通过该方式,统一处理所有的步骤,而无视所谓步骤与子步骤,程序变得更简单。

 

package stepframework;
import java.util.ArrayList;
import java.util.List;


public class StepSuite implements IStep{
	
	private Params params;
	private List<IStep> steps = new ArrayList<IStep>();  
	
	public StepSuite(){
	}
	
	public StepSuite addStep(IStep step){
		steps.add(step);
		return this;
	}
	
	//聚合模式的关键,集合对象,依次执行每个子对象
	@Override
	public Result run() {
		for(IStep step : steps){
			step.setParams(params);
			Result rs = step.run();
			if(!rs.isSuccess()){
				return rs;
			}
		}
		return Result.SUCCESS;
	}

	public void setParams(Params params){
		this.params = params;
	}
	public void putParam(String paramName, String paramValue){
		params.put(paramName, paramValue);
	}
	
	public String getParam(String paramName){
		return params.get(paramName);
	}

}

 

StepFramework使用示例

stepframework使用非常简单,只需两步:1. 扩展基类创建步骤组件,2. step.xml中描述如何运行这些组件

 

下面演示了加减乘除4个步骤的依次执行,每个步骤执行的结果,都能传递到后一步骤。

 

1. 编写步骤类,继承Step,或者StepSuite(包含多个Step或者StepSuite)。

 

下面定义了加减乘除4个Step,和1个综合了“除和减”两个Step的集合StepSuite。

 

对于单一步骤Step,需要继承Step类,重写run()方法,编写步骤的具体逻辑。在run方法中使用getParam查找参数,使用putParam设置传递到后面步骤的结果参数。如果执行失败,创建一个Result对象,填充错误信息 ,并且stepframework会马上体制,如果执行成功,直接返回Result.SUCCESS即可。

 

对于Step或StepSuite的步骤集合StepSuite,需要继承StepSuite类,编写构造函数,调用add()方法添加所需的Step或StepSuite。这些Step和StepSuite都共同关联同一个参数结合params。

 

package test;

import stepframework.Result;
import stepframework.Step;

public class Add extends Step{
	@Override
	public Result run() {
		String left = this.getParam("left");
		String right = this.getParam("right");
		Integer i = Integer.valueOf(left) + Integer.valueOf(right);
		String result = String.valueOf(i);
		this.putParam("result",result );
		System.out.println(left+"+"+right+"="+result);
		return Result.SUCCESS;
	}
}

 

package test;

import stepframework.Result;
import stepframework.Step;

public class Multiply  extends Step{
	@Override
	public Result run() {
		String result = this.getParam("result");
		String multi_num = this.getParam("multi_num");
		String orginResult = result;
		result = String.valueOf(Integer.valueOf(result)*Integer.valueOf(multi_num));
		System.out.println(orginResult+"*"+multi_num+"="+result);
		this.putParam("result", result);		
		return Result.SUCCESS;
	}
}

 

package test;

import stepframework.Result;
import stepframework.Step;

public class Divide extends Step{
	@Override
	public Result run() {
		String result = this.getParam("result");
		String divNum = this.getParam("div_num");
		String orginResult = result;
		result = String.valueOf(Integer.valueOf(result)/Integer.valueOf(divNum));
		System.out.println(orginResult+"/"+divNum+"="+result);
		this.putParam("result", result);
		return Result.SUCCESS;
	}
}

 

package test;

import stepframework.Result;
import stepframework.Step;

public class Sub  extends Step{
	@Override
	public Result run() {
		String result = this.getParam("result");
		String sub_num = this.getParam("sub_num");
		String orginResult = result;

		result = String.valueOf(Integer.valueOf(result) - Integer.valueOf(sub_num));
		System.out.println(orginResult+"-"+sub_num+"="+result);
		this.putParam("result", result);
		return Result.SUCCESS;
	}
}

 

package test;

import stepframework.StepSuite;

public class TryStepSuit extends StepSuite{
	
	public TryStepSuit(){
		this.addStep(new Divide()).addStep(new Sub());
	}
}

 

2. 配置step.xml,让stepframework自动按顺序执行各个步骤。

    a)在step.xml中的<step/>中,添加上步骤名,步骤实现类和引用的参数集合名。

    b)在step.xml中的<params/>中,配置每个步骤所需要的参数。

    c)在step.xml中main中,配置要执行的步骤,stepframework会按照先后顺序执行。

    d)step.xml放在classpath下

<step-root>
	<main>add,multiply,divideAndSubtractionStepSuite</main>
	<all-step>
		<step name="add" class="test.Add" params-ref="add"/>
		<step name="multiply" class="test.Multiply" params-ref="multiply"/>
		<step name="divideAndSubtractionStepSuite" class="test.TryStepSuit" 
			params-ref="divideAndSubtractionStepSuite"
		/>
	</all-step>
	
	<all-params>
		<params name="add">
			<param name="left" value="10"/>
			<param name="right" value="20"/>
			<param name="result" value=""/>
		</params>
		
		<params name="multiply">
			<param name="multi_num" value="3"/>
		</params>
		<params name="divideAndSubtractionStepSuite">
			<param name="div_num" value="2"/>
			<param name="sub_num" value="3"/>
		</params>
	</all-params>
</step-root>

 3 调用StepRunner类执行程序

public class Main {
	public static void main(String[] args) throws URISyntaxException, DocumentException, ClassNotFoundException, InstantiationException, IllegalAccessException{
		StepRunner.run();
	}
}

 

3
1
分享到:
评论

相关推荐

    目录 步骤 1:拉取 CentOS 镜像 示例命令 步骤 2:运行 CentOS 容器 交互式会话 后台运行容器 步骤 3:管

    步骤 2:运行 CentOS 容器 交互式会话 后台运行容器 步骤 3:管理容器 查看正在运行的容器 停止容器 重新启动容器 连接到已启动的容器 步骤 4:使用 Docker Compose 创建 docker-compose.yml 文件 启动服务 停止服务...

    Qt5.9.1可执行程序做成可执行文件的步骤

    ### Qt5.9.1可执行程序转换为安装文件的步骤详解 #### 一、简述 本篇文章将详细介绍如何将Qt5.9.1开发的可执行程序转化为可直接安装使用的`.exe`安装文件。这不仅适用于Qt5.9.1版本,也适用于其他版本的Qt框架开发...

    压力容器的设计步骤.rar

    《压力容器设计步骤详解》 压力容器是一种在工业生产中广泛应用的重要设备,它主要用于存储、运输或处理具有高压、高温的气体或液体。其设计过程严谨且复杂,涉及到材料选择、强度计算、工艺流程等多个方面。以下是...

    小黄鸭容器直装.zip

    小黄鸭容器直装是一款专为用户打造的轻量级应用程序容器化工具,它使得用户无需复杂的配置步骤,即可直接安装和运行各种应用程序。这款软件的主要功能在于提供一个虚拟化的环境,让应用能在独立的、隔离的环境中运行...

    c# winform 自定义折叠容器

    下面是一个简化的步骤来创建带有慢动画效果的折叠容器: 1. **创建自定义控件类**:首先,创建一个新的用户控件(UserControl)继承自`Panel`。这将是我们的折叠容器。 2. **设置初始状态**:在控件的构造函数中,...

    容器云搭建3master操作步骤

    容器云搭建3master操作步骤

    linux centos环境kettle部署与定时作业执行

    下面将详细介绍 Kettle 部署和定时作业执行的步骤。 一、java 安装和配置 在部署 Kettle 之前,需要安装和配置 java 环境。首先,需要查看系统是否已经安装了 JDK,可以使用命令“java -version”来检查。如果没有...

    企业网站运营方案执行步骤

    企业网站运营方案执行步骤,第一、网站运营之市场分析 网站的功能与作用: “ 在网站采用新开发系统后,一定要有新颖的内容会出现在网站 中,新页面的效果以及功能不仅可以吸引来访者,还也可以给来访者提供娱乐休闲...

    基于PLC和组态软件的炼化装置压力容器控制系统.pdf

    控制部分主要由伺服放大器、手操器和电动执行机构组成,它们按照PLC发出的指令,对进料阀和排空阀等执行元件进行操作,以实现对压力容器内参数的精确控制。 上位机程序方面,本系统选择了Realinfo组态软件,它能够...

    kettle转换数据的步骤,还算全面

    9. **测试与调试**:完成设计后,先在"单步执行"模式下测试每个步骤,然后在"运行"模式下整体验证转换效果。使用"日志"和"查看"选项卡跟踪数据流动和转换状态。 10. **优化与性能监控**:在大数据量处理时,注意...

    压力容器制造工艺纪律.pdf

    【压力容器制造工艺纪律】是制造压力容器过程中必须遵循的...以上各环节的严格执行是保证压力容器安全、可靠的关键。每一步骤都有严格的工艺纪律,以确保最终制造出的压力容器能满足设计要求,具备良好的性能和安全性。

    通过分析SQL语句的执行计划优化SQL(六)

    例如,对于图5-1所示的查询,Oracle会首先执行步骤3,然后对每行执行步骤5、4、2、6,最后是步骤1。某些步骤可能在获得单行数据后立即执行,形成串联式的执行链,这适用于优化目标为first_rows的情况,以快速返回...

    执行力管理企业执行力管理四步骤(ppt 45).pptx

    执行力管理企业执行力管理四步骤(ppt 45).pptx

    Docker创建Mysql容器的简单步骤

    下面就来给大家介绍下Docker创建Mysql容器的简单步骤,话不多说了,来一起看看详细的介绍吧 步骤如下 1、启动docker服务 [root@docker ~]# systemctl start docker 2、查看docker里面的镜像 [root@docker ~]# ...

    文档的ActiveX容器

    具体的内容可能包括了如何创建和使用ActiveX控件,以及如何在不同环境中集成ActiveX容器的详细步骤。 总的来说,ActiveX容器是Windows平台上的一个强大工具,它使得开发人员可以轻松地将丰富的功能集成到文档和应用...

    控制docker容器日志大小的方法V1.2.docx

    **步骤二:** 进入容器目录 `/var/lib/docker/containers/&lt;container_id&gt;` 并找到 `hostconfig.json` 文件。 **步骤三:** 修改 `hostconfig.json` 文件中的日志配置部分。 将 “LogConfig” 字段修改为: ```...

    压力容器施工组织设计-压力容器罐体隐蔽工程记录

    《压力容器施工组织设计-压力容器罐体隐蔽工程记录》是一个重要的文档,它详细记录了在压力容器建造过程中的关键步骤、技术要点以及质量控制环节。压力容器是一种用于储存或处理高压气体或液体的设备,广泛应用于...

    WF4 自定义容器活动

    自定义容器活动是在WF4中创建自己的复合活动,可以包含其他活动,类似于在流程图中使用一个形状来封装多个子步骤。下面我们将深入探讨如何实现WF4自定义容器活动,并在自定义活动中添加其他活动。 一、理解WF4...

    容器网络实验手册1

    我们也学习了如何使用 docker exec 命令来进入容器并执行命令。 第五个知识点:Docker 网络命令 在实验中,我们学习了 Docker 网络相关的命令,包括 docker network create、docker network inspect、docker ...

Global site tag (gtag.js) - Google Analytics