SpringBoot同一個方法操作多個數(shù)據(jù)源保證事務(wù)一致性

更新時間：2024年11月22日 11:40:23 作者：編程經(jīng)驗分享

本文探討了在Spring Boot應(yīng)用中,如何在同一個方法中操作多個數(shù)據(jù)源并保證事務(wù)的一致性,由于聲明式事務(wù)的限制,直接使用@Transactional注解無法滿足需求,文章介紹了解決方案：編程式事務(wù),它允許在代碼級別更靈活地管理事務(wù),確保多數(shù)據(jù)源操作的事務(wù)一致性

前言

工作中開發(fā)過多數(shù)據(jù)源的系統(tǒng)，比如資產(chǎn)清查系統(tǒng)，數(shù)據(jù)的存儲分成了兩個庫，一個當前庫和歸檔庫，系統(tǒng)就需要配置兩個數(shù)據(jù)源來滿足業(yè)務(wù)需求。在常規(guī)的業(yè)務(wù)場景下，對兩個庫的業(yè)務(wù)操作是分開的，井水不犯河水。但是有一個功能實現(xiàn)是個例外，就是歸檔。將當前庫的數(shù)據(jù)進行歸檔，需要修改當前庫數(shù)據(jù)的狀態(tài)，并將當前庫數(shù)據(jù)插入到歸檔庫中，這就需要在同一個方法實現(xiàn)中同時操作兩個數(shù)據(jù)源，直接使用聲明式事務(wù)@Transcational注解是無法保證兩個事務(wù)的一致性的。

聲明式事務(wù)則只能做到方法級別的顆粒度，而且每個方法只能配置一個事務(wù)管理器，雖然可以將邏輯拆分到多個方法中，再為每個方法加上@Transactional注解，但還是會存在問題，無法很好地處理多事務(wù)的業(yè)務(wù)場景。而這種問題可以使用編程式事務(wù)來解決，編程式事務(wù)可以將做到代碼級別的顆粒度，更加的靈活。

前置環(huán)境

JDK8 + SringBoot2 + MySQL8

數(shù)據(jù)庫

分別創(chuàng)建數(shù)據(jù)庫 test1 test2

分別在兩個數(shù)據(jù)庫中創(chuàng)建 user 表

create table user (
    id int auto_increment primary key,
    username varchar(255),
    password varchar(255)
);

pom

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>${spring-boot.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
 
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
 
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>
 
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
    <dependencies>

yml

server:
  port: 8888

spring:
  datasource:
    primary:
      url: jdbc:mysql://localhost:3306/test1?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC&allowPublicKeyRetrieval=true
      username: root
      password: mysql
      driver-class-name: com.mysql.cj.jdbc.Driver
    secondary:
      url: jdbc:mysql://localhost:3306/test2?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC&allowPublicKeyRetrieval=true
      username: root
      password: mysql
      driver-class-name: com.mysql.cj.jdbc.Driver

  jpa:
    primary:
      show-sql: true
      properties:
        hibernate:
          hbm2ddl:
            auto: update
          dialect: org.hibernate.dialect.MySQL5InnoDBDialect
    secondary:
      show-sql: true
      properties:
        hibernate:
          hbm2ddl:
            auto: update
          dialect: org.hibernate.dialect.MySQL5InnoDBDialect

Config

這里主要注入主庫和從庫各自的JDBCTemplate和TransactionManager，以便后續(xù)使用

主庫數(shù)據(jù)源配置

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories (
        basePackages = PrimaryDatasourceAndJpaConfig.REPOSITORY_PACKAGE,
        entityManagerFactoryRef = "primaryEntityManagerFactory",
        transactionManagerRef = "primaryTransactionManager"
)
public class PrimaryDatasourceAndJpaConfig {

    private static final String REPOSITORY_PACKAGE = "com.jpa.dao.primary";
    private static final String ENTITY_PACKAGE = "com.jpa.entity.primary";

    //--------------數(shù)據(jù)源配置-------------------

    /**
     * 掃描spring.datasource.primary開頭的配置信息
     *
     * @return 數(shù)據(jù)源配置信息
     */
    @Primary
    @Bean(name = "primaryDataSourceProperties")
    @ConfigurationProperties(prefix = "spring.datasource.primary")
    public DataSourceProperties dataSourceProperties() {
        return new DataSourceProperties();
    }

    /**
     * 取主庫數(shù)據(jù)源對象
     *
     * @param dataSourceProperties 注入名為primaryDataSourceProperties的bean
     * @return 數(shù)據(jù)源對象
     */
    @Primary
    @Bean(name = "primaryDataSource")
    public DataSource dataSource(@Qualifier("primaryDataSourceProperties") DataSourceProperties dataSourceProperties) {
        return dataSourceProperties.initializeDataSourceBuilder().build();
    }

    /**
     * 該方法僅在需要使用JdbcTemplate對象時選用
     *
     * @param dataSource 注入名為primaryDataSource的bean
     * @return 數(shù)據(jù)源JdbcTemplate對象
     */
    @Primary
    @Bean(name = "primaryJdbcTemplate")
    public JdbcTemplate jdbcTemplate(@Qualifier("primaryDataSource") DataSource dataSource) {
        return new JdbcTemplate(dataSource);
    }

    /**
     * 掃描spring.jpa.primary開頭的配置信息
     *
     * @return jpa配置信息
     */
    @Primary
    @Bean (name = "primaryJpaProperties")
    @ConfigurationProperties (prefix = "spring.jpa.primary")
    public JpaProperties jpaProperties() {
        return new JpaProperties();
    }

    /**
     * 獲取主庫實體管理工廠對象
     *
     * @param primaryDataSource 注入名為primaryDataSource的數(shù)據(jù)源
     * @param jpaProperties     注入名為primaryJpaProperties的jpa配置信息
     * @param builder           注入EntityManagerFactoryBuilder
     * @return 實體管理工廠對象
     */
    @Primary
    @Bean(name = "primaryEntityManagerFactory")
    public LocalContainerEntityManagerFactoryBean entityManagerFactoryBean(
            @Qualifier ("primaryDataSource") DataSource primaryDataSource,
            @Qualifier("primaryJpaProperties") JpaProperties jpaProperties,
            EntityManagerFactoryBuilder builder
    ) {
        return builder
                // 設(shè)置數(shù)據(jù)源
                .dataSource(primaryDataSource)
                // 設(shè)置jpa配置
                .properties(jpaProperties.getProperties())
                // 設(shè)置實體包名
                .packages(ENTITY_PACKAGE)
                // 設(shè)置持久化單元名，用于@PersistenceContext注解獲取EntityManager時指定數(shù)據(jù)源
                .persistenceUnit("primaryPersistenceUnit").build();
    }

    /**
     * 獲取實體管理對象
     *
     * @param factory 注入名為primaryEntityManagerFactory的bean
     * @return 實體管理對象
     */
    @Primary
    @Bean(name = "primaryEntityManager")
    public EntityManager entityManager(@Qualifier("primaryEntityManagerFactory") EntityManagerFactory factory) {
        return factory.createEntityManager();
    }

    /**
     * 獲取主庫事務(wù)管理對象
     *
     * @param factory 注入名為primaryEntityManagerFactory的bean
     * @return 事務(wù)管理對象
     */
    @Primary
    @Bean(name = "primaryTransactionManager")
    public JpaTransactionManager transactionManager(@Qualifier("primaryEntityManagerFactory") EntityManagerFactory factory) {
        return new JpaTransactionManager(factory);
    }
}

從庫數(shù)據(jù)源配置

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
        basePackages = SecondaryDatasourceAndJpaConfig.REPOSITORY_PACKAGE,
        entityManagerFactoryRef = "secondaryEntityManagerFactory",
        transactionManagerRef = "secondaryTransactionManager"
)
public class SecondaryDatasourceAndJpaConfig {
    
    static final String REPOSITORY_PACKAGE = "com.jpa.dao.secondary";
    static final String ENTITY_PACKAGE = "com.jpa.entity.secondary";

    //--------------數(shù)據(jù)源配置-------------------

    /**
     * 掃描spring.datasource.secondary開頭的配置信息
     *
     * @return 數(shù)據(jù)源配置信息
     */
    @Bean(name = "secondaryDataSourceProperties")
    @ConfigurationProperties(prefix = "spring.datasource.secondary")
    public DataSourceProperties dataSourceProperties() {
        return new DataSourceProperties();
    }

    /**
     * 獲取次數(shù)據(jù)源對象
     *
     * @param dataSourceProperties 注入名為secondaryDataSourceProperties的bean
     * @return 數(shù)據(jù)源對象
     */
    @Bean("secondaryDataSource")
    public DataSource dataSource(@Qualifier("secondaryDataSourceProperties") DataSourceProperties dataSourceProperties) {
        return dataSourceProperties.initializeDataSourceBuilder().build();
    }

    /**
     * 該方法僅在需要使用JdbcTemplate對象時選用
     *
     * @param dataSource 注入名為secondaryDataSource的bean
     * @return 數(shù)據(jù)源JdbcTemplate對象
     */
    @Bean(name = "secondaryJdbcTemplate")
    public JdbcTemplate jdbcTemplate(@Qualifier("secondaryDataSource") DataSource dataSource) {
        return new JdbcTemplate(dataSource);
    }

    /**
     * 掃描spring.jpa.secondary
     *
     * @return jpa配置信息
     */
    @Bean(name = "secondaryJpaProperties")
    @ConfigurationProperties(prefix = "spring.jpa.secondary")
    public JpaProperties jpaProperties() {
        return new JpaProperties();
    }

    /**
     * 獲取次庫實體管理工廠對象
     *
     * @param secondaryDataSource 注入名為secondaryDataSource的數(shù)據(jù)源
     * @param jpaProperties       注入名為secondaryJpaProperties的jpa配置信息
     * @param builder             注入EntityManagerFactoryBuilder
     * @return 實體管理工廠對象
     */
    @Bean(name = "secondaryEntityManagerFactory")
    public LocalContainerEntityManagerFactoryBean entityManagerFactory(
            @Qualifier("secondaryDataSource") DataSource secondaryDataSource,
            @Qualifier("secondaryJpaProperties") JpaProperties jpaProperties,
            EntityManagerFactoryBuilder builder
    ) {
        return builder
                // 設(shè)置數(shù)據(jù)源
                .dataSource(secondaryDataSource)
                // 設(shè)置jpa配置
                .properties(jpaProperties.getProperties())
                // 設(shè)置實體包名
                .packages(ENTITY_PACKAGE)
                // 設(shè)置持久化單元名，用于@PersistenceContext注解獲取EntityManager時指定數(shù)據(jù)源
                .persistenceUnit("secondaryPersistenceUnit").build();
    }

    /**
     * 獲取實體管理對象
     *
     * @param factory 注入名為secondaryEntityManagerFactory的bean
     * @return 實體管理對象
     */
    @Bean(name = "secondaryEntityManager")
    public EntityManager entityManager(@Qualifier("secondaryEntityManagerFactory") EntityManagerFactory factory) {
        return factory.createEntityManager();
    }

    /**
     * 獲取事務(wù)管理對象
     *
     * @param factory 注入名為secondaryEntityManagerFactory的bean
     * @return 事務(wù)管理對象
     */
    @Bean(name = "secondaryTransactionManager")
    public JpaTransactionManager transactionManager(@Qualifier("secondaryEntityManagerFactory") EntityManagerFactory factory) {
        return new JpaTransactionManager(factory);
    }
}

聲明式事務(wù)

錯誤寫法

@Service
public class TestService {

    @Resource
    JdbcTemplate primaryJdbcTemplate;

    @Resource
    JdbcTemplate secondaryJdbcTemplate;

    @Transactional
    public void method() {

        //do something 1
        
        primaryJdbcTemplate.execute("insert into user(username, password) values('張三', '123456')");

        //do something 2

        secondaryJdbcTemplate.execute("insert into user(username, password) values('李四', '123456');");

        //do something 3
    }
}

@Transactional中沒有指定事務(wù)管理器，這在單數(shù)據(jù)源系統(tǒng)中就不會有任何問題，在單數(shù)據(jù)源系統(tǒng)中，整個Spring容器中只定義了一個事務(wù)管理器，Spring啟動事務(wù)的時候，默認會按類型在容器中查找事務(wù)管理器，而容器中就只有一個事務(wù)管理器，正好拿來用，不會有問題。

但是在多數(shù)據(jù)源系統(tǒng)中，Spring容器中是會存在多個事務(wù)管理器的，如果不指定事務(wù)管理器，如果使用的事務(wù)管理器和實際操作的數(shù)據(jù)源不一致的話，是管理不了事務(wù)的（由于配置主庫數(shù)據(jù)源使用@primary注解，所有默認會使用主庫的事務(wù)管理器），所以在數(shù)據(jù)源系統(tǒng)中使用聲明式事務(wù)，必須指定事務(wù)管理器

上面代碼將兩個數(shù)據(jù)庫操作都放在同一個方法中，無論拿到了哪個事務(wù)管理器，只要 do something 3 處發(fā)生了異常，那么其中的一個事務(wù)是不會回滾的

改進寫法

@Service
public class TestService {

    @Resource
    JdbcTemplate primaryJdbcTemplate;

    @Resource
    JdbcTemplate secondaryJdbcTemplate;

    @Transactional(value = "primaryTransactionManager")
    public void method1() {

        //do something 1

        primaryJdbcTemplate.execute("insert into user(username, password) values('張三', '123456')");

        //do something 2

        method2();

        //do something 5
    }

    @Transactional(value = "secondaryTransactionManager")
    public void method2() {

        //do something 3

        secondaryJdbcTemplate.execute("insert into user(username, password) values('李四', '123456');");

        //do something 4
    }
}

改進的寫法，將不同數(shù)據(jù)源的操作拆到不同的方法中，分別加上了@Transactional注解，并指定了對應(yīng)的事務(wù)管理器。這種寫法相對之前的就規(guī)范了不少，但是還是存在問題，如果在 do something 5 處發(fā)生了異常，因為 method2 方法已經(jīng)執(zhí)行結(jié)束了，事務(wù)已經(jīng)提交了，所以還是無法做到一起回滾。

編程式事務(wù)

@Service
public class TestService {

    @Resource
    JdbcTemplate primaryJdbcTemplate;

    @Resource
    JdbcTemplate secondaryJdbcTemplate;

    @Resource
    PlatformTransactionManager primaryTransactionManager;

    @Resource
    PlatformTransactionManager secondaryTransactionManager;

    public void method() {
        TransactionDefinition primaryDef = new DefaultTransactionDefinition();
        TransactionStatus primaryStatus = primaryTransactionManager.getTransaction(primaryDef);

        TransactionDefinition secondaryDef = new DefaultTransactionDefinition();
        TransactionStatus secondaryStatus = secondaryTransactionManager.getTransaction(secondaryDef);

        try {
            //do something 1

            primaryJdbcTemplate.execute("insert into user(username, password) values('張三', '123456')");

            //do something 2

            secondaryJdbcTemplate.execute("insert into user(username, password) values('李四', '123456');");

            //do something 3

            primaryTransactionManager.commit(primaryStatus);
            secondaryTransactionManager.commit(secondaryStatus);
        } catch (Exception e) {
            primaryTransactionManager.rollback(primaryStatus);
            secondaryTransactionManager.rollback(secondaryStatus);
            throw new RuntimeException(e.getMessage());
        }
    }
}

編程式事務(wù)的顆粒度時代碼級別的，可以嵌入到方法里面，這樣可以控制不同數(shù)據(jù)源的事務(wù)同時開啟，一旦出現(xiàn)異常，則兩個事務(wù)一起回滾，這樣就保證了多數(shù)據(jù)事務(wù)的一致性。

這種實現(xiàn)實際上和分布式事務(wù)的XA模式思想一樣，只不過分布式事務(wù)管理的是分布式系統(tǒng)中不同服務(wù)不同的數(shù)據(jù)源，而這里是一個服務(wù)同一個方法中操作多個數(shù)據(jù)源。本質(zhì)上都是處理管理多數(shù)據(jù)源的事務(wù)。

到此這篇關(guān)于SpringBoot同一個方法操作多個數(shù)據(jù)源保證事務(wù)一致性的文章就介紹到這了,更多相關(guān)SpringBoot 事務(wù)一致性內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

国产无遮挡裸体免费直播视频,久久精品国产蜜臀av,动漫在线视频一区二区,欧亚日韩一区二区三区,久艹在线免费视频,国产精品美女网站免费,正在播放 97超级视频在线观看,斗破苍穹年番在线观看免费,51最新乱码中文字幕

SpringBoot同一個方法操作多個數(shù)據(jù)源保證事務(wù)一致性

目錄

前言

前置環(huán)境

數(shù)據(jù)庫

pom

yml

Config

聲明式事務(wù)

錯誤寫法

改進寫法

編程式事務(wù)

相關(guān)文章

最新評論

大家感興趣的內(nèi)容

最近更新的內(nèi)容

常用在線小工具

国产无遮挡裸体免费直播视频,久久精品国产蜜臀av,动漫在线视频一区二区,欧亚日韩一区二区三区,久艹在线 免费视频,国产精品美女网站免费,正在播放 97超级视频在线观看,斗破苍穹年番在线观看免费,51最新乱码中文字幕

SpringBoot同一個方法操作多個數(shù)據(jù)源保證事務(wù)一致性

目錄

前言

前置環(huán)境

數(shù)據(jù)庫

pom

yml

Config

聲明式事務(wù)

錯誤寫法

改進寫法

編程式事務(wù)

相關(guān)文章

最新評論

大家感興趣的內(nèi)容

最近更新的內(nèi)容

常用在線小工具

国产无遮挡裸体免费直播视频,久久精品国产蜜臀av,动漫在线视频一区二区,欧亚日韩一区二区三区,久艹在线免费视频,国产精品美女网站免费,正在播放 97超级视频在线观看,斗破苍穹年番在线观看免费,51最新乱码中文字幕