LCN分布式事务管理（一）

#######################################txmanager-start#################################################
#服务端口
server.port=8899

#tx-manager不得修改
spring.application.name=tx-manager

spring.mvc.static-path-pattern=/**
spring.resources.static-locations=classpath:/static/
#######################################txmanager-end#################################################


#zookeeper地址
#spring.cloud.zookeeper.connect-string=127.0.0.1:2181
#spring.cloud.zookeeper.discovery.preferIpAddress = true

#eureka 地址
eureka.client.service-url.defaultZone=http://localhost:8083/eureka/
eureka.instance.prefer-ip-address=true

#######################################redis-start#################################################
#redis 配置文件，根据情况选择集群或者单机模式

##redis 集群环境配置
##redis cluster
#spring.redis.cluster.nodes=127.0.0.1:7001,127.0.0.1:7002,127.0.0.1:7003
#spring.redis.cluster.commandTimeout=5000

##redis 单点环境配置
#redis
#redis主机地址
spring.redis.host=127.0.0.1
#redis主机端口
spring.redis.port=6379
#redis链接密码
spring.redis.password=
spring.redis.pool.maxActive=10
spring.redis.pool.maxWait=-1
spring.redis.pool.maxIdle=5
spring.redis.pool.minIdle=0
spring.redis.timeout=0
#####################################redis-end###################################################




#######################################LCN-start#################################################
#业务模块与TxManager之间通讯的最大等待时间（单位：秒）
#通讯时间是指：发起方与响应方之间完成一次的通讯时间。
#该字段代表的是Tx-Client模块与TxManager模块之间的最大通讯时间，超过该时间未响应本次请求失败。
tm.transaction.netty.delaytime = 5

#业务模块与TxManager之间通讯的心跳时间（单位：秒）
tm.transaction.netty.hearttime = 15

#存储到redis下的数据最大保存时间（单位：秒）
#该字段仅代表的事务模块数据的最大保存时间，补偿数据会永久保存。
tm.redis.savemaxtime=30

#socket server Socket对外服务端口
#TxManager的LCN协议的端口
tm.socket.port=9999

#最大socket连接数
#TxManager最大允许的建立连接数量
tm.socket.maxconnection=100

#事务自动补偿 (true:开启，false:关闭)
# 说明：
# 开启自动补偿以后，必须要配置 tm.compensate.notifyUrl 地址，仅当tm.compensate.notifyUrl 在请求补偿确认时返回success或者SUCCESS时，才会执行自动补偿，否则不会自动补偿。
# 关闭自动补偿，当出现数据时也会 tm.compensate.notifyUrl 地址。
# 当tm.compensate.notifyUrl 无效时，不影响TxManager运行，仅会影响自动补偿。
tm.compensate.auto=false

#事务补偿记录回调地址(rest api 地址，post json格式)
#请求补偿是在开启自动补偿时才会请求的地址。请求分为两种：1.补偿决策，2.补偿结果通知，可通过通过action参数区分compensate为补偿请求、notify为补偿通知。
#*注意当请求补偿决策时，需要补偿服务返回"SUCCESS"字符串以后才可以执行自动补偿。
#请求补偿结果通知则只需要接受通知即可。
#请求补偿的样例数据格式:
#{"groupId":"TtQxTwJP","action":"compensate","json":"{\"address\":\"133.133.5.100:8081\",\"className\":\"com.example.demo.service.impl.DemoServiceImpl\",\"currentTime\":1511356150413,\"data\":\"C5IBLWNvbS5leGFtcGxlLmRlbW8uc2VydmljZS5pbXBsLkRlbW9TZXJ2aWNlSW1wbAwSBHNhdmUbehBqYXZhLmxhbmcuT2JqZWN0GAAQARwjeg9qYXZhLmxhbmcuQ2xhc3MYABABJCo/cHVibGljIGludCBjb20uZXhhbXBsZS5kZW1vLnNlcnZpY2UuaW1wbC5EZW1vU2VydmljZUltcGwuc2F2ZSgp\",\"groupId\":\"TtQxTwJP\",\"methodStr\":\"public int com.example.demo.service.impl.DemoServiceImpl.save()\",\"model\":\"demo1\",\"state\":0,\"time\":36,\"txGroup\":{\"groupId\":\"TtQxTwJP\",\"hasOver\":1,\"isCompensate\":0,\"list\":[{\"address\":\"133.133.5.100:8899\",\"isCompensate\":0,\"isGroup\":0,\"kid\":\"wnlEJoSl\",\"methodStr\":\"public int com.example.demo.service.impl.DemoServiceImpl.save()\",\"model\":\"demo2\",\"modelIpAddress\":\"133.133.5.100:8082\",\"channelAddress\":\"/133.133.5.100:64153\",\"notify\":1,\"uniqueKey\":\"bc13881a5d2ab2ace89ae5d34d608447\"}],\"nowTime\":0,\"startTime\":1511356150379,\"state\":1},\"uniqueKey\":\"be6eea31e382f1f0878d07cef319e4d7\"}"}
#请求补偿的返回数据样例数据格式:
#SUCCESS
#请求补偿结果通知的样例数据格式:
#{"resState":true,"groupId":"TtQxTwJP","action":"notify"}
tm.compensate.notifyUrl=http://ip:port/path

#补偿失败，再次尝试间隔（秒），最大尝试次数3次，当超过3次即为补偿失败,失败的数据依旧还会存在TxManager下。
tm.compensate.tryTime=30

#各事务模块自动补偿的时间上限(毫秒)
#指的是模块执行自动超时的最大时间，该最大时间若过段会导致事务机制异常，该时间必须要模块之间通讯的最大超过时间。
#例如，若模块A与模块B，请求超时的最大时间是5秒，则建议改时间至少大于5秒。
tm.compensate.maxWaitTime=5000
#######################################LCN-end#################################################




logging.level.com.codingapi=debug

 1 @Service
 2 public class TxManagerTxUrlServiceImpl implements TxManagerTxUrlService{
 3 
 4 
 5     @Value("${tm.manager.url}")
 6     private String url;
 7 
 8     @Override
 9     public String getTxUrl() {
10         System.out.println("load tm.manager.url ");
11         return url;
12     }
13 }

 1 @Service
 2 public class TxManagerHttpRequestServiceImpl implements TxManagerHttpRequestService{
 3 
 4     @Override
 5     public String httpGet(String url) {
 6         System.out.println("httpGet-start");
 7         String res = HttpUtils.get(url);
 8         System.out.println("httpGet-end");
 9         return res;
10     }
11 
12     @Override
13     public String httpPost(String url, String params) {
14         System.out.println("httpPost-start");
15         String res = HttpUtils.post(url,params);
16         System.out.println("httpPost-end");
17         return res;
18     }
19 }

 1 @Service
 2 public class DemoServiceImpl implements DemoService {
 3 
 4     @Autowired
 5     private Demo2Feign demo2Feign;
 6     @Autowired
 7     private Demo3Feign demo3Feign;
 8 
 9     @Autowired
10     private UserMapper userMapper;
11 
12     private static final Logger logger = LoggerFactory.getLogger(DemoServiceImpl.class);
13 
14     @Override
15     public List<User> list() {
16         return userMapper.findAll();
17     }
18 
19     @Override
20     @TxTransaction(isStart = true)
21     @Transactional
22     public int save() throws Exception {
23 
24         int rs1 = userMapper.save("zhangsan", "shanghai");
25         logger.info("本地服务数据插入成功");
26          int rs2 = demo2Feign.save();
27 //        Integer rs2 = restTemplate.getForObject("http://127.0.0.1:8087/demo/save", Integer.class);
28 //        System.out.println(rs2); 
29         logger.info("远程服务2号数据插入成功"+rs2);
30 //        if(0 ==rs2) {
31 //            throw new RuntimeException("远程访问出错，全部回滚");
32 //        }
33          int rs3 = demo3Feign.save();
34          logger.info("远程服务3号数据插入成功");
35          logger.info("插入" + (rs1 + rs2 + rs3) + "条记录");
36          logger.info("制造异常");
37          int v = 100 / 0;
38 //        if(1==rs2 ) {
39 //            throw new RuntimeException("本地出错，全部回滚");
40 //        }
41         return rs1 + rs2;
42     }
43 }

 1 @Service
 2 public class TxManagerTxUrlServiceImpl implements TxManagerTxUrlService{
 3 
 4 
 5     @Value("${tm.manager.url}")
 6     private String url;
 7 
 8     @Override
 9     public String getTxUrl() {
10         System.out.println("load tm.manager.url ");
11         return url;
12     }
13 }

 1 @Service
 2 public class DemoServiceImpl implements DemoService,ITxTransaction{
 3 
 4     @Autowired
 5     private PeopleMapper peopleMapper;
 6 
 7     private static final Logger logger = LoggerFactory.getLogger(DemoServiceImpl.class);
 8 
 9 
10     @Override
11     public List<People> list() {
12         return peopleMapper.findAll();
13     }
14 
15 
16     @Override
17     @Transactional
18     public int save() {
19         try {
20         
21         int rs = peopleMapper.save("男", "22");
22         logger.info("插入" + rs + "条记录");
23         int a = 1/1;
24         System.out.println(a);
25         return rs;
26         }catch (Exception e) {
27             logger.error(e.getMessage());
28             return 0;
29         }
30     }
31 }