您的位置: 旅游网 > 生活

WorkFlow的事务回滚实现

发布时间:2019-09-13 19:40:51

Workflow Project 目前状态

版本 0.11

已经完成

1。完成了接口1 和接口2 的方法

2。完成接口3的默认实现

3。完成事务回滚的实现方法-等待测试

未完成

1。接口3的注册与实例化解决方案

2。应用的并发访问问题以及解决数据的脏读问题

3。与具体的某个应用挂接并测试

-事务的回滚

OSWorkFlow的事务回滚是依靠WorkflowContext这个接口来实现的,在New出某个WorkFlow的时候需要声明WorkflowContext的实现类,一般会采用uper.context = new GearWheelWorkFlowContext(_caller);方法

比如这样实现:

public GearWheelWorkFlow(String _caller)

{

super.context = new GearWheelWorkFlowContext(_caller);

}

但OSWorkFlow的WorkflowContext的默认实现BasicWorkFlowContext中根本没有实现setRollbackOnly方法,也就没有了参考的可能

再看看这个接口的其他实现类也都是建立在JTA这样的跨Session的事务服务上,比如它的EJB的实现也是要调用容器提供的JTA实现才行!而JTA的实现比如要JNDI到数据库池,此时的应用光JTA+JNDI就已经宣布 -这样的例子必须生存在应用服务器的环境下!!

可是,我不死心,我记得Hibernate可以实现本地事务,也就是依靠JDBC本身的事务处理能力,而要实现这样的功能就需要在数据库连接的获取上下一些功夫,也就是要保证回滚的数据库连接必须是获取时的那个连接,而存储连接就成了一个需要首先解决的问题。

解决数据库连接的存储问题

目前存储数据库连接除了依靠静态类外,还有一个通用的方法ThreadLocal类,这样获取数据库连接的方法写成了如下的形式:

package com.company.common;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.Collections;

import java.util.HashMap;

import java.util.Map;

import org.apache.log4j.Logger;

public class DB2ConnectFactory

{

/**

* Logger for this class

*/

private static final Logger logger = Logger.getLogger(DB2ConnectFactory.class);

private static ThreadLocal threadLocal = new ThreadLocal();

//~

private Connection connect = null;

private Statement state = null;

private ResultSet result = null;

private boolean closeConnWhenDone = false;

//~

private String url = "jdbc:db2:WORKFLOW";

private String user = "";

private String password = "";

private String driverClassName = "COM.ibm.db2.jdbc.app.DB2Driver";

public DB2ConnectFactory() throws SQLException

{

this.init();

}

/**

* 获取数据库连接

* @return

* @throws SQLException

*/

public Connection getConn() throws SQLException

{

return (Connection)threadLocal.get();

}

/**

* 初始化数据库,并在缓冲中注册数据库连接

* @throws SQLException

*/

private void init() throws SQLException

{

try

{

// Get connect object

Class.forName(driverClassName);

closeConnWhenDone = true;

connect = DriverManager.getConnection(url, user, password);

state = connect.createStatement();

//Register the connection object in the threadlocal

threadLocal.set(connect);

}

catch (Exception e)

{

e.printStackTrace();

throw new SQLException(e.getMessage());

}

}

}

解决事务回滚

刚才说了需要实现WorkflowContext接口

package com.company.engine.workflow;

import java.sql.Connection;

import java.sql.SQLException;

import org.apache.log4j.Logger;

import com.company.common.DB2ConnectFactory;

import com.opensymphony.workflow.WorkflowContext;

public class GearWheelWorkFlowContext implements WorkflowContext

{

/**

* Logger for this class

*/

private static final Logger logger = Logger.getLogger(GearWheelWorkFlowContext.class);

private static ThreadLocal threadLocal = new ThreadLocal();

// ~ Instance fields

// ////////////////////////////////////////////////////////

private String caller;

// ~ Constructors

// ///////////////////////////////////////////////////////////

public GearWheelWorkFlowContext(String caller)

{

this.caller = caller;

}

// ~ Methods

// ////////////////////////////////////////////////////////////////

public String getCaller()

{

return this.caller;

}

/**

* Tranaction : Set Roll back

* @throws SQLException

*/

public void setRollbackOnly()

{

Connection connect = null;

try

{

DB2ConnectFactory factory = new DB2ConnectFactory();

connect = factory.getConn();

if(connect != null) connect.rollback();

}

catch (Exception e)

{

e.printStackTrace();

}

finally

{

this.clostConnection(connect);

}

}

private void clostConnection(Connection connect)

{

try

{

if(connect != null) connect.close();

}

catch (Exception e)

{

e.printStackTrace();

}

}

}

总结

1。我们可以看到由于接口中setRollbackOnly没有异常的声明,方法中即使抛出了异常也要自己"忍了"!看来良好的接口声明其实是非常重要的。

2。而且需要重载原来JDBCWorkflow 中的cleanup方法,将其中的代码屏蔽掉!数据库的关闭放在了setRollbackOnly访访的finally中,原因就是由于我们要统一的管理数据库连接所引发的,我们不能够在WorkFlowStore的每一个方法执行完毕后就关闭连接,因为这样的话你根本没有了事务回滚的可能,所以此时的连接需要在WorkflowContext中来处理。

感触

OSWorkFlow的实现方法并不是像网上所说的那样的优秀和文雅,更像是一个未完成任务的"半成品",Heni被网上鼓吹为大牛,但一个不写注释和文档的人,根本称不上什么大牛!

OSWorkFlow更多的是实现了一个微内核,而它的用户模式是与OSUser这样的框架耦合的(偶已经将这样的耦合打开了,也就是接口3的定义),它的相关数据是与PropertySet框架耦合的(也就是接口2的定义),而且采用OSWorkFlow要经过很原始的修改(比如我实现了DB2下的WorkFlowStore的实现)。

不过也好即使以后不采用OSWorkFlow,自己实现一个这样的引擎也应该没有什么问题的,有时间了我倒是很想看看别的工作流的产品。

热淋清颗粒作用
汉森四磨汤适用人群
幼儿咳嗽吃什么药效果好
小孩吃什么健脾胃
猜你会喜欢的
猜你会喜欢的