Package org.omegazero.net.server

Class UDPServer

java.lang.Object

org.omegazero.net.common.SelectorHandler

org.omegazero.net.common.ConnectionSelectorHandler

org.omegazero.net.server.UDPServer

All Implemented Interfaces:

Runnable, NetworkApplication, NetServer

Direct Known Subclasses:

DTLSServer, PlainUDPServer

public abstract class UDPServer
extends ConnectionSelectorHandler
implements NetServer

UDP/IP server implementation of a NetServer based on java.nio channels.

Field Summary

Fields

Modifier and Type	Field	Description
protected final Collection<InetAddress>	bindAddresses
protected final Collection<Integer>	ports
protected final Consumer<Runnable>	worker

Constructor Summary

Constructors

Constructor	Description
UDPServer(Collection<Integer> ports)
UDPServer(Collection<InetAddress> bindAddresses, Collection<Integer> ports, Consumer<Runnable> worker, long idleTimeout, int receiveBufferSize)	Constructs a new UDPServer instance. To initialize the server, NetworkApplication.init() of this object must be called.

Method Summary

Modifier and Type	Method	Description
void	close()	Closes this application, closing all bound and connected sockets and stopping the main loop, causing a call to NetworkApplication.start() to return.
long	getIdleTimeout()
protected abstract ChannelConnection	handleConnection(SelectionKey serverKey, SocketAddress remote)
protected void	handleConnectionPost(ChannelConnection connection)
protected void	handleSelectedKey(SelectionKey key)	Called when a key was selected in a select call in the SelectorHandler.runSelectorLoop() method.
void	init()	Initializes this application.
protected void	onConnectionClosed(SocketConnection conn)	Notify this ConnectionSelectorHandler that a ChannelConnection was closed locally by a call to SocketConnection.close().
void	setConnectionCallback(Consumer<SocketConnection> handler)	Sets the callback for a new incoming request. The first parameter of this callback is an SocketConnection instance representing the new connection from the client.
void	setIdleTimeout(long idleTimeout)
void	start()	Runs the main loop of this instance.
protected final void	writeBacklogStarted(ChannelConnection connection)

Methods inherited from class org.omegazero.net.common.ConnectionSelectorHandler

handleConnectionClosed, loopIteration

Methods inherited from class org.omegazero.net.common.SelectorHandler

closeSelector, initSelector, isRunning, registerChannel, registerChannel, runSelectorLoop, selectorKeys, selectorWakeup

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.omegazero.net.common.NetworkApplication

run

Field Details

bindAddresses

protected final Collection<InetAddress> bindAddresses

ports

protected final Collection<Integer> ports

worker

protected final Consumer<Runnable> worker

Constructor Details

UDPServer

public UDPServer(Collection<Integer> ports)

See Also:

• UDPServer#UDPServer(String, Collection, Consumer, long, int)

UDPServer

public UDPServer(Collection<InetAddress> bindAddresses,
 Collection<Integer> ports,
 Consumer<Runnable> worker,
 long idleTimeout,
 int receiveBufferSize)

Constructs a new UDPServer instance.

To initialize the server, NetworkApplication.init() of this object must be called. After the call succeeded, the server will listen on the specified local address (bindAddress) on the given ports and NetworkApplication.start() must be called to start processing incoming and outgoing data.

Parameters:

bindAddresses - A collection of local addresses to bind to (see ServerSocketChannel.bind(java.net.SocketAddress, int)). May be null to use an automatically assigned address

ports - The list of ports to listen on

worker - A callback accepting tasks to run that may require increased processing time. May be null to run everything using a single thread

idleTimeout - The time in milliseconds to keep connections that had no traffic. Metadata for UDP connections not closed using SocketConnection.close() or by this idle timeout will be stored indefinitely, which should be avoided

receiveBufferSize - The size of the receive buffer. Should be set to the maximum expected packet size

Method Details

handleConnection

protected abstract ChannelConnection handleConnection(SelectionKey serverKey,
 SocketAddress remote)
                                               throws IOException

Throws:

IOException

handleConnectionPost

protected void handleConnectionPost(ChannelConnection connection)

writeBacklogStarted

protected final void writeBacklogStarted(ChannelConnection connection)

init

public void init()
          throws IOException

Description copied from interface: NetworkApplication

Initializes this application.

Specified by:

init in interface NetworkApplication

Throws:

IOException - If an IO error occurs during initialization

close

public void close()
           throws IOException

Description copied from interface: NetworkApplication

Closes this application, closing all bound and connected sockets and stopping the main loop, causing a call to NetworkApplication.start() to return.

Specified by:

close in interface NetworkApplication

Throws:

IOException - If an IO error occurs

start

public void start()
           throws IOException

Description copied from interface: NetworkApplication

Runs the main loop of this instance. This loop processes incoming or outgoing connection requests and network traffic.

Under normal circumstances, should never return before NetworkApplication.close() is called. After close() is called, this function should return as soon as possible.

If this method is called before NetworkApplication.init(), the behavior is undefined.

Specified by:

start in interface NetworkApplication

Throws:

IOException - If an IO error occurs during any networking operation

setConnectionCallback

public void setConnectionCallback(Consumer<SocketConnection> handler)

Description copied from interface: NetServer

Sets the callback for a new incoming request.

The first parameter of this callback is an SocketConnection instance representing the new connection from the client.

Specified by:

setConnectionCallback in interface NetServer

Parameters:

handler - The connection callback

handleSelectedKey

protected void handleSelectedKey(SelectionKey key)
                          throws IOException

Description copied from class: SelectorHandler

Called when a key was selected in a select call in the SelectorHandler.runSelectorLoop() method.

Specified by:

handleSelectedKey in class SelectorHandler

Parameters:

key - The selected key

Throws:

IOException - If an IO error occurs

onConnectionClosed

protected void onConnectionClosed(SocketConnection conn)

Description copied from class: ConnectionSelectorHandler

Notify this ConnectionSelectorHandler that a ChannelConnection was closed locally by a call to SocketConnection.close().

Overrides:

onConnectionClosed in class ConnectionSelectorHandler

Parameters:

conn - The connection that closed

getIdleTimeout

public long getIdleTimeout()

setIdleTimeout

public void setIdleTimeout(long idleTimeout)