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

chat/handler/GroupHandler
chat/server/call/CallObject
 threadFactory
$Ljava/util/concurrent/ThreadFactory;
<init>
()V
Code
 
chat/handler/GroupHandler$1

(Lchat/handler/GroupHandler;)V    

LineNumberTable
LocalVariableTable
this
Lchat/handler/GroupHandler;
 publishMethod
createGroup


addOneMethod
(Ljava/lang/String;)V
    quitGroup!
getInfo#

addMembers%
 getMemberList'
setGroupManager)
friendUnread+
 transferGroup-
join/
leave1
kickoff3
changeGroupName5
changeMemberAlias7
modifyGroupAlias9
modifyGroup;
pull=
publish

Exceptions@
java/lang/Exception    
BCD
dataPool
Lchat/server/im/DataPool;F
3cn/wildfirechat/proto/WFCMessage$CreateGroupRequest
HJI
chat/server/im/DataPoolKL
 getWFCMessage
%(Ljava/lang/Class;)Ljava/lang/Object;
ENOP
getGroup
*()Lcn/wildfirechat/proto/WFCMessage$Group;
RTS
&cn/wildfirechat/proto/WFCMessage$GroupUV
getGroupInfo
.()Lcn/wildfirechat/proto/WFCMessage$GroupInfo;
XZY
*cn/wildfirechat/proto/WFCMessage$GroupInfo[\
getExtra
()Ljava/lang/String;
^`_
chat/module/entity/GroupTypeab
parse
2(Ljava/lang/String;)Lchat/module/entity/GroupType;
dfe
chat/module/GroupBucketgh
getInstance
9(Lchat/module/entity/GroupType;)Lchat/module/GroupBucket;    
jkl
user
Lchat/user/User;
dnop
getOrCreate
T(Lcn/wildfirechat/proto/WFCMessage$Group;Lchat/user/User;)Lchat/module/entity/Group;
rts
chat/user/Useru\
getId
wyx
chat/module/entity/Groupz{
createGroupMessage
q(Lcn/wildfirechat/proto/WFCMessage$GroupInfo;Ljava/lang/String;)Lcn/wildfirechat/proto/WFCMessage$MessageContent;
d}~
sendGroupNotification
“(Lchat/user/User;Lcn/wildfirechat/proto/WFCMessage$CreateGroupRequest;Lcn/wildfirechat/proto/WFCMessage$MessageContent;Lchat/module/entity/Group;)V
wt
‚„ƒ
java/lang/String…†
getBytes
()[B    
ˆ‰Š

resultPool
Lchat/server/im/ResultPool;
ŒŽ
chat/server/im/ResultPool
setBytes
([B)V
request
5Lcn/wildfirechat/proto/WFCMessage$CreateGroupRequest;
wfcGroup
(Lcn/wildfirechat/proto/WFCMessage$Group;
type
Lchat/module/entity/GroupType;
groupBucket
Lchat/module/GroupBucket;
group
Lchat/module/entity/Group;
content
1Lcn/wildfirechat/proto/WFCMessage$MessageContent;
groupId
Ljava/lang/String;
data
[B¢
1cn/wildfirechat/proto/WFCMessage$QuitGroupRequest
¡¤¥\

getGroupId
d§O¨
.(Ljava/lang/String;)Lchat/module/entity/Group;
wª«
quit
3Lcn/wildfirechat/proto/WFCMessage$QuitGroupRequest;
 StackMapTable¯
2com/google/protobuf/InvalidProtocolBufferException±
0cn/wildfirechat/proto/WFCMessage$PullUserRequest
°³´µ
getRequestList
()Ljava/util/List;
d·¸¹
getGroupList
"(Ljava/util/List;)Ljava/util/List;
»½¼
4cn/wildfirechat/proto/WFCMessage$PullGroupInfoResult¾¿

newBuilder
@()Lcn/wildfirechat/proto/WFCMessage$PullGroupInfoResult$Builder;
ÁÃÂ
<cn/wildfirechat/proto/WFCMessage$PullGroupInfoResult$BuilderÄÅ

addAllInfo
T(Ljava/lang/Iterable;)Lcn/wildfirechat/proto/WFCMessage$PullGroupInfoResult$Builder;
ÁÇÈÉ
build
8()Lcn/wildfirechat/proto/WFCMessage$PullGroupInfoResult;
»Ë̆
toByteArray
2Lcn/wildfirechat/proto/WFCMessage$PullUserRequest;
    groupList
Ljava/util/List;
friendGroupList
builder
>Lcn/wildfirechat/proto/WFCMessage$PullGroupInfoResult$Builder;
resBytes
LocalVariableTypeTable
@Ljava/util/List<Lcn/wildfirechat/proto/WFCMessage$UserRequest;>;
>Ljava/util/List<Lcn/wildfirechat/proto/WFCMessage$GroupInfo;>;Ø
6cn/wildfirechat/proto/WFCMessage$AddGroupMemberRequest
פ
×Ûܵ
getAddedMemberList
wÞßà
 addMembersWfc
%(Ljava/lang/String;Ljava/util/List;)Vâ
 chat/message/SendMessageCallback
á
áåæç
    setSender
(Lchat/user/User;)V
wé%µ
áëìí
 setMemberList
(Ljava/util/List;)Vï
hello 
áñò

setMessage
Œôõö
setCallback
%(Lchat/message/SendMessageCallback;)V
8Lcn/wildfirechat/proto/WFCMessage$AddGroupMemberRequest;
callback
"Lchat/message/SendMessageCallback;û
7cn/wildfirechat/proto/WFCMessage$PullGroupMemberRequest
úýþ\
    getTarget
w


µ
getWFCMemberList




6cn/wildfirechat/proto/WFCMessage$PullGroupMemberResult¾

B()Lcn/wildfirechat/proto/WFCMessage$PullGroupMemberResult$Builder;
 

    
>cn/wildfirechat/proto/WFCMessage$PullGroupMemberResult$Builder


addAllMember
V(Ljava/lang/Iterable;)Lcn/wildfirechat/proto/WFCMessage$PullGroupMemberResult$Builder;


È

:()Lcn/wildfirechat/proto/WFCMessage$PullGroupMemberResult;

Ë
9Lcn/wildfirechat/proto/WFCMessage$PullGroupMemberRequest;
friendGroup
members
@Lcn/wildfirechat/proto/WFCMessage$PullGroupMemberResult$Builder;
@Ljava/util/List<Lcn/wildfirechat/proto/WFCMessage$GroupMember;>;
H



    getString
&(Ljava/lang/String;)Ljava/lang/String;

memberId    

 

"chat/module/entity/PublishOperator
!
"
KickOff
$Lchat/module/entity/PublishOperator;
w
$
%
&
notify
K(Lchat/module/entity/PublishOperator;Ljava/lang/Object;Ljava/lang/String;)V
w
(
)
deleteOneMember
userId
FriendGroup
-
    groupName
w
/
0
setName    

2
3
"

ChangeName
5
alias
w
7
8
9
setMemberAlias
'(Ljava/lang/String;Ljava/lang/String;)V
;
    timePoint

=
?
>
java/lang/Long
@
A
    parseLong
(Ljava/lang/String;)J
w
C
D
E
getMessageList
(J)Ljava/util/List;
Œ
G
H
I
add
(Ljava/lang/Object;)V
    timeStamp

J
messageList
4Ljava/util/List<Lchat/module/entity/MessageRecord;>;
H
O
P
Q
getMessageRecord
$()Lchat/module/entity/MessageRecord;    

S
T
"
PublishMessage
w
V
%
W
Y(Lchat/module/entity/PublishOperator;Lchat/module/entity/MessageRecord;Lchat/user/User;)V
record
"Lchat/module/entity/MessageRecord;
[
 chat/module/entity/MessageRecord

exeMessage

Z
^
_
`
newMessageId
()I

b
d
c
.cn/wildfirechat/proto/WFCMessage$NotifyMessage¾
e
:()Lcn/wildfirechat/proto/WFCMessage$NotifyMessage$Builder;

g
i
h
6cn/wildfirechat/proto/WFCMessage$NotifyMessage$Builder
j
k
setType
;(I)Lcn/wildfirechat/proto/WFCMessage$NotifyMessage$Builder;

g
m
n
o
setHead
;(J)Lcn/wildfirechat/proto/WFCMessage$NotifyMessage$Builder;

g
qÈ
r
2()Lcn/wildfirechat/proto/WFCMessage$NotifyMessage;

t
v
u
io/netty/buffer/Unpooled
w
x
buffer
()Lio/netty/buffer/ByteBuf;

bË

{
}
|
io/netty/buffer/ByteBuf
~

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

{

‚
ƒ

writeBytes
([B)Lio/netty/buffer/ByteBuf;
…
MN    
‡
‰
ˆ
$chat/server/moquette/message/MqttQoS
Š
‹
AT_MOST_ONCE
&Lchat/server/moquette/message/MqttQoS;



Ž

notRetainedPublish
„(Ljava/lang/String;Lchat/server/moquette/message/MqttQoS;Lio/netty/buffer/ByteBuf;)Lchat/server/moquette/message/MqttPublishMessage;
r
‘
’
“
    getClient
&(Ljava/lang/String;)Lchat/user/Client;

•
—
–
chat/user/Client
˜
™

getSession
()Lchat/user/Session;

›

œ
chat/user/Session
ž
Ÿ

getChannel
()Lio/netty/channel/Channel;
¡
£
¢
io/netty/channel/Channel
¤
¥
 writeAndFlush
4(Ljava/lang/Object;)Lio/netty/channel/ChannelFuture;
?
§
¨
printStackTrace

messageSeq
 notifyMessage
0Lcn/wildfirechat/proto/WFCMessage$NotifyMessage;
payload
Lio/netty/buffer/ByteBuf;
byteData

publishMsg
1Lchat/server/moquette/message/MqttPublishMessage;
client
Lchat/user/Client;
sessionC
Lchat/user/Session;
channel
Lio/netty/channel/Channel;

e
Ljava/lang/Exception;


º
»
¼
notRetainedPublishWithMessageId
…(Ljava/lang/String;Lchat/server/moquette/message/MqttQoS;Lio/netty/buffer/ByteBuf;I)Lchat/server/moquette/message/MqttPublishMessage;
topic
qos
message
Á
,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
    messageId

I
fixedHeader
.Lchat/server/moquette/message/MqttFixedHeader;
    varHeader
8Lchat/server/moquette/message/MqttPublishVariableHeader;
Ü
7cn/wildfirechat/proto/WFCMessage$ModifyGroupMemberAlias
9Lcn/wildfirechat/proto/WFCMessage$ModifyGroupMemberAlias;
ß
7cn/wildfirechat/proto/WFCMessage$ModifyGroupInfoRequest
9Lcn/wildfirechat/proto/WFCMessage$ModifyGroupInfoRequest;
â
7cn/wildfirechat/proto/WFCMessage$SetGroupManagerRequest
9Lcn/wildfirechat/proto/WFCMessage$SetGroupManagerRequest;
å
(cn/wildfirechat/proto/WFCMessage$Version
head
[J
*Lcn/wildfirechat/proto/WFCMessage$Version;
ê
5cn/wildfirechat/proto/WFCMessage$TransferGroupRequest
7Lcn/wildfirechat/proto/WFCMessage$TransferGroupRequest;

SourceFile
GroupHandler.java
InnerClasses
ð
 cn/wildfirechat/proto/WFCMessage
AddGroupMemberRequest
CreateGroupRequest
Group
    GroupInfo
ö
,cn/wildfirechat/proto/WFCMessage$GroupMember
GroupMember
ù
/cn/wildfirechat/proto/WFCMessage$MessageContent
MessageContent
ModifyGroupInfoRequest
ModifyGroupMemberAlias
 NotifyMessage
Builder
PullGroupInfoResult
PullGroupMemberRequest
PullGroupMemberResult
PullUserRequest
QuitGroupRequest
SetGroupManagerRequest
TransferGroupRequest
,cn/wildfirechat/proto/WFCMessage$UserRequest
UserRequest
Version!



    C
*·
*»Y*·µ±
0

    Õ
g*¶*¶* ¶*"¶*$¶*&¶*(¶**¶*,¶*.¶*0¶*2¶*4¶*6¶*8¶*:¶*<¶±J!"#$%&$'*(0*6+<,B-H.N/T0Z1`2f3
g
>
?    
        g*´AE¶GÀEL+¶MM,¶Q¶W¸]N-¸c:,*´i¶m:,¶Q*´i¶q¶v:*´i+¶|¶€:¶:*´‡¶‹±.6 9:<#=/AABOEVF]GfP\    g Z‘’
U“”J•–#D—˜/8™šA&›œVž]
Ÿ 
>
?    ¡)*´A¡¶GÀ¡L+¶£M,¸¦N-DZ-¶©*´‡
¶‹±"T VXZ[^ a(b*) ‘¬
ž™š­
þ¡‚w
!>
®    Ë7*´A°¶GÀ°L+¶²M,¸¶N¸º:-¶ÀW¶Æ¶Ê:*´‡¶‹±"f gjlm#o-p6q>7 *‘Í
%ÎÏ ÐÏÑÒ-
Ó Ô%ÎÕ ÐÖ
#>
?    ÎT*´A׶GÀ×L+¶ÙM,¸¦N-,+¶Ú¶Ý*´‡
¶‹»áY·ã:*´i¶ä-¶è¶êî¶ð*´‡¶ó±.t wxy |(1€:C‚J„S…4T G‘÷
Bž=™š1#øù
%>
®    ÷C*´Aú¶GÀúL+¶üM,¸¦N-DZ-¶ÿ:¸
:¶
W¶
 ¶
:*´‡¶‹±.‰ ŠŒŽ“"•'–/™9šB›HC 6‘

1ž,
š"!
Ï'Ñ
9
Ó Ô
"!

­
þú‚w
1>
?    Ë;*´i¶qL*´A
¶
M*´A
¶
N,¸¦:DZ²
-+¶
#-¶
'±&    ÁÂÃÅ$Ç)È*Ì4Ï:Ð4;3
*ž
(ž
ž$
+š­
ÿ*
‚‚‚w
3
    Ë;*´i¶qL*´A
¶
M*´A
,¶
N,¸¦:DZ-¶
.²
1-+¶
#±&    ÓÔÕ×$Ù)Ú*Þ0á:â4;3
*ž
(ž
-ž$
+š­
ÿ*
‚‚‚w
5
    Á5*´A
¶
L*´A
¶
M*´A
4¶
N+¸¦:DZ,-¶
6±"åæç!é'ë,ì-ð4ò45*ž

ž!
5ž'
+š­
ÿ-
‚‚‚w;
    É7*´A
¶
L*´A
:¶
¸
<A+¸¦:DZ ¶
B:*´‡¶
F±"õöøú$û%ÿ-
6
47,ž

J
K
+š-

LÏÔ
-

L
M­
þ%‚w=
    ž**´A
¶
L*´A¶
NM+¸¦N-DZ-²
R,*´i¶
U±


    


)
**ž

X
Y
+š­
þ‚
Zw

\ç
    
^q¸
]…A¸
a¶
f ¶
l¶
p:¸
s:¶
y:¾¶
z¶
€W
„²
†¸
Œ:++¶q¶
:¶
”:        Æ!    ¶
š:
Æ
¹
 W§M,¶
¦±
hk?N







!
 /
!<
#F
$M
%R
&Y
'^
(h
+l
,p
.pqqkl
c
©
KS
ª
«N
¬
­!G
® <,
¯
°F"
±
²M
³
´    Y
µ
¶
l
·
¸­    ÷k?    
Ž

    F*+,¸
¹°

= 
½ž
¾
‹

¿
­

»
¼
    Œ(»
ÀY²
Â+·
È:»
ËY*·
Í:»
ÐY,·
Ò°
B
C
D>(
½ž(
¾
‹
(
¿
­(
Õ
Ö
×
Ø 
Ù
Ú
7>
?    S*´A
Û¶GÀ
ÛL*´‡
¶‹±
I
L
M    ‘
Ý

9>
?    S*´A
Þ¶GÀ
ÞL*´‡
¶‹±
Q
T
U    ‘
à

'>
?    S*´A
á¶GÀ
áL*´‡
¶‹±
Y
\
]    ‘
ã

)>
?    e¼L*´A
ä¶GÀ
äM*´‡
¶‹±
`
b
e
f 
æ
ç
    ‘
è
+>
?    S*´A
é¶GÀ
éL*´‡
¶‹±
j
m
n    ‘
ë

ì
í
î²×
ï
ñE
ï
òR
ï
óX
ï
ô
õ
ï
÷
ø
ï
ú
Þ
ï
û
Û
ï
ü
b
ï
ý
g
b
þ»
ï
ÿÁ»
þú
ï

ï



þ°
ï¡
ï
á
ï
é
ï
ï
ä
ï