初始导入

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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
Êþº¾3
2
I
‘’    “”
    •–—
˜
™š
›
œ
     ž
Ÿ 
 ¡
 ¢    £
¤¥¦
§
¨©

ª
«    ¬­
®
¯
°
±²
±³
´µ
¶
´·
¸
´¹
º
»
¼½¾¿ÀÁ
ÂÃÄ
ÅÆ
ÇÈÉÊËÊÌ
Í
ÎÏ
Ð
Ñ
Ò
ÓÔÕ
 Ö
×
Ø    ÙÚÛ
ܥݠ   Þßà¥áâã
configReader
&Lcom/codingapi/tm/config/ConfigReader;
RuntimeVisibleAnnotations
8Lorg/springframework/beans/factory/annotation/Autowired;
redisServerService
3Lcom/codingapi/tm/redis/service/RedisServerService;
transactionConfirmService
9Lcom/codingapi/tm/manager/service/TxManagerSenderService;
loadBalanceService
5Lcom/codingapi/tm/manager/service/LoadBalanceService;
compensateService
7Lcom/codingapi/tm/compensate/service/CompensateService;
logger
Lorg/slf4j/Logger;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
<Lcom/codingapi/tm/manager/service/impl/TxManagerServiceImpl;
createTransactionGroup
:(Ljava/lang/String;)Lcom/codingapi/tm/netty/model/TxGroup;
groupId
Ljava/lang/String;
txGroup
&Lcom/codingapi/tm/netty/model/TxGroup;
key
 StackMapTable”
addTransactionGroup
q(Ljava/lang/String;Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;)Lcom/codingapi/tm/netty/model/TxGroup;
taskId
isGroup

I
channelAddress
    methodStr
txInfo
%Lcom/codingapi/tm/netty/model/TxInfo;
    modelInfo
"Lcom/codingapi/tm/model/ModelInfo;ä©å
rollbackTransactionGroup
(Ljava/lang/String;)Z
cleanNotifyTransaction
'(Ljava/lang/String;Ljava/lang/String;)I
info
res
hasSet

Z
isOveræ
closeTransactionGroup
(Ljava/lang/String;I)I
state
dealTxGroup
*(Lcom/codingapi/tm/netty/model/TxGroup;Z)V
hasOk
 deleteTxGroup
)(Lcom/codingapi/tm/netty/model/TxGroup;)V

getTxGroup
 getTxGroupKey
&(Ljava/lang/String;)Ljava/lang/String;

SourceFile
TxManagerServiceImpl.java
(Lorg/springframework/stereotype/Service;YZ
:com/codingapi/tm/manager/service/impl/TxManagerServiceImplçèéWX
$com/codingapi/tm/netty/model/TxGroupUVêëaìíîïðñòóô
java/lang/StringBuilderKLõö÷øùú÷OPû÷üýþŠ‹‰a
#com/codingapi/tm/netty/model/TxInfoÿô
ô


c
ô
í
ô



    

å
÷
ô
 ÷
ô
÷
ô


í
&start-cleanNotifyTransaction->groupId:
,taskId:
{ô
+cleanNotifyTransaction - > txGroup is null 


#cleanNotifyTransaction - > groupId 
) not over,all transaction must rollback !


 only rollback !




æ



 
!֊
"
#
$

%

&í‡ˆ
$end-cleanNotifyTransaction->groupId:
,res(1:commit,0:rollback):ø
'
(í
)íQR
*
+
,
-÷
.ôST
/
0x
1a
java/lang/Object
1com/codingapi/tm/manager/service/TxManagerService
java/lang/String
 com/codingapi/tm/model/ModelInfo
java/util/Iterator
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;
5com/codingapi/tm/compensate/service/CompensateService
getCompensateByGroupId
setIsCompensate
(I)V
java/lang/System
currentTimeMillis
()J
setStartTime
(J)V

setGroupId
(Ljava/lang/String;)V
$com/codingapi/tm/config/ConfigReader
getKeyPrefix
()Ljava/lang/String;
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
toString
toJsonString
1com/codingapi/tm/redis/service/RedisServerService
saveTransaction
'(Ljava/lang/String;Ljava/lang/String;)V
setChannelAddress
setKid
com/codingapi/tm/Constants
address

setAddress

setIsGroup
setMethodStr
)com/codingapi/tm/manager/ModelInfoManager
getInstance
-()Lcom/codingapi/tm/manager/ModelInfoManager;
getModelByChannelName
6(Ljava/lang/String;)Lcom/codingapi/tm/model/ModelInfo;
getUniqueKey
setUniqueKey
getIpAddress
setModelIpAddress
getModel
setModel
addTransactionInfo
((Lcom/codingapi/tm/netty/model/TxInfo;)V
setRollback
org/slf4j/Logger

getHasOver
()I
getRollback
getList
()Ljava/util/List;
java/util/List
iterator
()Ljava/util/Iterator;
hasNext
()Z
next
()Ljava/lang/Object;
getKid
equals
(Ljava/lang/Object;)Z
    getNotify

getIsGroup
    setNotify
(I)Ljava/lang/StringBuilder;
setState

setHasOver
7com/codingapi/tm/manager/service/TxManagerSenderService
confirm
)(Lcom/codingapi/tm/netty/model/TxGroup;)I

getGroupId
    deleteKey
3com/codingapi/tm/manager/service/LoadBalanceService
remove
getTxGroupByKey!I
JKL
M
NOP
M
NQR
M
NST
M
NUV
M
NWX

YZ
[<
*·
*¸µ±\
.]
^_
`a
[ÁO»Y·M*´+¹Æ,¶    ,¸
¶,+¶» Y·*´¶¶+¶¶N*´-,¶¹,°\"3458!9&;?<M>]*O^_Obc
Gde?fcg
üh
ij
[
i
‡*+¶:*+¶:Ç
°»Y·:¶,¶²¶¶¶¸ ¶!:        Æ!    ¶"¶#    ¶$¶%    ¶&¶'¶(*´¶¹°\JDEFGIJ%K+L3M9N@QJROSYTcUmXtZ„\]f
‡^_‡bc
‡kc‡lm‡nc‡oc€fcydeipqJ=rs    gýthýWuv
wx
[˜'*+¶M*+¶N-Ǭ-¶)*´,-¶¹¬\abcdfg%h]*'^_'bc
!fcdeg
ýth
yz
[×

™>*´» Y·*¶+¶+¶,¶¶¹,*+¶:*+¶:Ç*´-¹,¬¶.š<¶)*´¶¹*´» Y·/¶+¶0¶¶¹,¬¶1 &*´» Y·/¶+¶2¶¶¹,¬6¶3¹4
:¹5
™<¹6
À:¶7,¶8™!¶9š¶:š¶;6>§§ÿÀ6¶3¹4
:¹5
™(¹6
À:        ¶:š    ¶9š    6§§ÿÔ™    *¶<š™*´¶¹*´» Y·=¶+¶+¶,¶>¶¶?¶¹,¬\’$mn'o.p5q:rEsGvOyUze|†}ˆ€‘²‚´†·‡Ùˆå‰õŠû‹þŒ
Ž
‘
”
    •
+–
;—
>˜
Aš
Dœ
I
O¡
Y¢
i¥
—¦]f
Ù*{q
+{q    
™^_
™bc

™kc
—|m.
kfc5
dde·â}~
    ~g(þG
thû@+ý
€?úý
€+ú

‚
[º;*+¶N*+¶:Ǭ¶@¶A*´-¶¹*´B¹C¬\"¬­ ®¯±² ³/´]4;^_;bc
;ƒm5fc .deg
ýth
„…
[Y
™*+¶<±\º»    ½] 
^_
de

†~g
    
‡ˆ
[y!+¶DM*,¶N*´-¹E*´F,¹GW±\ÂÄÅÇ È]*!^_!de
bcfc
‰a
[S*+¶M*´,¹H°\
ÍÎ] ^_bc
fc
Š‹
[M» Y·*´¶¶+¶¶°\
Ó]^_bc
ŒM
Ž