org.springframework.web.socket.sockjs.client

Class AbstractClientSockJsSession

java.lang.Object

org.springframework.web.socket.sockjs.client.AbstractClientSockJsSession

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, WebSocketSession

Direct Known Subclasses:

WebSocketClientSockJsSession, XhrClientSockJsSession

public abstract class AbstractClientSockJsSession
extends java.lang.Object
implements WebSocketSession

Base class for SockJS client implementations of WebSocketSession. Provides processing of incoming SockJS message frames and delegates lifecycle events and messages to the (application) WebSocketHandler. Sub-classes implement actual send as well as disconnect logic.

Since:

4.1

Author:

Rossen Stoyanchev, Juergen Hoeller

Field Summary

Fields

Modifier and Type	Field and Description
protected Log	logger

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractClientSockJsSession(TransportRequest request, WebSocketHandler handler, SettableListenableFuture<WebSocketSession> connectFuture)

Method Summary

Modifier and Type	Method and Description
void	afterTransportClosed(CloseStatus closeStatus)
void	close() Close the WebSocket connection with status 1000, i.e.
void	close(CloseStatus status) Close the WebSocket connection with the given close status.
protected void	closeInternal(CloseStatus status)
protected abstract void	disconnect(CloseStatus status)
java.util.Map<java.lang.String,java.lang.Object>	getAttributes() Return the map with attributes associated with the WebSocket session.
HttpHeaders	getHandshakeHeaders() Return the headers used in the handshake request (never null).
java.lang.String	getId() Return a unique session identifier.
SockJsMessageCodec	getMessageCodec()
java.security.Principal	getPrincipal() Return a Principal instance containing the name of the authenticated user.
java.net.URI	getUri() Return the URI used to open the WebSocket connection.
WebSocketHandler	getWebSocketHandler()
void	handleFrame(java.lang.String payload)
void	handleTransportError(java.lang.Throwable error)
boolean	isDisconnected()
boolean	isOpen() Return whether the connection is still open.
protected abstract void	sendInternal(TextMessage textMessage)
void	sendMessage(WebSocketMessage<?> message) Send a WebSocket message: either TextMessage or BinaryMessage.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.web.socket.WebSocketSession

getAcceptedProtocol, getBinaryMessageSizeLimit, getExtensions, getLocalAddress, getRemoteAddress, getTextMessageSizeLimit, setBinaryMessageSizeLimit, setTextMessageSizeLimit

Field Detail

logger

protected final Log logger

Constructor Detail

AbstractClientSockJsSession

protected AbstractClientSockJsSession(TransportRequest request,
                                      WebSocketHandler handler,
                                      SettableListenableFuture<WebSocketSession> connectFuture)

Method Detail

getId

public java.lang.String getId()

Description copied from interface: WebSocketSession

Return a unique session identifier.

Specified by:

getId in interface WebSocketSession

getUri

public java.net.URI getUri()

Description copied from interface: WebSocketSession

Return the URI used to open the WebSocket connection.

Specified by:

getUri in interface WebSocketSession

getHandshakeHeaders

public HttpHeaders getHandshakeHeaders()

Description copied from interface: WebSocketSession

Return the headers used in the handshake request (never null).

Specified by:

getHandshakeHeaders in interface WebSocketSession

getAttributes

public java.util.Map<java.lang.String,java.lang.Object> getAttributes()

Description copied from interface: WebSocketSession

Return the map with attributes associated with the WebSocket session.

On the server side the map can be populated initially through a HandshakeInterceptor. On the client side the map can be populated via WebSocketClient handshake methods.

Specified by:

getAttributes in interface WebSocketSession

Returns:

a Map with the session attributes (never null)

getPrincipal

public java.security.Principal getPrincipal()

Description copied from interface: WebSocketSession

Return a Principal instance containing the name of the authenticated user.

If the user has not been authenticated, the method returns null.

Specified by:

getPrincipal in interface WebSocketSession

getMessageCodec

public SockJsMessageCodec getMessageCodec()

getWebSocketHandler

public WebSocketHandler getWebSocketHandler()

isOpen

public boolean isOpen()

Description copied from interface: WebSocketSession

Return whether the connection is still open.

Specified by:

isOpen in interface WebSocketSession

isDisconnected

public boolean isDisconnected()

sendMessage

public final void sendMessage(WebSocketMessage<?> message)
                       throws java.io.IOException

Description copied from interface: WebSocketSession

Send a WebSocket message: either TextMessage or BinaryMessage.

Note: The underlying standard WebSocket session (JSR-356) does not allow concurrent sending. Therefore sending must be synchronized. To ensure that, one option is to wrap the WebSocketSession with the ConcurrentWebSocketSessionDecorator.

Specified by:

sendMessage in interface WebSocketSession

Throws:

java.io.IOException

See Also:

ConcurrentWebSocketSessionDecorator

sendInternal

protected abstract void sendInternal(TextMessage textMessage)
                              throws java.io.IOException

Throws:

java.io.IOException

close

public final void close()
                 throws java.io.IOException

Description copied from interface: WebSocketSession

Close the WebSocket connection with status 1000, i.e. equivalent to:

 session.close(CloseStatus.NORMAL);
 

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface WebSocketSession

Throws:

java.io.IOException

close

public final void close(CloseStatus status)
                 throws java.io.IOException

Description copied from interface: WebSocketSession

Close the WebSocket connection with the given close status.

Specified by:

close in interface WebSocketSession

Throws:

java.io.IOException

closeInternal

protected void closeInternal(CloseStatus status)
                      throws java.io.IOException

Throws:

java.io.IOException

disconnect

protected abstract void disconnect(CloseStatus status)
                            throws java.io.IOException

Throws:

java.io.IOException

handleFrame

public void handleFrame(java.lang.String payload)

handleTransportError

public void handleTransportError(java.lang.Throwable error)

afterTransportClosed

public void afterTransportClosed(@Nullable
                                 CloseStatus closeStatus)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object