SpringBoot使用GTS的示例详解

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;

     }

}

spring:

     boot:

         txc:

            txcAppName: demo

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

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

            accessKey: xxx #非测试时需提供

            secretKey: xxxx #非测试时需提供

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();

     }