关于Tomcat 结合Atomikos 实现JTA的方法

最近项目切换环境，把weblogic 换成tomcat 记录中间遇到的问题
Tomcat下配置Atomikos实现JTA
Tomcat作为一款经典的Web服务器，在开发、测试和生产环境中得到了广泛的使用。但Tomcat毕竟不是Java EE服务器，因此在EJB，JTA方面并没有提供支持。本文讲述了Tomcat使用Atomikos实现JTA的一种方法。

 在Tomcat中使用JTA，可以将Atomikos部署在Tomcat中，使用Tomcat支持的数据源；也可以在项目中配置，利用Spring配置好数据源、连接池、事务管理器等等。两种方式各有特点，本文只介绍Tomcat与Atomikos的集成，集成后Tomcat可以对外提供JTA的事务管理器和数据源。

         在使用Atomikos之前，我们也曾使用过JOTM，不过在高并发的情况下，JOTM频频出错，最后不得不放弃，通过测试，发现Atomikos性能和稳定性都不错。

         我们使用了Atomikos最新的4.04版本，Jar包的获取可以从maven的配置库中得到，链接地址：http://mvnrepository.com/artifact/com.atomikos

如果不使用Hibernate，需要的包包括：

atomikos-util.jar,
jta.jar,
transactions.jar,
transactions-api.jar,
transactions-jdbc.jar,
transactions-jta.jar

集成包：
atomikos-integration-extension-3.7.2.jar

记得放数据库 驱动

Step 1：将这些jar 拷贝到tomcat 的lib 目录中。要实现Tomcat与Atomikos集成，还需要一个集成包，这个集成包里面有两个class,可以自己参考实现，也可以使用官方提供的jar包，最新的是

atomikos-integration-extension-3.7.2.jar

Step2：在tomcat/config/server.xml中 增加一个监听器

  <Listener className="com.atomikos.tomcat.AtomikosLifecycleListener" />

Step3：在tomcat/config/context.xml中增加数据源和相关的事务管理器，下面是一个参考的例子，参数酌情修改

 <Resource name="jdbc/DS_MYSQL"

            auth="Container"

            type="com.atomikos.jdbc.AtomikosDataSourceBean"

            uniqueResourceName="jdbc/DS_MYSQL"

            xaDataSourceClassName="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"

            xaProperties.databaseName="db_test"

            xaProperties.serverName="localhost"

            xaProperties.port="3306"

            xaProperties.user="root"

            xaProperties.password="root"

            maxPoolSize="200"

            xaProperties.url="jdbc:mysql://localhost:3306/db_test?characterEncoding=UTF8"

            factory="com.atomikos.tomcat.EnhancedTomcatAtomikosBeanFactory" />

  <Resource name="UserTransaction"

            auth="Container"

            type="javax.transaction.UserTransaction" />   

   <Transaction factory="com.atomikos.icatch.jta.UserTransactionFactory" />

Step4：在tomcat/lib目录下增加一个jta.properties文件，设置Atomikos事务相关的参数，否则将使用默认的配置参数，一些并发事务数（默认50个），超时时间等都需要调整，下面给出了文件中的一些参数配置，参数解释请查阅官方文档：https://www.atomikos.com/Documentation/JtaProperties

添加此行配置

com.atomikos.icatch.service=com.atomikos.icatch.standalone.UserTransactionServiceFactory

 Atomikos中参数的默认值在transactions.jar中定义，transactions-default.properties：有兴趣的可以自己去看

     配置完以上四个步骤，Tomcat的集成就算完成了，项目中可以使用Spring来关联数据源和事务管理器，参考配置如下：

<!-- JNDI模板配置信息，用于连接应用服务器-->

<bean class="org.springframework.jndi.JndiTemplate" id="jndiTemplate" />
<bean class="org.springframework.jndi.JndiObjectFactoryBean" id="dataSource">

    <property name="jndiName">

        <value>java:comp/env/jdbc/DS_MYSQL</value>

    </property>

    <property name="jndiTemplate">

        <ref bean="jndiTemplate"/>

    </property>

</bean>

<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">

    <property name="dataSource">

        <ref bean="dataSource" />

    </property>

</bean>  

<!--用户事务对象-->

<bean class="org.springframework.jndi.JndiObjectFactoryBean" id="userTransaction">

    <!--class="org.springframework.transaction.jta.WebLogicJtaTransactionManager">-->

    <property name="jndiName">

        <value>java:comp/UserTransaction</value>

    </property>

    <property name="jndiTemplate">

        <ref bean="jndiTemplate"/>

    </property>

</bean>

<bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager"

    init-method="init" destroy-method="close">

    <property name="forceShutdown" value="false" />

</bean>

<!-- 配置基于注解的声明式事务管理器 -->

<bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">

    <property name="userTransaction" ref="userTransaction" />

    <property name="transactionManager" ref="atomikosTransactionManager" />

</bean> 

<tx:annotation-driven transaction-manager="transactionManager" />

以下是我项目中使用的配置：推荐在 conf.xml中配置

在Tomcat配置中使用的XA的数据源和JDBC驱动，可以使用nonXA的相关设置，Atomikos中也支持非XA的连接，以提高运行速度。关于nonXa的数据源，可以参考一下配置：

<Resource name="jdbc/DS_MYSQL"

 auth="Container"
    type="com.atomikos.jdbc.nonxa.AtomikosNonXADataSourceBean"

        uniqueResourceName="jdbc/DS_MYSQL"

        driverClassName="com.mysql.jdbc.Driver"

        maxPoolSize="200"

        url="jdbc:mysql://localhost:3306/db_test?characterEncoding=UTF8"

        user="root"

        password="root"

        factory="com.atomikos.tomcat.EnhancedTomcatAtomikosBeanFactory" />

**踩坑记录**

**在这里因为有事务管理 TransactionManager  通过这个type 一直获取不到  UserTransaction  经debug发现找取的不是这个类 **

**换成 type="com.atomikos.icatch.jta.userTransactionImp" 成功获取到 UserTransaction，**

 <Resource name="UserTransaction"

            auth="Container"
type="com.atomikos.icatch.jta.userTransactionImp"/>   

   <Transaction factory="com.atomikos.icatch.jta.UserTransactionFactory" />

https://blog.csdn.net/xuyu_yt/article/details/77905553?locationNum=14%20fps=1

到此这篇关于Tomcat 结合Atomikos 实现JTA的文章就介绍到这了,更多相关Atomikos 实现JTA内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

时间： 2021-11-22

springboot jta atomikos实现分布式事物管理

这篇文章主要介绍了springboot jta atomikos实现分布式事物管理,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 当项目在连接多个数据库时可能会发生事务问题,即一个库的事务不可能去操作另一个数据库的事务,这时就需要使用atomikos对数据库的事务进行统一的管理 第一步添加atomikos的依赖 <dependency> <groupId>org.springframework.boot</groupId&g

SpringBoot中整合Shiro实现权限管理的示例代码

之前在 SSM 项目中使用过 shiro,发现 shiro 的权限管理做的真不错,但是在 SSM 项目中的配置太繁杂了,于是这次在 SpringBoot 中使用了 shiro,下面一起看看吧 一.简介 Apache Shiro是一个强大且易用的Java安全框架,执行身份验证.授权.密码和会话管理.使用Shiro的易于理解的API,您可以快速.轻松地获得任何应用程序,从最小的移动应用程序到最大的网络和企业应用程序. 三个核心组件: 1.Subject 即"当前操作用户".但是,在 Shi

MyBatis5中Spring集成MyBatis事物管理

单独使用MyBatis对事物进行管理 前面MyBatis的文章有写过相关内容,这里继续写一个最简单的Demo,算是复习一下之前MyBatis的内容吧,先是建表,建立一个简单的Student表: create table student ( student_id int auto_increment, student_name varchar(20) not null, primary key(student_id) ) 建立实体类Student.java: public class Studen

Vue+SpringBoot开发V部落博客管理平台

V部落是一个多用户博客管理平台,采用Vue+SpringBoot开发. 演示地址: http://45.77.146.32:8081/index.html 项目地址: https://github.com/lenve/VBlog 登陆页面 文章列表 发表文章 用户管理 栏目管理 数据统计 技术栈 后端技术栈 后端主要采用了: 1.SpringBoot 2.SpringSecurity 3.MyBatis 4.部分接口遵循Restful风格 5.MySQL 前端技术栈 前端主要采用了: 1.Vue

SpringBoot集成Zipkin实现分布式全链路监控

Zipkin 简介 Zipkin is a distributed tracing system. It helps gather timing data needed to troubleshoot latency problems in service architectures. Features include both the collection and lookup of this data. If you have a trace ID in a log file, you ca

浅谈Java(SpringBoot)基于zookeeper的分布式锁实现

通过zookeeper实现分布式锁 1.创建zookeeper的client 首先通过CuratorFrameworkFactory创建一个连接zookeeper的连接CuratorFramework client public class CuratorFactoryBean implements FactoryBean<CuratorFramework>, InitializingBean, DisposableBean { private static final Logger LOGG

spring整合atomikos实现分布式事务的方法示例

前言 Atomikos 是一个为Java平台提供增值服务的并且开源类事务管理器,主要用于处理跨数据库事务,比如某个指令在A库和B库都有写操作,业务上要求A库和B库的写操作要具有原子性,这时候就可以用到atomikos.笔者这里整合了一个spring和atomikos的demo,并且通过案例演示说明atomikos的作用. 准备工作 开发工具:idea 数据库:mysql , oracle 正文 源码地址: https://github.com/qw870602/atomikos 演示原理:通过在

SpringBoot集成Redisson实现分布式锁的方法示例

上篇 <SpringBoot 集成 redis 分布式锁优化>对死锁的问题进行了优化,今天介绍的是 redis 官方推荐使用的 Redisson ,Redisson 架设在 redis 基础上的 Java 驻内存数据网格(In-Memory Data Grid),基于NIO的 Netty 框架上,利用了 redis 键值数据库.功能非常强大,解决了很多分布式架构中的问题. Github的wiki地址: https://github.com/redisson/redisson/wiki 官方文档

SpringBoot使用Redisson实现分布式锁（秒杀系统）

前面讲完了Redis的分布式锁的实现,接下来讲Redisson的分布式锁的实现,一般提及到Redis的分布式锁我们更多的使用的是Redisson的分布式锁,Redis的官方也是建议我们这样去做的.Redisson点我可以直接跳转到Redisson的官方文档. 1.1.引入Maven依赖 <dependency> <groupId>org.redisson</groupId> <artifactId>redisson-spring-boot-starter&l

SpringBoot使用Redis实现分布式锁

前言 在单机应用时代,我们对一个共享的对象进行多线程访问的时候,使用java的synchronized关键字或者ReentrantLock类对操作的对象加锁就可以解决对象的线程安全问题. 分布式应用时代这个方法却行不通了,我们的应用可能被部署到多台机器上,运行在不同的JVM里,一个对象可能同时存在多台机器的内存中,怎样使共享对象同时只被一个线程处理就成了一个问题. 在分布式系统中为了保证一个对象在高并发的情况下只能被一个线程使用,我们需要一种跨JVM的互斥机制来控制共享资源的访问,此时就需要用到