演示

Author: [email protected]

demo-common/src/main/java/com/codingapi/example/common/spring/Service1Client.java

@@ -46,4 +46,3 @@ mybatis.configuration.use-generated-keys=true
 #tx-lcn.logger.jdbc-url=jdbc:mysql://127.0.0.1:3306/tx-logger?characterEncoding=UTF-8&serverTimezone=UTC
 #tx-lcn.logger.username=root
 #tx-lcn.logger.password=123456
-#

dubbo-demo-client/src/main/java/com/example/DefaultService4DemoService.java

@@ -32,12 +32,12 @@ dubbo.application.qos.enable=false
 
 ## DB
 spring.datasource.driver-class-name=com.mysql.jdbc.Driver
-spring.datasource.url=jdbc:mysql://127.0.0.1:3306/txlcn-demo\
-  ?characterEncoding=UTF-8&serverTimezone=UTC
+spring.datasource.url=jdbc:mysql://127.0.0.1:3306/txlcn-demo?characterEncoding=UTF-8&serverTimezone=UTC
 spring.datasource.username=root
 spring.datasource.password=root
 spring.datasource.hikari.maximum-pool-size=20
 mybatis.configuration.map-underscore-to-camel-case=true
 mybatis.configuration.use-generated-keys=true
 
-spring.sleuth.propagation-keys=groupId,appList,txManager
+## tx-manager 配置
+#tx-lcn.client.manager-address=127.0.0.1:8070

dubbo-demo-client/src/main/resources/application.properties

@@ -44,4 +44,5 @@ spring.datasource.hikari.maximum-pool-size=20
 mybatis.configuration.map-underscore-to-camel-case=true
 mybatis.configuration.use-generated-keys=true
 
-spring.sleuth.propagation-keys=groupId,appList,txManager
+## tx-manager 配置
+#tx-lcn.client.manager-address=127.0.0.1:8070

dubbo-demo-d/src/main/resources/application.properties

@@ -23,12 +23,8 @@ public DemoController(DemoService demoService) {
 
     @RequestMapping("/txlcn")
     public String execute(@RequestParam("value") String value) {
-        String result1 = demoService.transactionA();
-        return "DTX A:" + result1 + " | DTX B:" + demoService.transactionB(value);
+        return  demoService.execute(value);
     }
 
-    @RequestMapping("/call-by-e")
-    public String callByE(@RequestParam("value") String value) {
-        return demoService.transactionC();
-    }
+
 }

dubbo-demo-e/src/main/resources/application.properties

@@ -8,9 +8,6 @@
  */
 public interface DemoService {
 
-    String transactionA();
 
-    String transactionB(String value);
-
-    String transactionC();
+    String execute(String value);
 }

spring-demo-client/src/main/java/com/codingapi/txlcn/demo/service1/DemoController.java

@@ -4,16 +4,13 @@
 import com.codingapi.example.common.spring.DDemoClient;
 import com.codingapi.example.common.spring.EDemoClient;
 import com.codingapi.txlcn.common.util.Transactions;
-import com.codingapi.txlcn.tc.annotation.LcnTransaction;
 import com.codingapi.txlcn.tc.annotation.TxcTransaction;
 import com.codingapi.txlcn.tc.core.DTXLocalContext;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.util.Date;
-import java.util.Timer;
-import java.util.TimerTask;
 
 /**
  * Description:
@@ -40,19 +37,12 @@ public DemoServiceImpl(ClientDemoMapper demoMapper, DDemoClient dDemoClient, EDe
 
     @Override
     @TxcTransaction
-    public String transactionA() {
-        return "ok";
-    }
-
-    @Override
-    @TxcTransaction
-    public String transactionB(String value) {
+    public String execute(String value) {
         /*
          * 注意 5.0.0 请用 DTXLocal 类
          * 注意 5.0.0 请自行获取应用名称
          * 注意 5.0.0 其它类重新导入包名
          */
-        long start = System.currentTimeMillis();
 
         // ServiceD
         String dResp = dDemoClient.rpc(value);
@@ -67,30 +57,10 @@ public String transactionB(String value) {
         demo.setCreateTime(new Date());
         demo.setGroupId(DTXLocalContext.getOrNew().getGroupId());  // DTXLocal
         demo.setUnitId(DTXLocalContext.getOrNew().getUnitId());
-        for (int i = 0; i < 10; i++) {
-            demoMapper.save(demo);
-        }
-        long time = System.currentTimeMillis() - start;
-
-        // 稍后输出DTX B所用时间
-        new Timer().schedule(new TimerTask() {
-            @Override
-            public void run() {
-                log.info("DTX B used time: {}", time);
-            }
-        }, 1000);
+        demoMapper.save(demo);
 
         // 手动异常，DTX B回滚
 //        int i = 1 / 0;
-
         return dResp + " > " + eResp + " > " + "ok-client";
     }
-
-    @Override
-    @LcnTransaction
-    public String transactionC() {
-        return "transactionC";
-    }
-
-
 }

spring-demo-client/src/main/java/com/codingapi/txlcn/demo/service1/DemoService.java

@@ -15,7 +15,7 @@
 import java.util.Properties;
 
 /**
- * Description:
+ * Description: 本地事务扫描配置示例
  * Date: 19-1-13 下午2:46
  *
  * @author ujued

spring-demo-client/src/main/java/com/codingapi/txlcn/demo/service1/DemoServiceImpl.java

@@ -19,6 +19,6 @@ ribbon.MaxAutoRetriesNextServer=0
 ribbon.ReadTimeout=5000
 ribbon.ConnectTimeout=5000
 
-hystrix.command.default.execution.isolation.strategy=THREAD
-
 
+## tx-manager 配置
+#tx-lcn.client.manager-address=127.0.0.1:8070