Êþº¾ 2H .com/jeeplus/common/websocket/onchat/ChatServer )org/java_websocket/server/WebSocketServer <init> (I)V
|
Exceptions java/net/UnknownHostException Code java/net/InetSocketAddress
|
|
(Ljava/net/InetSocketAddress;)V LineNumberTable LocalVariableTable this 0Lcom/jeeplus/common/websocket/onchat/ChatServer; port I address Ljava/net/InetSocketAddress; onOpen O(Lorg/java_websocket/WebSocket;Lorg/java_websocket/handshake/ClientHandshake;)V conn Lorg/java_websocket/WebSocket; handshake .Lorg/java_websocket/handshake/ClientHandshake; onClose 5(Lorg/java_websocket/WebSocket;ILjava/lang/String;Z)V
|
# $ % userLeave !(Lorg/java_websocket/WebSocket;)V
|
' ) ( 2com/jeeplus/common/websocket/onchat/ChatServerPool * + getOnlineUser ()Ljava/util/Collection; - com/jeeplus/common/json/AjaxJson
|
, / 0 ()V 2 data
|
, 4 5 6 put '(Ljava/lang/String;Ljava/lang/Object;)V 8 java/lang/StringBuilder : _online_all_status_
|
7 < = (Ljava/lang/String;)V
|
, ? @ A
|
getJsonStr ()Ljava/lang/String;
|
7 C D E append -(Ljava/lang/String;)Ljava/lang/StringBuilder;
|
7 G H A toString
|
' J K = sendMessage code reason Ljava/lang/String; remote Z onlineUsers Ljava/util/Collection; j "Lcom/jeeplus/common/json/AjaxJson; LocalVariableTypeTable *Ljava/util/Collection<Ljava/lang/String;>; onMessage 3(Lorg/java_websocket/WebSocket;Ljava/lang/String;)V
|
Z G [ java/lang/String ] chatHistoryService
|
_ a ` ,com/jeeplus/common/utils/SpringContextHolder b c getBean &(Ljava/lang/String;)Ljava/lang/Object; e 2com/jeeplus/modules/iim/service/ChatHistoryService g _online_user_
|
Z i j k
|
startsWith (Ljava/lang/String;)Z m
|
Z o p q replaceFirst 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
|
s t u userjoin 3(Ljava/lang/String;Lorg/java_websocket/WebSocket;)V w *com/jeeplus/modules/iim/entity/ChatHistory
|
v /
|
v z { =
|
setUserid2 } 0
|
v = setStatus
|
d findList >(Lcom/jeeplus/modules/iim/entity/ChatHistory;)Ljava/util/List; java/util/List iterator ()Ljava/util/Iterator; java/util/Iterator next ()Ljava/lang/Object;
|
v A
|
getUserid1
|
Z valueOf &(Ljava/lang/Object;)Ljava/lang/String; _msg_
|
v A
|
getUserid2
|
v A getMsg ¡ java/text/SimpleDateFormat £ yyyy-MM-dd HH:mm:ss
|
<
|
v ¦ § ¨ getCreateDate ()Ljava/util/Date;
|
ª « ¬ format $(Ljava/util/Date;)Ljava/lang/String;
|
' ® ¯ X sendMessageToUser ± 1
|
d ³ ´ µ save /(Lcom/jeeplus/modules/iim/entity/ChatHistory;)V · ¸ ¹ hasNext ()Z » _leave_user_
|
Z ½ ¾ ¿ contains (Ljava/lang/CharSequence;)Z
|
Z Á Â Ã split '(Ljava/lang/String;)[Ljava/lang/String;
|
v Å Æ =
|
setUserid1
|
v È É = setMsg Ë java/util/Date
|
Ê /
|
v Î Ï Ð setCreateDate (Ljava/util/Date;)V
|
' Ò Ó Ô getWebSocketByUser 2(Ljava/lang/String;)Lorg/java_websocket/WebSocket; Ö ?_sys_对æ¹ç°å¨ç¦»çº¿ï¼ä»å°å¨ä¸çº¿åæ¶å°ä½ çæ¶æ¯! message 4Lcom/jeeplus/modules/iim/service/ChatHistoryService; userId chat ,Lcom/jeeplus/modules/iim/entity/ChatHistory; list Ljava/util/List; c arr [Ljava/lang/String; fromUser toUser msg
|
toUserConn >Ljava/util/List<Lcom/jeeplus/modules/iim/entity/ChatHistory;>; StackMapTable è org/java_websocket/WebSocket ê java/util/Collection à 6(Lorg/java_websocket/WebSocket;Ljava/nio/ByteBuffer;)V î UTF-8
|
ð ò ñ java/nio/charset/Charset ó ô forName .(Ljava/lang/String;)Ljava/nio/charset/Charset;
|
ð ö ÷ ø
|
newDecoder #()Ljava/nio/charset/CharsetDecoder;
|
ú ü û java/nio/ByteBuffer ý þ asReadOnlyBuffer ()Ljava/nio/ByteBuffer;
|
java/nio/charset/CharsetDecoder decode ,(Ljava/nio/ByteBuffer;)Ljava/nio/CharBuffer; java/lang/System
|
out Ljava/io/PrintStream;
|
G java/nio/CharBuffer
|
java/io/PrintStream = println
|
java/lang/Exception 0 printStackTrace buffer Ljava/nio/ByteBuffer; charset Ljava/nio/charset/Charset; decoder !Ljava/nio/charset/CharsetDecoder;
|
charBuffer Ljava/nio/CharBuffer; ex Ljava/lang/Exception;
|
onFragment G(Lorg/java_websocket/WebSocket;Lorg/java_websocket/framing/Framedata;)V fragment &Lorg/java_websocket/framing/Framedata; onError 6(Lorg/java_websocket/WebSocket;Ljava/lang/Exception;)V
|
') * u addUser user
|
'- ./ getUserByKey 2(Lorg/java_websocket/WebSocket;)Ljava/lang/String;
|
'1 23
|
removeUser !(Lorg/java_websocket/WebSocket;)Z b main ([Ljava/lang/String;)V8 java/lang/InterruptedException: java/io/IOException <>= org/java_websocket/WebSocketImpl ? P DEBUG
|
|
B C 0 start args s
|
SourceFile ChatServer.java !
|
E *» Y· · ±
|
$ %
|
> *+· ±
|
( )
|
? ± 4 !
|
À 4*+¶ "¸ &:» ,Y· .:1¶ 3» 7Y9· ;¶ >¶ B¶ F¸ I± ; <
|
= > ? 3 @ H 4 4 4 L 4 M N 4 O P
|
* Q R ! S T U
|
* Q V W X
|
Õ µ,¶ YM\¸ ^À dN,Æ â,f¶ h Ù,fl¶ n:*+¶ r¸ &:» ,Y· .:1¶ 3» 7Y9· ;¶ >¶ B¶ F¸ I» vY· x:¶ y|¶ ~-¶ :¹
:
|
§ e
|
¹ À v: +» 7Y ¶ ¸ · ;¶ B ¶ ¶ B¶ B ¶ ¶ B¶ B» Y¢· ¤ ¶ ¥¶ ©¶ B¶ F¸ °¶ ~- ¶ ²
|
¹ ¶ ÿ,Æ ?,º¶ h 6*+¶ "¸ &:» ,Y· .:1¶ 3» 7Y9· ;¶ >¶ B¶ F¸ I,Æ ,¶ ¼ y,¶ À:2:2:2:» vY· x:¶ Ķ y¶ Ç» ÊY· ̶ ͸ Ñ: Æ ¸ Ñ,¸ °¶ ~§ +Õ¸ |¶ ~-¶ ²± ® + G H J K % L , O 1 P : Q C R Z U c V j W q X y Y Z Ú [ á \ ç Y ñ ` þ a b c d e1 f> gF hL iR jX ma nh oo pv r u v w x y¡ z§ {® ~´ ¶ µ µ µ × N § ] Ø % Ì Ù N 1 À Q R : · S T c Ú Û y x Ü Ý V Þ Û ) Q R S T F n ß à L h á N R b â N X \ ã N a S Ú Û + ä U 1 À Q V y x Ü å ) Q V æ x ÿ
ç Z d Z é , v û aÿ ç Z d ?ÿ o
|
ç Z d ë Z Z Z v ç ÿ ç Z d W ì
|
ì 5N::í¸ ïN-¶ õ:,¶ ù¶ ÿ:²¶ ¶§
|
:¶± * - *
|
* / 4 H 5 5 5 3 0 - / ! æ ÿ - ç ú ð "#
|
? ± $% &'
|
G ,¶±
|
! t u
|
H +,¸(±
|
° ³ + N $ %
|
[ +¸,M+¸0>± º »
|
Ä * + N
|
4 P 56 79
|
d ³;!Û<» Y·@M,¶A± Æ Ç È É Ë D à E F G
|
