用PicoContainer和Nanning实现事务管理

类别:Java 点击:0 评论:0 推荐:

用PicoContainer和Nanning实现事务管理

Transaction Manager, with PicoContainer and Nanning

作者:冰云
Blog:http://icecloud.51.net
Email:icecloud(AT)sina.com

PicoContainer是constructor injector的IOC容器。Nanning是dynamic AOP的一种实现。项目中我用Pico作为我的微核心,在某些地方需要用到AOP,最典型的是:事务管理(Transaction Manager)。

首先考虑应用的前提,一个DAO需要进行数据库操作并需要事务。下面是两个接口声明:

 

public interface Dao {

    void update();

    Object create();

}

 

public interface TxManager {

    void begin();

    void commit();

    void rollback();

}

 

    如果用OO的实现方法,可能是要让SampleDao这个实现类同时实现两个接口等。按照单一职责原则,SampleDao不应该了解事务管理,或者,某种情况下,不需要事务处理,这时候应该可以关闭事务。

这里引入Aspect(方面)来负责事务处理。或者说,事务其实是Service的一个方面。

但是,一个问题是,事务往往和数据库相关。想要控制事务,必须要能够启动事务的Connection,Session,Transaction等等。必须把这些东西同时传递给Service和TxManager。

 

public interface ObjectReference{

    Object get();

    void set(Object obj);

}

 

public class DatabaseReference implements ObjectReference{

    private Connection conn ;

   

    public DatabaseReference(){

        // 从某处取得Connection

    }

    Objcet get(){

        return conn;

    }

    void set(Object obj){

        this.conn = (Connection)obj;

    }

}

 

    TxManager的实现类可以拥有一个 DatabaseReference的实例用来获取和Connection相关的对象。Service的实例也要得到同一个DatabaseReference,这样TxManager控制同一个Connection的事务才有效果。

示例如下,系统中我是使用的Hibernate的Session

 

public class TxManagerImpl implements TxManager {

    private Connection conn;

    public TxManagerImpl(DatabaseReference dref) {

        this.conn = (Connection)dref;

    }

    public void begin() {

        conn.setAutoCommit(false);

    }

    public void commit() {

        conn.commit();

    }

    public void rollback() {

        conn.rollback();

    }

}

 

public class SampleDao implements Dao {

    Connection conn;

    public SampleDao(DatabaseReference dref){

        this.conn = (Connection)dref.get();

    }

    void update() {

        conn.executeQuery("...");

    }

}

 

Dao和TxManager之间有了纽带:DatabaseReference。然而,如果要控制事务,还需要一个控制类,将所有的Dao操作置于事务管理内。

 

 

public class TransactionAspect implements Aspect {

    Pointcut transactionPointcut = P.all();

    TxManager txManager;

 

    public TransactionAspect(TxManager transactionManager) {

        this.txManager = transactionManager;

    }

 

    public void introduce(AspectInstance arg0) {

    }

 

    public void advise(AspectInstance instance) {

        transactionPointcut.advise(instance, new MethodInterceptor() {

            public Object invoke(Invocation invocation) throws Throwable {

                txManager.begin();

                try {

                    Object o = invocation.invokeNext();

                    txManager.commit();

                    return o;

                } catch (Exception e) {

                   txManager.rollback();

                    throw e;

                }

            }

        });

    }

}

 

    这时就可以建立一个调用的实例了,这就需要PicoContainer来负责对象的创建和管理:

 

    MutablePicoContainer pico = new DefaultPicoContainer(

                new CachingComponentAdapterFactory(

                        new NanningComponentAdapterFactory()));

       

        pico.registerComponentImplementation(TxManager.class,

                TxManagerImpl.class);

        pico.registerComponentImplementation(TransactionAspect.class,

                TransactionAspect.class);

        pico.registerComponentImplementation(SampleDao.class);

 

        pico.getComponentInstances();

 

        Dao dao = (Dao) pico.getComponentInstance(SampleDao.class);

        dao.update();

   

上面用到的NanningComponentAdapterFactory,是NanoContainer中nanning包提供,负责将Nanning实例整合到PicoContainer。

从log中可以看到,dao的执行前后分别执行了begin和commit,这样我们就整合了AOP与IOC。

本文需要读者有一定的AOP和IOC知识。本文仅提供示例实现,提供一种思路。欢迎对此有兴趣的人来我blog探讨。

 

版权声明:

本文由冰云完成,首发于CSDN,作者保留中文版权。

未经许可,不得使用于任何商业用途。

欢迎转载,但请保持文章及版权声明完整。

如需联络请发邮件:icecloud(AT)sina.com

 

 

本文地址:http://com.8s8s.com/it/it16830.htm