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
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
Êþº¾4
V
chat/server/netty/NettyAcceptor
java/lang/Object
logger
Lorg/apache/log4j/Logger;
instance
!Lchat/server/netty/NettyAcceptor;
    bossGroup
!Lio/netty/channel/EventLoopGroup;
workerGroup
channelClass
Ljava/lang/Class;
    Signature
ALjava/lang/Class<+Lio/netty/channel/socket/ServerSocketChannel;>;
httpChannelFuture
 Lio/netty/channel/ChannelFuture;
tcpChannelFuture
sslTCPChannelFuture
wsChannelFuture
messageMetricsCollector
.Lchat/server/moquette/MessageMetricsCollector;
bytesMetricsCollector
,Lchat/server/moquette/BytesMetricsCollector;
<clinit>
()V
Code

org/apache/log4j/Logger !
    getLogger
,(Ljava/lang/Class;)Lorg/apache/log4j/Logger;    
#
LineNumberTable
LocalVariableTable
<init>
(&
this
getInstance
#()Lchat/server/netty/NettyAcceptor;    
-

(
 StackMapTable
start

Exceptions3
java/lang/Exception

5*+

78
doStart
stop

;<
doStop
>?@
error
(Ljava/lang/Object;)V

e
Ljava/lang/Exception;D
Initializing Netty acceptor...
FG@
info

IJ
initLocalVariable

LM
initializeHttpTransport

OP
initializePlainTCPTransport

RS
initializeSSLTCPTransport

UV
initializeWSSTransportX
Netty acceptor initializedZ
Closing Netty acceptor...    
\

^_`
closeOneChannel
#(Lio/netty/channel/ChannelFuture;)V    
b    
d    
fh
worker group    
j
 

lmn
closeOneEventLoopGroup
6(Ljava/lang/String;Lio/netty/channel/EventLoopGroup;)Vp

boss group    
r    
t
netty.epoll
vxw
chat/server/Configeryz

getBoolean
(Ljava/lang/String;Z)Z|
Netty is using Epoll~
*io/netty/channel/epoll/EpollEventLoopGroup
}€&
(I)V
}(„
/io/netty/channel/epoll/EpollServerSocketChannel    
† ˆ
Netty is using NIOŠ
&io/netty/channel/nio/NioEventLoopGroup
‰€
‰(Ž
2io/netty/channel/socket/nio/NioServerSocketChannel
*chat/server/moquette/BytesMetricsCollector
(    
“•
,chat/server/moquette/MessageMetricsCollector
”(    
˜
epoll

Zœ
HTTPž
    http_port
v ¡¢

getInteger
:(Ljava/lang/String;Ljava/lang/Integer;)Ljava/lang/Integer;¤
java/lang/StringBuilder¦
skip server, Protocol=
£¨&©
(Ljava/lang/String;)V
£«¬­
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
£¯°±
toString
()Ljava/lang/String;³
Initializing server. Protocol=µ
-chat/server/netty/NettyHttpChannelInitializer
´(¸
&chat/server/netty/NettyServerBootstrap
·º&»
I(Lchat/server/netty/NettyAcceptor;Lio/netty/channel/ChannelInitializer;)V
½¿¾
java/lang/IntegerÀÁ
intValue
()I
ÃÅÄ
"io/netty/bootstrap/ServerBootstrapÆÇ
bind
#(I)Lio/netty/channel/ChannelFuture;ÉËÊ
io/netty/channel/ChannelFutureÌÍ
sync
"()Lio/netty/channel/ChannelFuture;    ÏÑÐ
&io/netty/channel/ChannelFutureListenerÒÓ
FIRE_EXCEPTION_ON_FAILURE
(Lio/netty/channel/ChannelFutureListener;ÉÕÖ×
addListener
R(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/channel/ChannelFuture;Ù
server bounded. Protocol=Û
: 
£Ý¬Þ
-(Ljava/lang/Object;)Ljava/lang/StringBuilder;
protocol
Ljava/lang/String;
port
Ljava/lang/Integer;
initializer
/Lchat/server/netty/NettyHttpChannelInitializer;
    bootStrap
$Lio/netty/bootstrap/ServerBootstrap;è
java/lang/Stringê
TCPáí
,chat/server/netty/NettyTCPChannelInitializer
ì(
ìðñò
setMessageMetricsCollector
1(Lchat/server/moquette/MessageMetricsCollector;)V
ìôõö
setBytesMetricsCollector
/(Lchat/server/moquette/BytesMetricsCollector;)V
.Lchat/server/netty/NettyTCPChannelInitializer;ù
java/lang/InterruptedExceptionû
SSLý
ssl_portÿ
,chat/server/netty/NettySSLChannelInitializer
þ(
þð
þô
.Lchat/server/netty/NettySSLChannelInitializer;

Secure Websocket

ws_port
    
+chat/server/netty/NettyWSChannelInitializer

(
%Lio/netty/channel/ChannelInitializer;
LocalVariableTypeTable
NLio/netty/channel/ChannelInitializer<Lio/netty/channel/socket/SocketChannel;>;É



channel
()Lio/netty/channel/Channel;



io/netty/channel/Channel
Í
close


Í
closeFuture
 channelFuture
Lio/netty/channel/Channel;



io/netty/channel/EventLoopGroup
 
!
shutdownGracefully
#()Lio/netty/util/concurrent/Future;
#
Waiting for
%
" event loop groups to terminate...    
)
+
*
java/util/concurrent/TimeUnit
,
-
SECONDS
Ljava/util/concurrent/TimeUnit;
/
1
0
io/netty/util/concurrent/Future
2
3
await
#(JLjava/util/concurrent/TimeUnit;)Z
5
PAn InterruptedException was caught while waiting for event loops to terminate...

7
8@
warn

:
;
<
isTerminated
()Z
>
Forcing shutdown 
@
...    
)
B
C
-
MILLISECONDS

E
 
F
D(JJLjava/util/concurrent/TimeUnit;)Lio/netty/util/concurrent/Future;
name
    loopGroup
waiter
!Lio/netty/util/concurrent/Future;
iex
 Ljava/lang/InterruptedException;
$Lio/netty/util/concurrent/Future<*>;
getBossGroup
#()Lio/netty/channel/EventLoopGroup;
getWorkerGroup
getChannelClass
()Ljava/lang/Class;
C()Ljava/lang/Class<+Lio/netty/channel/socket/ServerSocketChannel;>;

SourceFile
NettyAcceptor.java!

 
    
 
 

-
    
¸³"±$
-.%&
3

*·'±$
02%
))*+
E²,Ç »
Y·.³,²,°$569%/
    01
25
 ¸4³,²,¶6±$=>?%    9
k
¸4³,²,¶:§K²"*¶=±
2$CDEFGI%
AB/O2
81
2k
%²"C¶E*·H*·K*·N*·Q*·T²"W¶E±$"LORUX[]$^%
%)
<
ƒ
=²"Y¶E**´[·]**´a·]**´c·]**´e·]*g*´i·k*o*´q·k±$"adef g(j2k<l%
=)J
äos¸u<™+²"{¶E*»}Y·µq*»}Y·‚µi*ƒµ…§(²"‡¶E*»‰Y·‹µq*»‰Y·Œµi*µ…*»Y·‘µ’*»”Y·–µ—±$:pqstu*v0w3y;zG{R|X€cn‚%o)h™š
/ü3
$M1
2
›L
¸ŸM,Dz"»£Y¥·§+¶ª¶®¶E±²"»£Y²·§+¶ª¶®¶E»´Y·¶N»·Y*-·¹:*,¶¼¶Âµ[*´[¹È
²Î¹ÔW²"»£YØ·§+¶ªÚ¶ª,¶Ü¶®¶E±$2…†
ˆ‰$Š%Ž;CN“[”m–Œ—%4)Šßà

ƒáâCJãäN?åæ/
ý%ç½P1
2
‡éLë
¸ŸM,Dz"»£Y¥·§+¶ª¶®¶E±»ìY·îN-*´—¶ï-*´’¶ó»·Y*-·¹:*,¶¼¶Âµa*´a¹È
²Î¹ÔW²"»£YØ·§+¶ªÚ¶ª,¶Ü¶®¶E±$6 ›œ
žŸ$ %¤-¥5¦=¨H«U¬g®†¯%4‡)„ßà

}áâ-Zã÷H?åæ/
ý%ç½S1
ø
‡úLü
¸ŸM,Dz"»£Y¥·§+¶ª¶®¶E±»þY·
N-*´—¶

-*´’¶
»·Y*-·¹:*,¶¼¶Âµc*´c¹È
²Î¹ÔW²"»£YØ·§+¶ªÚ¶ª,¶Ü¶®¶E±$6 ³´
¶·$¸%¼-½5¾=ÀHÃUÄgƆÇ%4‡)„ßà

}áâ-Zã
H?åæ/
ý%ç½V1
2
y
L

¸ŸM,Dz"»£Y¥·§+¶ª¶®¶E±»
Y·

N»·Y*-·¹:*,¶¼¶Âµe*´e¹È
²Î¹ÔW²"»£YØ·§+¶ªÚ¶ª,¶Ü¶®¶E±$.ËÌÎÏ&Ð'Ô/Õ:ØGÙYÛxÜ%4y)ußà
máâ/Jã
:?åæ

/Jã
 /
ý'ç½_`
´
(+DZ+¹

M,¹

W§N,¹

¹È
W§N±2#&2$"ßàãåæê#ë'í% ()(



/ÿ
É

2N2mn

0w,DZ,¹

N²"»£Y
"·§+¶ª
$¶ª¶®¶E-
&²
(¹
.W§:²"
4¶
6,¹
9
š,²"»£Y
=·§+¶ª
?¶ª¶®¶
6,        ²
A¹
DW±
)69ø$2ðñõ÷)ù6ú9û;üD
M

j
v
%4w)w
Gà
w
H
k
I
J;    
K
L

k
I
M/ÿ3
ç

/
ø
1

N
O
/

*´q°$

%
)

P
O
/

*´i°$

%
)

Q
R
S/

*´…°$

%
)

T
U