初始导入

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
Êþº¾3Ó    e
1fg
hi    j    k
lm
lno
    fpq
    rstu
    v    w
xyz
f{
|
v}~
€‚
ƒ„
1…†
‡}ˆ
l‰Š‹
1Œ
lŽ
xŠ‘
’“
”•
)–    —˜    —™š    —›œ
InnerClasses
logger
Lorg/slf4j/Logger;
nettyControlService
4Lcom/codingapi/tx/netty/service/NettyControlService;
    heartJson
Ljava/lang/String;

threadPool
Ljava/util/concurrent/Executor;
<init>
W(Ljava/util/concurrent/Executor;Lcom/codingapi/tx/netty/service/NettyControlService;I)V
Code
LineNumberTable
LocalVariableTable
this
3Lcom/codingapi/tx/netty/handler/TransactionHandler;
delay

I
heartJo
!Lcom/alibaba/fastjson/JSONObject;
channelRead
=(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V
ctx
(Lio/netty/channel/ChannelHandlerContext;
msg
Ljava/lang/Object;
json

Exceptions
exceptionCaught
@(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Throwable;)V
cause
Ljava/lang/Throwable;
channelInactive
+(Lio/netty/channel/ChannelHandlerContext;)V
 channelActive
userEventTriggered
event
)Lio/netty/handler/timeout/IdleStateEvent;
evt
 StackMapTable‘

access$000
i(Lcom/codingapi/tx/netty/handler/TransactionHandler;)Lcom/codingapi/tx/netty/service/NettyControlService;
x0

SourceFile
TransactionHandler.java
RuntimeVisibleAnnotationsŸ
Sharable
*Lio/netty/channel/ChannelHandler$Sharable;56; 
1com/codingapi/tx/netty/handler/TransactionHandler¡¢£349:¤¥¦§¨
com/alibaba/fastjson/JSONObject

a

h©ª

k

p
{}«¬78­®¯
java/lang/StringBuilder
TxManager-response->°±²³´
3com/codingapi/tx/netty/handler/TransactionHandler$1;µ¶·¸¹º ST
disconnection  -->°»¼´½¾¿À UTÁT
connection -->ÂÃÄ 
'io/netty/handler/timeout/IdleStateEventÅÆÇÈÉÊËÌÍÎÏÐÏ
hart data --->ÑÏ
-io/netty/channel/ChannelInboundHandlerAdapter
java/lang/ExceptionÒ
(io/netty/channel/ChannelHandler$Sharable
()V
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;
.com/codingapi/tx/framework/utils/SocketManager
getInstance
2()Lcom/codingapi/tx/framework/utils/SocketManager;
setDelay
(I)V
put
8(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
toString
()Ljava/lang/String;
,com/codingapi/tx/framework/utils/SocketUtils
getJson
&(Ljava/lang/Object;)Ljava/lang/String;
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
org/slf4j/Logger
debug
(Ljava/lang/String;)V
p(Lcom/codingapi/tx/netty/handler/TransactionHandler;Lio/netty/channel/ChannelHandlerContext;Ljava/lang/String;)V
java/util/concurrent/Executor
execute
(Ljava/lang/Runnable;)V
java/lang/Throwable
printStackTrace
-(Ljava/lang/Object;)Ljava/lang/StringBuilder;
info
setNetState
(Z)V
2com/codingapi/tx/netty/service/NettyControlService
restart
setCtx
sendMsg
=(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/String;)V
uploadModelInfo
java/lang/Object
getClass
()Ljava/lang/Class;
java/lang/Class
isAssignableFrom
(Ljava/lang/Class;)Z
state
&()Lio/netty/handler/timeout/IdleState;
"io/netty/handler/timeout/IdleState
READER_IDLE
$Lio/netty/handler/timeout/IdleState;
WRITER_IDLE
ALL_IDLE
io/netty/channel/ChannelHandler!13456789:
;<
=ÉO*·*¸µ*+µ*,µ
¸¶»    Y·
:¶ W¶ W¶ W*¶µ±>." #$&)'*1+;,E-N/?4O@AO9:
O56OBC'(DE
FG=‰5,¸N*´»Y·¶-¶¶¹*´»Y*+-·¹±>57!94??*5@A5HI
5JK0L8M
N
OP=G
,¶±>
CD? @AHI
QRM
N
ST=v2*+·*´»Y·¶+¶ ¶¹!¸¶"*´
¹#
±>HJ!L(N1O?2@A2HI
M
N
UT=‚:*+·$¸+¶%*´»Y·&¶+¶ ¶¹!+*´¸'*´
¹(
±>TUW(Z0\9]?:@A:HI
M
N
VG=Ó]),¶*¶+™S,À)N-¶,²-¦§A-¶,².¦-+*´¸'*´»Y·/¶*´¶¶¹§ -¶,²0¦±>"jklo(q0rRs\w?*KWX]@A]HI
]YKZü[3ú    M
N\]
=/

*´
°>
?
^A_`a
d2bžc&