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
Êþº¾4

chat/server/im/IMDispatcher
,io/netty/channel/SimpleChannelInboundHandler
logger
Lorg/apache/log4j/Logger;
<clinit>
()V
Code
 
org/apache/log4j/Logger
    getLogger
,(Ljava/lang/Class;)Lorg/apache/log4j/Logger;    

LineNumberTable
LocalVariableTable
<init>

this
Lchat/server/im/IMDispatcher;
channelRead0
X(Lio/netty/channel/ChannelHandlerContext;Lio/netty/handler/codec/http/FullHttpRequest;)V

Exceptions
java/lang/Exception
! 
%chat/server/moquette/message/ClientID"#
valueOf
V(Lio/netty/handler/codec/http/FullHttpRequest;)Lchat/server/moquette/message/ClientID;
%'&
chat/user/SessionStore()
get
<(Lchat/server/moquette/message/ClientID;)Lchat/user/Session;+
chat/server/im/DataPool    -/.
chat/server/im/RequestType01
Short
Lchat/server/im/RequestType;
*34
_(Lchat/server/im/RequestType;Lchat/user/Session;Lio/netty/handler/codec/http/FullHttpRequest;)V
*678
 getRequestURI
()Ljava/lang/String;
*:;8
getRequestTopic
=?>
chat/server/call/Operator@A
getInstance
A(Ljava/lang/String;Ljava/lang/String;)Lchat/server/call/Operator;
*CDE
getMessageId
()I
GIH
chat/user/SessionJ8
    getSecretL
N
chat/server/im/ResultPool
MPQ
D(Lchat/server/im/RequestType;Ljava/lang/String;ILjava/lang/String;)V
STU
isDebugEnabled
()ZW
java/lang/StringBuilderY
receive request(short): 
V[\
(Ljava/lang/String;)V^`_
+io/netty/handler/codec/http/FullHttpRequesta8
uri
Vcde
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;g

, method: 
=ij8
    getMethodl
    , topic: 
Vno8
toString
qrs
debug
(Ljava/lang/Object;)V
uwv
chat/server/call/CallObjectMap(x
:(Lchat/server/call/Operator;)Lchat/server/call/CallObject;z
unknown request(short) path: 
|}s
error    €
chat/server/call/ResultCode‚ƒ
Error_Path_NotExists
Lchat/server/call/ResultCode;
M…}†
 (Lchat/server/call/ResultCode;)V}‰
Path_NotExists
M‹Œ
add
'(Ljava/lang/String;Ljava/lang/Object;)V    ‘
java/lang/System’“
out
Ljava/io/PrintStream;
=•–8
getTopic
˜š™
java/io/PrintStream›\
println
Ÿž
chat/server/call/CallObject ¡
exec
e(Lchat/user/Session;Lchat/server/call/Operator;Lchat/server/im/DataPool;Lchat/server/im/ResultPool;)V£
return ¥
 short(§

)
M©ª«
 getResultData
()Ljava/lang/Object;­¯®
&io/netty/channel/ChannelHandlerContext°±
 writeAndFlush
4(Ljava/lang/Object;)Lio/netty/channel/ChannelFuture;
M³´µ
getCallback
()Lchat/message/Callback;
·¹¸
chat/message/Callback 
ctx
(Lio/netty/channel/ChannelHandlerContext;
httpRequest
-Lio/netty/handler/codec/http/FullHttpRequest;
clientID
'Lchat/server/moquette/message/ClientID;
session
Lchat/user/Session;
dataPool
Lchat/server/im/DataPool;
Ljava/lang/String;
topic
operator
Lchat/server/call/Operator;
    messageId

I
secret

resultPool
Lchat/server/im/ResultPool;

callObject
Lchat/server/call/CallObject;
data
Ljava/lang/Object;
callback
Lchat/message/Callback;
 StackMapTableÕ
java/lang/String×
java/lang/Throwable
N(Lio/netty/channel/Channel;Lchat/server/moquette/message/MqttPublishMessage;)V
Ú"Û
C(Lio/netty/channel/Channel;)Lchat/server/moquette/message/ClientID;Ý
long:
Vßdà
-(Ljava/lang/Object;)Ljava/lang/StringBuilder;
Gâãä

setChannel
(Lio/netty/channel/Channel;)V
Gæç
refreshLastActiveTime
éëê
/chat/server/moquette/message/MqttPublishMessageìí
variableHeader
:()Lchat/server/moquette/message/MqttPublishVariableHeader;
ïñð
6chat/server/moquette/message/MqttPublishVariableHeaderò8
    topicNameô
Topic===============>:ö
unknown publish(long): ø
receive request(long): method:     -úû1
Long
*ýþ
c(Lchat/server/im/RequestType;Lchat/user/Session;Lchat/server/moquette/message/MqttPublishMessage;)V
ï


E
packetId

unknown request(long): 

 send message:
¯

io/netty/channel/Channel


 long(
channel
Lio/netty/channel/Channel;
message
1Lchat/server/moquette/message/MqttPublishMessage;

java/lang/Object
=(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V
 
SourceFile
IMDispatcher.java
    Signature
]Lio/netty/channel/SimpleChannelInboundHandler<Lio/netty/handler/codec/http/FullHttpRequest;>;!


    -
    
¸
³±


    3

*·±



    H
¦,¸N-¸$:»*Y²,,·2:¶5:¶9:¸<:¶B6    Æ¶F§K:
»MY²,    
·O:Æβ¶R™5²»VYX·Z,¹]
¶bf¶b¶h¶bk¶b¶b¶m¶p¸t:Ç:²»VYy·Z¶b¶m¶{²~¶„‡»VYˆ·Z¶b¶m¶Š²Ž¶”¶—¶œ²¶R™ˆ²»VY¢·Z¶h¶b¤¶b¶b¦¶b¶m¶p§\²»VYy·Z¶bk¶b¶b¶m¶{²~¶„‡»VYˆ·Z¶b¶m¶Š§: ¶¨:+¹¬W ¿¶¨:+¹¬W¶²:Æ¶¶±
[
o
o’$#$&)!*(,1-8.I0[4`5i6›9¢;§<¾=Æ>ÞAéBöDÿE
(G
+I
LJ
TK
lM
oN
qP
xQ
R
„P
‹Q
”U
›W
 X
¥Z¢
¦
¦º»

¦¼½
¡¾¿
›ÀÁ
ŒÂÃ!
…aÄ(
~ÅÄ1
uÆÇ8
nÈÉ    I
]ÊÄ
[
KËÌ¢†ÍÎ
x    ÏÐ
‹    ÏÐ
›ÑÒÓHÿE

­^G*ÔÔ=
AÔýSÔMüBúL÷CÖü ·
Ø
    ù
x+¸ÙN-¸$:DZ²Ž»VYÜ·Z+¶Þ¶m¶—Æ+¶á¶å,¶è¶î:²Ž»VYó·Z¶b¶m¶—
¸<:Dz»VYõ·Z¶b¶m¶{±²¶R™'²»VY÷·Z¶h¶bk¶b¶b¶m¶p»*Y²ù,·ü:,¶è¶ÿ6¶F:    »MY²ù    ·O:
¸t:Dz»VY
·Z¶b¶m¶{±
¶œ
¶¨:²Ž»VY
·Z+¶Þ¶m¶—+¹
W²¶R™-²»VY¢·Z¶h¶b
    ¶b¶b¦¶b¶m¶p
¶²:  Æ ¶¶±Š"^_abe'f,g2h7k@lWn_pdq{r|u…v©z¸|Á}È~ځáƒæ„þ…ÿˆ
‹

*
3‘
<’
f–
m˜
r™
w›Ž
x
x



x
 

s¾¿
mÀÁ@
8ÅÄ_
ÆǸÀÂÃÁ·ÈÉÈ°ÊÄ    ÚžËÌ
á—ÍÎ
eÏÐ
mÑÒ ÓKýG%ýDÔ=,ÿU

éGÔ=*
ÔMüf
ü·A

    *
*+,À^¶
±