app开发者平台在数字化时代的重要性与发展趋势解析
697
2022-12-02
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
String restUrl = String.format("%s/api/scoreService/testTxc", "http://10.0.0.5:8762");
ResponseEntity
return restData.toString();
}
6. 发起全局事务使用注解@TxcTransaction
版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。
发表评论
暂时没有评论,来抢沙发吧~