2. 程式人生 > >基於spring+mybatis+atomikos+jta實現分布式事務(1)

基於spring+mybatis+atomikos+jta實現分布式事務(1)

阿新 • • 發佈：2018-02-20
dto action 綁定 adapter lns url tab source private

本文介紹基於spring+mybatis+atomikos+jta實現分布式事務，分布式事務的實現方式基於配置文件，不同的mybatis mapper綁定在不同的數據源上，通過atomikos可實現分布式事務一致性。

版本：spring-3.2.9.RELEASE、mybatis-3.4.4、atomikos-4.0.5、jdk1.8

1，maven配置文件pom.xml如下：

    <!-- test -->
    <dependency>
        <groupId>junit</groupId>
        <artifactId>junit</artifactId>
        <version>4.12</version>
        <scope>test</scope>
        <exclusions>
            <exclusion>
                <artifactId>hamcrest-core</artifactId>
                <groupId>org.hamcrest</groupId>
            </exclusion>
        </exclusions>
    </dependency>
    <dependency>
        <groupId>org.hamcrest</groupId>
        <artifactId>hamcrest-all</artifactId>
        <version>1.3</version>
        <scope>test</scope>
    </dependency>
    <dependency>
        <groupId>org.mockito</groupId>
        <artifactId>mockito-core</artifactId>
        <version>1.9.5</version>
        <scope>test</scope>
        <exclusions>
            <exclusion>
                <artifactId>hamcrest-core</artifactId>
                <groupId>org.hamcrest</groupId>
            </exclusion>
        </exclusions>
    </dependency>
    <dependency>
        <groupId>com.jayway.jsonpath</groupId>
        <artifactId>json-path</artifactId>
        <version>0.8.1</version>
        <scope>test</scope>
    </dependency>
    <!-- spring -->
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-aop</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-beans</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-core</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-expression</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-web</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-webmvc</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-webmvc-portlet</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-tx</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-jdbc</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-test</artifactId>
        <version>3.2.18.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-struts</artifactId>
        <version>${spring.version}</version>
    </dependency>
    <!-- mybatis -->
    <dependency>
        <groupId>org.mybatis</groupId>
        <artifactId>mybatis</artifactId>
        <version>3.4.4</version>
    </dependency>
    <dependency>
        <groupId>org.mybatis</groupId>
        <artifactId>mybatis-spring</artifactId>
        <version>1.3.1</version>
    </dependency>

    <!-- mysql-jdbc -->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>5.1.27</version>
    </dependency>

    <!-- atomikos begin -->
    <dependency>
        <groupId>com.atomikos</groupId>
        <artifactId>transactions-jdbc</artifactId>
        <version>4.0.5</version>
    </dependency>
    <!-- atomikos end -->

    <!-- jta begig -->
    <dependency>
        <groupId>javax.transaction</groupId>
        <artifactId>jta</artifactId>
        <version>1.1</version>
    </dependency>
    <!-- jta end -->
    <!-- jackson -->
    <dependency>
        <groupId>org.codehaus.jackson</groupId>
        <artifactId>jackson-mapper-asl</artifactId>
        <version>1.9.13</version>
    </dependency>
    <dependency>
        <groupId>org.codehaus.jackson</groupId>
        <artifactId>jackson-core-asl</artifactId>
        <version>1.9.13</version>
    </dependency>
    <!-- jackson end -->
    <dependency>
        <groupId>org.aspectj</groupId>
        <artifactId>aspectjweaver</artifactId>
        <version>1.8.13</version>
    </dependency>

    <dependency>
        <groupId>log4j</groupId>
        <artifactId>log4j</artifactId>
        <version>1.2.16</version>
    </dependency>
    <dependency>
        <groupId>javax.servlet</groupId>
        <artifactId>servlet-api</artifactId>
        <version>2.5</version>
        <scope>provided</scope>
    </dependency>

2，數據庫連接配置文件：jdbc.properties

jdbc.xaDataSourceClassName=com.mysql.jdbc.jdbc2.optional.MysqlXADataSource
validationQuery=select 1

ds1.jdbc.url=jdbc:mysql://xx.xx.xx.xx:3306/test1?characterEncoding=UTF-8
ds1.jdbc.username=xxxx
ds1.jdbc.password=xxxx

ds2.jdbc.url=jdbc:mysql://xx.xx.xx.xx:3306/test2?characterEncoding=UTF-8

ds2.jdbc.username=xxxx
ds2.jdbc.password=xxxx

3，atomikos配置文件：jta.properties

com.atomikos.icatch.service=com.atomikos.icatch.standalone.UserTransactionServiceFactory
com.atomikos.icatch.console_file_name=tm.release.out
com.atomikos.icatch.log_base_name=tm.releaselog
com.atomikos.icatch.tm_unique_name=com.atomikos.spring.jdbc.tm.release

com.atomikos.icatch.console_log_level=INFO

4，spring-datasource-jta.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<bean id="propertyConfigurer"
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="locations">
<list>
<value>classpath*:jdbc.properties</value>
</list>
</property>
</bean>
<bean id="txManager"
class="org.springframework.transaction.jta.JtaTransactionManager">
<property name="transactionManager">
<bean class="com.atomikos.icatch.jta.UserTransactionManager"
init-method="init" destroy-method="close">
<property name="forceShutdown" value="true"></property>
</bean>
</property>
<property name="userTransaction">
<bean class="com.atomikos.icatch.jta.UserTransactionImp">
<property name="transactionTimeout" value="300"></property>
</bean>
</property>
</bean>

${ds1.jdbc.url} ${ds1.jdbc.username} ${ds1.jdbc.password} ${ds2.jdbc.url} ${ds2.jdbc.username} ${ds2.jdbc.password} true ## 5，spring-mybatis.xml classpath:mybatis/model/*.xml classpath:mybatis/model2/*.xml ## 6，編寫mybatis.model代碼，HelloDO.java、HelloMapper.java、HelloMapper.xml HelloDO.java package mybatis.model; public class HelloDO { private Long id; private String name; public Long getId() { return id; } public void setId(Long id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } } HelloMapper.java package mybatis.model; import org.springframework.stereotype.Repository; @Repository(value="helloMapper") public interface HelloMapper { public void insert(HelloDO hello); } HelloMapper.xml insert into HELLO(ID,NAME) values(#{id},#{name}) ## 7，編寫mybatis.model2代碼，HelloDO.java、HelloMapper.java、HelloMapper.xml HelloDO.java package mybatis.model2; public class HelloDO { private Long id; private String name; public Long getId() { return id; } public void setId(Long id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } } HelloMapper.java package mybatis.model2; import org.springframework.stereotype.Repository; @Repository(value="helloMapper2") public interface HelloMapper { public void insert(HelloDO hello); } HelloMapper.xml insert into HELLO(ID,NAME) values(#{id},#{name}) ## 8，編寫service類：mybatis.service.HelloWorldService.java package mybatis.service; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import mybatis.model.HelloDO; import mybatis.model.HelloMapper; @Service("helloWorldService") public class HelloWorldService { @Autowired private HelloMapper helloMapper; @Autowired private mybatis.model2.HelloMapper helloMapper2; public void addHello(HelloDO helloDO) { // TODO Auto-generated method stub helloMapper.insert(helloDO); } public void addHello2(mybatis.model2.HelloDO helloDO) { helloMapper2.insert(helloDO); } } ## 9，編寫controller類：mybatis.controler.HelloWorldController.java package mybatis.controller; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.ResponseBody; import mybatis.model.HelloDO; import mybatis.service.HelloWorldService; @Controller(value = "helloWorldController") @RequestMapping(value="/hello") public class HelloWorldControler { @Autowired private HelloWorldService helloWorldService; @Transactional @RequestMapping(value="/create", method = RequestMethod.POST, consumes = {"text/plain", "application/*"}) public @ResponseBody long createHello(@RequestBody HelloDO helloDO) { helloWorldService.addHello(helloDO); mybatis.model2.HelloDO helloDO2 = new mybatis.model2.HelloDO(); BeanUtils.copyProperties(helloDO, helloDO2); helloWorldService.addHello2(helloDO2); return helloDO.getId(); } } ## 10，編寫測試類：HelloWorldControllerTest.java package mybatis.controller; import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.post; import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status; import org.codehaus.jackson.map.ObjectMapper; import org.codehaus.jackson.map.ObjectWriter; import org.junit.Before; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.MediaType; import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import org.springframework.test.context.web.WebAppConfiguration; import org.springframework.test.web.servlet.MockMvc; import org.springframework.test.web.servlet.setup.MockMvcBuilders; import org.springframework.web.context.WebApplicationContext; import mybatis.model.HelloDO; @RunWith(SpringJUnit4ClassRunner.class) @WebAppConfiguration @ContextConfiguration({ "classpath:spring-datasource-jta.xml", "classpath:spring-mybatis.xml" }) public class HelloWorldControlerTest { @Autowired private WebApplicationContext context; private MockMvc mocMvc; @Before public void setUp() throws Exception { mocMvc = MockMvcBuilders.webAppContextSetup(context).build(); } @Test public void test() throws Exception { String data = "{\"id\":1,\"name\":\"abc\"}"; HelloDO hello = new HelloDO(); hello.setId(1L); hello.setName("abc"); ObjectMapper mapper = new ObjectMapper(); ObjectWriter ow = mapper.writer().withDefaultPrettyPrinter(); java.lang.String requestJson = ow.writeValueAsString(hello); mocMvc.perform(post("/hello/create").contentType(MediaType.APPLICATION_JSON).content(data)).andExpect(status().isOk()); } } ## 11，至此，基於配置文件實現分布式事務一致性已經實現，下一篇文件將介紹通過代碼來動態切換數據源，並保持數據庫事務一致性。

基於spring+mybatis+atomikos+jta實現分布式事務(1)

相關推薦

基於spring+mybatis+atomikos+jta實現分布式事務(1)

dto action 綁定 adapter lns url tab source private 本文介紹基於spring+mybatis+atomikos+jta實現分布式事務，分布式事務的實現方式基於配置文件，不同的mybatis mapper綁定在不同的數據源上，通過

SpringMVC+MyBatis+JMS+JTA（分布式事務）

pack china ras broker classpath package listener internal eba SpringMVC+MyBatis 相信已經是如今企業開發中經常使用技術了。 由於一些需求，我們須要集成JMS（我使用的是Act

【分布式事務】使用atomikos+jta解決分布式事務問題

alt property 自己 control lec 技術 unique unicode har 一、前言 分布式事務，這個問題困惑了小編很久，在3個月之前，就間斷性的研究分布式事務。從MQ方面，數據庫事務方面，jta方面。近期終於成功了，使用JTA解決了分布式事務問題。

spring+mybatis+tkmapper+atomikos實現分布式事務(3)-動態切換數據源

springmvc mybatis tkmapper atomiks 動態數據源 本文介紹基於spring+mybatis+tkmapper+atomikos+jta實現分布式事務，由程序動態切換數據源，通過atomikos可實現分布式事務一致性。通過繼承MapperScannerConf

spring與quartz整合實現分布式動態創建，刪除，改變執行時間定時任務(mysql數據庫)

ces value 我們 job clu xsd collect 註解 common 背景：因為在項目中用到了定時任務，當時想到了spring的quartz，寫完發現費了很大功夫，光是整合就花了一上午，其中最大的問題就是版本問題，項目中用的是spring3.2.8的版本，查

spring3.0+Atomikos 構建jta的分布式事務

.org const classname rec bili cglib als 相關 ns-3 摘自： http://gongjiayun.iteye.com/blog/1570111 spring3.0+Atomikos 構建jta的分布式事務 spring3.0已經不

Spring.Net+WCF實現分布式事務

summary term 分布式 vpd req entity size returns 我們 1.在教師服務端，我們需要在WCF的接口上加上WCF分布式事務特性： [OperationContract] [TransactionFlow(TransactionFlowOp

使用JOTM實現分布式事務管理(多數據源)

cnblogs content 分布式 npr ransac flow tis nproxy 定義 使用spring和hibernate可以很方便的實現一個數據源的事務管理,但是如果需要同時對多個數據源進行事務控制,並且不想使

分布式事務、多數據源、分庫分表中間件之spring boot基於Atomikos+XADataSource分布式事務配置（100%純動態）

ads list() row safe ilo list odin context factor 本文描述spring boot基於Atomikos+DruidXADataSource分布式事務配置（100%純動態），也就是增加、減少數據源只需要修改application.

好文分享--java企業架構 spring mvc +mybatis + KafKa+Flume+Zookeeper分布式架構

分布式框架 Maven Springmvc mybatis Dubbo ZooKeeper Redis FastDFS ActiveMQ 開發工具 1.Eclipse IDE：采用Maven項目管理，模塊化。 2.代碼生成：通過界面方式簡單配置，自動生

基於zookeeper簡單實現分布式鎖

lean bool 思想 common factor exists play nec try 這裏利用zookeeper的EPHEMERAL_SEQUENTIAL類型節點及watcher機制。來簡單實現分布式鎖。 主要思想： 1、開啟10個線程。在disLocks節點下

使用Redisson實現分布式鎖，Spring AOP簡化之

獲取鎖 rip dss 執行c lease dset wire template alt 源碼 Redisson概述 Redisson是一個在Redis的基礎上實現的Java駐內存數據網格（In-Memory Data Grid）。它不僅提供了一系列的分布式的Java常用對

【redis】基於redis實現分布式並發鎖

val 內容 等待隊列 過多 具體實現 exec ret abs con 基於redis實現分布式並發鎖（註解實現） 說明 　　前提, 應用服務是分布式或多服務, 而這些"多"有共同的"redis"; 　　GitHub: https:

基於Redis實現分布式鎖

cti ces 實現 並不是 可能 rand urn 請求 lease 1.setnx鎖在redis中最簡單的數據結構就是string。最早的時候，上鎖的操作一般使用setnx，這個命令是當:lock不存在的時候set一個val，或許你還會記得使用expire來增加鎖的過期

spring+mybatis+Atomikos JTA事務配置說明

user roo aspect code out oracle mysq nta 4.2 一、概覽Atomikos是一個公司名字，旗下最著名的莫過於其Atomikos的事務管理器產品。產品分兩個：一個是開源的Transacti

Redis整合Spring實現分布式鎖

gte 展示 是否 alt cep 狀態 wait 封裝 RR spring把專門的數據操作獨立封裝在spring-data系列中，spring-data-redis是對Redis的封裝 <dependencies> <!-- 添加spri

基於Redis實現分布式鎖實戰

連接數 領取 pdf 性能優化 時間 fan apple 應該 系統 背景在很多互聯網產品應用中，有些場景需要加鎖處理，比如：秒殺，全局遞增ID，樓層生成等等。大部分的解決方案是基於DB實現的，Redis為單進程單線程模式，采用隊列模式將並發訪問變成串行訪問，且多客戶端對R

spring mvc +mybatis + KafKa+Flume+Zookeeper分布式架構

可用 src fast ges mvc schedule cit size fas 開發工具 1.Eclipse IDE：采用Maven項目管理，模塊化。 2.代碼生成：通過界面方式簡單配置，自動生成相應代碼，目前包括三種生成方式（增刪改查）：單表、一對多、樹結構。生成後的

spring整合curator實現分布式鎖

wait 進行 出現 兩個 重新 靜態 想要 只有一個 就是 為什麽要有分布式鎖？ 比如說，我們要下單，分為兩個操作，下單成功（訂單服務），扣減庫存（商品服務）。如果沒有鎖的話，同時兩個請求進來。先檢查有沒有庫存，一看都有，然後下訂單，減庫存。這時候肯定會出現錯誤。我們想

【原創】redis庫存操作，分布式鎖的四種實現方式[連載一]--基於zookeeper實現分布式鎖

zookeepe operation iat 並發 method logger 方案 nag 概念 一、背景 在電商系統中，庫存的概念一定是有的，例如配一些商品的庫存，做商品秒殺活動等，而由於庫存操作頻繁且要求原子性操作，所以絕大多數電商系統都用Redis來實現庫存的加減，