该帖已经被评为良好帖
|
|
---|---|
作者 | 正文 |
发表时间:2007-05-17
开发目的:一个协同平台项目,多托管用户,单门户系统,每个托管用户对应一个单一数据库,要求根据登陆用户的单位信息,自动选择操作数据库;同时,涉及跨库操作(比如跨库查询,跨库单据发送);同时事务处理必须支持这种多数据库模式,支持一些逻辑性不强的跨库事务,比如一些数据的发送和接收等<o:p></o:p> 当然,如果说跨库操作只涉及到数据的发送和接受的话,也可以通过构建专门web service以及通信线程来处理,<o:p></o:p> 开发环境: tomcat4.1,webwork<st1:chsdate month="12" islunardate="False" day="30" year="1899" w:st="on" isrocdate="False">2.2.4</st1:chsdate>,spring2.0.4,hibernate3.1,osworkflow2.8,mysql5.0.19 由于正式发布的应用服务器是weblogic8.1,所以没有采用jdk5环境以及struts2<o:p></o:p> 准备:<o:p></o:p> 问题一 由于有跨库操作,而且这种跨库操作无法预知,有的跨库操作完全是在逻辑运行中决定的,比如A托管用户或则C、D向B托管用户发了订单 ,B回复,这个回复是根据订单发送者来说的,具体到后台操作,是无法事先预知针对具体哪个后台物理数据库操作的.所以,也就是说,存在在业务执行过程中切换数据库的情况,传统的到注入设置dao类 sessionFactory、靠filter以及Interceptor设置线程安全的sessionFactory都无法完全达到设计目的<o:p></o:p> 问题二 事务,本来,我打算用JtaTransactionManager的,除了JtaTransactionManager,在开始时也实在没想到什么好的办法, 难道,JtaTransactionManager是唯一选择么?<o:p></o:p> 步骤:<o:p></o:p> 、 因为问题一,所以系统在资源方面是多sessionFactory并存的方式,也就是多少个托管用户多少个sessionFactory,当然,事实上,这种应用型项目本身并发访问量不会太高(什么,很高么,总比不过广告联盟吧,哈哈).不用担心多了几个sessionFactory会对系统或则数据库造成多大影响.<o:p></o:p> <o:p> xml 代码
然后复制,粘贴,修改jdbcUrl,象网站编辑一样.. 假设,我配置了两个sessionFatory ,一个是mitSessionFactory,一个是testSessionFactory,如下:
xml 代码
这个我自己系统配置的一部分,系统会解析他,从而知晓究竟存在多少个sessionFactory,item's XmlNode中的id可以理解会托管客户的客户单位<o:p></o:p> 编号,当然,这个配置完全可以忽略,直接从ApplicationContext中一样可以获取到这样的信息<o:p></o:p> 在客户登陆的时候,系统要记录下该客户所属托管单位,然后通过上面的id找到bean's name ,最后获取这个sessionFactory,托管单位信息一般<o:p></o:p> 都是个编号而已跟己方系统的托管用户管理相结合,一般是保存这个编号在session里面,也可以象asp.net一样,记录在安全凭证里,还不知道JAVA方面有没有类似实现,个人认为asp.net这个方法很值得采用,虽然MS号称安全系数+++++这个观点值得怀疑<o:p></o:p> <o:p> </o:p> 首先建立一个类,HibernateSupport ,存放当前请求线程所需sessionFactoryjava 代码
java 代码
多sessionFactory好做,配置在spring或则单独拿出来处理都可以,但是spring的HibernateDaoSupport 必须绑定一个sessionFactory,当然,我们完全可以写一个自己的HibernateDaoSupport ,但是既然用了spring的事务管理而又不想多花时间,还是将就改改用吧
java 代码
去掉HibernateAccessor 和HibernateTransactionManager中的上述两段代码,当然,也别忘了毙掉两个类中的<o:p></o:p> afterPropertiesSet方法中那些检查代码<o:p></o:p> 然后 ,ant打包就可以了,如果不想修改spring的代码,也可以单独把这几个类提出来另建jar包,我是单独提出来新建的,比如HibernateTransactionManager我改名成CHibernateTransactionManager,其他类似,但是包名必须是org.springframework.orm.hibernate3 ,谁也不想这么做,可是谁让sessionFactoryUtils中一个closexxxx方法没定义成public了??<o:p></o:p> 如果想变更sessionFactoryUtils,奉劝算了吧..<o:p></o:p> 然后可以做测试了,首先,部署测试的dao和service,先是事务部署<o:p></o:p> xml 代码
声明:ITeye文章版权属于作者,受法律保护。没有作者书面许可不得转载。
推荐链接
|
|
返回顶楼 | |
发表时间:2007-05-18
"其实,也有解决方法,就是延迟提交,具体实现方式以后讲述"
以下存属个人理解: 其实JtaTransactionManager做的正是这一点, 在spring中通过TransactionSynchronizer来实现的:service.save()并不会commit,而是将当前Transaction放入一个ThreadLocal的Transaction list里,到结束时一起处理. 楼主代码不错,适合于写框架,呵呵 |
|
返回顶楼 | |
发表时间:2007-05-18
http://www.linuxworld.com/news/2007/jw-04-xa.html
|
|
返回顶楼 | |
发表时间:2007-05-18
的确,我的确是按照Transaction list这个思路做的,通过新建一个PlatformTransactionManager类,大部分参照AbstractPlatformTransactionManager的内容,只是在这两个类的commit和rollback里面做点控制就可以了
|
|
返回顶楼 | |
发表时间:2007-05-19
hsqldb里的transaction是row transaction
就像command pattern的undo,而且还有一个MEMENTO,入在log里. dist transaction的机制应该差不多,只是加了个message queue |
|
返回顶楼 | |
发表时间:2007-05-19
家里网络环境不好,本来想修改下里面的代码格式,结果成了半截子,我转到回复里面来写把3
事务配置如下: <bean id="transactionManager" class="com.mit.web.hibernate.CHibernateTransactionManager"/> <bean id="transres" class="org.springframework.transaction.interceptor.NameMatchTransactionAttributeSource"> <property name="properties"> <props> <prop key="load*">PROPAGATION_REQUIRED,readOnly</prop> <prop key="save*">PROPAGATION_REQUIRED</prop> <prop key="delete*">PROPAGATION_REQUIRED</prop> <prop key="find*">PROPAGATION_REQUIRED,readOnly</prop> <prop key="query*">PROPAGATION_REQUIRED,readOnly</prop> <prop key="create*">PROPAGATION_REQUIRED</prop> <prop key="set*">PROPAGATION_REQUIRED,readOnly</prop> <prop key="execute*">PROPAGATION_REQUIRED</prop> </props> </property> </bean> <bean id="transactionInterceptor" class="org.springframework.transaction.interceptor.TransactionInterceptor"> <property name="transactionManager" ref="transactionManager"/> <property name="transactionAttributeSource"><ref local="transres"/></property> </bean> <bean class="org.springframework.aop.framework.autoproxy.BeanNameAutoProxyCreator"> <property name="beanNames"><value>*Service</value></property> <property name="interceptorNames"> <list> <value>transactionInterceptor</value> </list> </property> </bean> <bean class="org.springframework.transaction.interceptor.TransactionAttributeSourceAdvisor"> <property name="transactionInterceptor" ref="transactionInterceptor"/> </bean> 我把事务配置在service层,事务管理采用的是我修改后的HibernateTransactionManager ,他不在要求sessionFactory的注入了 以下是测试的dao类和service类配置 <bean id="personDao" class="com.mit.web.action.PersonDaoImpl"/> <bean id="personService" class="com.mit.web.action.PersonServiceImpl"> <property name="personDao"> <ref bean="personDao"/> </property> </bean> <bean id="departDao" class="com.mit.web.action.DepartDaoImpl"/> <bean id="departService" class="com.mit.web.action.DepartServiceImpl"> <property name="personService"> <ref bean="personService"/> </property> <property name="departDao"> <ref bean="departDao"/> </property> </bean> 具体代码不写了,大概如下: public class PersonDaoImpl extends CHibernateDaoSupport implements PersonDao; public class PersonServiceImpl implements PersonService; public class DepartDaoImpl extends CHibernateDaoSupport implements DepartDao; public class DepartServiceImpl implements DepartService; 测试代码的目的是将两个实体类分别存放到mit和test库,假设默认用户是mit这个托管库的,这个方法就写在DepartServiceImpl类里面 public class DepartServiceImpl implements DepartService { private DepartDao dao; private PersonService service; .............................. public void executeTest(Depart depart,Person person) { dao.save(depart); HibernateSupport.switchFactory("test"); service.save(person); HibernateSupport.restoreFactory(); } .............................. 上面代码中将depart对象存到mit库,而将person对象存到test库中. 事务 事务 ,没看见特别事务设置? 其实事务已经在运行了 如前面配置,事务我配置在了service层,那么当executeTest执行时,会启动针对mit库的事务(前面我们改了HibernateTransactionManager的sessionFactory获取方式), dao.save(depart);//然后保存depart到mit库 HibernateSupport.switchFactory("test");//切换库到test service.save(person);//调用personService的save方法,这也是个service,所以也会产生一个事务,而此时HibernateSupport.getCurrentFactory返回的sessionFactory已经是test库的了,所以,spring事务管理发现上下文中并没有针对test的事务,于是,会重新启动一个新的事务,这个service.save(person);方法执行完后,这个事务将会提交 HibernateSupport.restoreFactory();//切换回默认数据库 整个方法执行完后,针对mit的事务将会被提交 [color=green]如果service.save(person);发生异常,这两个事务就会被提交,一个简单跨库事务控制完成[color=green] 但是,问题也随之而来,如果在 HibernateSupport.restoreFactory();后,又进行了一些逻辑操作,那么发生异常时,而由于 service.save(person);这个事务已经被提交,也就是说,针对test的事务已经提交不会回滚了,这是个非常严重的问题。。 其实,也有解决方法,就是延迟提交,具体实现方式以后讲述 |
|
返回顶楼 | |
发表时间:2007-05-19
跨库事务之延迟提交
延迟事务,就是将事务延后提交,延迟的时间由事务管理器掌握。在我的系统中,只有跨库操作涉及到延迟提交,针对这种操作,我设计了一个基本的执行模型。就是如果一个逻辑中存在多个事务,将全部放到逻辑执行完以后提交,那么,既然如此,开始吧 PlatformTransactionManager是spring平台相关事务,比如HibernateTransactionManager都是继承于此类,为了达到延迟提交的目的,可以在AbstractPlatformTransactionManagershang上做修改达到目的 首先,说一下在spring中,通常的一个事务流程, 流程如下:初始化Transaction B,如果发现前面有其他Transaction ,比如 Transaction A,那么挂起TransactionA ,然后启动事务 ,当逻辑执行完后 ,commit,恢复挂起事务A,然后清除同步对象以及其他资源,如果执行发生异常,当然,异常发生后 rollback 延迟提交的设计思想是将事务都暂存在一个threadlocal的LIST里面,等逻辑执行完以后,再统一提交,那么首先在AbstractPlatformTransactionManager中设置一个threadlocal对象 private ThreadLocal lazytrace = new ThreadLocal(); LazyTransactionStatus用来管理需要延迟提交的事务 private static class LazyTransactionStatus { private java.util.List transliat; private int transnum;//代表未提交事务数量 public LazyTransactionStatus() { transliat= new java.util.ArrayList(); transnum=0; } public void newLazy() { transnum++; } public void push(TransactionStatus trasobj) { objmap.add(trasobj); } public void removeLazy(TransactionStatus trasobj) { transnum--; } public boolean canCommit() { if (transnum<1) { return true; } else return false; } public java.util.List getTransactionObjs() { return transliat; } } } 这就是local对象的存储内容.translist存放当前执行中的TransactionStatus实例 TransactionStatus顾名思义,事务状态,包含了事务、挂起资源等一系列信息 然后以事务提交为例 然后在AbstractTransactionManager增加如下两个方法 public final boolean isCommit(TransactionStatus status) { if (lazytrace.get()!=null) { LazyTransactionStatus lazystatus = (LazyTransactionStatus)lazytrace.get(); lazystatus.removeLazy(status); return lazy.canCommit(); } return true; } protected void begin(Object transaction, TransactionDefinition definition) { doBegin(transaction,definition); LazyTransactionStatus lazystatus = null; if (lazytrace.get()==null) { lazystatus = new LazyTransactionStatus(); lazytrace.set(lazystatus); } else { lazystatus = (LazyTransactionStatus)lazytrace.get(); } lazystatus.newLazy(); } public final void registerTraceStatus(TransactionStatus status) { LazyTransactionStatus lazystatus = null; if (lazytrace.get()==null) { lazystatus = new LazyTransactionStatus(); lazytrace.set(lazystatus); } else { lazystatus = (LazyTransactionStatus)lazytrace.get(); } lazystatus.push(status); } begin ,当一个事务开始时,将LazyTransactionStatus的transnum+1,表示又多了个刚开始,还未提交的事务 registerTraceStatus发生在commit的时候,注册这个事务到LazyTransactionStatus,同时, 注意 transnum表示的是未提交事务数量,所以当事务管理器执行commit表示要提交一个事务后,transnum将减一,如果减一后发现transnum<1,表示所有事务都提交了,那么,将所有事务提交。否则,不提交,继续等待... 关系如下: begin->transnum+1 表示新事务诞生 registerTraceStatus(发生在commit的时候)->将准备提交的TransStatus放到LazyTransactionStatus,是的,这个事务要提交了,来吧,先注册一下 紧接着 isCommit()->将transnum-1,如果发现transnum小于1 ,表示闹够了,可以都提交滚蛋了 注意 ,transnum与LazyTransactionStatus的translist的链表长度在执行commit的时候是反方向发展的 一个增,一个减 好了,首先是注册事务数量,不用管了,在事务开始时begin方法它自己会调用了, 然后是修改AbstractPlatformTransactionManager的commit方法 public final void commit(TransactionStatus txstatus) throws TransactionException { this.registerTraceStatus(txstatus); if (this.isCommit(txstatus)) { int error = 0; LazyTransactionStatus lazystatus = (LazyTransactionStatus)lazytrace.get(); List statuslist = lazystatus.getTransactionObjs(); for (int i=0;i<statuslist.size();i++) { try { TransactionStatus status = (TransactionStatus)statuslist.get(i); if (status.isCompleted()) { error++; continue; //throw new IllegalTransactionStateException( // "Transaction is already completed - do not call commit or rollback more than once per transaction"); } DefaultTransactionStatus defStatus = (DefaultTransactionStatus) status; if (defStatus.isLocalRollbackOnly()) { if (defStatus.isDebug()) { logger.debug("Transactional code has requested rollback"); } processRollback(defStatus); error++; continue; } if (!shouldCommitOnGlobalRollbackOnly() && defStatus.isGlobalRollbackOnly()) { if (defStatus.isDebug()) { logger.debug("Global transaction is marked as rollback-only but transactional code requested commit"); } processRollback(defStatus); // Throw UnexpectedRollbackException only at outermost transaction boundary // or if explicitly asked to. if (status.isNewTransaction() || isFailEarlyOnGlobalRollbackOnly()) { //throw new UnexpectedRollbackException( //"Transaction rolled back because it has been marked as rollback-only"); error++; continue; } continue; } processCommit(defStatus); } catch (Exception ex) { error++; ex.printStackTrace(); continue; } } lazytrace.set(null); if (error>0) throw new IllegalTransactionStateException( "Not commit all transaction"); } } this.registerTraceStatus(txstatus);//事务提交了,成了嫌疑犯,拖到threadlocal的LazyTransactionStatus监狱里面先关起来 if (isCommit()) //看看监狱的事务是不是满了,如果满了,就可以全放了 LazyTransactionStatus lazystatus = (LazyTransactionStatus)lazytrace.get(); List statuslist = lazystatus.getTransactionObjs(); for (int i=0;i<statuslist.size();i++) { ........ processCommit(defStatus); //看来真的满了,都放了吧 回滚道理是一样的,不过不用判断了,直接全部放出来让他们滚吧 当然,目前这个实现只是个模型,真要实际应用,还需要做进一步封装,实际做,我用了OpenSessionInViewFilter,我已经做过测试,测试了了OpenSessionInViewFilter中singleSession为true和false两种情况,测试都通过了,呵呵 |
|
返回顶楼 | |
发表时间:2007-09-20
CHibernateTransactionManager代码是怎么样的呢?帖出来好吗?用了你上面的代码,到一半了,我也想试用多数据源
|
|
返回顶楼 | |
发表时间:2007-10-06
tomcat 不能用JTA吧, 用了JTOM吗?
|
|
返回顶楼 | |
浏览 37885 次