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
Êþº¾4'
chat/handler/SystemHandler
chat/server/call/CallObject
KEY
Ljava/lang/String;
 ConstantValue    
imfile
<init>
()V
Code
 

LineNumberTable
LocalVariableTable
this
Lchat/handler/SystemHandler;
 publishMethod
route


addOneMethod
(Ljava/lang/String;)V
getMediaUploadToken
getQiniuUploadToken
uploadFileToServer!

getSetting#

setSetting%
getToken'
modifyMyInfo)
multiCastMessage+
 recallMessage-
sendMessage/
uploadDeviceToken

Exceptions2
java/lang/Exception
465
.cn/wildfirechat/proto/WFCMessage$RouteResponse78

newBuilder
:()Lcn/wildfirechat/proto/WFCMessage$RouteResponse$Builder;:
192.168.31.117
<>=
6cn/wildfirechat/proto/WFCMessage$RouteResponse$Builder?@
setHost
L(Ljava/lang/String;)Lcn/wildfirechat/proto/WFCMessage$RouteResponse$Builder;
<BCD
setLongPort
;(I)Lcn/wildfirechat/proto/WFCMessage$RouteResponse$Builder;
<FGD
setShortPort
<IJK
build
2()Lcn/wildfirechat/proto/WFCMessage$RouteResponse;
4MNO
toByteArray
()[B    
QRS

resultPool
Lchat/server/im/ResultPool;
UWV
chat/server/im/ResultPoolXY
setBytes
([B)V
response
0Lcn/wildfirechat/proto/WFCMessage$RouteResponse;
resBytes
[B    
_`a
dataPool
Lchat/server/im/DataPool;c
9cn/wildfirechat/proto/WFCMessage$UploadDeviceTokenRequest
egf
chat/server/im/DataPoolhi
 getWFCMessage
%(Ljava/lang/Class;)Ljava/lang/Object;
request
;Lcn/wildfirechat/proto/WFCMessage$UploadDeviceTokenRequest;m
(cn/wildfirechat/proto/WFCMessage$Message
oqp
 chat/module/entity/MessageRecordrs
newMessageId
()I
uwv
java/lang/Systemxy
currentTimeMillis
()J
l{|}
    toBuilder
4()Lcn/wildfirechat/proto/WFCMessage$Message$Builder;    
€
user
Lchat/user/User;
ƒ…„
chat/user/User†‡
getId
()Ljava/lang/String;
‰‹Š
0cn/wildfirechat/proto/WFCMessage$Message$BuilderŒ
setFromUser
F(Ljava/lang/String;)Lcn/wildfirechat/proto/WFCMessage$Message$Builder;
‰‘
setMessageId
5(J)Lcn/wildfirechat/proto/WFCMessage$Message$Builder;
‰“”‘
setServerTimestamp
‰–J—
,()Lcn/wildfirechat/proto/WFCMessage$Message;
l™š›
getConversation
1()Lcn/wildfirechat/proto/WFCMessage$Conversation;
Ÿž
-cn/wildfirechat/proto/WFCMessage$Conversation s
getType
¢¤£
 chat/module/entity/ChatSpaceType¥¦
pase
%(I)Lchat/module/entity/ChatSpaceType;
¨ª©
chat/module/Bucket«¬
getInstance
8(Lchat/module/entity/ChatSpaceType;)Lchat/module/Bucket;
¨®¯°
pushOneMessage
=(Lcn/wildfirechat/proto/WFCMessage$Message;Lchat/user/User;)V
²´³
io/netty/buffer/Unpooledµ¶
buffer
()Lio/netty/buffer/ByteBuf;
¸º¹
io/netty/buffer/ByteBuf»¼
capacity
(I)Lio/netty/buffer/ByteBuf;
¸¾¿À
    writeLong
(J)Lio/netty/buffer/ByteBuf;
¸ÂÃs
 readableBytes
¸ÅÆÇ
getBytes
(I[B)Lio/netty/buffer/ByteBuf;
message
*Lcn/wildfirechat/proto/WFCMessage$Message;
    messageId

J
    timeStamp
    spaceType
"Lchat/module/entity/ChatSpaceType;
bucket
Lchat/module/Bucket;

ackPayload
Lio/netty/buffer/ByteBuf;
LocalVariableTypeTable
Lchat/module/Bucket<*>;
getNotifyReceivers
V(Ljava/lang/String;Lcn/wildfirechat/proto/WFCMessage$Message$Builder;Ljava/util/Set;)I
    Signature
j(Ljava/lang/String;Lcn/wildfirechat/proto/WFCMessage$Message$Builder;Ljava/util/Set<Ljava/lang/String;>;)IÚÜÛ
 java/util/SetÝÞ
add
(Ljava/lang/Object;)Z
‰™
áâ‡
    getTarget
userId
messageBuilder
2Lcn/wildfirechat/proto/WFCMessage$Message$Builder;
notifyReceivers
Ljava/util/Set;
pullType

I
#Ljava/util/Set<Ljava/lang/String;>;ì
)cn/wildfirechat/proto/WFCMessage$INT64Buf
ëî|ï
5()Lcn/wildfirechat/proto/WFCMessage$INT64Buf$Builder;ñ

messageUid
eóôõ
    getString
&(Ljava/lang/String;)Ljava/lang/String;
÷ùø
java/lang/Longúû
    parseLong
(Ljava/lang/String;)J
ýÿþ
1cn/wildfirechat/proto/WFCMessage$INT64Buf$Builder



setId
6(J)Lcn/wildfirechat/proto/WFCMessage$INT64Buf$Builder;
ý
J

-()Lcn/wildfirechat/proto/WFCMessage$INT64Buf;
+Lcn/wildfirechat/proto/WFCMessage$INT64Buf;
requestB
3Lcn/wildfirechat/proto/WFCMessage$INT64Buf$Builder;
    
1cn/wildfirechat/proto/WFCMessage$MultiCastMessage
¸

¼
ensureWritable
¸

O
array
3Lcn/wildfirechat/proto/WFCMessage$MultiCastMessage;
payload

4cn/wildfirechat/proto/WFCMessage$ModifyMyInfoRequest
6Lcn/wildfirechat/proto/WFCMessage$ModifyMyInfoRequest;

0cn/wildfirechat/proto/WFCMessage$GetTokenRequest


|

<()Lcn/wildfirechat/proto/WFCMessage$GetTokenRequest$Builder;ã




8cn/wildfirechat/proto/WFCMessage$GetTokenRequest$Builder

 
    setUserId
N(Ljava/lang/String;)Lcn/wildfirechat/proto/WFCMessage$GetTokenRequest$Builder;
"
clientId


$
%
 
setClientId
'
platform

)
+
*
java/lang/Integer
,
-
valueOf
(I)Ljava/lang/Integer;
e
/
0
1

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

)
3
4s
intValue


6
7
8
setPlatform
=(I)Lcn/wildfirechat/proto/WFCMessage$GetTokenRequest$Builder;


:J
;
4()Lcn/wildfirechat/proto/WFCMessage$GetTokenRequest;
=

?
java/lang/StringBuilder

A
C
B
java/lang/String
,
D
&(Ljava/lang/Object;)Ljava/lang/String;

>
F

H

|

>
J
K
L
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;    

N
O
P
session
Lchat/user/Session;

R
T
S
chat/user/Session
U‡
    getSecret
W
123456

>
Y
Z‡
toString

A
\ÆO
2Lcn/wildfirechat/proto/WFCMessage$GetTokenRequest;
requestBuild
:Lcn/wildfirechat/proto/WFCMessage$GetTokenRequest$Builder;
strToken
result
bytes

d
f
e
5cn/wildfirechat/proto/WFCMessage$GetUploadTokenResult7
g
A()Lcn/wildfirechat/proto/WFCMessage$GetUploadTokenResult$Builder;


i%
j
(I)Ljava/lang/String;
l
http://    
n
p
o
chat/consts/MediaServerConfig
q
    SERVER_IP
s

:    
n
u
vé
HTTP_SERVER_PORT

>
x
K
y
(I)Ljava/lang/StringBuilder;

{
}
|
=cn/wildfirechat/proto/WFCMessage$GetUploadTokenResult$Builder
~

    setDomain
S(Ljava/lang/String;)Lcn/wildfirechat/proto/WFCMessage$GetUploadTokenResult$Builder;

{

‚

    setServer

{
„
…
†
setPort
B(I)Lcn/wildfirechat/proto/WFCMessage$GetUploadTokenResult$Builder;

{
ˆ
‰

setToken

{
‹
Œ

buildPartial
9()Lcn/wildfirechat/proto/WFCMessage$GetUploadTokenResult;

dM
token
 resultBuilder
?Lcn/wildfirechat/proto/WFCMessage$GetUploadTokenResult$Builder;
domain
data
•
6cn/wildfirechat/proto/WFCMessage$GetUploadTokenRequest

”
—
˜s
getMediaType
type
8Lcn/wildfirechat/proto/WFCMessage$GetUploadTokenRequest;
e
œ

ž
getHttpRequest
/()Lio/netty/handler/codec/http/FullHttpRequest;

 
¢
¡
cn/hutool/core/lang/UUID
£
¤

randomUUID
()Lcn/hutool/core/lang/UUID;

 
Y
§

-

A
©
ª
«
replace
D(Ljava/lang/CharSequence;Ljava/lang/CharSequence;)Ljava/lang/String;

­
¯
®
chat/upload/UploadFile
°
±
multipartUpload
S(Lio/netty/handler/codec/http/FullHttpRequest;Ljava/lang/String;)Ljava/lang/String;
U
³
´
µ
setNeedReturnCode
(Z)V
·
key
U
¹Ý
º
((Ljava/lang/String;Ljava/lang/Object;Z)V
-Lio/netty/handler/codec/http/FullHttpRequest;
    requestId
¾
imfile|

>
À
K
Á
(J)Ljava/lang/StringBuilder;

Ã
Å
Ä
chat/security/DES
Æõ

encryptDES
1
È
É
printStackTrace
signKey

e
Ljava/lang/Exception;
 StackMapTable
notRetainedPublish
„(Ljava/lang/String;Lchat/server/moquette/message/MqttQoS;Lio/netty/buffer/ByteBuf;)Lchat/server/moquette/message/MqttPublishMessage;


Ñ
Ò
Ó
notRetainedPublishWithMessageId
…(Ljava/lang/String;Lchat/server/moquette/message/MqttQoS;Lio/netty/buffer/ByteBuf;I)Lchat/server/moquette/message/MqttPublishMessage;
topic
qos
&Lchat/server/moquette/message/MqttQoS;
Ø
,chat/server/moquette/message/MqttFixedHeader    
Ú
Ü
Û
,chat/server/moquette/message/MqttMessageType
Ý
Þ
PUBLISH
.Lchat/server/moquette/message/MqttMessageType;

×
à

á
Z(Lchat/server/moquette/message/MqttMessageType;ZLchat/server/moquette/message/MqttQoS;ZI)V
ã
6chat/server/moquette/message/MqttPublishVariableHeader

â
å

æ
(Ljava/lang/String;I)V
è
/chat/server/moquette/message/MqttPublishMessage

ç
ê

ë
‚(Lchat/server/moquette/message/MqttFixedHeader;Lchat/server/moquette/message/MqttPublishVariableHeader;Lio/netty/buffer/ByteBuf;)V
fixedHeader
.Lchat/server/moquette/message/MqttFixedHeader;
    varHeader
8Lchat/server/moquette/message/MqttPublishVariableHeader;
main
([Ljava/lang/String;)V
ó
$31a95a1a-d169-4a26-be4c-ef73088c1b1f

õ
÷
ö
!io/moquette/spi/impl/security/AES
ø
ù

AESEncrypt
([BLjava/lang/String;)[B    
û
ý
ü
chat/server/call/ResultCode
þ
ÿ
Success
Lchat/server/call/ResultCode;

û
s
getValue
¸¼
    writeByte
¸    

writeBytes
([B)Lio/netty/buffer/ByteBuf;    u 
out
Ljava/io/PrintStream;

java/io/PrintStream
println
(Ljava/lang/Object;)V
args
[Ljava/lang/String;
buf

SourceFile
SystemHandler.java
InnerClasses
 cn/wildfirechat/proto/WFCMessage
Conversation
GetTokenRequest
Builder
GetUploadTokenRequest
GetUploadTokenResult
INT64Buf
Message
ModifyMyInfoRequest
MultiCastMessage
 RouteResponse
UploadDeviceTokenRequest!





/

*· ±


£
I*¶*¶*¶*¶* ¶*"¶*$¶*&¶*(¶**¶*,¶*.¶±6 !"#$%&$'*(0)6*<+B,H-
I
0
1o%¸39¶;[¶AP¶E¶HL+¶LM*´P,¶T±012$3 %Z[
    \]
/0
1R*´^b¶dÀbL*´P
¶T±7 :;     jk

-0
1
B
ˆ*´^l¶dÀlL¸n…A¸t7+¶z*´~¶‚¶ˆ ¶Ž¶’¶•L+¶˜¶œ¸¡:¸§:+*´~¶­¸±:¶·: ¶½W¶½W¶Á¼:        ¶ÄW*´P    ¶T±>@ BCD2F>GEHOKTM]NdOlQuR~T‡URˆ {ÈÉ
vÊËqÌË>JÍÎECÏÐT4ÑÒu\]    Ó
ECÏÔ
ÕÖ0
1×ØŒ6-+¹ÙW-,¶ß¶à¹ÙW¬XYZ[4ã
äåæçèéÓ
æê
+0
1ƒ1*´^ë¶dÀëL+¶íM,*´^ð¶ò¸ö¶üW,¶
W*´P
¶T±` bc#d(g0h 1 $j




)0
1¢8*´^
¶dÀ
L¸±M¸n…B,¶

!¶½¸t¶½W,¶
 :*´P¶T±lopq(s.t7u48*)

&
Ò!ÊË.
\]
'0
1S*´^
¶dÀ
L*´P
¶T±y|}    j


%0
1
*´^
¶dÀ
L+¶
M,*´^
¶ò¶
W,*´^
!¶ò¶
#W,*´^
&¸
(¶
.¶
2¶
5W,¶
9L
<N»
>Y-¸
@·
E
G¶
I*´
M¶
Q¶
I
G¶
I
V¶
I¶
X:¶
[:*´P¶T±.ƒ„"…1†GˆL‹PŒ|ƒŒ>j
]
z
^
_P=
`|
aƒ

b]
0
1ÎX¸
cM¸
hL»
>Y
k·
E²
m¶
I
r¶
I²
t¶
w¶
XN,-¶
zW,²
m¶
€W,²
t¶
ƒW,+¶
‡W,¶
Š¶
Ž:*´P¶T±*
”–    —)˜/™7š?›ENžWŸ4X    O

T

‘)/
’N

“]
0
1
s*´^
”¶dÀ
”N-¶
–=¸
c:¸
hL»
>Y
k·
E²
m¶
I
r¶
I²
t¶
w¶
X:¶
zW²
m¶
€W²
t¶
ƒW+¶
‡W¶
Š¶
Ž:*´P¶T±2¥¦¨ª«>¬F­O®X¯_±i²r³HsV

`
™éej
š[

‘>5
’i

“]
0
13*´^¶
›L¸
٦
¥
¦
<¶
¨M+,¸
¬N*´P¶
²*´P
¶-¶
¸±¶·¹»&¼2½*3+j
»

¼
·    %
j
–*»
>Y
½·
E¸t¶
¿
G¶
I¶
w¶
XL+¸
°M,¶
Ç
°
"#1ÀÂ#Ã$Å(Ç *
™é
Ê
$
Ë
Ì
Í
ÿ#

A
1
!0
1+

±
Ì


#0
1+

±
Ð

    
Î
Ï
F*+,¸
а
Ó 
Ô
Õ
Ö
ÈÒ

Ò
Ó
Œ(»
×Y²
Ù+·
ß:»
âY*·
ä:»
çY,·
é°ØÙÚ>(
Ô(
Õ
Ö
(ÈÒ(Êé
ì
í 
î
ï    
ð
ñ
®J¸39¶;[¶AP¶E¶HL+¶LM,
ò¸
ôM¸±N-¶

²
ú¶¶W-,¾¶

,¶W²
-¶±"Þßà$ä(æ7çBéIë*J3Z[
.\]("Òz



”
d 
{
dë!ýël"‰l
#
$4%<4b&