io.netty.handler.codec.http.websocketx

Class WebSocketClientProtocolHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.handler.codec.MessageToMessageDecoder<WebSocketFrame>

io.netty.handler.codec.http.websocketx.WebSocketProtocolHandler

io.netty.handler.codec.http.websocketx.WebSocketClientProtocolHandler

All Implemented Interfaces:

ChannelHandler, ChannelInboundHandler

public class WebSocketClientProtocolHandler
extends WebSocketProtocolHandler

This handler does all the heavy lifting for you to run a websocket client. It takes care of websocket handshaking as well as processing of Ping, Pong frames. Text and Binary data frames are passed to the next handler in the pipeline (implemented by you) for processing. Also the close frame is passed to the next handler as you may want inspect it before close the connection if the handleCloseFrames is false, default is true. This implementation will establish the websocket connection once the connection to the remote server was complete. To know once a handshake was done you can intercept the ChannelInboundHandler.userEventTriggered(ChannelHandlerContext, Object) and check if the event was of type WebSocketClientProtocolHandler.ClientHandshakeStateEvent.HANDSHAKE_ISSUED or WebSocketClientProtocolHandler.ClientHandshakeStateEvent.HANDSHAKE_COMPLETE.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WebSocketClientProtocolHandler.ClientHandshakeStateEvent Events that are fired to notify about handshake status

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	handleCloseFrames
private WebSocketClientHandshaker	handshaker

Constructor Summary

Constructors

Constructor and Description
WebSocketClientProtocolHandler(java.net.URI webSocketURL, WebSocketVersion version, java.lang.String subprotocol, boolean allowExtensions, HttpHeaders customHeaders, int maxFramePayloadLength) Base constructor
WebSocketClientProtocolHandler(java.net.URI webSocketURL, WebSocketVersion version, java.lang.String subprotocol, boolean allowExtensions, HttpHeaders customHeaders, int maxFramePayloadLength, boolean handleCloseFrames) Base constructor
WebSocketClientProtocolHandler(WebSocketClientHandshaker handshaker) Base constructor
WebSocketClientProtocolHandler(WebSocketClientHandshaker handshaker, boolean handleCloseFrames) Base constructor

Method Summary

Modifier and Type	Method and Description
protected void	decode(ChannelHandlerContext ctx, WebSocketFrame frame, java.util.List<java.lang.Object> out) Decode from one message to an other.
void	handlerAdded(ChannelHandlerContext ctx) Do nothing by default, sub-classes may override this method.
WebSocketClientHandshaker	handshaker() Returns the used handshaker

Methods inherited from class io.netty.handler.codec.http.websocketx.WebSocketProtocolHandler

exceptionCaught

Methods inherited from class io.netty.handler.codec.MessageToMessageDecoder

acceptInboundMessage, channelRead

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

handlerRemoved, isSharable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.netty.channel.ChannelHandler

handlerRemoved

Field Detail

handshaker

private final WebSocketClientHandshaker handshaker

handleCloseFrames

private final boolean handleCloseFrames

Constructor Detail

WebSocketClientProtocolHandler

public WebSocketClientProtocolHandler(java.net.URI webSocketURL,
                                      WebSocketVersion version,
                                      java.lang.String subprotocol,
                                      boolean allowExtensions,
                                      HttpHeaders customHeaders,
                                      int maxFramePayloadLength,
                                      boolean handleCloseFrames)

Base constructor

Parameters:

webSocketURL - URL for web socket communications. e.g "ws://myhost.com/mypath". Subsequent web socket frames will be sent to this URL.

version - Version of web socket specification to use to connect to the server

subprotocol - Sub protocol request sent to the server.

customHeaders - Map of custom headers to add to the client request

maxFramePayloadLength - Maximum length of a frame's payload

handleCloseFrames - true if close frames should not be forwarded and just close the channel

WebSocketClientProtocolHandler

public WebSocketClientProtocolHandler(java.net.URI webSocketURL,
                                      WebSocketVersion version,
                                      java.lang.String subprotocol,
                                      boolean allowExtensions,
                                      HttpHeaders customHeaders,
                                      int maxFramePayloadLength)

Base constructor

Parameters:

webSocketURL - URL for web socket communications. e.g "ws://myhost.com/mypath". Subsequent web socket frames will be sent to this URL.

version - Version of web socket specification to use to connect to the server

subprotocol - Sub protocol request sent to the server.

customHeaders - Map of custom headers to add to the client request

maxFramePayloadLength - Maximum length of a frame's payload

WebSocketClientProtocolHandler

public WebSocketClientProtocolHandler(WebSocketClientHandshaker handshaker,
                                      boolean handleCloseFrames)

Base constructor

Parameters:

handshaker - The WebSocketClientHandshaker which will be used to issue the handshake once the connection was established to the remote peer.

handleCloseFrames - true if close frames should not be forwarded and just close the channel

WebSocketClientProtocolHandler

public WebSocketClientProtocolHandler(WebSocketClientHandshaker handshaker)

Base constructor

Parameters:

handshaker - The WebSocketClientHandshaker which will be used to issue the handshake once the connection was established to the remote peer.

Method Detail

handshaker

public WebSocketClientHandshaker handshaker()

Returns the used handshaker

decode

protected void decode(ChannelHandlerContext ctx,
                      WebSocketFrame frame,
                      java.util.List<java.lang.Object> out)
               throws java.lang.Exception

Description copied from class: MessageToMessageDecoder

Decode from one message to an other. This method will be called for each written message that can be handled by this encoder.

Overrides:

decode in class WebSocketProtocolHandler

Parameters:

ctx - the ChannelHandlerContext which this MessageToMessageDecoder belongs to

frame - the message to decode to an other one

out - the List to which decoded messages should be added

Throws:

java.lang.Exception - is thrown if an error accour

handlerAdded

public void handlerAdded(ChannelHandlerContext ctx)

Description copied from class: ChannelHandlerAdapter

Do nothing by default, sub-classes may override this method.

Specified by:

handlerAdded in interface ChannelHandler

Overrides:

handlerAdded in class ChannelHandlerAdapter