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

chat/message/MessagesPublisher
java/lang/Object
<init>
()V
Code
    
LineNumberTable
LocalVariableTable
this
 Lchat/message/MessagesPublisher;
publish2Receivers
D(Lcn/wildfirechat/proto/WFCMessage$Message;Ljava/util/Collection;I)V
    Signature
X(Lcn/wildfirechat/proto/WFCMessage$Message;Ljava/util/Collection<Ljava/lang/String;>;I)V

(cn/wildfirechat/proto/WFCMessage$Message
getFromUser
()Ljava/lang/String;

getConversation
1()Lcn/wildfirechat/proto/WFCMessage$Conversation;

-cn/wildfirechat/proto/WFCMessage$Conversation !
getType
()I
#$
    getTarget
&'!
getLine
)*+
getMessageId
()J
-./

getContent
3()Lcn/wildfirechat/proto/WFCMessage$MessageContent;
12
/cn/wildfirechat/proto/WFCMessage$MessageContent
145!
getPersistFlag
178
getPushContent
1:;
getPushData
=>+
getServerTimestamp
1@A!
getMentionedType
1CDE
getMentionedTargetList
()Ljava/util/List;

GH
#publishTransparentMessage2ReceiversJLK
java/util/CollectionMN
iterator
()Ljava/util/Iterator;PRQ
java/util/IteratorST
next
()Ljava/lang/Object;V
java/lang/String
UXYZ
equals
(Ljava/lang/Object;)Z
\^]
chat/util/MessageShardingUtil_+

generateId
acb
.cn/wildfirechat/proto/WFCMessage$NotifyMessagede

newBuilder
:()Lcn/wildfirechat/proto/WFCMessage$NotifyMessage$Builder;
gih
6cn/wildfirechat/proto/WFCMessage$NotifyMessage$Builderjk
setType
;(I)Lcn/wildfirechat/proto/WFCMessage$NotifyMessage$Builder;
gmno
setHead
;(J)Lcn/wildfirechat/proto/WFCMessage$NotifyMessage$Builder;
gqrs
build
2()Lcn/wildfirechat/proto/WFCMessage$NotifyMessage;
uwv
io/netty/buffer/Unpooledxy
buffer
()Lio/netty/buffer/ByteBuf;
a{|}
toByteArray
()[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;
•—–
chat/user/UserStore˜™
getById
$(Ljava/lang/String;)Lchat/user/User;
›œ
chat/user/UseržŸ
    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;P³´µ
hasNext
()Z
·¹¸
java/lang/Exceptionº
printStackTrace
messageT
*Lcn/wildfirechat/proto/WFCMessage$Message;
    receivers
Ljava/util/Collection;
pullType

I
sender
Ljava/lang/String;
conversationType
target
line
    messageId

J
messageContentType
pushContent
pushData

serverTime
mentionType
mentionTargets
Ljava/util/List;
persistFlag
message
usr

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

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

e
Ljava/lang/Exception;
LocalVariableTypeTable
*Ljava/util/Collection<Ljava/lang/String;>;
$Ljava/util/List<Ljava/lang/String;>;
 StackMapTableè
java/util/List
{ë
MS
user

îïð
notRetainedPublishWithMessageId
…(Ljava/lang/String;Lchat/server/moquette/message/MqttQoS;Lio/netty/buffer/ByteBuf;I)Lchat/server/moquette/message/MqttPublishMessage;
topic
qosô
,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;

SourceFile
MessagesPublisher.java
InnerClasses

 cn/wildfirechat/proto/WFCMessage
Conversation
Message
MessageContent
 NotifyMessage
Builder!


/

*·±


 
W
J+¶:+¶¶6+¶¶":+¶¶%6+¶(7+¶,¶06
+¶,¶3     
:§
 +¶,¶6:+¶,¶9: +¶<7+¶,¶?6+¶,¶B:+¶,¶36
: *+,·F±,¹I
:§¢¹O
ÀU:¶W™§‰¸[7+¶¶™+¶¶W¶Wšh¸`¶f¶l¶p:¸t:¶z:¾¶~¶„Wˆ²Š¸:¸”¶š:¶ :ƶ¦:Æ ¹¬W¹²
šÿZ§
:¶¶±
‹
?
B·
º. !!"'#0';(>)A*G+P/Y1_2h3q4z5}7ƒ8Š9‹=¢>¬?¯B´E¾IÆLÐNÓO×PÜQßMáRæSíUûW
Y
[
\
]
&^
+_
5=
?d
De
Ig

J 
J»¼

J½¾
J¿À
DÁÂ
;ÃÀ
2ÄÂ!
)ÅÀ'
#ÆÇ0
ÈÀ
>ÉÂYñÊ _ëËÇhâÌÀqÙÍÎzÐÏÀ}Íм¢“Ñ´ÒÇáTÓÔæOÕÖíH×Ø
.ÙÚ
"ÛÜ
ÝÞ
&ßà
Dáâã
J½äqÙÍåæ

    ÿA

J
U
U

ÿ:
J
U
U

U
ç
ÿ

J
U
U

U
ç
Pÿ
J
U
U

U
ç
UPüÿn
J
U
U

U
ç
Pÿ
J
U
U

U
ç

·H
eu,¹I
:§b¹O
ÀU:¸t:+¶é:¾¶~¶„W겊¸:¸”¶š:        ¶ :
 
Æ
¶¦:Æ ¹¬W¹²
šÿš±
6 jkl"m0o<qHsOtTu[v`wjjt{pu uм
u½¾u¿ÀSìÂNÕÖ"H×Ø<.ÙÚH"ÛÜ    OÝÞ
[ßàã
u½äæÿ
J
Pû^
’“
F*+,¸í°

~ ñÂò
ÐÖ
ïð
Œ(»óY²õ+·û:»þY*·
:»
Y,·
°
‚ƒ„>(ñÂ(ò
(ÐÖ(ÆÀ

     




 
*



1

a

ga