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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
Êþº¾4
#chat/server/moquette/MqttDispatcher
-io/netty/channel/ChannelInboundHandlerAdapter
ATTR_KEEPALIVE
Lio/netty/util/AttributeKey;
    Signature
0Lio/netty/util/AttributeKey<Ljava/lang/Object;>;
ATTR_CLEANSESSION
 ATTR_CLIENTID
logger
Lorg/apache/log4j/Logger;
imDispatcher
Lchat/server/im/IMDispatcher;
:$SWITCH_TABLE$chat$server$moquette$message$MqttMessageType
[I
<clinit>
()V
Code
    keepAlive

io/netty/util/AttributeKey
valueOf
0(Ljava/lang/String;)Lio/netty/util/AttributeKey;    

cleanSession    
!    #
ClientID    
%
 
')(
org/apache/log4j/Logger*+
    getLogger
,(Ljava/lang/Class;)Lorg/apache/log4j/Logger;    
-/
chat/server/im/IMDispatcher
.12
<init>    
4 
LineNumberTable
LocalVariableTable
1
this
%Lchat/server/moquette/MqttDispatcher;
channelRead
=(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V=
(chat/server/moquette/message/MqttMessage
<?@A
messageType
0()Lchat/server/moquette/message/MqttMessageType;C
java/lang/StringBuilderE
Processing MQTT message, type=
BG2H
(Ljava/lang/String;)V
BJKL
append
-(Ljava/lang/Object;)Ljava/lang/StringBuilder;
BNOP
toString
()Ljava/lang/String;
'RST
info
(Ljava/lang/Object;)VVXW
&io/netty/channel/ChannelHandlerContextYZ
channel
()Lio/netty/channel/Channel;

\]
()[I
_a`
,chat/server/moquette/message/MqttMessageTypebc
ordinal
()I

efg
processConnect
G(Lio/netty/channel/Channel;Lchat/server/moquette/message/MqttMessage;)V

ijg
processDisconnectl
/chat/server/moquette/message/MqttPublishMessage
knop
variableHeader
:()Lchat/server/moquette/message/MqttPublishVariableHeader;
rts
6chat/server/moquette/message/MqttPublishVariableHeaderuP
    topicNamew
MP
y{z
java/lang/String|}
equals
(Ljava/lang/Object;)Z    €
java/lang/System‚ƒ
out
Ljava/io/PrintStream;
…‡†
java/io/PrintStreamˆH
println

Š‹g
processPublish

Žg
processPing
Unkonwn MessageType:
'’“T
error•
4Exception was caught while processing MQTT message, 
—™˜
java/lang/Throwableš›
getCause
()Ljava/lang/Throwable;
'“ž
*(Ljava/lang/Object;Ljava/lang/Throwable;)VV ¡¢
fireExceptionCaught
?(Ljava/lang/Throwable;)Lio/netty/channel/ChannelHandlerContext;V¤¥¦
close
"()Lio/netty/channel/ChannelFuture;
¨ª©
 io/netty/util/ReferenceCountUtil«}
release
ctx
(Lio/netty/channel/ChannelHandlerContext;
message
Ljava/lang/Object;
msg
*Lchat/server/moquette/message/MqttMessage;
.Lchat/server/moquette/message/MqttMessageType;
Lio/netty/channel/Channel;
mess
1Lchat/server/moquette/message/MqttPublishMessage;
topic
Ljava/lang/String;
ex
Ljava/lang/Throwable;
 StackMapTable¼
io/netty/channel/Channel¾
java/lang/Object
'ÀÁÂ
isDebugEnabled
()ZÄ
receive connect(channel=)»ÆÇÈ
id
()Lio/netty/channel/ChannelId;
'ÊËT
debugÍ
/chat/server/moquette/message/MqttConnectMessage
ÌÏÐÑ
payload
3()Lchat/server/moquette/message/MqttConnectPayload;
ÓÕÔ
%chat/server/moquette/message/ClientIDÖ
Z(Lchat/server/moquette/message/MqttConnectPayload;)Lchat/server/moquette/message/ClientID;
ØÚÙ
chat/server/ServerInstanceÛÂ
isStart»¤
ÓÞßÂ
isEmpty    áãâ
2chat/server/moquette/message/MqttConnectReturnCodeäå
&CONNECTION_REFUSED_IDENTIFIER_REJECTED
4Lchat/server/moquette/message/MqttConnectReturnCode;

çèé
createConnAckMessageFalse
i(Lchat/server/moquette/message/MqttConnectReturnCode;[B)Lchat/server/moquette/message/MqttConnAckMessage;»ëìí
 writeAndFlush
4(Ljava/lang/Object;)Lio/netty/channel/ChannelFuture;
Ìïoð
:()Lchat/server/moquette/message/MqttConnectVariableHeader;

òóô
customizeChannel
|(Lio/netty/channel/Channel;Lchat/server/moquette/message/ClientID;Lchat/server/moquette/message/MqttConnectVariableHeader;)V
Óö÷ø

setValueTo
(Lio/netty/channel/Channel;)V
úüû
chat/user/SessionStoreýþ
get
<(Lchat/server/moquette/message/ClientID;)Lchat/user/Session;





chat/user/Session
ø

setChannel




refreshLastActiveTime



    


createConnAckPayload
I(Lchat/user/Session;)Lcn/wildfirechat/proto/WFCMessage$ConnectAckPayload;    á

 å
CONNECTION_ACCEPTED




2cn/wildfirechat/proto/WFCMessage$ConnectAckPayload


toByteArray
()[B



é
createConnAckMessage
1Lchat/server/moquette/message/MqttConnectMessage;
1Lchat/server/moquette/message/MqttConnectPayload;
clientID
'Lchat/server/moquette/message/ClientID;
badIdMessage
1Lchat/server/moquette/message/MqttConnAckMessage;
header
8Lchat/server/moquette/message/MqttConnectVariableHeader;
session
Lchat/user/Session;

ackPayload
4Lcn/wildfirechat/proto/WFCMessage$ConnectAckPayload;
successMessage
%
/chat/server/moquette/message/MqttConnectPayload
'
6chat/server/moquette/message/MqttConnectVariableHeader

)
*
+
currentTimeMillis
()J


-
.
/

newBuilder
>()Lcn/wildfirechat/proto/WFCMessage$ConnectAckPayload$Builder;

1
3
2
:cn/wildfirechat/proto/WFCMessage$ConnectAckPayload$Builder
4
5

setMsgHead
?(J)Lcn/wildfirechat/proto/WFCMessage$ConnectAckPayload$Builder;

1
7
8
5
 setFriendHead

1
:
;
5
setFriendRqHead

1
=
>
5
setSettingHead

1
@
A
5
 setServerTime

1
C
D
E
build
6()Lcn/wildfirechat/proto/WFCMessage$ConnectAckPayload;
    timestamp

J
messageHead

friendHead
friendRqHead
settingHead
builder
<Lcn/wildfirechat/proto/WFCMessage$ConnectAckPayload$Builder;
O
,chat/server/moquette/message/MqttFixedHeader    _
Q
R²
CONNACK    
T
V
U
$chat/server/moquette/message/MqttQoS
W
X
AT_MOST_ONCE
&Lchat/server/moquette/message/MqttQoS;

N
Z2
[
Z(Lchat/server/moquette/message/MqttMessageType;ZLchat/server/moquette/message/MqttQoS;ZI)V
]
6chat/server/moquette/message/MqttConnAckVariableHeader

\
_2
`
8(Lchat/server/moquette/message/MqttConnectReturnCode;Z)V
b
/chat/server/moquette/message/MqttConnAckMessage
d
2chat/server/moquette/message/MqttConnectAckPayload

c
f2
g
([B)V

a
i2
j
(Lchat/server/moquette/message/MqttFixedHeader;Lchat/server/moquette/message/MqttConnAckVariableHeader;Lchat/server/moquette/message/MqttConnectAckPayload;)V
code
data
[B
mqttFixedHeader
.Lchat/server/moquette/message/MqttFixedHeader;
mqttConnAckVariableHeader
8Lchat/server/moquette/message/MqttConnAckVariableHeader;
result»
t
u
v
attr
7(Lio/netty/util/AttributeKey;)Lio/netty/util/Attribute;
Ó
x
yP
getValue
{
}
|
io/netty/util/Attribute
~T
set

&
€
c
keepAliveTimeSeconds

ƒ
…
„
java/lang/Integer
†
(I)Ljava/lang/Integer;

&
ˆ
‰Â
isCleanSession

‹

Œ
java/lang/Boolean
Ž
(Z)Ljava/lang/Boolean;»

‘
’
pipeline
$()Lio/netty/channel/ChannelPipeline;
”
–
•
 io/netty/channel/ChannelPipeline
—
˜
names
()Ljava/util/List;
š
idleStateHandler
œ
ž

java/util/List
Ÿ}
contains
”
¡
¢
£
remove
5(Ljava/lang/String;)Lio/netty/channel/ChannelHandler;?À

¦
¨
§
java/lang/Math
©
ª
round
(F)I
¬
)io/netty/handler/timeout/IdleStateHandler

«
®2
¯
(III)V
”
±
²
³
addFirst
W(Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;

I

Z
"Lio/netty/channel/ChannelPipeline;
idleTime

Exceptions
º
java/lang/InterruptedException
¼
receive disconnect(channel=)
Ó
¾
¿
C(Lio/netty/channel/Channel;)Lchat/server/moquette/message/ClientID;»
Á
ÂZ
flush


Ä
Å
closeChannel
ú
Ç
È
É
delete
*(Lchat/server/moquette/message/ClientID;)V
Ë
java/lang/Exception
Í
receive request(channel=)
Ï
    : publish
B
ÑK
Ò
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
.
Ô
Õ
Ö
channelRead0
N(Lio/netty/channel/Channel;Lchat/server/moquette/message/MqttPublishMessage;)V
publishMessage
Ù
receive ping(channel=)    _
Û
ܲ
PINGRESP
<
Þ2
ß
1(Lchat/server/moquette/message/MqttFixedHeader;)V

pingHeader    

â
_
ä
å
æ
values
1()[Lchat/server/moquette/message/MqttMessageType;    _
è
é²
CONNECT    _
ë
ì²

DISCONNECT    _
î
ï²
PINGREQ    _
ñ
ò²
PUBACK    _
ô
õ²
PUBCOMP    _
÷
ø²
PUBLISH    _
ú
û²
PUBREC    _
ý
þ²
PUBREL    _
²
SUBACK    _²
    SUBSCRIBE    _²
UNSUBACK    _    
²
UNSUBSCRIBE
java/lang/NoSuchFieldError

SourceFile
MqttDispatcher.java
InnerClasses
 cn/wildfirechat/proto/WFCMessage
ConnectAckPayload
Builder!

 
    

 
 
 
 

_+¸³¸³ "¸³$
¸&³,».Y·0³3±5"#$* +*,6
2
3

*·7±5
.06
89
:;
8    
,À<N-¶>:²,»BYD·F¶I¶M¶Q+¹U
:¸[¶^.«s
)=i3*-¶d§™*-¶h§-Àk:¶m¶q:v¶x™²~v¶„*-¶‰§c*-·Œ§Y²,»BY·F¶I¶M¶‘§?N²,»BY”·F-¶–¶I¶M-¶œ+-¹ŸW+¹£
W,¸§W§:,¸§W¿,¸§W±½À—êò5v568":*<\>c?fAmBpDvE€FŠG’I™JœL£M¦O½RÀSÁTÛUãVêYòXôYùZüY

[6\    
89
¬­

®¯¸°±²@²*“Y³v&´µ€¶·Á)¸¹º6
þ\<_»        ý!kyù        ÿ
V½
—q—    
fg

¼
³²,¶¿™²,»BY÷F+¹Å
¶I¶M¶É,ÀÌN-¶Î:¸Ò:¸×š+¹Ü
W±¶Ý™*²à
·æ:+¹êW+¹Ü
W±-¶î:*+·ñ+¶õ¸ù:Æ+¶ÿ¶
*·
:*²
¶
·
:    +    ¹êW±5b^    _$b)c/e6h<iCjDnLoVp_qfrgvmwvz||ƒ~ˆŽ€“„›…©†²‹6p³89³Y³
³°±)Š®
/„Ð
6}

V

mF

ƒ0

 ›
!
"©

#
    º$þÌ
$Ó"ý+
&

    


òH¸
(A 7 7 7 7
¸
,:¶
0W¶
6W¶
9W
¶
<W¸
(¶
?W¶
B:  °56 Ž
‘ ’”•–%—-˜5™>›Eœ6\    H89H

 
D
F
GA
H
G
>
I
G ;
J
G8
K
G
3
L
MEÐ
" 
é
›3»
NY²
P²
S·
YN»
\Y+·
^:»
aY-»
cY,·
e·
h:°5 ¡£0¤6>3893
kå
3
l
m"
n
o
p
q0
r
èé
›3»
NY²
P²
S·
YN»
\Y+·
^:»
aY-»
cY,·
e·
h:°5¨©«0¬6>3893
kå
3
l
m"
n
o
p
q0
r
óô

4Œ+²$¹
s,¶
w¹
z-¶
6+²¹
s¸
‚¹
z-¶
‡6+² ¹
s¸
Š¹
z+¹

:¹
“

™¹
›™
™¹
 W†
¤j¸
¥6
™»
«Y·
­¹
°W±5.±´µ+¸1¹D¼L¾^¿iÂuËÄ6RŒ89ŒY³
Œ

Œ

t

´1[
µL@
‘
¶u
·
´º

þi


”
jg
¸

¹ö[²,¶¿™²,»BY
»·F+¹Å
¶I¶M¶É+¸
½N+¹
À
W-¶Ý™+¹Ü
W±-¸ù:DZ¶
¶
Ã-¸
Ʊ5:Ç    È%Ë*Î1Ñ8Ò?Ó@×FÙKÚLÝQÞVáZâ64[89[Y³
[°±*1

F

 º%üÓü

‹g
¸

Êš9²,¶¿™%²,»BY
Ì·F+¹Å
¶I
ζ
жM¶É,ÀkN²3+-¶
Ó±5å    æ+é0ê8ë6*9899Y³
9®±0    
×µº
+Žg
¹J²,¶¿™²,»BY
Ø·F+¹Å
¶I¶M¶É»
NY²
Ú²
S·
YN»<Y-·
Ý:+¹êW±5î    ï%ò6ó@ôIõ64J89JY³
J®±6
à
o@

r±º
%]

À
Õ²
áYÆ°W¸
ã¾¼
K*²
P¶^O§W*²
ç¶^O§W*²
ê¶^O§W*²
í¶^O§W*²
Ú¶^ O§W*²
ð¶^O§W*²
ó¶^O§W*²
ö¶^O§W*²
ù¶^O§W*²
ü¶^O§W*²
ÿ¶^    O§W*²¶^O§W*²¶^O§W*²¶^
O§W*Y³
á°&)*478BEFPST]`aknox{|…ˆ‰“–—¡¤¥¯²³½ÀÁËÎ5
 6ºUH ÿ
 
KLLLKLKKLLLLL

1