com.buabook.common.net

Class SocketAcceptorThread

java.lang.Object

java.lang.Thread

com.buabook.common.net.SocketAcceptorThread

All Implemented Interfaces:

Runnable

public class SocketAcceptorThread
extends Thread

Socket Acceptor Thread

Provides a thread that will wait for incoming connections for 3rd party processes and notify any listeners (of type INewClientSocketListener) when those connections are made. Multiple listeners are supported.

(c) 2016 Sport Trades Ltd

Since:

11 Jul 2016

Version:

1.0.0

Author:

Jas Rajasansir

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private Process	bindToPort
private static org.slf4j.Logger	log
private List<INewClientSocketListener>	newConnectionListeners
private ServerSocket	serverSocket

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
SocketAcceptorThread(Process bindToPort)

Method Summary

Modifier and Type	Method and Description
void	addNewConnectionListener(INewClientSocketListener listener)
static ServerSocket	openServerSocket(Process bindToPort) Opens the ServerSocket on the specified port
void	removeConnectionListener(INewClientSocketListener listener)
void	run()
private void	waitForClient() Blocks the thread and waits for a new inbound client to connect.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

log

private static final org.slf4j.Logger log

bindToPort

private final Process bindToPort

serverSocket

private final ServerSocket serverSocket

newConnectionListeners

private final List<INewClientSocketListener> newConnectionListeners

Constructor Detail

SocketAcceptorThread

public SocketAcceptorThread(Process bindToPort)
                     throws IllegalArgumentException,
                            FailedToBindToPortException

Throws:

IllegalArgumentException

FailedToBindToPortException

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

addNewConnectionListener

public void addNewConnectionListener(INewClientSocketListener listener)

removeConnectionListener

public void removeConnectionListener(INewClientSocketListener listener)

waitForClient

private void waitForClient()

Blocks the thread and waits for a new inbound client to connect.

NOTE: No exception is thrown in the case a client connection cannot be created.

See Also:

ServerSocket.accept()

openServerSocket

public static ServerSocket openServerSocket(Process bindToPort)
                                     throws FailedToBindToPortException

Opens the ServerSocket on the specified port

Parameters:

bindToPort - The port to bind the server socket to

Returns:

The new server socket object to use to accept new inbound client connections

Throws:

FailedToBindToPortException - If the server socket fails to bind to the specified port.