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
Êþº¾4
chat/user/SessionStore
java/lang/Object

sessionMap
Ljava/util/Map;
    Signature
6Ljava/util/Map<Ljava/lang/String;Lchat/user/Session;>;
<clinit>
()V
Code
 

init
LineNumberTable
LocalVariableTable
<init>
 

this
Lchat/user/SessionStore;
&java/util/concurrent/ConcurrentHashMap
    

getOrCreate
'(Lchat/user/Client;)Lchat/user/Session;

Exceptions
java/lang/Exception
!#"
chat/user/Client$%
getId
()Ljava/lang/String;')(
 java/util/Map*+
get
&(Ljava/lang/Object;)Ljava/lang/Object;-
chat/user/Session
,/0
(Lchat/user/Client;)V'234
put
8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
client
Lchat/user/Client;
clientId
Ljava/lang/String;
result
Lchat/user/Session;
 StackMapTable=
java/lang/String
<(Lchat/server/moquette/message/ClientID;)Lchat/user/Session;
@BA
%chat/server/moquette/message/ClientIDCD
isEmpty
()Z
@FG%
getValue
'Lchat/server/moquette/message/ClientID;
key
'(Ljava/lang/String;)Lchat/user/Session;
delete
*(Lchat/server/moquette/message/ClientID;)V'NO+
remove
clientID
contains
(Ljava/lang/String;)Z'TUV
containsKey
(Ljava/lang/Object;)Z
clearSessionByUser
(Ljava/lang/String;)V
Z\[
chat/user/User]^
getInstance
$(Ljava/lang/String;)Lchat/user/User;
Z`ab
getClientSet
()Ljava/util/Set;dfe
 java/util/Setgh
iterator
()Ljava/util/Iterator;jlk
java/util/Iteratormn
next
()Ljava/lang/Object;
,pq

closeChanneljstD
hasNext
userId
user
Lchat/user/User;
    clientSet
Ljava/util/Set;
session
LocalVariableTypeTable
#Ljava/util/Set<Lchat/user/Client;>;

SourceFile
SessionStore.java!



        

(¸±
 

/

*·±

 
 

/»Y·³±
 
    
ž2*Ç
°*¶ L²+¹&À,M,Ç»,Y*·.M²+,¹1W,°"% 0# 256'78
9:;ý)<,    *>
ƒ#*Ç
°*¶?™
°*¶EL²+¹&À,M,°'(+ ,/0!2 #7HI8
!9:;    *J
^*Ç
°²*¹&À,L+°67:;789:
;
    KL
b*DZ*¶EL²+¹MW±?@C
DEPH
I8
;
    QR
K
*Ǭ²*¹S¬HIL
78;
    WX

U*¸YL+DZ+¶_M,¹c
:§3¹i
À!N-¶ :²¹&À,:¶o²¹MW¹r
šÿɱ.PR    S
VX%Y+Z:\?]JXT_>Uu8Pvw
Fxy%%56+78:z:{
Fx|;ü
Zÿ<Zdj/
}~