IM服务端

hefeixia

2021-02-18 5b8c95c760840f09910730943b21391e47187315

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
Êþº¾4}
,chat/server/netty/NettyTCPChannelInitializer
#io/netty/channel/ChannelInitializer
bytesMetricsCollector
,Lchat/server/moquette/BytesMetricsCollector;
logger
Lorg/apache/log4j/Logger;
<init>
()V
Code
     
 

org/apache/log4j/Logger
    getLogger
,(Ljava/lang/Class;)Lorg/apache/log4j/Logger;    

LineNumberTable
LocalVariableTable
this
.Lchat/server/netty/NettyTCPChannelInitializer;
initChannel
*(Lio/netty/channel/socket/SocketChannel;)V

Exceptions
java/lang/Exception 
timeout
"$#
java/lang/Integer%&
valueOf
(I)Ljava/lang/Integer;
(*)
chat/server/Configer+,

getInteger
:(Ljava/lang/String;Ljava/lang/Integer;)Ljava/lang/Integer;
"./0
intValue
()I243
%io/netty/channel/socket/SocketChannel56
pipeline
$()Lio/netty/channel/ChannelPipeline;8
,chat/server/moquette/MqttBytesMetricsHandler    
:
7<    =
/(Lchat/server/moquette/BytesMetricsCollector;)V?
)io/netty/handler/timeout/IdleStateHandler
>A    B
(III)VD
+chat/server/moquette/MqttIdleTimeoutHandler
C G
%chat/server/moquette/MqttDecodHandler
F J
%chat/server/moquette/MqttEncodHandler
I M
#chat/server/moquette/MqttDispatcher
L P
bytemetricsRTS
 io/netty/channel/ChannelPipelineUV
addFirst
W(Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;X
idleStateHandlerRZ[V
addLast]
idleEventHandlerR_`a
addAfter
i(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;c
decodere
encoderg
handler
channel
'Lio/netty/channel/socket/SocketChannel;
timeoutSeconds

I
"Lio/netty/channel/ChannelPipeline;
bytesMetricsHandler
!Lio/netty/channel/ChannelHandler;
timeoutHandler

dispatcher
setMessageMetricsCollector
1(Lchat/server/moquette/MessageMetricsCollector;)V
messageMetricsCollector
.Lchat/server/moquette/MessageMetricsCollector;
setBytesMetricsCollector
(Lio/netty/channel/Channel;)V

x

SourceFile
NettyTCPChannelInitializer.java
    Signature
NLio/netty/channel/ChannelInitializer<Lio/netty/channel/socket/SocketChannel;>;!

    

@
*·*
¸µ± 


S
—
¸!¸'¶-=+¹1
N»7Y*´9·;:»>Y·@:»CY·E:»FY·H:»IY·K:»LY·N:    -O¹QW-W¹YW-W\¹^W-b¹YW-d¹YW-f    ¹YW±>!"".#7$@%I(R*]+h,u.€/‹2–3f
——hi
‰jk‚5l"umn.iXn7`on@WcnINenREpn    
qr
5
±
7

st

u=
>*+µ9±
:;
Dv
)    *+À2¶w±

yz{|