netty-all-4.1.29.Final.jar
登录
|
io.netty:netty-all:4.1.29.Final
io
netty
internal
example
buffer
bootstrap
util
handler
traffic
timeout
stream
flush
flow
proxy
ipfilter
ssl
codec
Headers.java
UnsupportedMessageTypeException.java
dns
ValueConverter.java
ReplayingDecoderByteBuf.java
package-info.java
LengthFieldBasedFrameDecoder.java
LineBasedFrameDecoder.java
FixedLengthFrameDecoder.java
LengthFieldPrepender.java
haproxy
DefaultHeadersImpl.java
bytes
EmptyHeaders.java
MessageToMessageEncoder.java
http
HttpServerCodec.java
HttpHeaders.java
websocketx
WebSocketServerHandshaker08.java
WebSocketClientProtocolHandler.java
WebSocket07FrameDecoder.java
Utf8FrameValidator.java
WebSocketFrameEncoder.java
CloseWebSocketFrame.java
WebSocketClientProtocolHandshakeHandler.java
package-info.java
WebSocket13FrameEncoder.java
WebSocket08FrameEncoder.java
WebSocketProtocolHandler.java
ContinuationWebSocketFrame.java
Utf8Validator.java
WebSocket00FrameDecoder.java
BinaryWebSocketFrame.java
WebSocketFrameDecoder.java
extensions
WebSocketClientHandshaker13.java
WebSocket08FrameDecoder.java
WebSocketServerProtocolHandshakeHandler.java
WebSocketClientHandshaker.java
WebSocketClientHandshaker00.java
WebSocketServerHandshaker.java
WebSocketServerHandshaker07.java
WebSocketServerHandshakerFactory.java
WebSocketServerHandshaker00.java
WebSocketClientHandshakerFactory.java
WebSocketClientHandshaker07.java
WebSocket07FrameEncoder.java
WebSocketServerHandshaker13.java
WebSocketServerProtocolHandler.java
WebSocket13FrameDecoder.java
WebSocketClientHandshaker08.java
WebSocketHandshakeException.java
WebSocketVersion.java
TextWebSocketFrame.java
WebSocket00FrameEncoder.java
PongWebSocketFrame.java
WebSocketScheme.java
WebSocketFrame.java
WebSocketFrameAggregator.java
PingWebSocketFrame.java
WebSocketUtil.java
WebSocketChunkedInput.java
ServerCookieEncoder.java
HttpContentEncoder.java
package-info.java
DefaultHttpMessage.java
HttpObjectEncoder.java
HttpContentDecompressor.java
DefaultHttpObject.java
HttpObjectAggregator.java
DefaultHttpHeaders.java
HttpServerExpectContinueHandler.java
HttpObject.java
CookieDecoder.java
HttpConstants.java
HttpStatusClass.java
ComposedLastHttpContent.java
HttpContentCompressor.java
DefaultFullHttpRequest.java
HttpClientCodec.java
cors
EmptyHttpHeaders.java
HttpMessage.java
HttpHeaderNames.java
HttpVersion.java
QueryStringDecoder.java
DefaultFullHttpResponse.java
HttpContent.java
HttpResponseStatus.java
CookieUtil.java
HttpContentDecoder.java
HttpServerKeepAliveHandler.java
DefaultLastHttpContent.java
multipart
HttpScheme.java
HttpObjectDecoder.java
Cookie.java
DefaultHttpContent.java
LastHttpContent.java
FullHttpMessage.java
HttpMethod.java
HttpResponseEncoder.java
CombinedHttpHeaders.java
DefaultHttpResponse.java
DefaultHttpRequest.java
QueryStringEncoder.java
DefaultCookie.java
FullHttpRequest.java
HttpChunkedInput.java
HttpMessageUtil.java
HttpResponseDecoder.java
HttpResponse.java
HttpExpectationFailedEvent.java
HttpRequestDecoder.java
cookie
HttpClientUpgradeHandler.java
ReadOnlyHttpHeaders.java
ClientCookieEncoder.java
HttpRequestEncoder.java
FullHttpResponse.java
HttpServerUpgradeHandler.java
HttpHeaderDateFormat.java
HttpRequest.java
HttpUtil.java
HttpHeadersEncoder.java
HttpHeaderValues.java
DecoderResult.java
redis
base64
ReplayingDecoder.java
stomp
ByteToMessageCodec.java
Delimiters.java
PrematureChannelClosureException.java
CorruptedFrameException.java
CodecOutputList.java
DefaultHeaders.java
ProtocolDetectionState.java
CodecException.java
DecoderResultProvider.java
string
AsciiHeadersEncoder.java
MessageAggregator.java
MessageAggregationException.java
DatagramPacketEncoder.java
DelimiterBasedFrameDecoder.java
memcache
mqtt
smtp
marshalling
UnsupportedValueConverter.java
MessageToByteEncoder.java
MessageToMessageDecoder.java
EncoderException.java
rtsp
HeadersUtils.java
DatagramPacketDecoder.java
xml
ProtocolDetectionResult.java
spdy
http2
compression
DecoderException.java
MessageToMessageCodec.java
serialization
DateFormatter.java
socks
ByteToMessageDecoder.java
sctp
socksx
protobuf
json
TooLongFrameException.java
CharSequenceValueConverter.java
logging
channel
resolver
META-INF
WebSocketClientProtocolHandshakeHandler.java
清空
类结构
/* * Copyright 2013 The Netty Project * * The Netty Project licenses this file to you under the Apache License, * version 2.0 (the "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at: * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the * License for the specific language governing permissions and limitations * under the License. */ package io.netty.handler.codec.http.websocketx; import io.netty.channel.
ChannelFuture
; import io.netty.channel.
ChannelFutureListener
; import io.netty.channel.
ChannelHandlerContext
; import io.netty.channel.
ChannelInboundHandlerAdapter
; import io.netty.handler.codec.http.
FullHttpResponse
; class
WebSocketClientProtocolHandshakeHandler
extends
ChannelInboundHandlerAdapter
{ private final
WebSocketClientHandshaker
handshaker
;
WebSocketClientProtocolHandshakeHandler
(
WebSocketClientHandshaker
handshaker
) { this.
handshaker
=
handshaker
; } @
Override
public void
channelActive
(final
ChannelHandlerContext
ctx
) throws
Exception
{ super.channelActive(
ctx
);
handshaker
.
handshake
(
ctx
.
channel
()).
addListener
(new
ChannelFutureListener
() { @
Override
public void
operationComplete
(
ChannelFuture
future
) throws
Exception
{ if (!
future
.
isSuccess
()) {
ctx
.
fireExceptionCaught
(
future
.
cause
()); } else {
ctx
.
fireUserEventTriggered
(
WebSocketClientProtocolHandler
.
ClientHandshakeStateEvent
.
HANDSHAKE_ISSUED
); } } }); } @
Override
public void
channelRead
(
ChannelHandlerContext
ctx
,
Object
msg
) throws
Exception
{ if (!(
msg
instanceof
FullHttpResponse
)) {
ctx
.
fireChannelRead
(
msg
); return; }
FullHttpResponse
response
= (
FullHttpResponse
)
msg
; try { if (!
handshaker
.
isHandshakeComplete
()) {
handshaker
.
finishHandshake
(
ctx
.
channel
(),
response
);
ctx
.
fireUserEventTriggered
(
WebSocketClientProtocolHandler
.
ClientHandshakeStateEvent
.
HANDSHAKE_COMPLETE
);
ctx
.
pipeline
().
remove
(this); return; } throw new
IllegalStateException
("WebSocketClientHandshaker should have been non finished yet"); } finally {
response
.
release
(); } } }
查找资源
Jre/Lib
输入类名或文件名
类结构窗口