debug

Author: ujued

tx-manager/src/main/java/com/codingapi/txlcn/manager/core/context/SimpleTransactionManager.java

@@ -84,7 +84,7 @@ public void join(DTXTransaction dtxTransaction, TransactionUnit transactionUnit)
         transUnit.setRemoteKey(transactionUnit.messageContextId());
         transUnit.setUnitType(transactionUnit.unitType());
         transUnit.setUnitId(transactionUnit.unitId());
-        log.info("unit:{} joined group:{}", transactionUnit.unitId(), dtxTransaction.groupId());
+        log.debug("unit:{} joined group:{}", transactionUnit.unitId(), dtxTransaction.groupId());
         try {
             //手动回滚时设置状态为回滚状态 0
             if(transactionUnit.getTransactionState()==0){

tx-manager/src/main/java/com/codingapi/txlcn/manager/core/message/HashGroupRpcCmdHandler.java

@@ -75,7 +75,7 @@ public void handleMessage(RpcCmd rpcCmd) {
             throw new IllegalStateException("bad request! message's groupId not nullable!");
         }
         int index = Math.abs(rpcCmd.getMsg().getGroupId().hashCode() % this.concurrentLevel);
-        log.info("group:{}'s message dispatched executor index: {}", rpcCmd.getMsg().getGroupId(), index);
+        log.debug("group:{}'s message dispatched executor index: {}", rpcCmd.getMsg().getGroupId(), index);
 
         // 提交事务消息，处理
         executors.get(index).submit(new RpcCmdTask(beanHelper, rpcCmd));

tx-manager/src/main/resources/application.properties

@@ -9,7 +9,7 @@ spring.datasource.password=123456
 mybatis.configuration.map-underscore-to-camel-case=true
 mybatis.configuration.use-generated-keys=true
 
-tx-lcn.logger.enabled=true
+#tx-lcn.logger.enabled=true
 
 # TxManager Host Ip
 tx-lcn.manager.host=127.0.0.1
@@ -21,6 +21,8 @@ tx-lcn.manager.heart-time=15000
 tx-lcn.manager.dtx-time=30000
 #参数延迟删除时间单位ms
 tx-lcn.message.netty.attr-delay-time=10000
+
+#tx-lcn.manager.concurrent-level=128
 # 开启日志
 #tx-lcn.logger.enabled=true