com.epam.common.transport.server.tcp

Class TCPServer

java.lang.Object

com.epam.common.transport.server.AbstractServer

com.epam.common.transport.server.tcp.TCPServer

All Implemented Interfaces:

Server

Direct Known Subclasses:

NIOTCPServer, SSLTCPServer

public class TCPServer
extends AbstractServer
implements Server

TCP server implementation.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_BACKLOG

Fields inherited from class com.epam.common.transport.server.AbstractServer

autoClose, DEFAULT_PORT, port, sessionRefCounter, started

Constructor Summary

Constructors

Constructor and Description
TCPServer() Creates server with default port.
TCPServer(int port) Creates server.
TCPServer(int port, boolean enableNagle) Creates server.
TCPServer(int port, boolean enableNagle, String nic) Creates server.
TCPServer(int port, boolean enableNagle, String nic, int sendBufferSize, int receiveBufferSize) Creates server.
TCPServer(int port, ServerSocketFactory serverSocketFactory) Creates server.

Method Summary

Modifier and Type	Method and Description
protected ServerSocket	createServerSocket(int port)
protected ServerSocket	createServerSocket(int port, int backlog, InetAddress address)
void	setIncomingConnectionExecutor(ExecutorService executorService) Set custom executor service.
void	setIncomingConnectionListener(ConnectionListener listener) Sets the connection listener.
void	setServerSocketFactory(ServerSocketFactory serverSocketFactory) Sets server socket factory.
void	start() Start the server.
void	stop() Stop server.
String	toString()

Methods inherited from class com.epam.common.transport.server.AbstractServer

decrementRefCounter, getPort, incrementRefCounter, isAutoClose, isStarted, setAutoClose, setPort, setStarted

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.epam.common.transport.server.Server

asAbstract, isAbstract

Field Detail

DEFAULT_BACKLOG

public static final int DEFAULT_BACKLOG

See Also:

Constant Field Values

Constructor Detail

TCPServer

public TCPServer()

Creates server with default port. The default value for port is 3001

TCPServer

public TCPServer(int port)

Creates server.

Parameters:

port - - server port

TCPServer

public TCPServer(int port,
                 ServerSocketFactory serverSocketFactory)

Creates server.

Parameters:

port - - server port

TCPServer

public TCPServer(int port,
                 boolean enableNagle)

Creates server.

Parameters:

port - - server port

enableNagle - - enable/disable nagle algorithm

TCPServer

public TCPServer(int port,
                 boolean enableNagle,
                 String nic,
                 int sendBufferSize,
                 int receiveBufferSize)

Creates server.

Parameters:

port - - server port

enableNagle - - enable/disable nagle algorithm

sendBufferSize - send buffer size

receiveBufferSize - receive buffer size

TCPServer

public TCPServer(int port,
                 boolean enableNagle,
                 String nic)

Creates server.

Parameters:

port - - server port

enableNagle - - enable/disable nagle algorithm

nic - - specific connection address

Method Detail

setServerSocketFactory

public void setServerSocketFactory(ServerSocketFactory serverSocketFactory)

Sets server socket factory. User can replace default socket factory with own implementation.

Parameters:

serverSocketFactory - - socket factory

setIncomingConnectionListener

public void setIncomingConnectionListener(ConnectionListener listener)

Description copied from interface: Server

Sets the connection listener.

Specified by:

setIncomingConnectionListener in interface Server

Parameters:

listener - the connection listener

See Also:

Server.setIncomingConnectionListener(com.epam.common.transport.server.ConnectionListener)

setIncomingConnectionExecutor

public void setIncomingConnectionExecutor(ExecutorService executorService)

Set custom executor service. If the custom executor is not set, Executors.newWorkStealingPool() will be used.

Specified by:

setIncomingConnectionExecutor in interface Server

Parameters:

executorService - the executor will be used for working with incoming connections.

start

public void start()
           throws IOException

Description copied from interface: Server

Start the server.

Specified by:

start in interface Server

Throws:

IOException - - if error occurred

See Also:

Server.start()

createServerSocket

protected ServerSocket createServerSocket(int port,
                                          int backlog,
                                          InetAddress address)
                                   throws IOException

Throws:

IOException

createServerSocket

protected ServerSocket createServerSocket(int port)
                                   throws IOException

Throws:

IOException

stop

public void stop()
          throws IOException

Description copied from interface: Server

Stop server.

Specified by:

stop in interface Server

Throws:

IOException - - if error occurred

See Also:

Server.stop()

toString

public String toString()

Overrides:

toString in class Object