SpringBoot使用GTS的示例详解_Java教程

SpringBoot使用GTS的示例详解

2022-02-15 16:01jmbkeyes Java教程

这篇文章主要介绍了SpringBoot使用GTS的示例详解,代码简单易懂，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下

1. 依赖类库txc-client.jar, txt-client-spring-cloud-2.0.1.jar

2. 使用TxcDataSource代理源数据源【注意：dbcp2.BasicDataSource不支持，可以使用DruidDataSource】

3. 添加自动配置类文件

				?

									package com.bodytrack.restapi;

									import com.taobao.txc.client.aop.TxcTransactionScaner;

									import com.taobao.txc.client.boot.TxcSpringBootProperties;

									import org.springframework.beans.factory.annotation.Autowired;

									import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;

									import org.springframework.boot.context.properties.EnableConfigurationProperties;

									import org.springframework.context.ApplicationContext;

									import org.springframework.context.annotation.Bean;

									import org.springframework.context.annotation.Configuration;

									import org.springframework.context.annotation.DependsOn;

									@Configuration

									@EnableConfigurationProperties({TxcSpringBootProperties.class})

									public class TxcSpringBootAutoConfiguration {

									    @Autowired

									    private TxcSpringBootProperties txcSpringBootProperties;

									    @Autowired

									    private ApplicationContext applicationContext;

									    private static boolean isEmpty(String str) {

									        return str == null || str.length() == 0;

									    }

									    @Bean(name = "txcScanner")

									    @ConditionalOnProperty(

									        prefix = "spring.boot.txc",

									        name = {"txcServerGroup"}

									    )

									    //定义声明式事务，要想让事务annotation感知的话，要在这里定义一下

									    public TxcTransactionScaner txcTransactionScaner() {

									        String appName = this.txcSpringBootProperties.getTxcAppName() == null ? this.applicationContext.getEnvironment().getProperty("spring.application.name") : this.txcSpringBootProperties.getTxcAppName();

									        String txServiceGroup = this.txcSpringBootProperties.getTxcServerGroup();

									        int mode = this.txcSpringBootProperties.getMode() == 0 ? 1 : this.txcSpringBootProperties.getMode();

									        TxcTransactionScaner txcTransactionScanner = new TxcTransactionScaner(appName, txServiceGroup, mode, this.txcSpringBootProperties.getUrl());

									        if (!isEmpty(this.txcSpringBootProperties.getAccessKey())) {

									            txcTransactionScanner.setAccessKey(this.txcSpringBootProperties.getAccessKey());

									        }

									        if (!isEmpty(this.txcSpringBootProperties.getSecretKey())) {

									            txcTransactionScanner.setSecretKey(this.txcSpringBootProperties.getSecretKey());

									        }

									        return txcTransactionScanner;

									    }

									}

4. 添加GTS配置

				?

									spring:

									    boot:

									        txc:

									           txcAppName: demo

									           txcServerGroup: txc_test_public.1129361738553704.QD #公网测试的专用事务分组

									           url: https://test-cs-gts.aliyuncs.com #公网测试url

									           accessKey: xxx #非测试时需提供

									           secretKey: xxxx #非测试时需提供

5. 发送rest请求时，请求添加header(TXC_XID,BEGIN_COUNT,COMMIT_COUNT)

				?

									public String callTestTxc() {

									        HttpHeaders requestHeaders = new HttpHeaders();

									        requestHeaders.set("TXC_XID", String.valueOf(TxcContext.getCurrentXid()));

									        requestHeaders.set("BEGIN_COUNT", String.valueOf(TxcContext.getBeginCount()));

									        requestHeaders.set("COMMIT_COUNT", String.valueOf(TxcContext.getCommitCount()));

									        HttpEntity<String> entity = new HttpEntity<>("parameters", requestHeaders);

									        String restUrl = String.format("%s/api/scoreService/testTxc", "http://10.0.0.5:8762");

									        ResponseEntity<String> restData = restTemplate.exchange(restUrl, HttpMethod.GET, entity,  String.class);

									        return restData.toString();

									    }