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
Êþº¾4
t
chat/server/im/DataPool
java/lang/Object
logger
Lorg/apache/log4j/Logger;
messageParseTable
%Lchat/server/im/WFCMessageParseTable;
requestType
Lchat/server/im/RequestType;
httpRequest
-Lio/netty/handler/codec/http/FullHttpRequest;

jsonObject
Lorg/json/JSONObject;
body
Ljava/lang/String;
secret
rawData
[B
data
srcBytes
httpWrapper
0Lcn/wildfirechat/proto/WFCMessage$IMHttpWrapper;
    messageId

I
phone
<clinit>
()V
Code
chat/server/im/IMDispatcher
!#"
org/apache/log4j/Logger$%
    getLogger
,(Ljava/lang/Class;)Lorg/apache/log4j/Logger;    
'
)+*
#chat/server/im/WFCMessageParseTable,-
getInstance
'()Lchat/server/im/WFCMessageParseTable;    
/
LineNumberTable
LocalVariableTable
getPhone
()Ljava/lang/String;    
5
this
Lchat/server/im/DataPool;
setPhone
(Ljava/lang/String;)V
<init>
_(Lchat/server/im/RequestType;Lchat/user/Session;Lio/netty/handler/codec/http/FullHttpRequest;)V
=:    
?    
    
A
CED
chat/user/SessionF3
    getSecret    
H

JK3
readHttpRequestJSON    
MO

{
QSR
java/lang/StringTU

startsWith
(Ljava/lang/String;)ZW
org/json/JSONObject
VY:9    
[ 

]^_
createHttpWrapper
V(Ljava/lang/String;Ljava/lang/String;)Lcn/wildfirechat/proto/WFCMessage$IMHttpWrapper;    
a
session
Lchat/user/Session;
 StackMapTablef
chat/server/im/RequestTypeh
+io/netty/handler/codec/http/FullHttpRequest
c(Lchat/server/im/RequestType;Lchat/user/Session;Lchat/server/moquette/message/MqttPublishMessage;)V

Exceptionsl
java/lang/Exception
npo
/chat/server/moquette/message/MqttPublishMessageqr
variableHeader
:()Lchat/server/moquette/message/MqttPublishVariableHeader;
tvu
6chat/server/moquette/message/MqttPublishVariableHeaderwx
packetId
()I    
z
n|}~
payload
()Lio/netty/buffer/ByteBuf;

€‚
readBytesAndRewind
(Lio/netty/buffer/ByteBuf;)[B
„†…
chat/security/AES‡ˆ

AESDecrypt
([BLjava/lang/String;Z)[B
ŠŒ‹
java/util/Base64Ž

getDecoder
()Ljava/util/Base64$Decoder;
Q:‘
([B)V
“•”
java/util/Base64$Decoder–—
decode
(Ljava/lang/String;)[B
™›š
.cn/wildfirechat/proto/WFCMessage$IMHttpWrapperœ
    parseFrom
4([B)Lcn/wildfirechat/proto/WFCMessage$IMHttpWrapper;    
Ÿ
message
1Lchat/server/moquette/message/MqttPublishMessage;
Lio/netty/buffer/ByteBuf;
content
bytes

e
Ljava/lang/Exception;¨
io/netty/buffer/ByteBuf
 getWFCMessage
%(Ljava/lang/Class;)Ljava/lang/Object;
    Signature
U<T:Ljava/lang/Object;>(Ljava/lang/Class<+Lcom/google/protobuf/GeneratedMessage;>;)TT;
™¯°±
getData
"()Lcom/google/protobuf/ByteString;
³µ´
com/google/protobuf/ByteString¶·
toByteArray
()[B
Q¹º·
getBytes
)¼½¾
    getMethod
-(Ljava/lang/Class;)Ljava/lang/reflect/Method;
ÀÂÁ
java/lang/reflect/MethodÃÄ
invoke
9(Ljava/lang/Object;[Ljava/lang/Object;)Ljava/lang/Object;
!ÆÇÈ
isDebugEnabled
()Z
kÊË
printStackTrace
clazz
Ljava/lang/Class;
method
Ljava/lang/reflect/Method;
result
Ljava/lang/Object;
LocalVariableTypeTable
:Ljava/lang/Class<+Lcom/google/protobuf/GeneratedMessage;>;
TT;Ö
java/lang/ClassgØ£~    ÚÜÛ
!java/nio/charset/StandardCharsetsÝÞ
UTF_8
Ljava/nio/charset/Charset;
Qà:á
([BLjava/nio/charset/Charset;)V
readPublishMessageJSON
E(Lchat/server/moquette/message/MqttPublishMessage;)Ljava/lang/String;
clearContent
§æçx
 readableBytes
§éêx
readerIndex
§ìíî
    readBytes
([B)Lio/netty/buffer/ByteBuf;
§ðêñ
(I)Lio/netty/buffer/ByteBuf;
payloadContent
mark
    getObject
&(Ljava/lang/String;)Ljava/lang/Object;
V÷øõ
get
name
    getString
&(Ljava/lang/String;)Ljava/lang/String;
Výúû

getInteger
:(Ljava/lang/String;Ljava/lang/Integer;)Ljava/lang/Integer;



ôõ




#frame/variant/translator/Translator


    toInteger
:(Ljava/lang/Object;Ljava/lang/Integer;)Ljava/lang/Integer;
defaultValue
Ljava/lang/Integer;
value
getDate
$(Ljava/lang/String;)Ljava/util/Date;

java/text/ParseException

java/text/SimpleDateFormat


yyyy-MM-dd

Y





parse
string
sdf
Ljava/text/SimpleDateFormat;
getJSONArray
9(Ljava/lang/String;)Lcom/xiaoleilu/hutool/json/JSONArray;

#com/xiaoleilu/hutool/json/JSONArray
obj
    getHeaderg
!
"
#
headers
+()Lio/netty/handler/codec/http/HttpHeaders;

%
'
&
'io/netty/handler/codec/http/HttpHeadersøû
getMessageRecord
$()Lchat/module/entity/MessageRecord;
getList
$(Ljava/lang/String;)Ljava/util/List;
8(Ljava/lang/String;)Ljava/util/List<Ljava/lang/String;>;
getBody    

/    

1

getRawData
getHttpWrapper
2()Lcn/wildfirechat/proto/WFCMessage$IMHttpWrapper;
 getRequestURIg
7
83
uri
getRequestTopic
™
;
<3

getRequest
getRequestType
()Lchat/server/im/RequestType;
getHttpRequest
/()Lio/netty/handler/codec/http/FullHttpRequest;
getMessageId
setMessageId
(I)V
 getJsonObject
()Lorg/json/JSONObject;
 setJsonObject
(Lorg/json/JSONObject;)V
toString
J
frame/util/ContentBuilder

I=
M
java/lang/StringBuilder
O
 requestType: 

LY

L
R
S
T
append
-(Ljava/lang/Object;)Ljava/lang/StringBuilder;

L
V
H3

I
X
S
Y
/(Ljava/lang/String;)Lframe/util/ContentBuilder;
[
jsonObject: 
]
body: 

L
_
S
`
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
b
    rawData: 
d
 httpWrapper: 
f
messageId: 

L
h
S
i
(I)Ljava/lang/StringBuilder;

I
V
builder
Lframe/util/ContentBuilder;

SourceFile
 DataPool.java
InnerClasses
q
 cn/wildfirechat/proto/WFCMessage
 IMHttpWrapper
Decoder!
 
 
    
  
7
¸ ³&¸(³.±06781
23
/

*´4°0
.1
67
89
>*+µ4±0
23167

:;
ù_*·<*+µ>*-µ@,Æ*,¶BµG**¶IµL*´LDZ*´LN¶P™*»VY*´L·XµZ§*´GÆ**´L*´G¸\µ`±0:;=    >@AE"G)H*K6LEMHNOO^Q1*_67_    

_bc_dÿ
eCg
:ij
k
zˆ*·<*+µ>*-¶m¶sµy,Æ*,¶BµG-¶{:¸:DZ*´G¸ƒ:DZ*´GÆ>*
µL¸‰»QY·¶’:*´G¸ƒ:*¸˜µ`§:*
µ`*µž±
Lwzk0VTV    WYZ k&l-n2o3r?tDuExLzQ{b|n}w~|€‡Ž1Rˆ67ˆ    

ˆbcˆ ¡&b}¢-[£b¤|¥¦d$ÿ 
eCný§©tk
ª«¬­
Xe
M*´`Æ*´`¶®¶²M§!*´žÆ*´žM§*´LÆ*´L¶¸M,Ç
°².+¶»N-+½Y,S¶¿:°M²&¶Å™,¶É
°9Uk;TUk0J“•    –—˜™#š&›-œ5Ÿ9 ;£C¥R¦U¨V©_ªc«1>e67eÌÍ
S¤CÎÏRÐÑV¥¦ÒeÌÓ
RÐÔd!ü©ÿ
Õ
kü kK3
¦%
L*´@¹×
¸M»QY,²Ù·ßL§M,¶É+°
k0°²³´¶·#º1*%67#Ð
¤¥¦dÿ
Q
kâã

!A
M+¶{N-¸:Ç
°*´G¸ƒ:Ç
°*µž»QY·M§N-¶É,°:k%:k'7:k0:¾ÀÁ ÃÄÇ É%Ê'Í-Î7Ï:Ð;Ñ?Ô1HA67A ¡
?Ð0}¢ *£ ä;¥¦d(þQ§©ü©ÿ
nQ
k    ‚
h*¶å¼L*¶è=*+¶ëW*¶ïW+°0ØÙÚÛÝ1 }¢ò
ó
ôõ
W*´ZÆ*´Z+¶ö°
°0áâå167ù
d

úû
x*´ZÆ*´Z+¶ü°M
°
°
k0êëðñó1 67ù
¥¦dPk
þÿ
X*+¶
N-,¸
°0
÷ø1*67ù


    

Ñ


j

 S»
Y
·
M,+¶
°0
ÿ
1 67







i*+¶
M,Ç
°,À
°0


 
1 67ù

Ñd
ü

û
B*´@¹
 
+¶
$°0

167ù


(
)
,


°0

1
67

*
+¬
,6

°0

167



-3
/

*´L°0

1
67
–
?
**´
.*´G¸ƒµ
0±0

 
!1
67

2·
/

*´
.°0

$1
67
°·
/

*´
0°0

(1
67

3
4
/

*´`°0

,1
67    ^_
 
M¸‰*¶’N-+¸ƒN-¸˜M§N,°
k0
0
3

4
5
6
7
91*£
Ð
¤dÿQQ™
k

53
N

*´@Ç
°*´@¹
6
°0
=
>    
A1
67d
    

93
L

*´`Ç
°*´`¶
:°0
E
F    
I1
67d
    

=
>
/

*´>°0

M1
67

?
@
/

*´@°0

Q1
67

Ax
/

*´y¬0

U1
67

B
C
>*µy±0

Y
Z167


D
E
/

*´Z°0

]1
67

F
G
>*+µZ±0

a
b167 


H3
ó£»
IY·
KL+»
LY
N·
P*´>¶
Q¶
U¶
WW+»
LY
Z·
P*´Z¶
Q¶
U¶
WW+»
LY
\·
P*´L¶
^¶
U¶
WW+»
LY
a·
P*´
.¶
Q¶
U¶
WW+»
LY
c·
P*´`¶
Q¶
U¶
WW+»
LY
e·
P*´y¶
g¶
U¶
WW+¶
j°0"
f
g!
h:
iS
jl
k…
lž
n1£67›
k
l

m
n
o™
p
r“Š
s