ch.dermitza.securenio

Class TCPServer

java.lang.Object

ch.dermitza.securenio.AbstractSelector

ch.dermitza.securenio.TCPServer

All Implemented Interfaces:

HandshakeListener, TaskListener, TimeoutListener, java.lang.Runnable

public class TCPServer
extends AbstractSelector

A TCP Server implementation of AbstractSelector. This implementation is purely non-blocking and can handle both PlainSockets and SecureSockets.

Since:

0.18

Field Summary

Fields inherited from class ch.dermitza.securenio.AbstractSelector

address, cipherSuits, container, context, isClient, logger, needClientAuth, pendingData, port, protocols, selector, singleThreaded, taskWorker, toWorker, usingSSL

Constructor Summary

Constructors

Constructor and Description
TCPServer(java.net.InetAddress address, int port, AbstractPacketWorker packetWorker, boolean usingSSL, boolean needClientAuth) Create a TCPServer instance.

Method Summary

Methods

Modifier and Type	Method and Description
protected void	accept(java.nio.channels.SelectionKey key) Accepts incoming connections and binds new non-blocking SocketIF instances to them.
protected void	connect(java.nio.channels.SelectionKey key) As this is the server implementation, it is NOT allowed to call this method which is only useful for client implementations.
protected void	initConnection() Initialize a server connection.
void	send(SocketIF sc, PacketIF packet) Send an PacketIF over the specified SocketIF.

Methods inherited from class ch.dermitza.securenio.AbstractSelector

addListener, closeSocket, handshakeComplete, invalidateSession, isRunning, read, removeListener, run, send, setRunning, setupEngine, setupSSL, taskComplete, timeoutExpired, write

Methods inherited from class java.lang.Object

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

Constructor Detail

TCPServer

public TCPServer(java.net.InetAddress address,
         int port,
         AbstractPacketWorker packetWorker,
         boolean usingSSL,
         boolean needClientAuth)

Create a TCPServer instance.

Parameters:

address - The address to bind to

port - The port to listen on

packetWorker - The instance of packet worker to use

usingSSL - Whether we are using SSL/TLS

needClientAuth - Whether we need clients to also authenticate

Method Detail

send

public void send(SocketIF sc,
        PacketIF packet)

Send an PacketIF over the specified SocketIF.

Parameters:

sc - The SocketIF to send the packet through.

packet - The PacketIF to send through the associated SocketIF.

See Also:

AbstractSelector.send(ch.dermitza.securenio.socket.SocketIF, java.nio.ByteBuffer)

initConnection

protected void initConnection()
                       throws java.io.IOException

Initialize a server connection. This method initializes a ServerSocketChannel, configures it to non-blocking, binds it to the specified (if any) host and port, sets the specified backlog and registers it with the underlying Selector instance with an OP_ACCEPT SelectionKey.

Specified by:

initConnection in class AbstractSelector

Throws:

java.io.IOException - Propagates all underlying IOExceptions as thrown, to be handled by the application layer.

See Also:

AbstractSelector.run()

accept

protected void accept(java.nio.channels.SelectionKey key)

Accepts incoming connections and binds new non-blocking SocketIF instances to them. If this server implementation is using SSL/TLS, it also sets up the SSLEngine, to be used.

Specified by:

accept in class AbstractSelector

Parameters:

key - The selection key with the underlying SocketChannel to be accepted

See Also:

AbstractSelector.run()

connect

protected void connect(java.nio.channels.SelectionKey key)

As this is the server implementation, it is NOT allowed to call this method which is only useful for client implementations. This implementation will throw a NoSuchMethodError if it is called and do nothing else.

Specified by:

connect in class AbstractSelector

Parameters:

key - The selection key to be used for connecting.

See Also:

AbstractSelector.run()