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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
Êþº¾43
%chat/server/moquette/MqttEncodHandler
.io/netty/handler/codec/MessageToMessageEncoder
INSTANCE
'Lchat/server/moquette/MqttEncodHandler;
logger
Lorg/apache/log4j/Logger;
:$SWITCH_TABLE$chat$server$moquette$message$MqttMessageType
[I
<clinit>
()V
Code


<init>    


org/apache/log4j/Logger
    getLogger
,(Ljava/lang/Class;)Lorg/apache/log4j/Logger;    

LineNumberTable
LocalVariableTable

this
getInstance
#()Lio/netty/channel/ChannelHandler;
encode
e(Lio/netty/channel/ChannelHandlerContext;Lchat/server/moquette/message/MqttMessage;Ljava/util/List;)V

Exceptions%
java/lang/Exception
    Signature
y(Lio/netty/channel/ChannelHandlerContext;Lchat/server/moquette/message/MqttMessage;Ljava/util/List<Ljava/lang/Object;>;)V)+*
&io/netty/channel/ChannelHandlerContext,-
alloc
$()Lio/netty/buffer/ByteBufAllocator;

/01
doEncode
g(Lio/netty/buffer/ByteBufAllocator;Lchat/server/moquette/message/MqttMessage;)Lio/netty/buffer/ByteBuf;354
java/util/List67
add
(Ljava/lang/Object;)Z
ctx
(Lio/netty/channel/ChannelHandlerContext;
msg
*Lchat/server/moquette/message/MqttMessage;
out
Ljava/util/List;
LocalVariableTypeTable
$Ljava/util/List<Ljava/lang/Object;>;

A    B
()[I
DFE
(chat/server/moquette/message/MqttMessageGH
fixedHeader
0()Lchat/server/moquette/message/MqttFixedHeader;
JLK
,chat/server/moquette/message/MqttFixedHeaderMN
messageType
0()Lchat/server/moquette/message/MqttMessageType;
PRQ
,chat/server/moquette/message/MqttMessageTypeST
ordinal
()IV
encode CONNECT
XYZ
debug
(Ljava/lang/Object;)V\
/chat/server/moquette/message/MqttConnectMessage

^_`
encodeConnectMessage
n(Lio/netty/buffer/ByteBufAllocator;Lchat/server/moquette/message/MqttConnectMessage;)Lio/netty/buffer/ByteBuf;b
encode CONNACKd
/chat/server/moquette/message/MqttConnAckMessage

fgh
encodeConnAckMessage
n(Lio/netty/buffer/ByteBufAllocator;Lchat/server/moquette/message/MqttConnAckMessage;)Lio/netty/buffer/ByteBuf;j
encode PUBLISHl
/chat/server/moquette/message/MqttPublishMessage

nop
encodePublishMessage
n(Lio/netty/buffer/ByteBufAllocator;Lchat/server/moquette/message/MqttPublishMessage;)Lio/netty/buffer/ByteBuf;r
encode SUBSCRIBEt
1chat/server/moquette/message/MqttSubscribeMessage

vwx
encodeSubscribeMessage
p(Lio/netty/buffer/ByteBufAllocator;Lchat/server/moquette/message/MqttSubscribeMessage;)Lio/netty/buffer/ByteBuf;z
encode UNSUBSCRIBE|
3chat/server/moquette/message/MqttUnsubscribeMessage

~€
encodeUnsubscribeMessage
r(Lio/netty/buffer/ByteBufAllocator;Lchat/server/moquette/message/MqttUnsubscribeMessage;)Lio/netty/buffer/ByteBuf;‚
 encode SUBACK„
.chat/server/moquette/message/MqttSubAckMessage

†‡ˆ
encodeSubAckMessage
m(Lio/netty/buffer/ByteBufAllocator;Lchat/server/moquette/message/MqttSubAckMessage;)Lio/netty/buffer/ByteBuf;Š
encode PUBCOMP

Œ1
6encodeMessageWithOnlySingleByteFixedHeaderAndMessageId
encode DISCONNECT

‘’1
*encodeMessageWithOnlySingleByteFixedHeader”
"java/lang/IllegalArgumentException–
java/lang/StringBuilder˜
Unknown message type: 
•š›
(Ljava/lang/String;)V
PžT
value
• ¡¢
append
(I)Ljava/lang/StringBuilder;
•¤¥¦
toString
()Ljava/lang/String;
“š
$©ª
printStackTrace
byteBufAllocator
"Lio/netty/buffer/ByteBufAllocator;
message

e
Ljava/lang/Exception;
 StackMapTable²
encode encodeConnectMessage
[F
[µ¶·
variableHeader
:()Lchat/server/moquette/message/MqttConnectVariableHeader;
[¹º»
payload
3()Lchat/server/moquette/message/MqttConnectPayload;
½¿¾
6chat/server/moquette/message/MqttConnectVariableHeaderÀ¦
name
½ÂÃT
version
ÅÇÆ
 chat/server/moquette/MqttVersionÈÉ
fromProtocolNameAndLevel
7(Ljava/lang/String;B)Lchat/server/moquette/MqttVersion;
ËÍÌ
/chat/server/moquette/message/MqttConnectPayloadΦ
clientIdentifier
ÐÒÑ
"chat/server/moquette/MqttCodecUtilÓÔ
isValidClientId
7(Lchat/server/moquette/MqttVersion;Ljava/lang/String;)ZÖ
4chat/server/moquette/MqttIdentifierRejectedExceptionØ
invalid clientIdentifier: 
•Ú¡Û
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
՚

Þßà
encodeStringUtf8
(Ljava/lang/String;)[B
Ëâã¦
    willTopic    åçæ
"io/netty/util/internal/EmptyArraysèé
EMPTY_BYTES
[B
Ëëì¦
willMessage
½îïð

isWillFlag
()Z
Ëòó¦
userName
½õöð
hasUserName
Ëøùú
password
()[B
½üýð
hasPassword
Åÿ
ú
protocolNameBytes





getVariableLengthInt
(I)I



 io/netty/buffer/ByteBufAllocator
    


buffer
(I)Lio/netty/buffer/ByteBuf;



 

getFixedHeaderByte1
1(Lchat/server/moquette/message/MqttFixedHeader;)I




io/netty/buffer/ByteBuf



    writeByte





writeVariableLengthInt
(Lio/netty/buffer/ByteBuf;I)V
 
 
writeShort
 
writeBytes
([B)Lio/netty/buffer/ByteBuf;


 
!
"
getConnVariableHeaderFlag
;(Lchat/server/moquette/message/MqttConnectVariableHeader;)I
½
$
%T
keepAliveTimeSeconds


'

(
([BII)Lio/netty/buffer/ByteBuf;
1Lchat/server/moquette/message/MqttConnectMessage;
payloadBufferSize

I
mqttFixedHeader
.Lchat/server/moquette/message/MqttFixedHeader;
8Lchat/server/moquette/message/MqttConnectVariableHeader;
1Lchat/server/moquette/message/MqttConnectPayload;
mqttVersion
"Lchat/server/moquette/MqttVersion;
Ljava/lang/String;
clientIdentifierBytes
willTopicBytes
willMessageBytes
 userNameBytes
 passwordBytes
variableHeaderBufferSize
variablePartSize
fixedHeaderBufferSize
buf
Lio/netty/buffer/ByteBuf;
>
java/lang/Stringé
A
 encode getConnVariableHeaderFlag
½
C
Dð
isWillRetain
½
F
GT
willQos
½
I
Jð
isCleanSession
flagByte
M
encode encodeConnAckMessage
c
Oº
P
()Ljava/lang/Object;
R
2chat/server/moquette/message/MqttConnectAckPayload

Q
T
Uú
getData
cF
c
X¶
Y
:()Lchat/server/moquette/message/MqttConnAckVariableHeader;

[
]
\
6chat/server/moquette/message/MqttConnAckVariableHeader
^ð
isSessionPresent

[
`
a
b
connectReturnCode
6()Lchat/server/moquette/message/MqttConnectReturnCode;

d
f
e
2chat/server/moquette/message/MqttConnectReturnCode
g
h
    byteValue
()B
1Lchat/server/moquette/message/MqttConnAckMessage;
length
4Lchat/server/moquette/message/MqttConnectAckPayload;
m
encode encodeSubscribeMessage
sF
s
p¶
q
<()Lchat/server/moquette/message/MqttMessageIdVariableHeader;
s
sº
t
5()Lchat/server/moquette/message/MqttSubscribePayload;

v
x
w
1chat/server/moquette/message/MqttSubscribePayload
y
z
topicSubscriptions
()Ljava/util/List;3
|
}
~
iterator
()Ljava/util/Iterator;
€
‚

java/util/Iterator
ƒ
P
next
…
2chat/server/moquette/message/MqttTopicSubscription

„
‡
ˆ¦
    topicName
€
Š
‹ð
hasNext



Ž
8chat/server/moquette/message/MqttMessageIdVariableHeader
T
    messageId

„
’
“
”
qualityOfService
(()Lchat/server/moquette/message/MqttQoS;

–
—
$chat/server/moquette/message/MqttQoS
3Lchat/server/moquette/message/MqttSubscribeMessage;
:Lchat/server/moquette/message/MqttMessageIdVariableHeader;
3Lchat/server/moquette/message/MqttSubscribePayload;
topic
4Lchat/server/moquette/message/MqttTopicSubscription;
topicNameBytes
Ÿ
encode encodeUnsubscribeMessage
{F
{
p
{
£º
¤
7()Lchat/server/moquette/message/MqttUnsubscribePayload;

¦
¨
§
3chat/server/moquette/message/MqttUnsubscribePayload
©
z
topics
5Lchat/server/moquette/message/MqttUnsubscribeMessage;
5Lchat/server/moquette/message/MqttUnsubscribePayload;
­
encode encodeSubAckMessage
ƒ
¯º
°
2()Lchat/server/moquette/message/MqttSubAckPayload;

²
´
³
.chat/server/moquette/message/MqttSubAckPayload
µ
z
grantedQoSLevels3
·
¸T
size
ƒF
ƒ
p
¼
java/lang/Integer

»
¾
¿T
intValue
0Lchat/server/moquette/message/MqttSubAckMessage;
qos
Ã
encode encodePublishMessage
kF
k
Æ¶
Ç
:()Lchat/server/moquette/message/MqttPublishVariableHeader;
k
Éº
Ê
()Lio/netty/buffer/ByteBuf;


Ì
Í
Ê
    duplicate

Ï
‡
Ð
6chat/server/moquette/message/MqttPublishVariableHeader
J
Ò
Ó
”
qosLevel


Õ
ÖT
 readableBytes

Ï



Ù

Ú
4(Lio/netty/buffer/ByteBuf;)Lio/netty/buffer/ByteBuf;
1Lchat/server/moquette/message/MqttPublishMessage;
8Lchat/server/moquette/message/MqttPublishVariableHeader;
Þ
=encode encodeMessageWithOnlySingleByteFixedHeaderAndMessageId
D
à¶
P
D
O
msgId
J
ä
åð
isDup
J
ç
èð
isRetain
header
ret
num
digit
count    
ï
ñ
ð
io/netty/util/CharsetUtil
ò
ó
UTF_8
Ljava/nio/charset/Charset;

=
õ
ö
÷
getBytes
(Ljava/nio/charset/Charset;)[B

s
M(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;Ljava/util/List;)V


û!"    

ý    
 
P
ÿ

values
1()[Lchat/server/moquette/message/MqttMessageType;    P
CONNACK
.Lchat/server/moquette/message/MqttMessageType;    P
CONNECT    P
 
DISCONNECT    P 
PINGREQ    P
PINGRESP    P
PUBACK    P
PUBCOMP    P
PUBLISH    P
PUBREC    P 
PUBREL    P"#
SUBACK    P%&
    SUBSCRIBE    P()
UNSUBACK    P+,
UNSUBSCRIBE.
java/lang/NoSuchFieldError
 
SourceFile
MqttEncodHandler.java
\Lio/netty/handler/codec/MessageToMessageEncoder<Lchat/server/moquette/message/MqttMessage;>;!

 
    

 7»
Y·³
¸³±
!
#

 /

*·±
%
     
 $
²°
(!"#
$&' p-+¹(
,¸.¹2W±
./*89
:;<=>
<?01
 
óþ¸@+¶C¶I¶O.ªÈ
FWh¬¬¬¬y›Š¬ººº²U¶W*+À[¸]°²a¶W*+Àc¸e°²i¶W*+Àk¸m°²q¶W*+Às¸u°²y¶W*+À{¸}°²¶W*+Àƒ¸…°²‰¶W*+¸‹°²Ž¶W*+¸°»“Y»•Y—·™+¶C¶I¶œ¶Ÿ¶£·§¿M,¶¨
°    d÷$eu÷$v†÷$‡—÷$˜¨÷$©¹÷$ºÇ÷$ÈÕ÷$Ö÷÷$^;T=\>eAmBvE~F‡IJ˜M N©Q±RºYÂZÈ_Ð`ÖcÚdóc÷gøhüi þ«¬þ­;
ø®¯°
ûT  `$
_`
 >
á²±¶W=+¶³N+¶´:+¶¸:¶¼¶Á‘¸Ä:¶Ê:¸Ïš»ÕY»•Y×·™¶Ù¶£·Ü¿¸Ý:¾``=¶á:        Æ    ¸Ý§²ä:
¶ê:Ƹݧ²ä:¶í™
¾``=¾``=¶ñ:  Æ ¸Ý§²ä:¶ô™¾``=¶÷:¶û™¾``=¶þ:¾``6`6¸

`6*`¹
:-¸
¶
W¸
¾¶
W¶
W¶Á¶
W¸
¶
W¶
#¶
W¾¶
W¾¶
&W¶í™-
¾¶
W
 
¾¶
&W¾¶
W¾¶
&W¶ô™¾¶
W¾¶
&W¶û™¾¶
W¾¶
&W°Ö5pr
tuvw x&w+{2|<}U\€dƒk„}…„†–‡žˆ¦‰®ŒµÇŽÏ×’Þ“æ”î˜õ™þš
›
 œ

$ž
+ 
4¡
<£
G¤
R¥
]¨
f©
rª
z«
ƒ¬
­
˜®
¤°
±
µ²
Á´
ɵ
Ò¶
Þ¸Ô
᫬
á­
)


×
*
+
Ò
,
-
̶
.
ƺ
/+
¶
0
12
¯Î
2\
…
3ék
vã
2    }
d
4é
„
]ì
2–
K
5éµ
,ó
2 Ç

6éÞ

7éõì
éþã
8
+
Ý
9
+
 Ô
:
+
Ç
;
<°• ÿU
[
J½ËÅ
=ý"
?
=B
?ý
?
=B
?ü
?ü
=B
?ü
?ü
?ÿµ
[
J½ËÅ
=
?
=
?
=
?
=
?
?
?





!
"
 ËS²
@¶W<*¶ô™    €€<*¶û™@€<*¶
B™ €<*¶
E~x€<*¶í™€<*¶
H™€<¬:¼    ¾¿ÀÂÃ$Å+Æ0È;ÉBÊFÌMÍQÏS¶
.H
K
+
°
ü

 
gh
 
R‰²
L¶W=
N+¶
NÆ"+¶
NÀ
QN-¶
SÆ-¶
S¾ž-¶
S¾`=*¹
:+¶
V¸
¶
Wd¶
W+¶
W¶
Z™§¶
W+¶
W¶
_¶
c¶
W¤ -¶
S¶
W°>Õ    ×Ø ÙÚÛ+Ü3ß<àIáRâgãwä|å†è4‰«¬‰­
i
~
j
+ |º
k<M
;
<°9ý3

Qÿ.
c

Q


ÿ
c

Q


"
wx
 lò²
l¶W=>+¶
n:+¶
o:+¶
r:¶
u¹
{
:§(¹

À
„:¶
†:        ¸Ý:
 
¾``>„
¹
‰
šÿÔ`6¸

`6*`¹
:        ¸
¶
W    ¸
¶
Œ6
    
¶
W¶
u¹
{
:§@¹

À
„:¶
†:  ¸Ý:    ¾¶
W    ¾¶
&W    ¶
Ԧ
•¶
W¹
‰
šÿ¼    °nî    ðñ óôõ÷:øAùHúPûS÷]þbÿk

x
ƒ
Š
‘
™

´
»
Â
 Ë
×
å

ï
¬ò«¬ò­
˜
ç
8
+ å
*
+ß
,
-Ù¶
™Óº
š:
›
œA
ˆ
2    H
é
b
9
+k‡
:
+xz
;
<    ‘a

+
´1
›
œ»*
ˆ
2 Â#
é°Bÿ.    
s

J

v
€$ÿT 
s

J

v




€<
€
 )Ó²
ž¶W=>+¶
 :+¶
¡:+¶
¢:¶
¥¹
{
:§¹

À
=:¸Ý:        ¾``>¹
‰
šÿÞ`6¸

`6*`¹
:        ¸
¶
W    ¸
¶
Œ6
    
¶
W¶
¥¹
{
:§+¹

À
=:¸Ý:      ¾¶
W      ¾¶
&W¹
‰
šÿÑ    °^
    

 



!:
"A
#I
!S
&X
'a
)n
*y
+€
.‡
/
2ª
3±
4º
5Æ
2Ð
8˜Ó«¬Ó­
ª
È
8
+ Æ
*
+À
,
-º¶
™´º
«:
ˆ
2A
é    X{
9
+ar
:
+ne
;
<    ‡L

+
ª
ˆ
2±
é °Bÿ.    
{

J

¦
€ÿT 
{

J

¦




€'
‡ˆ
 
J    ‰²
¬¶W=+¶
®¶
±¹
¶
>`6¸

`6*`¹
:+¶
¹¸
¶
W¸
+¶
º¶
Φ
W+¶
®¶
±¹
{
:§¹

À
Ȧ
½6¶
W¹
‰
šÿâ°6 
>    
@
A
B
C&
D3
E@
FG
GT
Ht
I|
H†
LR‰«¬‰­
À
~
8
+q
*
+l
9
+&c
:
+3V
;
<t
Á
+°ÿe    
ƒ





€
op
 
ó¥²
¶W+¶
ÄM+¶
ÅN+¶
ȶ
Ë:-¶
Î:¸Ý:¾`,¶
Ѷ
•ž§`6¶
Ô6`6        ¸

`6
*
    `¹
:,¸
¶
W    ¸
¾¶
W¶
W,¶
Ѷ
•ž -¶
׶
W¶
ØW°V
S    
U
V
W
Y"
Z)
\.
]=
\@
^G
_N
`W
bd
cn
du
e~
f†
g
hš
j¢
lz¥«¬¥­
Û
—
,
-’¶
܉º
<"ƒ
ˆ
2)|
é@e
8
+G^
*
+NW
9
+    WN
:
+
dA
;
<°`ÿ<
kJ
Ï

=
?

ÿ
kJ
Ï

=
?

ÿ\
kJ
Ï

=
?





1
 
_    ~²
ݶW+¶CM+¶
ßÀ
N-¶
Œ66
:+¶
áÆ+¶
áÀ
¶
Ë:¶
Ô`6¸

`6*`¹
:,¸
¶
W¸
¶
Wƶ
ØW°F
r    
t
u
v
x
z"
{)
|5
}?
H
€U
_
‚f
ƒn
„s
…{
ˆ\    ~«¬~­;
p
,
-h¶
™b
â
+_
8
+"\º
<H6
:
+U)
;
<°!ÿ?
DJ



ý;


’1
 v+¶CM*¹
N-,¸
¶
W-¶
W-°

‘ 
’
“
•*«¬­;

,
- 
;
<

 

 3<*¶I¶œx€<*¶
㙀<*¶
Ѷ
•x€<*¶
晀<¬"
›
œ

ž
 &
¡-
¢1
¤3
é
-1
ê
+
°ü




 ˆ!€p=€l<ž    €€=*¶
Wÿã±"
«
¬
­
®
°
±
ª 
² !
;
<!
ë
+

ì
+°ü




 e<€l;„

ÿö¬
µ
·
¸
¹
¶
º
ë
+
í
+
°
ü

ßà
 2
*²
î¶
ô°

¿

ø
2D!
ù#
$ +*+,ÀD-¶
ú±

    B
 
À
Õ²
üYÆ°W¸
þ¾¼
K*²¶OO§W*²¶OO§W*²    ¶OO§W*²¶OO§W*²¶O O§W*²¶OO§W*²¶OO§W*²¶OO§W*²¶OO§W*²¶OO§W*²!¶O    O§W*²$¶OO§W*²'¶OO§W*²*¶O
O§W*Y³
ü°-&)-*47-8BE-FPS-T]`-akn-ox{-|…ˆ-‰“–-—¡¤-¥¯²-³½À-ÁËÎ-
°UH/ÿ
/
-K-L-L-L-K-L-K-K-L-L-L-L-L-01&2