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
24
25
26
Êþº¾4„
,chat/server/netty/NettySSLChannelInitializer
#io/netty/channel/ChannelInitializer
messageMetricsCollector
.Lchat/server/moquette/MessageMetricsCollector;
bytesMetricsCollector
,Lchat/server/moquette/BytesMetricsCollector;
<init>
()V
Code
     

LineNumberTable
LocalVariableTable
this
.Lchat/server/netty/NettySSLChannelInitializer;
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;
&'(
intValue
()I*,+
%io/netty/channel/socket/SocketChannel-.
pipeline
$()Lio/netty/channel/ChannelPipeline;0
,chat/server/moquette/MqttBytesMetricsHandler    
2
/4    5
/(Lchat/server/moquette/BytesMetricsCollector;)V7
)io/netty/handler/timeout/IdleStateHandler
69    :
(III)V<
+chat/server/moquette/MqttIdleTimeoutHandler
; ?
%chat/server/moquette/MqttDecodHandler
> 
BDC
%chat/server/moquette/MqttEncodHandlerEF
getInstance
#()Lio/netty/channel/ChannelHandler;H
.chat/server/moquette/MqttMessageMetricsHandler    
J
GL    M
1(Lchat/server/moquette/MessageMetricsCollector;)VO
-chat/server/moquette/MqttMessageLoggerHandler
N R
chat/server/im/IMDispatcher
Q U
bytemetricsWYX
 io/netty/channel/ChannelPipelineZ[
addFirst
W(Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;]
idleStateHandlerW_`[
addLastb
idleEventHandlerWdef
addAfter
i(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;h
decoderj
encoderl
metricsn
 messageLoggerp
handler
channel
'Lio/netty/channel/socket/SocketChannel;
timeoutSeconds

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

dispatcher
setMessageMetricsCollector
setBytesMetricsCollector
(Lio/netty/channel/Channel;)V



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

    

/

*·±



Ÿ¿
¸¸¶%=+¹)
N»/Y*´1·3:»6Y·8:»;Y·=:»>Y·@:¸A:»GY*´I·K:    »NY·P:
»QY·S:-T¹VW-\¹^W-\a¹cW-g¹^W-i¹^W-k    ¹^W-m
¹^W-o¹^W±N" .!7#@$E%R&['d)o*z+‡-’./¨0³1¾2z¿¿qr
±stª-u"vw.‘]w7ˆxw@hwEzjwRmyw    [dnw
d[zw
{M
>*+µI±
56

|5
>*+µ1±
9:
D}
)    *+À*¶~±

€‚ƒ