数据库提交

cuikaidong

2025-06-12 066063ed92fdd40da4dfe21770557f3adba3e1af

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
Êþº¾4Ã
.j    #k    #l
*m    #nop    #qr
js
t
*u
v
wxyz
*{|}x~
j€‚
ƒ„…'†
‡ˆ‰
*Š‹Œ‹Ž'
o‘’“
”•–
*j—
,j˜
log
Lorg/slf4j/Logger;
session
Ljavax/websocket/Session;

webSockets
*Ljava/util/concurrent/CopyOnWriteArraySet;
    Signature
[Ljava/util/concurrent/CopyOnWriteArraySet<Lorg/jeecg/modules/message/websocket/WebSocket;>;
sessionPool
Ljava/util/Map;
<Ljava/util/Map<Ljava/lang/String;Ljavax/websocket/Session;>;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
/Lorg/jeecg/modules/message/websocket/WebSocket;
onOpen
.(Ljavax/websocket/Session;Ljava/lang/String;)V
userId
Ljava/lang/String;
 StackMapTablez
MethodParameters
RuntimeVisibleAnnotations
Ljavax/websocket/OnOpen;
"RuntimeVisibleParameterAnnotations
"Ljavax/websocket/server/PathParam;
value
onClose
Ljavax/websocket/OnClose;
    onMessage
(Ljava/lang/String;)V
message
obj
!Lcom/alibaba/fastjson/JSONObject;
Ljavax/websocket/OnMessage;
sendAllMessage

e
Ljava/lang/Exception;
    webSocket™Ž
sendOneMessage
'(Ljava/lang/String;Ljava/lang/String;)Vš’
sendMoreMessage
(([Ljava/lang/String;Ljava/lang/String;)V
userIds
[Ljava/lang/String;b
<clinit>

SourceFile
WebSocket.java
*Lorg/springframework/stereotype/Component;
'Ljavax/websocket/server/ServerEndpoint;
/websocket/{userId}:;1234›œ78žŸ/0
java/lang/StringBuilder
1【websocket消息】有新的连接，总数为: ¡¢£ ¤¥¦§¨P
java/lang/Exception©œ
.【websocket消息】连接断开，总数为:
+【websocket消息】收到客户端消息:ªP
com/alibaba/fastjson/JSONObject
(org/jeecg/common/constant/WebsocketConst
cmd

heartcheckž«
msgTxt
心跳响应¬¯°¦²³´µ¶™·¸¹º
-org/jeecg/modules/message/websocket/WebSocket»¸¼;½¾
javax/websocket/Session
#【websocket消息】 å•ç‚¹æ¶ˆæ¯:¿ÀÁ
(java/util/concurrent/CopyOnWriteArraySet
java/util/HashMap
java/lang/Object
java/util/Iterator
java/lang/String
add
(Ljava/lang/Object;)Z
 java/util/Map
put
8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
size
()I
(I)Ljava/lang/StringBuilder;
toString
()Ljava/lang/String;
org/slf4j/Logger
info
remove
debug
8(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
getAsyncRemote
Async
InnerClasses
(()Ljavax/websocket/RemoteEndpoint$Async;
toJSONStringÂ
$javax/websocket/RemoteEndpoint$Async
sendText
1(Ljava/lang/String;)Ljava/util/concurrent/Future;
iterator
()Ljava/util/Iterator;
hasNext
()Z
next
()Ljava/lang/Object;
isOpen
printStackTrace
get
&(Ljava/lang/Object;)Ljava/lang/Object;
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;
javax/websocket/RemoteEndpoint!#./012
34
56
78
59
:;
</

*·
±=
>
?@
AB<¨=*+µ²*¶W²,+¹W²»Y·    
¶²¶¶ ¶¹§N±
8;='( )*8,;+<-> =?@=12
=CDE{FG    1CH
IJ
K
LsC
M;<|-²*¶W²»Y·    ¶²¶¶ ¶¹§L±
(+=23(5+4,6>
-?@EkFH
N
OP<›I²»Y·    ¶+¶¶¹»Y·M,¶W,¶W*´¹
,¶¹W±=;<#=,>5?H@> I?@IQD
#&RSG
QH
T
UP<ÎD²¶ M,¹!
™6,¹"
À#N-´¹$
™-´¹
+¹W§
:¶%§ÿDZ
69="EG&H6L9J;K@MCN>*;VW&X@D?@DQD
EüYü.ZBFúúG
Q
[\<âM²+¹&À'N-Æ>-¹$
™5²»Y·    (¶,¶¶¹-¹
,¹W§
:¶%±
BE="R SU5VBYEWGXL[>4GVWM?@MCD
MQD @12EÿEZ]]^
FG    CQ
_`<
*    n+N-¾66¢`-2:²¹&À':Æ@¹$
™6²»Y·    (¶,¶¶¹¹
,¹W§
:¶%„
§ÿŸ±
4]`=*
_`%a4cOd]g`ebfg_mk>>bVW%B12QCDn?@nab
nQDE.þ    c

ÿVZc]c

]^
FùøG    aQd;
<=#¸)³»*Y·+³»,Y·-³±
=!"efHgh
Lsi®

ˆ±­