初始导入

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

z
7{|
}~        €    
‚ƒ„
    {…
    †
    ‡ˆ‰Š
‹Œ
Ž
‘
’“”•–—˜
™‡š›œž
{
Ÿ ¡¢
‡ˆ£
‚¤
¥¦
¥§
¥¨•©
7ª
¥«
¥¬
­®
­¯
7°•±
²³´
™µ
¶·
2¸    ¹º»
InnerClasses
nettyService
-Lcom/codingapi/tm/netty/service/NettyService;
logger
Lorg/slf4j/Logger;

threadPool
Ljava/util/concurrent/Executor;
<init>
O(Ljava/util/concurrent/Executor;Lcom/codingapi/tm/netty/service/NettyService;)V
Code
LineNumberTable
LocalVariableTable
this
4Lcom/codingapi/tm/netty/handler/TxCoreServerHandler;
channelRead
=(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V
ctx
(Lio/netty/channel/ChannelHandlerContext;
msg
Ljava/lang/Object;
json
Ljava/lang/String;

Exceptions¼
service
=(Ljava/lang/String;Lio/netty/channel/ChannelHandlerContext;)V

jsonObject
!Lcom/alibaba/fastjson/JSONObject;
action
key
params
channelAddress
 actionService
/Lcom/codingapi/tm/netty/service/IActionService;
res
resObj
 StackMapTable|½¾ž¿
channelRegistered
+(Lio/netty/channel/ChannelHandlerContext;)V
channelUnregistered
    modelName
channelReadComplete
exceptionCaught
@(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Throwable;)V
cause
Ljava/lang/Throwable;
userEventTriggered
event
)Lio/netty/handler/timeout/IdleStateEvent;
evt

access$000
q(Lcom/codingapi/tm/netty/handler/TxCoreServerHandler;Ljava/lang/String;Lio/netty/channel/ChannelHandlerContext;)V
x0
x1
x2

SourceFile
TxCoreServerHandler.java
RuntimeVisibleAnnotationsÁ
Sharable
*Lio/netty/channel/ChannelHandler$Sharable;PQ?Â
2com/codingapi/tm/netty/handler/TxCoreServerHandlerÃÄÅ;<=>9:ÆÇÈ
java/lang/StringBuilder
    request->ÉÊËÌÍÎÏ
4com/codingapi/tm/netty/handler/TxCoreServerHandler$1?pÐÑÒÓÔÕÖ×

aØÙ

k

p¾ÚÛÜÝÞßàáâ¿Ñã
com/alibaba/fastjson/JSONObjectäå

d
8com/codingapi/tm/netty/service/impl/ActionATGServiceImpl
返回:æÏçèéêëìíîïðñbcòïóÏôêõöÏdc÷øùúÂ
'io/netty/handler/timeout/IdleStateEventûüýþÿ






-io/netty/channel/ChannelInboundHandlerAdapter
java/lang/Exception
java/lang/String
&io/netty/channel/ChannelHandlerContext
-com/codingapi/tm/netty/service/IActionService

(io/netty/channel/ChannelHandler$Sharable
()V
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;
,com/codingapi/tm/framework/utils/SocketUtils
getJson
&(Ljava/lang/Object;)Ljava/lang/String;
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
toString
()Ljava/lang/String;
org/slf4j/Logger
debug
(Ljava/lang/String;)V
java/util/concurrent/Executor
execute
(Ljava/lang/Runnable;)V
#org/apache/commons/lang/StringUtils

isNotEmpty
(Ljava/lang/String;)Z
parseObject
5(Ljava/lang/String;)Lcom/alibaba/fastjson/JSONObject;
    getString
&(Ljava/lang/String;)Ljava/lang/String;
channel
()Lio/netty/channel/Channel;
io/netty/channel/Channel
 remoteAddress
()Ljava/net/SocketAddress;
java/lang/Object
+com/codingapi/tm/netty/service/NettyService
getActionService
C(Ljava/lang/String;)Lcom/codingapi/tm/netty/service/IActionService;
Y(Ljava/lang/String;Ljava/lang/String;Lcom/alibaba/fastjson/JSONObject;)Ljava/lang/String;
put
8(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
info
sendMsg
=(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/String;)V
.com/codingapi/tm/framework/utils/SocketManager
getInstance
2()Lcom/codingapi/tm/framework/utils/SocketManager;
isAllowConnection
()Z
    addClient
(Lio/netty/channel/Channel;)V
close
"()Lio/netty/channel/ChannelFuture;
removeClient
outLine
)com/codingapi/tm/manager/ModelInfoManager
-()Lcom/codingapi/tm/manager/ModelInfoManager;
removeModelInfo
flush
*()Lio/netty/channel/ChannelHandlerContext;
java/lang/Throwable
printStackTrace
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;
io/netty/channel/ChannelHandler!79:;<=>    
?@
Af*·*¸µ*+µ*,µ±B)# *+,C DE=>
9:
FGA‰5,¸N*´»    Y·
¶-¶¶ ¹*´»Y*-+·¹±B01!248C*5DE5HI
5JK0LMN
OPQ
A
¨¢+¸™+¸N-¶:-¶:-¶¸:,¹
¹
¶:*´¹:¹:    »Y·:
 
¶W
     ¶WÁ!™#*´»    Y·
"¶
¶#¶¶ ¹$,
¶#¸%±B>;<=>?'@7BDDSF\GfHpIxJ˜L¡OCp•RSTM…UM'zVS7jWMD]XYSNZM    \E[S
¢DE¢LM
¢HI\:ÿ˜]^_`^^`^a^`ÿ]^_
bcAs%¸&¶'™¸&+¹
¶(§
+¹)
W*+·*±BU    VXZ$[C%DE%HI
\N
O
dcA/¸&+¹
¶++¹
¹
¶M¸&,¶,¸-,¶.*+·/±B`ab"d)e.fC /DE/HI
eMN
O
fcA@
+¹0
W±B
jkCDEHI
N
O
ghAG
,¶1±B
oqC DEHI
ijN
O
kGA„#2,¶3¶4™,À2N-¶5²6¦
+¹)
W±Bvwxy"|C*lm#DE#HI
#nK\
"N
Oop
AE*+,·
±B
C qErM
sItuv
y8wÀx&