puzhibing
2023-04-01 36ad91a6d6887c60bfa1dc101dbfa9758a471dbc
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
Êþº¾4u
`Ÿ  ¡¢
£    ¤¥
¤¦    ¤§    ¤¨©ª«
Ÿ
¬­  ® ¯°
±²
³´  µ  ¶ \·
¸¹º \»¼
½¾
±¦¿    ÀÁ    ÂÃ
!ÅÆÇÈ
 É
 Ê    !Ë
 Ì
ÍÎÏ
ÍÑÒÓ
ÕÖ
,× ¯ØÙÚÛ
2Ü  ÝÞß
1àá
:Ÿâ
ãä
:åætçè
1Üê
Eë    ìí îï ðñ
Âò
Âó    ôõ
³ö ðÔ
Õ÷
Õø ¯µ    ùú ûü îý    þÿ
 î
 
!    
!
 
handshakerBLio/netty/handler/codec/http/websocketx/WebSocketServerHandshaker;WEB_SOCKET_URLLjava/lang/String; ConstantValue<init>()VCodeLineNumberTableLocalVariableTablethis/Lcom/sinata/zuul/util/applets/WebSocketHandler;channelReadComplete+(Lio/netty/channel/ChannelHandlerContext;)Vctx(Lio/netty/channel/ChannelHandlerContext;
ExceptionsuserEventTriggered=(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)Vmsgevent)Lio/netty/handler/timeout/IdleStateEvent;evtLjava/lang/Object; StackMapTable¢exceptionCaught@(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Throwable;)VcauseLjava/lang/Throwable;handleHttpRequestX(Lio/netty/channel/ChannelHandlerContext;Lio/netty/handler/codec/http/FullHttpRequest;)Vreq-Lio/netty/handler/codec/http/FullHttpRequest;    wsFactoryILio/netty/handler/codec/http/websocketx/WebSocketServerHandshakerFactory;ÆhandleWebSocketRequestb(Lio/netty/channel/ChannelHandlerContext;Lio/netty/handler/codec/http/websocketx/WebSocketFrame;)V7Lio/netty/handler/codec/http/websocketx/WebSocketFrame;
requestmsg
jsonObject!Lcom/alibaba/fastjson/JSONObject;tws;Lio/netty/handler/codec/http/websocketx/TextWebSocketFrame;sendHttpResponse†(Lio/netty/channel/ChannelHandlerContext;Lio/netty/handler/codec/http/FullHttpRequest;Lio/netty/handler/codec/http/FullHttpResponse;)VbufLio/netty/buffer/ByteBuf;res.Lio/netty/handler/codec/http/FullHttpResponse;f Lio/netty/channel/ChannelFuture;  channelActivechannelInactive channelRead channelRead0    SignatureBLio/netty/channel/SimpleChannelInboundHandler<Ljava/lang/Object;>;
SourceFileWebSocketHandler.java fg 'io/netty/handler/timeout/IdleStateEvent      com/sinata/zuul/util/echo/MethodOKjava/util/HashMap    ! "#$ %& '( )* +,- .     websocket /0Upgrade1 233io/netty/handler/codec/http/DefaultFullHttpResponse4 567 89 f: ŽGio/netty/handler/codec/http/websocketx/WebSocketServerHandshakerFactory-com/sinata/zuul/util/applets/WebSocketHandlerws://localhost:9090/websocket f; <= ab >?@ AB:io/netty/handler/codec/http/websocketx/CloseWebSocketFrame CD )E9io/netty/handler/codec/http/websocketx/PingWebSocketFrame9io/netty/handler/codec/http/websocketx/PongWebSocketFrame FGH CG fI J(9io/netty/handler/codec/http/websocketx/TextWebSocketFrame'java/lang/UnsupportedOperationException6当前只支持文本消息,不支持二进制消息 fK L java/lang/Exception<尚未握手成功,无法向客户端发送WebSocket消息 MNcom/alibaba/fastjson/JSONObjectcodeO PQ RSmethodSUCCESSdata TN5com/sinata/zuul/util/applets/NettyWebSocketController UVW XYZ '[\ ]^ â_ `Na bc %d ef g h ij kl mn op客户端与服务器端开启q rK st sn!客户端与服务器链接关闭+io/netty/handler/codec/http/FullHttpRequest €5io/netty/handler/codec/http/websocketx/WebSocketFrame †‡,io/netty/channel/SimpleChannelInboundHandlerio/netty/channel/ChannelFuture&io/netty/channel/ChannelHandlerContextflush*()Lio/netty/channel/ChannelHandlerContext;state&()Lio/netty/handler/timeout/IdleState;"io/netty/handler/timeout/IdleState READER_IDLE$Lio/netty/handler/timeout/IdleState;equals(Ljava/lang/Object;)Z WRITER_IDLEALL_IDLE"com/sinata/zuul/util/echo/NettyMsgsetMsg5(Ljava/lang/String;Ljava/util/Map;)Ljava/lang/String;channel()Lio/netty/channel/Channel;io/netty/channel/ChannelisActive()Zjava/lang/StringgetBytes()[Bio/netty/buffer/Unpooled copiedBuffer([B)Lio/netty/buffer/ByteBuf; writeAndFlush4(Ljava/lang/Object;)Lio/netty/channel/ChannelFuture;close"()Lio/netty/channel/ChannelFuture;getDecoderResult(()Lio/netty/handler/codec/DecoderResult;$io/netty/handler/codec/DecoderResult    isSuccessheaders+()Lio/netty/handler/codec/http/HttpHeaders;'io/netty/handler/codec/http/HttpHeadersget&(Ljava/lang/String;)Ljava/lang/String;'io/netty/handler/codec/http/HttpVersionHTTP_1_1)Lio/netty/handler/codec/http/HttpVersion;.io/netty/handler/codec/http/HttpResponseStatus BAD_REQUEST0Lio/netty/handler/codec/http/HttpResponseStatus;\(Lio/netty/handler/codec/http/HttpVersion;Lio/netty/handler/codec/http/HttpResponseStatus;)V((Ljava/lang/String;Ljava/lang/String;Z)V newHandshakerm(Lio/netty/handler/codec/http/HttpRequest;)Lio/netty/handler/codec/http/websocketx/WebSocketServerHandshaker;'sendUnsupportedWebSocketVersionResponse(Lio/netty/channel/Channel;)V@io/netty/handler/codec/http/websocketx/WebSocketServerHandshaker    handshakei(Lio/netty/channel/Channel;Lio/netty/handler/codec/http/FullHttpRequest;)Lio/netty/channel/ChannelFuture;retain9()Lio/netty/handler/codec/http/websocketx/WebSocketFrame;x(Lio/netty/channel/Channel;Lio/netty/handler/codec/http/websocketx/CloseWebSocketFrame;)Lio/netty/channel/ChannelFuture;content()Lio/netty/buffer/ByteBuf;io/netty/buffer/ByteBuf(Lio/netty/buffer/ByteBuf;)Vwrite(Ljava/lang/String;)V    isRemovedtext()Ljava/lang/String;java/lang/IntegervalueOf(I)Ljava/lang/Integer;put8(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object; toJSONStringJudgeOperation=(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/String;)V#com/sinata/zuul/util/applets/Globalgroup%Lio/netty/channel/group/ChannelGroup;#io/netty/channel/group/ChannelGroup?(Ljava/lang/Object;)Lio/netty/channel/group/ChannelGroupFuture;,io/netty/handler/codec/http/FullHttpResponse    getStatus2()Lio/netty/handler/codec/http/HttpResponseStatus;()ItoStringio/netty/util/CharsetUtilUTF_8Ljava/nio/charset/Charset;M(Ljava/lang/CharSequence;Ljava/nio/charset/Charset;)Lio/netty/buffer/ByteBuf;
writeBytes4(Lio/netty/buffer/ByteBuf;)Lio/netty/buffer/ByteBuf;release&io/netty/channel/ChannelFutureListenerCLOSE(Lio/netty/channel/ChannelFutureListener; addListenerR(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/channel/ChannelFuture;addjava/lang/SystemerrLjava/io/PrintStream;java/io/PrintStreamprintlnremove)com/sinata/zuul/util/echo/NettyChannelMap!!`abcde" fgh/*·±ij klmnh@+¹W±i
+,jklopq6rshíi,Á™d,ÀN-¶²¶™§O-¶²¶™§?-¶²¶™2
» Y· ¸ :+Æ +¹¹™+¶¸¹W±i&    12 37,;9=G>Y?hDj4G!td \uvikliopiwxy üzú;q6{|hJ+¹W±i
HIj klop}~q6€häk,¹¶™,¹¶¶š*+,»Y²²··±» Y"·#N*-,¶$µ%*´%Ç+¹¸&§*´%+¹,¶'W±i&    MN2O3R?THUOW[Zj\j*kklkopk‚?,ƒ„y ü'…†‡h•à,Á(™*´%+¹,¶)À(¶*W±,Á+™+¹»,Y,¶-¶.·/¹0W±,Á1š »2Y3·4¿+Æ*´%Æ +¹5™ »6Y7·8¿,À1¶9N»:Y·;:<ȸ=¶>W?
¶>W@A¶>WB»:Y·;¶>W»1Y¶C·D:»EY·F+-¶G²H»1Y¶9·D¹IW±iR_abd$e>f?hFiPkdlnnvstu—v¡w°x¾{Ê~ßj>àklàopàˆvj‰daŠ‹¾"Œy!    q6Žhâ[-¹J¶Kȟ&-¹J¶L²M¸N:-¹O¶PW¶QW+¹-¹R:-¹J¶Kȟ²S¹TW±i"ƒ„ …,†2‰@‹OŒZŽj> ‘[kl[op[‚[’“@”•y    2ü'–—nhT²H+¹¹UW²VW¶X±i“”•jklopq6˜nh\²H+¹¹YW+¸Z²V[¶X±i™š›œjklopq6™sh|$,Á\™*+,À\·]§,Á^™ *+,À^·_±i¡£¤¦#¨j $kl$op$txyq6šsh|$,Á\™*+,À\·]§,Á^™ *+,À^·_±i¬®¯±#³j $kl$op$txyq6›œž