Class WebSocketClientHandshaker00

java.lang.Object

io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker

io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker00

public class WebSocketClientHandshaker00
extends WebSocketClientHandshaker

Performs client side opening and closing handshakes for web socket specification version draft-ietf-hybi-thewebsocketprotocol- 00

A very large portion of this code was taken from the Netty 3.2 HTTP example.

Field Summary

Fields inherited from class WebSocketClientHandshaker

customHeaders, DEFAULT_FORCE_CLOSE_TIMEOUT_MILLIS, generateOriginHeader

Modifier and Type	Field	Description
protected final HttpHeaders	customHeaders
protected static final int	DEFAULT_FORCE_CLOSE_TIMEOUT_MILLIS
protected final boolean	generateOriginHeader

Constructor Summary

Constructors

Constructor	Description
WebSocketClientHandshaker00(URI webSocketURL, WebSocketVersion version, String subprotocol, HttpHeaders customHeaders, int maxFramePayloadLength)	Creates a new instance with the specified destination WebSocket location and version to initiate.
WebSocketClientHandshaker00(URI webSocketURL, WebSocketVersion version, String subprotocol, HttpHeaders customHeaders, int maxFramePayloadLength, long forceCloseTimeoutMillis)	Creates a new instance with the specified destination WebSocket location and version to initiate.

Method Summary

Modifier and Type	Method	Description
protected FullHttpRequest	newHandshakeRequest()	Sends the opening request to the server:
protected WebSocketFrameDecoder	newWebsocketDecoder()	Returns the decoder to use after handshake is complete.
protected WebSocketFrameEncoder	newWebSocketEncoder()	Returns the encoder to use after the handshake is complete.
WebSocketClientHandshaker00	setForceCloseTimeoutMillis(long forceCloseTimeoutMillis)	Sets timeout to close the connection if it was not closed by the server.
protected void	verify(FullHttpResponse response)	Process server response:

Methods inherited from class WebSocketClientHandshaker

actualSubprotocol, close, close, close, close, expectedSubprotocol, finishHandshake, forceCloseTimeoutMillis, handshake, handshake, isForceCloseComplete, isHandshakeComplete, maxFramePayloadLength, processHandshake, processHandshake, upgradeUrl, uri, version

Modifier and Type	Method	Description
String	actualSubprotocol()	Returns the subprotocol response sent by the server.
ChannelFuture	close(ChannelHandlerContext ctx, CloseWebSocketFrame frame)	Performs the closing handshake
ChannelFuture	close(ChannelHandlerContext ctx, CloseWebSocketFrame frame, ChannelPromise promise)	Performs the closing handshake
ChannelFuture	close(Channel channel, CloseWebSocketFrame frame)	Performs the closing handshake.
ChannelFuture	close(Channel channel, CloseWebSocketFrame frame, ChannelPromise promise)	Performs the closing handshake When called from within a ChannelHandler you most likely want to use WebSocketClientHandshaker.close(ChannelHandlerContext, CloseWebSocketFrame, ChannelPromise).
String	expectedSubprotocol()	Returns the CSV of requested subprotocol(s) sent to the server as specified in the constructor
final void	finishHandshake(Channel channel, FullHttpResponse response)	Validates and finishes the opening handshake initiated by WebSocketClientHandshaker.handshake(Channel)}.
long	forceCloseTimeoutMillis()
ChannelFuture	handshake(Channel channel)	Begins the opening handshake
final ChannelFuture	handshake(Channel channel, ChannelPromise promise)	Begins the opening handshake
protected boolean	isForceCloseComplete()	Flag to indicate if the closing handshake was initiated because of timeout.
boolean	isHandshakeComplete()	Flag to indicate if the opening handshake is complete
int	maxFramePayloadLength()	Returns the max length for any frame's payload
final ChannelFuture	processHandshake(Channel channel, HttpResponse response)	Process the opening handshake initiated by WebSocketClientHandshaker.handshake(Channel)}.
final ChannelFuture	processHandshake(Channel channel, HttpResponse response, ChannelPromise promise)	Process the opening handshake initiated by WebSocketClientHandshaker.handshake(Channel)}.
protected String	upgradeUrl(URI wsURL)	Return the constructed raw path for the give URI.
URI	uri()	Returns the URI to the web socket. e.g.
WebSocketVersion	version()	Version of the web socket specification that is being used

Methods inherited from class Object

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

Constructor Details

WebSocketClientHandshaker00

public WebSocketClientHandshaker00(URI webSocketURL,
 WebSocketVersion version,
 String subprotocol,
 HttpHeaders customHeaders,
 int maxFramePayloadLength)

Creates a new instance with the specified destination WebSocket location and version to initiate.

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

WebSocketClientHandshaker00

public WebSocketClientHandshaker00(URI webSocketURL,
 WebSocketVersion version,
 String subprotocol,
 HttpHeaders customHeaders,
 int maxFramePayloadLength,
 long forceCloseTimeoutMillis)

Creates a new instance with the specified destination WebSocket location and version to initiate.

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

forceCloseTimeoutMillis - Close the connection if it was not closed by the server after timeout specified

Method Details

newHandshakeRequest

protected FullHttpRequest newHandshakeRequest()

Sends the opening request to the server:

GET /demo HTTP/1.1
Upgrade: WebSocket
Connection: Upgrade
Host: example.com
Origin: http://example.com
Sec-WebSocket-Key1: 4 @1  46546xW%0l 1 5
Sec-WebSocket-Key2: 12998 5 Y3 1  .P00

^n:ds[4U

Specified by:

newHandshakeRequest in class WebSocketClientHandshaker

verify

protected void verify(FullHttpResponse response)

Process server response:

HTTP/1.1 101 WebSocket Protocol Handshake
Upgrade: WebSocket
Connection: Upgrade
Sec-WebSocket-Origin: http://example.com
Sec-WebSocket-Location: ws://example.com/demo
Sec-WebSocket-Protocol: sample

8jKS'y:G*Co,Wxa-

Specified by:

verify in class WebSocketClientHandshaker

Parameters:

response - HTTP response returned from the server for the request sent by beginOpeningHandshake00().

Throws:

WebSocketHandshakeException

newWebsocketDecoder

protected WebSocketFrameDecoder newWebsocketDecoder()

Description copied from class: WebSocketClientHandshaker

Returns the decoder to use after handshake is complete.

Specified by:

newWebsocketDecoder in class WebSocketClientHandshaker

newWebSocketEncoder

protected WebSocketFrameEncoder newWebSocketEncoder()

Description copied from class: WebSocketClientHandshaker

Returns the encoder to use after the handshake is complete.

Specified by:

newWebSocketEncoder in class WebSocketClientHandshaker

setForceCloseTimeoutMillis

public WebSocketClientHandshaker00 setForceCloseTimeoutMillis(long forceCloseTimeoutMillis)

Description copied from class: WebSocketClientHandshaker

Sets timeout to close the connection if it was not closed by the server.

Overrides:

setForceCloseTimeoutMillis in class WebSocketClientHandshaker

Parameters:

forceCloseTimeoutMillis - Close the connection if it was not closed by the server after timeout specified