- 浏览: 564261 次
- 性别:
- 来自: 成都
文章分类
最新评论
-
a1641693970:
还不错,学习了
BeanUtils使用总结(二)LazyDynaBean -
zjfshowtime:
很好的办法,学习了。
ORA-28001: the password has expired -
ya654277yo:
哦,多谢分享
Apache整合Tomcat后get方式提交中文乱码问题解决 -
foolkeeper:
nice !!
jvm内存参数设定 -
tracy821:
谢谢了,找了好久才找到
关于Spring 声明式事务处理时,throws exception不回滚的问题
Spring 中集成 JOTM 配置 JTA 事务:
假如业务中要用到多个数据库,我们希望在业务方法中,当对某一个数据库的数据表进行操作的事务失败并回退(rollback),另外某一个数据库的数据表的操作事务也要回退,但应用一般的事务管理达不到这样的事务管理效果,这就需要实现 JTA 事务管理了。
这里我们在SPring中集成 Object web 的一个开源JTA实现JOTM (可以在http://jotm.objectweb.org
下载完整版) 来实现JTA事务管理。
1、将必须的类包放入类路径中:
jotm.jar, xapool.jar, jotm_jrmp_stubs.jar, jta-spect1_0_1.jar, connector-1_5.jar等等。
2、编写JOTM配置文件carol.properties,将其放到类路径下:
- #JNDI调用协议
- carol.protocols=jrmp
- #不使用CAROL JNDI封装器
- carol.start.jndi= false
- #不启动命名服务器
- carol.start.ns= false
3、在MYSQL中创建两个数据库 "jtatesta","jtatestb":
- CREATE DATABASE IF NOT EXISTS jtatesta;
- USE jtatesta;
- DROP TABLE IF EXISTS `user`;
- CREATE TABLE `user` (
- `user_id` int ( 10 ) unsigned NOT NULL auto_increment,
- `user_name` varchar( 45 ) NOT NULL,
- `user_password` varchar( 45 ) NOT NULL,
- PRIMARY KEY (`user_id`)
- ) ENGINE=InnoDB AUTO_INCREMENT= 5 DEFAULT CHARSET=latin1;
- INSERT INTO `user` (`user_id`,`user_name`,`user_password`) VALUES
- ( 1 , 'tufu' , 'tufu' );
- CREATE DATABASE IF NOT EXISTS jtatestb;
- USE jtatestb;
- DROP TABLE IF EXISTS `grade`;
- CREATE TABLE `grade` (
- `grade_id` int ( 10 ) unsigned NOT NULL auto_increment,
- `user_id` int ( 10 ) unsigned NOT NULL,
- `grade` double NOT NULL,
- PRIMARY KEY (`grade_id`)
- ) ENGINE=InnoDB AUTO_INCREMENT= 9 DEFAULT CHARSET=latin1;
- INSERT INTO `grade` (`grade_id`,`user_id`,`grade`) VALUES
- ( 1 , 0 , 100 );
4、域对象、数据访问类和其他事务管理的一样,如:
- //Domain对象User.java:
- package com.domain;
- import java.io.Serializable;
- public class User implements Serializable {
- private int user_id;
- private String user_name;
- private String user_password;
- ...... //省略set、get方法
- }
- //Domain对象Grade.java:
- package com.domain;
- import java.io.Serializable;
- public class Grade implements Serializable{
- private int grade_id;
- private User user;
- private double grade;
- ..... //省略set、get方法
- }
- 应用Spring JDBC的DAO:(省略DAO接口)
- //UserJdbcDao.java:
- package com.dao.jdbc;
- import org.springframework.jdbc.core.support.JdbcDaoSupport;
- import com.dao.UserDao;
- import com.domain.User;
- public class UserJdbcDao extends JdbcDaoSupport implements UserDao{
- public void addUser(User user){
- String SQL = "INSERT INTO user(user_id,user_name,user_password) VALUES(?,?,?)" ;
- Object[] params = new Object[]{
- user.getUser_id(),user.getUser_name(),user.getUser_password()
- };
- this .getJdbcTemplate().update(SQL, params);
- }
- }
- //GradeJdbcDao.java:
- package com.dao.jdbc;
- import com.dao.GradeDao;
- import com.domain.Grade;
- import org.springframework.jdbc.core.support.JdbcDaoSupport;
- public class GradeJdbcDao extends JdbcDaoSupport implements GradeDao{
- public void addGrade(Grade grade){
- final String SQL = "INSERT INTO grade(user_id,grade) VALUES(?,?)" ;
- Object[] params = new Object[]{
- grade.getUser().getUser_id(),grade.getGrade()
- };
- this .getJdbcTemplate().update(SQL, params);
- }
- }
5、应用了JTA事务管理的业务类(省略了接口),用@Transactional注解标注,以在配置文件中可以用<tx:annotation-driven>注解驱动自动进行事务增强:
- package com.service.impl;
- import com.dao.GradeDao;
- import com.dao.UserDao;
- import com.domain.*;
- import org.springframework.transaction.annotation.Transactional;
- import com.service.MyService;
- @Transactional
- public class MyServiceImpl implements MyService {
- private UserDao userDao;
- private GradeDao gradeDao;
- public void setUserDao(UserDao userDao){
- this .userDao = userDao;
- }
- public void setGradeDao(GradeDao gradeDao){
- this .gradeDao = gradeDao;
- }
- @Transactional (readOnly= false )
- public void addGrade(User user,Grade grade){
- //假如希望两个添加数据的事务,其中有一个添加失败时,均回滚,
- //由于两个操作是在两个不同的数据库上进行的,故要JTA事务来进行管理
- //否则,将会出现添加一个,回滚一个的情形
- gradeDao.addGrade(grade);
- userDao.addUser(user);
- }
- }
6、spring为JOTM提供了一个org.springframework.transaction.jta.JotmFactoryBean 支持类,可以用其方便地创建本地JOTM实例。
具体的配置文件app_jta.xml如下:
- <? xml version = "1.0" encoding = "UTF-8" ?>
- < beans xmlns = "http://www.springframework.org/schema/beans"
- xmlns:xsp = "http://www.w3.org/2001/XMLSchema-instance"
- xmlns:aop = "http://www.springframework.org/schema/aop"
- xmlns:tx = "http://www.springframework.org/schema/tx"
- xsp:schemaLocation ="http://www.springframework.org/schema/beans
- http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
- http://www.springframework.org/schema/aop
- http://www.springframework.org/schema/aop/spring-aop-2.0.xsd
- http://www.springframework.org/schema/tx
- http://www.springframework.org/schema/tx/spring-tx-2.0.xsd" >
- <!--JOTM本地实例-->
- < bean id = "jotm" class = "org.springframework.transaction.jta.JotmFactoryBean" />
- <!--JTA事务管理器-->
- < bean id = "txManager" class = "org.springframework.transaction.jta.JtaTransactionManager" >
- < property name = "userTransaction" ref = "jotm" /> <!--指定userTransaction属性引用JOTM本地实例-->
- </ bean >
- <!--XAPool配置,内部包含了一XA数据源,对应了数据库jtatesta
- 支持JTA事务的数据源,必须封装成XAPool-- >
- < bean id = "jtaTestADS" class = "org.enhydra.jdbc.pool.StandardXAPoolDataSource"
- destroy-method = "shutdown" >
- < property name = "dataSource" > <!--内部XA数据源-->
- < bean class = "org.enhydra.jdbc.standard.StandardXADataSource"
- destroy-method = "shutdown" >
- < property name = "transactionManager" ref = "jotm" />
- < property name = "driverName" value = "com.mysql.jdbc.Driver" />
- < property name = "url" value = "jdbc:mysql://localhost/jtatesta" />
- </ bean >
- </ property >
- < property name = "user" value = "root" />
- < property name = "password" value = "885123" />
- </ bean >
- <!--类似地,对应了数据库jtatestb的XAPool配置,内部包含了一XA数据源-->
- < bean id = "jtaTestBDS" class = "org.enhydra.jdbc.pool.StandardXAPoolDataSource"
- destroy-method = "shutdown" >
- < property name = "dataSource" > <!--内部XA数据源-->
- < bean class = "org.enhydra.jdbc.standard.StandardXADataSource"
- destroy-method = "shutdown" >
- < property name = "transactionManager" ref = "jotm" />
- < property name = "driverName" value = "com.mysql.jdbc.Driver" />
- < property name = "url" value = "jdbc:mysql://localhost/jtatestb" />
- </ bean >
- </ property >
- < property name = "user" value = "root" />
- < property name = "password" value = "885123" />
- </ bean >
- <!--分别配置访问jtaTestADS、jtaTestBDS数据源的Spring JDBC模板-->
- < bean id = "jtaTestATemplate" class = "org.springframework.jdbc.core.JdbcTemplate" >
- < property name = "dataSource" ref = "jtaTestADS" />
- </ bean >
- < bean id = "jtaTestBTemplate" class = "org.springframework.jdbc.core.JdbcTemplate" >
- < property name = "dataSource" ref = "jtaTestBDS" />
- </ bean >
- <!--分别配置基于模板jtaTestADS,jtaTestBDS的DAO-->
- < bean id = "userDao" class = "com.dao.jdbc.UserJdbcDao" >
- < property name = "jdbcTemplate" ref = "jtaTestATemplate" />
- </ bean >
- < bean id = "gradeDao" class = "com.dao.jdbc.GradeJdbcDao" >
- < property name = "jdbcTemplate" ref = "jtaTestBTemplate" />
- </ bean >
- <!--跨数据库的JTA事务的业务类-->
- < bean id = "myService" class = "com.service.impl.MyServiceImpl" >
- < property name = "userDao" ref = "userDao" />
- < property name = "gradeDao" ref = "gradeDao" />
- </ bean >
- <!--注解事务驱动-->
- < tx:annotation-driven transaction-manager = "txManager" proxy-target-class = "true" />
- </ beans >
7、测试main方法:
- import com.service.MyService;
- import com.service.impl.MyServiceImpl;
- import com.domain.*;
- import org.springframework.context.support.ClassPathXmlApplicationContext;
- public class TestMain {
- public static void main(String args[]){
- ClassPathXmlApplicationContext ctx =
- new ClassPathXmlApplicationContext( "beans_jta.xml" );
- MyService ms = (MyServiceImpl)ctx.getBean( "myService" );
- User user = new User();
- //特意添加一个重复的主键,以使添加user的事务失败并回退
- //如果此时应用JTA事务失败,将仍会执行添加grade的事务并提交(前提是先于添加user操作)
- //如果应用JTA事务成功,就会两个添加事务同时执行或同时回退。
- user.setUser_id( 1 );
- user.setUser_name( "tufu" );
- user.setUser_password( "tufu" );
- Grade grade = new Grade();
- grade.setGrade( 100 );
- grade.setUser(user);
- ms.addGrade(user,grade);
- }
- }
注:将log4j.properties中的log4j日志设置为DEBUG级别,可以看到详细的JTA事务执行情况:
.......
log4j.rootLogger=DEBUG,R,A1
.......
在特定应用服务器使用JTA
一般来说,Spring的事务抽象与应用服务器是无关的。不过,如果你如果希望事务管理器使用特定的UserTransaction 和
TransactionManager 对象(可以被自动探测),以获取更多的增强事务语义。这时,针对不同的Java
EE应用服务器,Spring的事务管理器可以采取不同的配置。 3 d0 W4 y5 k3 u, h! G
BEA WebLogic
在一个使用WebLogic 7.0、8.1或更高版本的环境中,你一般会优先选用特定于WebLogic的
WebLogicJtaTransactionManager 类来取代基础的 JtaTransactionManager
类,因为在WebLogic环境中,该类提供了对Spring事务定义的完全支持,超过了标准的JTA语义。你可以使用以下的配置达到目的:
<bean id="txManager" class="org.springframework.transaction.jta.WebLogicJtaTransactionManager"/> 7 n6 e" n' j: m9 X- Q
它的特性包括:支持事务名,支持为每个事务定义隔离级别,以及在任何环境下正确地恢复事务的能力。
IBM WebSphere
. |' v# o% K7 }( K& B
在WebSphere 5.1、5.0和4.x环境下,你可以使用Spring的
WebSphereTransactionManagerFactoryBean
类。这是一个工厂类,通过WebSphere的静态访问方法(每个版本的WebSphere中都不同)获取到JTA
TransactionManager 实例。一旦通过工厂bean获取到JTA TransactionManager
实例,就可以使用该实例装配一个Spring的 JtaTransactionManager bean,它封装了JTA
UserTransaction,提供增强的事务语义。你可以按以下方式进行配置: 8 |6 Y+ C: C: k6 C
①引用WebSphere的JTA事务管理器
< bean id = " wsJtaTm " class = " org.springframework.transaction.jta.WebSphereTransactionManagerFactoryBean " />
< bean id = " transactionManager " class = " org.springframework.transaction.jta.JtaTransactionManager " >
< property name = " transactionManager ref= " wsJtaTm " />
</
bean
>
小结
你既可以在没有任务应用服务器支持的情况下,直接通过集成JOTM在Spring中使用JTA事务管理,也可以通过引用Java
EE应用服务器的JNDI数据源,利用应用服务器提供的JTA事务功能间接实现Spring 中的JTA事务管理。为了利用一些高级Java
EE应用服务器的JTA事务高级功能,你可以通过Spring所提供的特定于应用服务器的JTA事务管理器进行配置。
发表评论
-
F5负载均衡WAS重定向端口问题
2014-05-27 11:09 3349基于F5 WAS负载均衡,可直接通过IP访问首页http:X ... -
Spring 多数据源声明式事务控制(PlatformTransactionManager )
2014-04-11 18:31 4653首先是TransactionManager的配置: ... -
Spring 动态数据源(AbstractRoutingDataSource )
2014-04-11 18:25 1592Spring动态配置多数据源,即在大型应用中对数据进行横向 ... -
(转)Spring Security 3.0 多页面登录配置
2012-10-19 17:01 5340网上很多文章是关于Spri ... -
同一个Weblogic两个Domain CookieName冲突导致session失效问题
2012-09-25 11:03 2855问题描述: 同一个weblogic下新 ... -
EL表达式在tomcat7.0下的new关键字不能使用
2012-08-24 17:25 3998最近生产系统部署个小应用,服务器选型tomcat7.0,一直运 ... -
设置WebLogic启动内存
2012-07-02 20:25 1439我们经常在使用WebLoigc部署应用程序后,发现程序运行速度 ... -
Tomcat处理HTTP请求源码分析(下)
2012-05-18 17:18 1309很多开源应用服务器都是集成tomcat作为web contai ... -
Tomcat处理HTTP请求源码分析(上)
2012-05-18 17:16 1134很多开源应用服务器都是集成tomcat作为web contai ... -
Tomcat配置集锦
2012-05-16 16:37 980配置基础验证(Basic Authentication) 容 ... -
多Tomcat多JDK部署
2012-03-23 17:51 10581、bin/catalina.bat: echo Using ... -
linux下apache、tomcat的安装及优化
2012-02-29 11:48 4153本文主要内容: (1)安装apr,这是 Apache 为了提 ... -
在Tomcat中通过JOTM支持JTA
2011-12-27 19:40 2038Tomcat是Servlet容器,但它提供了JND ... -
jconsole监控JVM
2011-12-12 17:46 1516本地监控: Jconsole [processed] ... -
Spring 3.1整合EhCache
2011-08-29 16:42 1422Spring 3.1提供了对cache的 ... -
APACHE实现负载均衡
2011-08-09 12:58 1245随 着访问量的不断提高,以及对响应速度的要求,进行负载均衡设 ... -
理解session机制
2011-05-19 11:59 1373session机制是一种服务器端的机制,服务器使用一种类似于散 ... -
spring集成xfire教程
2011-04-02 15:20 1537配置web.xml <!-- SPRING ... -
(转)Tomcat5集群中的SESSION复制 (3)
2010-12-08 16:46 992集群安装 为了 ... -
(转)Tomcat 5集群中的SESSION复制(2)
2010-12-08 16:45 1456Tomcat 5中的SESSION复制 ...
相关推荐
1 通过集成JOTM,直接在Spring中使用JTA事务 1.1. 将JOTM以下类库添加到类路径中 1.2. 编写JOTM配置文件,放到类路径下 1.3. 在MySQL上建立两个数据库 1.4. 在Spring配置文件中配置JOTM 1.5. 在Spring中运行测试 2 ...
NULL 博文链接:https://zhaoshijie.iteye.com/blog/1836707
JCaptcha4Struts2 是一个 Struts2的插件,用来增加验证码的支持,使用时只需要用一个 JSP 标签 (<jcaptcha:image label="Type the text "/> ) 即可,直接在 struts.xml 中进行配置,使用强大的 JCaptcha来生成验证码...
JCaptcha4Struts2 是一个 Struts2的插件,用来增加验证码的支持,使用时只需要用一个 JSP 标签 (<jcaptcha:image label="Type the text "/> ) 即可,直接在 struts.xml 中进行配置,使用强大的 JCaptcha来生成验证码...
JCaptcha4Struts2 是一个 Struts2的插件,用来增加验证码的支持,使用时只需要用一个 JSP 标签 (<jcaptcha:image label="Type the text "/> ) 即可,直接在 struts.xml 中进行配置,使用强大的 JCaptcha来生成验证码...
JCaptcha4Struts2 是一个 Struts2的插件,用来增加验证码的支持,使用时只需要用一个 JSP 标签 (<jcaptcha:image label="Type the text "/> ) 即可,直接在 struts.xml 中进行配置,使用强大的 JCaptcha来生成验证码...
JCaptcha4Struts2 是一个 Struts2的插件,用来增加验证码的支持,使用时只需要用一个 JSP 标签 (<jcaptcha:image label="Type the text "/> ) 即可,直接在 struts.xml 中进行配置,使用强大的 JCaptcha来生成验证码...
JCaptcha4Struts2 是一个 Struts2的插件,用来增加验证码的支持,使用时只需要用一个 JSP 标签 (<jcaptcha:image label="Type the text "/> ) 即可,直接在 struts.xml 中进行配置,使用强大的 JCaptcha来生成验证码...
JCaptcha4Struts2 是一个 Struts2的插件,用来增加验证码的支持,使用时只需要用一个 JSP 标签 (<jcaptcha:image label="Type the text "/> ) 即可,直接在 struts.xml 中进行配置,使用强大的 JCaptcha来生成验证码...
JCaptcha4Struts2 是一个 Struts2的插件,用来增加验证码的支持,使用时只需要用一个 JSP 标签 (<jcaptcha:image label="Type the text "/> ) 即可,直接在 struts.xml 中进行配置,使用强大的 JCaptcha来生成验证码...
JCaptcha4Struts2 是一个 Struts2的插件,用来增加验证码的支持,使用时只需要用一个 JSP 标签 (<jcaptcha:image label="Type the text "/> ) 即可,直接在 struts.xml 中进行配置,使用强大的 JCaptcha来生成验证码...
JCaptcha4Struts2 是一个 Struts2的插件,用来增加验证码的支持,使用时只需要用一个 JSP 标签 (<jcaptcha:image label="Type the text "/> ) 即可,直接在 struts.xml 中进行配置,使用强大的 JCaptcha来生成验证码...
JCaptcha4Struts2 是一个 Struts2的插件,用来增加验证码的支持,使用时只需要用一个 JSP 标签 (<jcaptcha:image label="Type the text "/> ) 即可,直接在 struts.xml 中进行配置,使用强大的 JCaptcha来生成验证码...
JCaptcha4Struts2 是一个 Struts2的插件,用来增加验证码的支持,使用时只需要用一个 JSP 标签 (<jcaptcha:image label="Type the text "/> ) 即可,直接在 struts.xml 中进行配置,使用强大的 JCaptcha来生成验证码...
JCaptcha4Struts2 是一个 Struts2的插件,用来增加验证码的支持,使用时只需要用一个 JSP 标签 (<jcaptcha:image label="Type the text "/> ) 即可,直接在 struts.xml 中进行配置,使用强大的 JCaptcha来生成验证码...
在有状态SessionBean中,用累加器,以对话状态存储起来,创建EJB对象,并将当前的计数器初始化,调用每一个EJB对象的count()方法,保证Bean正常被激活和钝化,EJB对象是用完毕,从内存中清除…… Java Socket 聊天...
在有状态SessionBean中,用累加器,以对话状态存储起来,创建EJB对象,并将当前的计数器初始化,调用每一个EJB对象的count()方法,保证Bean正常被激活和钝化,EJB对象是用完毕,从内存中清除…… Java Socket 聊天...