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
Êþº¾4ï
chat/handler/ChatRoomHandler
chat/server/call/CallObject
chatroomBucket
Lchat/module/ChatroomBucket;
<clinit>
()V
Code
 
chat/module/ChatroomBucket
getInstance
()Lchat/module/ChatroomBucket;    

LineNumberTable
LocalVariableTable
<init>

this
Lchat/handler/ChatRoomHandler;
 publishMethod
create


addOneMethod
(Ljava/lang/String;)V!
destroy#
getInfo%
getRoomList'
join)
leave+
kickoff-
pull/
publish    
123
dataPool
Lchat/server/im/DataPool;5
roomName
798
chat/server/im/DataPool:;
    getString
&(Ljava/lang/String;)Ljava/lang/String;    
=>?

resultPool
Lchat/server/im/ResultPool;
ACB
chat/server/im/ResultPoolD
success
Ljava/lang/String;    
GHI
user
Lchat/user/User;
KML
chat/user/UserNO
getId
()Ljava/lang/String;Q
roomId
STU
getOne
9(Ljava/lang/String;)Lchat/module/entity/MessageContainer;W
chat/module/entity/ChatRoom    Y[Z
"chat/module/entity/PublishOperator\]
Destroy
$Lchat/module/entity/PublishOperator;
V_`a
notify
9(Lchat/module/entity/PublishOperator;Ljava/lang/String;)V
cdU
    deleteOne
userId
chatRoom
Lchat/module/entity/ChatRoom;
chatRoomInfo

Exceptionsk
java/lang/Exceptionm
7cn/wildfirechat/proto/WFCMessage$GetChatroomInfoRequest
7opq
 getWFCMessage
%(Ljava/lang/Class;)Ljava/lang/Object;
sut
-cn/wildfirechat/proto/WFCMessage$ChatroomInfovw
    toBuilder
9()Lcn/wildfirechat/proto/WFCMessage$ChatroomInfo$Builder;
y{z
5cn/wildfirechat/proto/WFCMessage$ChatroomInfo$Builder|}
setMemberCount
:(I)Lcn/wildfirechat/proto/WFCMessage$ChatroomInfo$Builder;
y€
build
1()Lcn/wildfirechat/proto/WFCMessage$ChatroomInfo;
sƒ„…
toByteArray
()[B
A‡ˆ‰
setBytes
([B)V
request
9Lcn/wildfirechat/proto/WFCMessage$GetChatroomInfoRequest;
info
/Lcn/wildfirechat/proto/WFCMessage$ChatroomInfo;
memberCount

I
bytes
[B
getChatRoomMember”
=cn/wildfirechat/proto/WFCMessage$GetChatroomMemberInfoRequest
–ƒ—
3cn/wildfirechat/proto/WFCMessage$ChatroomMemberInfo
?Lcn/wildfirechat/proto/WFCMessage$GetChatroomMemberInfoRequest;
5Lcn/wildfirechat/proto/WFCMessage$ChatroomMemberInfo;
joinChatRoomœ
&cn/wildfirechat/proto/WFCMessage$IDBuf
(Lcn/wildfirechat/proto/WFCMessage$IDBuf;
AŸ ¡
add
(Ljava/lang/Object;)V
£¤¥
getAll
()Ljava/util/List;
roomlist
Ljava/util/List;
LocalVariableTypeTable
/Ljava/util/List<Lchat/module/entity/ChatRoom;>;    Y«¬]
Join®
chat/module/entity/Member°

­²³
'(Ljava/lang/String;Ljava/lang/String;)V
Vµ¶·
addOneMember
(Lchat/module/entity/Member;)V
member
Lchat/module/entity/Member;
 StackMapTable¼
java/lang/String    Y¾¿]
Leave
VÁÂ
deleteOneMember    YÄÅ]
KickOffÇ
    timePoint
ÉËÊ
java/lang/LongÌÍ
    parseLong
(Ljava/lang/String;)J
VÏÐÑ
getMessageList
(J)Ljava/util/List;
    timeStamp

J
messageList
4Ljava/util/List<Lchat/module/entity/MessageRecord;>;
7×ØÙ
getMessageRecord
$()Lchat/module/entity/MessageRecord;    YÛÜ]
PublishMessage
VÞ`ß
Y(Lchat/module/entity/PublishOperator;Lchat/module/entity/MessageRecord;Lchat/user/User;)V
record
"Lchat/module/entity/MessageRecord;ã
 chat/module/entity/MessageRecord

SourceFile
ChatRoomHandler.java
InnerClassesè
 cn/wildfirechat/proto/WFCMessage
ChatroomInfo
Builder
ChatroomMemberInfo
GetChatroomInfoRequest
GetChatroomMemberInfoRequest
IDBuf!



    +
¸
³±


    /

*·±


    …
7*¶* ¶*"¶*$¶*&¶*(¶**¶*,¶*.¶±*
 $!*"0#6$
7

    N*´04¶6L*´<¶@±'
-.
5E

!
    •5*´F¶JL*´0P¶6M²,¶RÀVN-²X+¶^²,¶bW*´<¶@±1256%9-<4=*5-eE
#QEfg
hi
j    ’,*´0l¶nÀlL
M
>,¶r¶x¶~¶‚:*´<¶†±A KLM"O+P4, Š‹
ŒŽ"
‘
’i
j    u*´0“¶nÀ“L
M,¶•N*´<-¶†±T \]_`* Š˜
Œ™    ‘
ši
j    R*´0›¶nÀ›L*´<
¶†±d gh     Š

#
    h*´0P¶6L²+¶RÀVM*´<,¶ž±k
lno 
QE
    fg
%
    ^²¶¢L*´<+¶ž±rst    ¦§
¨
    ¦©

'
    ÎD*´F¶JL*´0P¶6M²,¶RÀVN-DZ-²ª+¶^»­Y,¯·±:-¶´*´<¶@±*
wxz|!}"*„6…<ˆC‰4D<eE
2QE'fg6¸¹º
þ"»»V
)i
j    ³7*´F¶JL*´0P¶6M²,¶RÀVN-DZ-²½+¶^-+¶À*´<¶@±&    Œ‘!’"–*™/œ6*7/eE
%QEfgº
þ"»»V
+i
j    ³7*´F¶JL*´0P¶6M²,¶RÀVN-DZ-²Ã+¶^-+¶À*´<¶@±&     ¡£¥!¦"ª*­/°6±*7/eE
%QEfgº
þ"»»V-
    Í;*´0P¶6L*´0ƶ6¸ÈA²+¶RÀV:DZ ¶Î:*´<¶ž±"´
µ·#¹(º)¾1Á:Â4;
1QE
$ÒÓ#fg1
郎
1
ÔÕº
þ)»V/
    ®6*´0P¶6L*´0¶ÖM²+¶RÀVN-DZ-²Ú,*´F¶Ý*´<¶@±"Æ
ÇÉË!Ì"Ó.Ö5×*6
,QE
$àáfgº
þ"»âVäåæ2sçéysê–çëlçì“çí›çî