Package net.officefloor.server

Class SocketManager

java.lang.Object

net.officefloor.server.SocketManager

public class SocketManager
extends java.lang.Object

Manages the Socket interaction.

Author:

Daniel Sagenschneider

Field Summary

Fields

Modifier and Type	Field	Description
static int	DEFAULT_SERVER_SOCKET_BACKLOG_SIZE	Default ServerSocket backlog size.

Constructor Summary

Constructors

Constructor	Description
SocketManager(int listenerCount, int socketReceiveBufferSize, int maxReadsOnSelect, StreamBufferPool<java.nio.ByteBuffer> bufferPool, int socketSendBufferSize)	Instantiate.

Method Summary

Modifier and Type	Method	Description
<R> void	bindServerSocket(int port, ServerSocketDecorator serverSocketDecorator, AcceptedSocketDecorator acceptedSocketDecorator, SocketServicerFactory<R> socketServicerFactory, RequestServicerFactory<R> requestServicerFactory)	Binds a ServerSocket to be serviced.
java.lang.Runnable[]	getRunnables()	Obtains the Runnable instances to be executed for this SocketManager.
StreamBufferPool<java.nio.ByteBuffer>	getStreamBufferPool()	Obtains the StreamBufferPool used by this SocketManager.
void	shutdown()	Shuts down this SocketManager.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_SERVER_SOCKET_BACKLOG_SIZE

public static final int DEFAULT_SERVER_SOCKET_BACKLOG_SIZE

Default ServerSocket backlog size.

See Also:

Constant Field Values

Constructor Detail

SocketManager

public SocketManager(int listenerCount,
                     int socketReceiveBufferSize,
                     int maxReadsOnSelect,
                     StreamBufferPool<java.nio.ByteBuffer> bufferPool,
                     int socketSendBufferSize)
              throws java.io.IOException

Instantiate.

Parameters:

listenerCount - Number of SocketManager.SocketListener instances.

socketReceiveBufferSize - Receive buffer size for the Socket.

maxReadsOnSelect - Maximum number of reads per SocketChannel per select. The Selector has locking overheads that slow performance. By undertaking multiple reads on the SocketChannel it makes draining and servicing more efficient (and subsequently faster). This also allows the StreamBuffer sizes to be smaller than the receive Socket buffer size (but still maintain efficiency).

bufferPool - StreamBufferPool.

socketSendBufferSize - Send buffer size for the Socket.

Throws:

java.io.IOException - If fails to initialise Socket management.

Method Detail

getStreamBufferPool

public final StreamBufferPool<java.nio.ByteBuffer> getStreamBufferPool()

Obtains the StreamBufferPool used by this SocketManager.

Returns:

StreamBufferPool used by this SocketManager.

getRunnables

public final java.lang.Runnable[] getRunnables()

Obtains the Runnable instances to be executed for this SocketManager.

Returns:

Runnable instances to be executed for this SocketManager.

bindServerSocket

public final <R> void bindServerSocket(int port,
                                       ServerSocketDecorator serverSocketDecorator,
                                       AcceptedSocketDecorator acceptedSocketDecorator,
                                       SocketServicerFactory<R> socketServicerFactory,
                                       RequestServicerFactory<R> requestServicerFactory)
                                throws java.io.IOException

Binds a ServerSocket to be serviced.

Type Parameters:

R - Request type.

Parameters:

port - Port for the ServerSocket.

serverSocketDecorator - Optional ServerSocketDecorator. May be null.

acceptedSocketDecorator - Optional AcceptedSocketDecorator. May be null.

socketServicerFactory - SocketServicerFactory to service accepted connections.

requestServicerFactory - RequestServicerFactory to service requests on the Socket.

Throws:

java.io.IOException - If fails to bind the ServerSocket.

shutdown

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

Shuts down this SocketManager. This involves closing all Socket instances being managed and stopping the SocketManager.SocketListener instances.

Throws:

java.io.IOException - If fails to shutdown this SocketManager.