devbox
小丑西瓜9
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Spring Boot集成atomikos快速入门Demo

作者：小丑西瓜9 | 2024-04-22 01:23:09

赞

踩

Spring Boot集成atomikos快速入门Demo

1.什么是atomikos

Atomikos是一个轻量级的分布式事务管理器，实现了Java Transaction API (JTA)规范，可以很方便的和Spring Boot集成，支持微服务场景下跨节点的全局事务。Atomikos公司官方网址为：https://www.atomikos.com/。其旗下最著名的产品就是事务管理器。产品分两个版本：

  • TransactionEssentials：开源的免费产品

  • ExtremeTransactions：上商业版，需要收费。

2.环境搭建

第一个mysql数据库

docker run --name docker-mysql -e MYSQL_ROOT_PASSWORD=123456 -p 3333:3306 -d mysql

第二个mysql数据库

docker run --name docker-mysql-2 -e MYSQL_ROOT_PASSWORD=123456 -p 3334:3306 -d mysql

初始化数据

  1. create database demo;
  2. create table user_info
  3. (
  4. user_id     varchar(64)          not null primary key,
  5. username    varchar(100)         null ,
  6. age         int(3)               null ,
  7. gender      tinyint(1)           null ,
  8. remark      varchar(255)         null ,
  9. create_time datetime             null ,
  10. create_id   varchar(64)          null ,
  11. update_time datetime             null ,
  12. update_id   varchar(64)          null ,
  13. enabled     tinyint(1) default 1 null
  14. );

说明

  1. msyql账号root
  2. mysql密码123456

3.项目代码

实验目的：实现2个mysql数据的分布式事务管理，要么全部成功，只要有一个失败就会滚。

pom..xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>springboot-demo</artifactId>
  7.         <groupId>com.et</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  11.  
  12.  
  13.     <artifactId>atomikos</artifactId>
  14.  
  15.  
  16.     <properties>
  17.         <maven.compiler.source>8</maven.compiler.source>
  18.         <maven.compiler.target>8</maven.compiler.target>
  19.     </properties>
  20.     <dependencies>
  21.  
  22.  
  23.         <dependency>
  24.             <groupId>org.springframework.boot</groupId>
  25.             <artifactId>spring-boot-starter-web</artifactId>
  26.         </dependency>
  27.  
  28.  
  29.         <dependency>
  30.             <groupId>org.springframework.boot</groupId>
  31.             <artifactId>spring-boot-autoconfigure</artifactId>
  32.         </dependency>
  33.         <dependency>
  34.             <groupId>org.springframework.boot</groupId>
  35.             <artifactId>spring-boot-starter-test</artifactId>
  36.             <scope>test</scope>
  37.         </dependency>
  38.         <!-- https://mvnrepository.com/artifact/org.mybatis.spring.boot/mybatis-spring-boot-starter -->
  39.         <dependency>
  40.             <groupId>org.mybatis.spring.boot</groupId>
  41.             <artifactId>mybatis-spring-boot-starter</artifactId>
  42.             <version>1.3.0</version><!-- 1.3.0以上的版本没有@MapperScan以及@Select注解 -->
  43.         </dependency>
  44.         <!-- automatic+jta的分布式事务管理 -->
  45.         <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-jta-atomikos -->
  46.         <dependency>
  47.             <groupId>org.springframework.boot</groupId>
  48.             <artifactId>spring-boot-starter-jta-atomikos</artifactId>
  49.         </dependency>
  50.  
  51.  
  52.         <dependency>
  53.             <groupId>org.springframework.boot</groupId>
  54.             <artifactId>spring-boot-devtools</artifactId>
  55.             <scope>runtime</scope>
  56.         </dependency>
  57.         <dependency>
  58.             <groupId>mysql</groupId>
  59.             <artifactId>mysql-connector-java</artifactId>
  60.             <!--boot 2.1默认 mysql8的版本; boot 2.0默认mysql5版本-->
  61.             <version>8.0.13</version>
  62.             <!--<version>5.1.46</version>-->
  63.             <!--<scope>runtime</scope>-->
  64.         </dependency>
  65.  
  66.  
  67.         <dependency>
  68.             <groupId>org.projectlombok</groupId>
  69.             <artifactId>lombok</artifactId>
  70.             <optional>true</optional>
  71.             <version>1.18.2</version>
  72.         </dependency>
  73.  
  74.  
  75.     </dependencies>
  76. </project>

mapper

创建2个mapper连接不同的数据库

  1. package com.et.atomikos.mapper1;
  2.  
  3.  
  4. import org.apache.catalina.User;
  5. import org.apache.ibatis.annotations.Insert;
  6. import org.apache.ibatis.annotations.Param;
  7. import org.apache.ibatis.annotations.Select;
  8.  
  9.  
  10. public interface UserInfoMapper1 {
  11.     // query
  12.     @Select("SELECT * FROM user_info WHERE username = #{username}")
  13.     User findByName(@Param("username") String username);
  14.  
  15.  
  16.     // add
  17.     @Insert("INSERT INTO user_info(user_id,username, age) VALUES(#{userId},#{username}, #{age})")
  18.     int insert(@Param("userId") String userId,@Param("username") String username, @Param("age") Integer age);
  19. }
  1. package com.et.atomikos.mapper2;
  2.  
  3.  
  4. import org.apache.catalina.User;
  5. import org.apache.ibatis.annotations.Insert;
  6. import org.apache.ibatis.annotations.Param;
  7. import org.apache.ibatis.annotations.Select;
  8.  
  9.  
  10. public interface UserInfoMapper2 {
  11.     // query
  12.     @Select("SELECT * FROM user_info WHERE username = #{username}")
  13.     User findByName(@Param("username") String username);
  14.  
  15.  
  16.     // add
  17.     @Insert("INSERT INTO user_info(user_id,username, age) VALUES(#{userId},#{username}, #{age})")
  18.     int insert(@Param("userId") String userId,@Param("username") String username, @Param("age") Integer age);
  19. }

service

创建2个service，分别用不同mapper

  1. package com.et.atomikos.mapper1;
  2.  
  3.  
  4. import com.et.atomikos.mapper1.UserInfoMapper1;
  5. import com.et.atomikos.mapper2.UserInfoMapper2;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.stereotype.Service;
  8. import org.springframework.transaction.annotation.Transactional;
  9.  
  10.  
  11. @Service
  12. public class ManyService1 {
  13.  
  14.  
  15.     @Autowired
  16.     private UserInfoMapper1 userInfoMapper1;
  17.     @Autowired
  18.     private UserInfoMapper2 userInfoMapper2;
  19.  
  20.  
  21.  
  22.  
  23.     @Transactional
  24.     public int insert(String userId,String username, Integer age) {
  25.         int insert = userInfoMapper1.insert(userId,username, age);
  26.         int i = 1 / age;// if age is zero  ,then a error will be happened.
  27.         return insert;
  28.     }
  29.  
  30.  
  31.     @Transactional
  32.     public int insertDb1AndDb2(String userId,String username, Integer age) {
  33.         int insert = userInfoMapper1.insert(userId,username, age);
  34.         int insert2 = userInfoMapper2.insert(userId,username, age);
  35.         int i = 1 / age;// if age is zero  ,then a error will be happened.
  36.         return insert + insert2;
  37.     }
  38.  
  39.  
  40.  
  41.  
  42. }
  1. package com.et.atomikos.mapper2;
  2.  
  3.  
  4. import com.et.atomikos.mapper2.UserInfoMapper2;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.stereotype.Service;
  7. import org.springframework.transaction.annotation.Transactional;
  8.  
  9.  
  10. @Service
  11. public class ManyService2 {
  12.  
  13.  
  14.     @Autowired
  15.     private UserInfoMapper2 userInfoMapper2;
  16.  
  17.  
  18.     @Transactional
  19.     public int insert(String userId,String username, Integer age) {
  20.         int i = userInfoMapper2.insert(userId,username, age);
  21.         System.out.println("userInfoMapper2.insert end :" + null);
  22.         int a = 1 / 0;//touch a error
  23.         return i;
  24.     }
  25.  
  26.  
  27. }

config

初始化数据源1和数据源2

  1. package com.et.atomikos.config;
  2.  
  3.  
  4. import lombok.Data;
  5. import org.springframework.boot.context.properties.ConfigurationProperties;
  6.  
  7.  
  8. @Data
  9. @ConfigurationProperties(prefix = "spring.datasource.test1")
  10. public class DBConfig1 {
  11.    // @Value("${mysql.datasource.test1.jdbcurl}")
  12.    //@Value("${jdbcurl}")
  13.     private String jdbcurl;
  14.     //private String url;
  15.     private String username;
  16.     private String password;
  17.     private int minPoolSize;
  18.     private int maxPoolSize;
  19.     private int maxLifetime;
  20.     private int borrowConnectionTimeout;
  21.     private int loginTimeout;
  22.     private int maintenanceInterval;
  23.     private int maxIdleTime;
  24.     private String testQuery;
  25. }
  1. package com.et.atomikos.config;
  2.  
  3.  
  4. import com.atomikos.jdbc.AtomikosDataSourceBean;
  5. import com.mysql.cj.jdbc.MysqlXADataSource;
  6. import org.apache.ibatis.session.SqlSessionFactory;
  7. import org.mybatis.spring.SqlSessionFactoryBean;
  8. import org.mybatis.spring.SqlSessionTemplate;
  9. import org.mybatis.spring.annotation.MapperScan;
  10. import org.springframework.beans.factory.annotation.Qualifier;
  11. import org.springframework.context.annotation.Bean;
  12. import org.springframework.context.annotation.Configuration;
  13.  
  14.  
  15. import javax.sql.DataSource;
  16. import java.sql.SQLException;
  17.  
  18.  
  19. /**
  20.  * @author liuhaihua
  21.  * @version 1.0
  22.  * @ClassName MyBatisConfig1
  23.  * @Description todo
  24.  * @date 2024年04月18日 13:37
  25.  */
  26.  
  27.  
  28. @Configuration
  29. @MapperScan(basePackages = "com.et.atomikos.mapper1", sqlSessionTemplateRef = "test1SqlSessionTemplate")
  30. public class MyBatisConfig1 {
  31.  
  32.  
  33.     @Bean(name = "test1DataSource")  //test1DataSource
  34.     public DataSource testDataSource(DBConfig1 testConfig) throws SQLException {
  35.         MysqlXADataSource mysqlXaDataSource = new MysqlXADataSource();
  36.         //mysqlXaDataSource.setUrl(testConfig.getUrl());
  37.         mysqlXaDataSource.setUrl(testConfig.getJdbcurl());
  38.         mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true);
  39.         mysqlXaDataSource.setPassword(testConfig.getPassword());
  40.         mysqlXaDataSource.setUser(testConfig.getUsername());
  41.         mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true);
  42.  
  43.  
  44.         // 将本地事务注册到创 Atomikos全局事务
  45.         AtomikosDataSourceBean xaDataSource = new AtomikosDataSourceBean();
  46.         xaDataSource.setXaDataSource(mysqlXaDataSource);
  47.         xaDataSource.setUniqueResourceName("test1DataSource");
  48.  
  49.  
  50.         xaDataSource.setMinPoolSize(testConfig.getMinPoolSize());
  51.         xaDataSource.setMaxPoolSize(testConfig.getMaxPoolSize());
  52.         xaDataSource.setMaxLifetime(testConfig.getMaxLifetime());
  53.         xaDataSource.setBorrowConnectionTimeout(testConfig.getBorrowConnectionTimeout());
  54.         xaDataSource.setLoginTimeout(testConfig.getLoginTimeout());
  55.         xaDataSource.setMaintenanceInterval(testConfig.getMaintenanceInterval());
  56.         xaDataSource.setMaxIdleTime(testConfig.getMaxIdleTime());
  57.         xaDataSource.setTestQuery(testConfig.getTestQuery());
  58.         return xaDataSource;
  59.     }
  60.  
  61.  
  62.     @Bean(name = "test1SqlSessionFactory")
  63.     public SqlSessionFactory testSqlSessionFactory(@Qualifier("test1DataSource") DataSource dataSource)
  64.             throws Exception {
  65.         SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
  66.         bean.setDataSource(dataSource);
  67.         return bean.getObject();
  68.     }
  69.  
  70.  
  71.     @Bean(name = "test1SqlSessionTemplate")
  72.     public SqlSessionTemplate testSqlSessionTemplate(
  73.             @Qualifier("test1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
  74.         return new SqlSessionTemplate(sqlSessionFactory);
  75.     }
  76. }

数据源2也是类似配置

controller

  1. package com.et.atomikos.controller;
  2.  
  3.  
  4. import com.et.atomikos.mapper1.ManyService1;
  5. import com.et.atomikos.mapper2.ManyService2;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.web.bind.annotation.RequestMapping;
  8. import org.springframework.web.bind.annotation.RestController;
  9.  
  10.  
  11. import javax.annotation.Resource;
  12.  
  13.  
  14. @RestController
  15. public class HelloWorldController {
  16.  
  17.  
  18.     @Autowired
  19.     private ManyService1 manyService1;
  20.  
  21.  
  22.     @Resource
  23.     private ManyService2 manyService2;
  24.     //http://localhost:8088/datasource1?userId=9&username=datasource1&age=2
  25.     @RequestMapping(value = "datasource1")
  26.     public int datasource1(String userId,String username, Integer age) {
  27.         return manyService1.insert(userId,username, age);
  28.     }
  29.     //http://localhost:8088/datasource2?userId=9&username=datasource2&age=2
  30.     @RequestMapping(value = "datasource2")
  31.     public int datasource2(String userId,String username, Integer age) {
  32.         return manyService2.insert(userId,username, age);
  33.     }
  34.  
  35.  
  36.     //http://localhost:8088/insertDb1AndDb2?userId=1&username=tom5&age=2
  37.     //http://localhost:8088/insertDb1AndDb2?userId=2&username=tom5&age=0  //touch a error
  38.     @RequestMapping(value = "insertDb1AndDb2")
  39.     public int insertDb1AndDb2(String userId,String username, Integer age) {
  40.         return manyService1.insertDb1AndDb2(userId,username, age);
  41.     }
  42.  
  43.  
  44. }

application.yaml

  1. server:
  2.   port: 8088
  3.  
  4.  
  5. spring:
  6.   application:
  7.     name: manyDatasource
  8.   datasource:
  9.     #  spring.datasource.test1
  10.     #    druid:
  11.     test1:
  12.       jdbcurl: jdbc:mysql://localhost:3333/demo?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=utf-8
  13.       username: root
  14.       password: 123456
  15.       initial-size: 1
  16.       min-idle: 1
  17.       max-active: 20
  18.       test-on-borrow: true
  19.       driver-class-name: com.mysql.cj.jdbc.Driver
  20.       type: com.alibaba.druid.pool.DruidDataSource
  21.       minPoolSize: 3
  22.       maxPoolSize: 25
  23.       maxLifetime: 20000
  24.       borrowConnectionTimeout: 30
  25.       loginTimeout: 30
  26.       maintenanceInterval: 60
  27.       maxIdleTime: 60
  28.  
  29.  
  30.     test2:
  31.       jdbcurl: jdbc:mysql://localhost:3334/demo?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=utf-8
  32.       username: root
  33.       password: 123456
  34.       driver-class-name: com.mysql.cj.jdbc.Driver
  35.       type: com.alibaba.druid.pool.DruidDataSource
  36.       minPoolSize: 3
  37.       maxPoolSize: 25
  38.       maxLifetime: 20000
  39.       borrowConnectionTimeout: 30
  40.       loginTimeout: 30
  41.       maintenanceInterval: 60
  42.       maxIdleTime: 60
  43.  
  44.  
  45. mybatis:
  46.   mapper-locations: classpath:mapper/*.xml
  47.  
  48.  
  49.  
  50.  
  51. spring.resources.static-locations: classpath:static/,file:static/
  52.  
  53.  
  54. logging:
  55.   level:
  56.     czs: debug
  57.     org.springframework: WARN
  58.     org.spring.springboot.dao: debug

以上只是一些关键代码，所有代码请参见下面代码仓库

代码仓库

  • https://github.com/Harries/springboot-demo

4.测试

启动Spring Boot 应用

插入第一个数据测试

http://localhost:8088/datasource1?userId=9&username=datasource1&age=2

插入第二个数据库

http://localhost:8088/datasource2?userId=9&username=datasource2&age=2

同时插入2个数据库

http://localhost:8088/insertDb1AndDb2?userId=1&username=tom5&age=2

异常回滚测试

http://localhost:8088/insertDb1AndDb2?userId=2&username=tom5&age=0  //touch a error

5.参考

  • https://github.com/ColoZhu/springbootmanyDatasource

  • http://www.liuhaihua.cn/archives/710435.html

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/小丑西瓜9/article/detail/466134
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号