Class WebSocketSession

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.ContainerLifeCycle

org.eclipse.jetty.websocket.common.WebSocketSession

All Implemented Interfaces:

Closeable, AutoCloseable, org.eclipse.jetty.io.Connection.Listener, org.eclipse.jetty.util.component.Container, org.eclipse.jetty.util.component.Destroyable, org.eclipse.jetty.util.component.Dumpable, org.eclipse.jetty.util.component.Dumpable.DumpableContainer, org.eclipse.jetty.util.component.LifeCycle, IncomingFrames, OutgoingFrames, Session, RemoteEndpointFactory, WebSocketSessionScope

Direct Known Subclasses:

JsrSession

@ManagedObject("A Jetty WebSocket Session")
public class WebSocketSession
extends org.eclipse.jetty.util.component.ContainerLifeCycle
implements Session, RemoteEndpointFactory, WebSocketSessionScope, IncomingFrames, OutgoingFrames, org.eclipse.jetty.io.Connection.Listener

Nested Class Summary

Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.AbstractLifeCycle.AbstractLifeCycleListener

Nested classes/interfaces inherited from interface org.eclipse.jetty.io.Connection.Listener

org.eclipse.jetty.io.Connection.Listener.Adapter

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Container

org.eclipse.jetty.util.component.Container.InheritedListener, org.eclipse.jetty.util.component.Container.Listener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Dumpable

org.eclipse.jetty.util.component.Dumpable.DumpableContainer

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.LifeCycle

org.eclipse.jetty.util.component.LifeCycle.Listener

Field Summary

Fields

Modifier and Type	Field	Description
private final ClassLoader	classLoader
private final LogicalConnection	connection
private final WebSocketContainerScope	containerScope
private static final RemoteEndpointFactory	defaultRemoteEndpointFactory
private final Executor	executor
private ExtensionFactory	extensionFactory
private final IncomingFrames	incomingHandler
private static final org.eclipse.jetty.util.log.Logger	LOG
private final AtomicBoolean	onCloseCalled
private CompletableFuture<Session>	openFuture
private OutgoingFrames	outgoingHandler
private final Map<String,String[]>	parameterMap
private final WebSocketPolicy	policy
private String	protocolVersion
private RemoteEndpoint	remote
private final RemoteEndpointFactory	remoteEndpointFactory
private final URI	requestURI
private UpgradeRequest	upgradeRequest
private UpgradeResponse	upgradeResponse
private final EventDriver	websocket

Fields inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING

Fields inherited from interface org.eclipse.jetty.util.component.Dumpable

KEY

Constructor Summary

Constructors

Constructor	Description
WebSocketSession(WebSocketContainerScope containerScope, URI requestURI, EventDriver websocket, LogicalConnection connection)

Method Summary

Modifier and Type	Method	Description
void	callApplicationOnClose(CloseInfo closeInfo)
void	callApplicationOnError(Throwable cause)
void	close()	Request a close of the current conversation with a normal status code and no reason phrase.
void	close(int statusCode, String reason)	Send a websocket Close frame, with status code.
void	close(Throwable cause)	Close the active session based on the throwable
void	close(CloseStatus closeStatus)	Request Close the current conversation, giving a reason for the closure.
private void	close(CloseInfo closeInfo, org.eclipse.jetty.util.Callback callback)	Close Primary Entry Point.
void	disconnect()	Harsh disconnect
void	dispatch(Runnable runnable)
protected void	doStart()
protected void	doStop()
String	dumpSelf()
BatchMode	getBatchMode()
org.eclipse.jetty.io.ByteBufferPool	getBufferPool()
ClassLoader	getClassLoader()
LogicalConnection	getConnection()
WebSocketContainerScope	getContainerScope()	The parent WebSocketContainerScope for this session scope.
ExtensionFactory	getExtensionFactory()
long	getIdleTimeout()	The idle timeout in milliseconds
IncomingFrames	getIncomingHandler()
InetSocketAddress	getLocalAddress()	Get the address of the local side.
OutgoingFrames	getOutgoingHandler()
WebSocketPolicy	getPolicy()	Access the (now read-only) WebSocketPolicy in use for this connection.
String	getProtocolVersion()	Returns the version of the websocket protocol currently being used.
RemoteEndpoint	getRemote()	Return a reference to the RemoteEndpoint object representing the other end of this conversation.
InetSocketAddress	getRemoteAddress()	Get the address of the remote side.
URI	getRequestURI()
UpgradeRequest	getUpgradeRequest()	Get the UpgradeRequest used to create this session
UpgradeResponse	getUpgradeResponse()	Get the UpgradeResponse used to create this session
WebSocketSession	getWebSocketSession()	Active WebSocketSession associated with this scope.
void	incomingFrame(Frame frame)	Incoming Raw Frames from Parser
boolean	isOpen()	Return true if and only if the underlying socket is open.
boolean	isSecure()	Return true if and only if the underlying socket is using a secure transport.
WebSocketRemoteEndpoint	newRemoteEndpoint(LogicalConnection connection, OutgoingFrames outgoingFrames, BatchMode batchMode)
private void	notifySessionListeners(WebSocketContainerScope scope, Consumer<WebSocketSessionListener> consumer)
void	onClosed(org.eclipse.jetty.io.Connection connection)	Jetty Connection onSessionClosed event
void	onOpened(org.eclipse.jetty.io.Connection connection)	Jetty Connection onOpen event
void	open()	Open/Activate the session
void	outgoingFrame(Frame frame, WriteCallback callback, BatchMode batchMode)	A frame, and optional callback, intended for the network layer.
void	setExtensionFactory(ExtensionFactory extensionFactory)
void	setFuture(CompletableFuture<Session> fut)
void	setIdleTimeout(long ms)	Set the timeout in milliseconds
void	setOutgoingHandler(OutgoingFrames outgoing)
void	setPolicy(WebSocketPolicy policy)	Deprecated.
void	setUpgradeRequest(UpgradeRequest request)
void	setUpgradeResponse(UpgradeResponse response)
SuspendToken	suspend()	Suspend the incoming read events on the connection.
String	toString()

Methods inherited from class org.eclipse.jetty.util.component.ContainerLifeCycle

addBean, addBean, addEventListener, addManaged, contains, destroy, dump, dump, dump, dump, dump, dumpBeans, dumpObject, dumpObjects, dumpStdErr, dumpThis, getBean, getBeans, getBeans, getContainedBeans, getContainedBeans, isAuto, isManaged, isUnmanaged, manage, removeBean, removeBeans, removeEventListener, setBeans, setStopTimeout, start, stop, unmanage, updateBean, updateBean, updateBeans

Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

addLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop

Methods inherited from class Object

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

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable.DumpableContainer

isDumpable

Field Details

LOG

private static final org.eclipse.jetty.util.log.Logger LOG

defaultRemoteEndpointFactory

private static final RemoteEndpointFactory defaultRemoteEndpointFactory

containerScope

private final WebSocketContainerScope containerScope

requestURI

private final URI requestURI

connection

private final LogicalConnection connection

websocket

private final EventDriver websocket

executor

private final Executor executor

policy

private final WebSocketPolicy policy

onCloseCalled

private final AtomicBoolean onCloseCalled

remoteEndpointFactory

private final RemoteEndpointFactory remoteEndpointFactory

classLoader

private final ClassLoader classLoader

extensionFactory

private ExtensionFactory extensionFactory

protocolVersion

private String protocolVersion

parameterMap

private final Map<String,String[]> parameterMap

remote

private RemoteEndpoint remote

incomingHandler

private final IncomingFrames incomingHandler

outgoingHandler

private OutgoingFrames outgoingHandler

upgradeRequest

private UpgradeRequest upgradeRequest

upgradeResponse

private UpgradeResponse upgradeResponse

openFuture

private CompletableFuture<Session> openFuture

Constructor Details

WebSocketSession

public WebSocketSession(WebSocketContainerScope containerScope,
 URI requestURI,
 EventDriver websocket,
 LogicalConnection connection)

Method Details

close

public void close(Throwable cause)

Close the active session based on the throwable

Parameters:

cause - the cause for closing the connection

close

public void close()

Description copied from interface: Session

Request a close of the current conversation with a normal status code and no reason phrase.

This will enqueue a graceful close to the remote endpoint.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Session

See Also:

• Session.close(CloseStatus)
• Session.close(int, String)
• Session.disconnect()

close

public void close(CloseStatus closeStatus)

Description copied from interface: Session

Request Close the current conversation, giving a reason for the closure. Note the websocket spec defines the acceptable uses of status codes and reason phrases.

This will enqueue a graceful close to the remote endpoint.

Specified by:

close in interface Session

Parameters:

closeStatus - the reason for the closure

See Also:

• Session.close()
• Session.close(int, String)
• Session.disconnect()

close

public void close(int statusCode,
 String reason)

Description copied from interface: Session

Send a websocket Close frame, with status code.

This will enqueue a graceful close to the remote endpoint.

Specified by:

close in interface Session

Parameters:

statusCode - the status code

reason - the (optional) reason. (can be null for no reason)

See Also:

• StatusCode
• Session.close()
• Session.close(CloseStatus)
• Session.disconnect()

close

private void close(CloseInfo closeInfo,
 org.eclipse.jetty.util.Callback callback)

Close Primary Entry Point.

Parameters:

closeInfo - the close details

disconnect

public void disconnect()

Harsh disconnect

Specified by:

disconnect in interface Session

See Also:

• Session.close()
• Session.close(CloseStatus)
• Session.close(int, String)
• Session.disconnect()

dispatch

public void dispatch(Runnable runnable)

doStart

protected void doStart()
                throws Exception

Overrides:

doStart in class org.eclipse.jetty.util.component.ContainerLifeCycle

Throws:

Exception

doStop

protected void doStop()
               throws Exception

Overrides:

doStop in class org.eclipse.jetty.util.component.ContainerLifeCycle

Throws:

Exception

dumpSelf

public String dumpSelf()

Specified by:

dumpSelf in interface org.eclipse.jetty.util.component.Dumpable

getBufferPool

public org.eclipse.jetty.io.ByteBufferPool getBufferPool()

getClassLoader

public ClassLoader getClassLoader()

getConnection

public LogicalConnection getConnection()

getContainerScope

public WebSocketContainerScope getContainerScope()

Description copied from interface: WebSocketSessionScope

The parent WebSocketContainerScope for this session scope.

Specified by:

getContainerScope in interface WebSocketSessionScope

Returns:

the websocket container scope

getExtensionFactory

public ExtensionFactory getExtensionFactory()

getIdleTimeout

public long getIdleTimeout()

The idle timeout in milliseconds

Specified by:

getIdleTimeout in interface Session

Returns:

the timeout in milliseconds.

getIncomingHandler

@ManagedAttribute(readonly=true)
public IncomingFrames getIncomingHandler()

getLocalAddress

public InetSocketAddress getLocalAddress()

Description copied from interface: Session

Get the address of the local side.

Specified by:

getLocalAddress in interface Session

Returns:

the local side address

getOutgoingHandler

@ManagedAttribute(readonly=true)
public OutgoingFrames getOutgoingHandler()

getPolicy

public WebSocketPolicy getPolicy()

Description copied from interface: Session

Access the (now read-only) WebSocketPolicy in use for this connection.

Specified by:

getPolicy in interface Session

Returns:

the policy in use

getProtocolVersion

public String getProtocolVersion()

Description copied from interface: Session

Returns the version of the websocket protocol currently being used. This is taken as the value of the Sec-WebSocket-Version header used in the opening handshake. i.e. "13".

Specified by:

getProtocolVersion in interface Session

Returns:

the protocol version

getRemote

public RemoteEndpoint getRemote()

Description copied from interface: Session

Return a reference to the RemoteEndpoint object representing the other end of this conversation.

Specified by:

getRemote in interface Session

Returns:

the remote endpoint

getRemoteAddress

public InetSocketAddress getRemoteAddress()

Description copied from interface: Session

Get the address of the remote side.

Specified by:

getRemoteAddress in interface Session

Returns:

the remote side address

getRequestURI

public URI getRequestURI()

getUpgradeRequest

public UpgradeRequest getUpgradeRequest()

Description copied from interface: Session

Get the UpgradeRequest used to create this session

Specified by:

getUpgradeRequest in interface Session

Returns:

the UpgradeRequest used to create this session

getUpgradeResponse

public UpgradeResponse getUpgradeResponse()

Description copied from interface: Session

Get the UpgradeResponse used to create this session

Specified by:

getUpgradeResponse in interface Session

Returns:

the UpgradeResponse used to create this session

getWebSocketSession

public WebSocketSession getWebSocketSession()

Description copied from interface: WebSocketSessionScope

Active WebSocketSession associated with this scope.

Specified by:

getWebSocketSession in interface WebSocketSessionScope

Returns:

the websocket session

incomingFrame

public void incomingFrame(Frame frame)

Incoming Raw Frames from Parser

Specified by:

incomingFrame in interface IncomingFrames

Parameters:

frame - the frame to process

outgoingFrame

public void outgoingFrame(Frame frame,
 WriteCallback callback,
 BatchMode batchMode)

Description copied from interface: OutgoingFrames

A frame, and optional callback, intended for the network layer.

Note: the frame can undergo many transformations in the various layers and extensions present in the implementation.

If you are implementing a mutation, you are obliged to handle the incoming WriteCallback appropriately.

Specified by:

outgoingFrame in interface OutgoingFrames

Parameters:

frame - the frame to eventually write to the network layer.

callback - the callback to notify when the frame is written.

batchMode - the batch mode requested by the sender.

isOpen

public boolean isOpen()

Description copied from interface: Session

Return true if and only if the underlying socket is open.

Specified by:

isOpen in interface Session

Returns:

whether the session is open

isSecure

public boolean isSecure()

Description copied from interface: Session

Return true if and only if the underlying socket is using a secure transport.

Specified by:

isSecure in interface Session

Returns:

whether its using a secure transport

callApplicationOnClose

public void callApplicationOnClose(CloseInfo closeInfo)

callApplicationOnError

public void callApplicationOnError(Throwable cause)

onClosed

public void onClosed(org.eclipse.jetty.io.Connection connection)

Jetty Connection onSessionClosed event

Specified by:

onClosed in interface org.eclipse.jetty.io.Connection.Listener

Parameters:

connection - the connection that was closed

onOpened

public void onOpened(org.eclipse.jetty.io.Connection connection)

Jetty Connection onOpen event

Specified by:

onOpened in interface org.eclipse.jetty.io.Connection.Listener

Parameters:

connection - the connection that was opened

newRemoteEndpoint

public WebSocketRemoteEndpoint newRemoteEndpoint(LogicalConnection connection,
 OutgoingFrames outgoingFrames,
 BatchMode batchMode)

Specified by:

newRemoteEndpoint in interface RemoteEndpointFactory

open

public void open()

Open/Activate the session

setExtensionFactory

public void setExtensionFactory(ExtensionFactory extensionFactory)

setFuture

public void setFuture(CompletableFuture<Session> fut)

setIdleTimeout

public void setIdleTimeout(long ms)

Set the timeout in milliseconds

Specified by:

setIdleTimeout in interface Session

Parameters:

ms - the number of milliseconds.

setOutgoingHandler

public void setOutgoingHandler(OutgoingFrames outgoing)

setPolicy

@Deprecated
public void setPolicy(WebSocketPolicy policy)

Deprecated.

setUpgradeRequest

public void setUpgradeRequest(UpgradeRequest request)

setUpgradeResponse

public void setUpgradeResponse(UpgradeResponse response)

suspend

public SuspendToken suspend()

Description copied from interface: Session

Suspend the incoming read events on the connection.

Specified by:

suspend in interface Session

Returns:

the suspend token suitable for resuming the reading of data on the connection.

getBatchMode

public BatchMode getBatchMode()

Returns:

the default (initial) value for the batching mode.

notifySessionListeners

private void notifySessionListeners(WebSocketContainerScope scope,
 Consumer<WebSocketSessionListener> consumer)

toString

public String toString()

Overrides:

toString in class org.eclipse.jetty.util.component.AbstractLifeCycle