初始导入

zm

2020-05-18 a18bfacbf56b401f6e0fdae8710fbca4df8cff77

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
Êþº¾3

6}~
€    ‚ƒ„
…†
‡ˆ
‰Š
‡‹    ŒŽ
 }
 
 ‘    ’“
”•
 –
 —˜™
 š›
œ
œž
Ÿ 
Ÿ¡
Ÿ¢
£¤¥
¦
Ÿ§    ¨©
¨ª«¬­
%}®
%¯°±²
%³´
µ¶
6·
¸¹º
»¼½¾½¿ÀÁ
logger
Lorg/slf4j/Logger;
txManagerService
3Lcom/codingapi/tx/netty/service/MQTxManagerService;
RuntimeVisibleAnnotations
8Lorg/springframework/beans/factory/annotation/Autowired;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
@Lcom/codingapi/tx/aop/service/impl/TxStartTransactionServerImpl;
execute
g(Lorg/aspectj/lang/ProceedingJoinPoint;Lcom/codingapi/tx/aop/bean/TxTransactionInfo;)Ljava/lang/Object;

e
 Ljava/lang/InterruptedException;
end

J
time
type
Ljava/lang/String;
rs

I
    lastState
executeConnectionError
waitTask
(Lcom/codingapi/tx/framework/task/TxTask;
compensateLocal
-Lcom/codingapi/tx/aop/bean/TxCompensateLocal;
obj
Ljava/lang/Object;
Ljava/lang/Throwable;
point
&Lorg/aspectj/lang/ProceedingJoinPoint;
info
-Lcom/codingapi/tx/aop/bean/TxTransactionInfo;
start
state
groupId
txTransactionLocal
.Lcom/codingapi/tx/aop/bean/TxTransactionLocal;
 StackMapTableÂ~ÃďÀÅ¥ÆÇ­´

Exceptions
rollbackException
E(Lcom/codingapi/tx/aop/bean/TxTransactionInfo;Ljava/lang/Throwable;)I
rollbackFor
Ljava/lang/Class;
    throwable
LocalVariableTypeTable
)Ljava/lang/Class<+Ljava/lang/Throwable;>;È

SourceFile
!TxStartTransactionServerImpl.java
(Lorg/springframework/stereotype/Service;
value
txStartTransactionServer>?
>com/codingapi/tx/aop/service/impl/TxStartTransactionServerImplÉÊË89
--->begin start transactionÇÌÍÎÏÐÆÑÒÓÔÕÖÕ:;×ØÍ
,com/codingapi/tx/aop/bean/TxTransactionLocalÙÍÚÛÜÝÞßàáâãäåÃæçèÕéêëìíîïÅðãñ?òóôõö
java/lang/InterruptedException÷?øáùúûüáýþ
<---end start transaction
java/lang/StringBuilder
'start transaction over, res -> groupId:ÿ

, now state:
commit
rollback

Õ
java/lang/Throwablepq
java/lang/RuntimeException





java/lang/ErrorÄ


    r

 

java/lang/Object
.com/codingapi/tx/aop/service/TransactionServer
java/lang/String
$org/aspectj/lang/ProceedingJoinPoint
+com/codingapi/tx/aop/bean/TxTransactionInfo
&com/codingapi/tx/framework/task/TxTask
+com/codingapi/tx/aop/bean/TxCompensateLocal
org/slf4j/Logger
[Ljava/lang/Class;
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;
debug
(Ljava/lang/String;)V
java/lang/System
currentTimeMillis
()J
current
/()Lcom/codingapi/tx/aop/bean/TxCompensateLocal;
'com/lorne/core/framework/utils/KidUtils
generateShortUuid
()Ljava/lang/String;

getGroupId
1com/codingapi/tx/netty/service/MQTxManagerService
createTransactionGroup

setGroupId
setHasStart
(Z)V
com/codingapi/tx/Constants
txServer
!Lcom/codingapi/tx/model/TxServer;
com/codingapi/tx/model/TxServer
getCompensateMaxWaitTime
()I
 setMaxTimeOut
(I)V

setCurrent
1(Lcom/codingapi/tx/aop/bean/TxTransactionLocal;)V
proceed
()Ljava/lang/Object;
getType
closeTransactionGroup
(Ljava/lang/String;I)I
0com/codingapi/tx/framework/task/TaskGroupManager
getInstance
4()Lcom/codingapi/tx/framework/task/TaskGroupManager;
getTask
N(Ljava/lang/String;Ljava/lang/String;)Lcom/codingapi/tx/framework/task/TxTask;
setState

signalTask
isRemove
()Z
java/lang/Thread
sleep
(J)V
printStackTrace
getState
)com/codingapi/tx/framework/task/TaskState
connectionError
+Lcom/codingapi/tx/framework/task/TaskState;
getCode
sendCompensateMsg
D(Ljava/lang/String;JLcom/codingapi/tx/aop/bean/TxTransactionInfo;I)V
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
toString
getClass
()Ljava/lang/Class;
java/lang/Class
isAssignableFrom
(Ljava/lang/Class;)Z
getTransaction
-()Lcom/codingapi/tx/annotation/TxTransaction;
)com/codingapi/tx/annotation/TxTransaction
()[Ljava/lang/Class;
 noRollbackFor!6
789:;
<
=
>?
@<
*·
*¸µ±A
B
CD
EF@™|*´¹¸B6¸Ç    ¸    §    ¸¶
:*´¹» Y·:¶¶²¶¶¸+¹
:6:    ¶:
*´¹6 §66 ¸
¶:Æ<¶¶¶š
¸§ÿô:¶§ÿ궠²!¶"     6 6¸:Ç8¸7!e7      Ÿ š*´, ¹#§     6§6
¸*´$¹*´»%Y·&'¶(¶()¶( *§+¶(¶,¹    °:*,·.6¿:¶:*´¹6 §66¸¶:Æ<¶¶¶š
¸§ÿô:¶§ÿ궠²!¶"     66¸:Ç8¸7!e7     Ÿ š*´,¹#§     6§6
¸*´$¹*´»%Y·&'¶(¶()¶( *§+¶(¶,¹¿²¶¹Wf
i-Wf
w
Å
É
Ì
i
y
wA
:N&(*,&/12:3A4G5R6W:_;b<fBmD|FŠHK™LžM¥NªP²R¶U¹S»TÀUÃXÑZÔ\×`Übácædìe
g
i
j
k
"m
%q
)r
4s
fu
i=
k>
t?
wB
€D
F
H
 K
¬L
±M
¸N
½P
ÅR
ÉU
ÌS
ÎT
ÓU
ÖX
äZ
ç\
ê`
ïb
ôc
ùd
ÿeg&i)j/k5m8q<rGsyuB
»GHæ-IJì'KJmùLM
|êNOŠÜPOÙQO ™ÍRS܊TU_

VW
kGX
ÎGH
ù-IJ
ÿ'KJ
€ùLM
êNO
ÜPO
 ÙQO
¬ÍRS
ïŠTU|CD|YZ
|[\m]Jj^O&V_M:B`ab
 ý
Ecÿadef
cghhc
A
þ!

iNj    þ k
ùÿ3def
cghhc


iklmÿ
def
cghhc


iklmcÿ def
cg
nMnÿ!def
cgnc
A
þ!

iNj    þ k
ùÿ3def
cgnc


iklmÿ
def
cgnc


iklmco
-pq
@
B‚/,¶0¶1™¬2,¶0¶1™¬+¶3¹4
N-¾66¢-2:,¶0¶1™¬„
§ÿâ+¶3¹5
N-¾66¢-2:,¶0¶1™¬„
§ÿâ¬A6 |}€…:ˆF‰H…Nl’x“z€–B4:rslrs‚CD‚[\
‚tXu:rvlrvb þw

øþw

øxy<
z
{s|