SpringBoot使用GTS的示例详解

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.txcSpringBootPropertihttp://es.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

mErcl 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 entity = new HttpEntity<>("parameters", requestHeaders);

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

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

return restData.toString();

}

6. 发起全局事务使用注解@TxcTransaction

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。