Package marauroa.server.net

Class NetworkServerManager

java.lang.Object

marauroa.server.net.NetworkServerManager

All Implemented Interfaces:

INetworkServerManager, IServerManager

public final class NetworkServerManager
extends Object
implements IServerManager, INetworkServerManager

This is the implementation of a worker that sends messages, receives them, ... This class also handles validation of connection and disconnection events

Author:

miguel

Constructor Summary

Constructors

Constructor	Description
NetworkServerManager()	Constructor

Method Summary

Modifier and Type	Method	Description
void	addServer(ConnectionManager server)	Associate this object with a server.
void	disconnectClient(Channel channel)	This method disconnect a socket.
void	finish()	This method notifies the thread to finish the execution
Channel	getChannel(Object internalChannel)	gets the channel associated with an internalChannel
Message	getMessage()	This method blocks until a message is available
ConnectionValidator	getValidator()	Returns a instance of the connection validator ConnectionValidator so that other layers can manipulate it for banning IP.
Channel	onConnect(ConnectionManager connectionManager, InetSocketAddress address, Object internalChannel)	handles a connection from a client
void	onDisconnect(ConnectionManager server, Object internalChannel)	Removes stored parts of message for this channel at the decoder.
void	onMessage(ConnectionManager server, Object internalChannel, Message msg)	This method is called when data is received from a socket channel
void	registerDisconnectedListener(IDisconnectedListener listener)	Register a listener for disconnection events.
void	sendMessage(Message msg)	This method add a message to be delivered to the client the message is pointed to.
void	start()	This method inits the active object

Methods inherited from class java.lang.Object

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

Constructor Details

NetworkServerManager

public NetworkServerManager()
                     throws IOException

Constructor

Throws:

IOException - if there any exception when starting the socket server.

Method Details

start

public void start()

Description copied from interface: INetworkServerManager

This method inits the active object

Specified by:

start in interface INetworkServerManager

addServer

public void addServer(ConnectionManager server)

Associate this object with a server. This model a master-slave approach for managing network messages.

Specified by:

addServer in interface IServerManager

Parameters:

server - the master server.

finish

public void finish()

This method notifies the thread to finish the execution

Specified by:

finish in interface INetworkServerManager

getMessage

public Message getMessage()

This method blocks until a message is available

Specified by:

getMessage in interface INetworkServerManager

Returns:

a Message

sendMessage

public void sendMessage(Message msg)

This method add a message to be delivered to the client the message is pointed to.

Specified by:

sendMessage in interface INetworkServerManager

Parameters:

msg - the message to be delivered.

disconnectClient

public void disconnectClient(Channel channel)

This method disconnect a socket.

Specified by:

disconnectClient in interface INetworkServerManager

Parameters:

channel - the socket channel to close

getValidator

public ConnectionValidator getValidator()

Returns a instance of the connection validator ConnectionValidator so that other layers can manipulate it for banning IP.

Specified by:

getValidator in interface INetworkServerManager

Returns:

the Connection validator instance

registerDisconnectedListener

public void registerDisconnectedListener(IDisconnectedListener listener)

Register a listener for disconnection events.

Specified by:

registerDisconnectedListener in interface INetworkServerManager

Specified by:

registerDisconnectedListener in interface IServerManager

Parameters:

listener - a listener for disconnection events.

getChannel

public Channel getChannel(Object internalChannel)

gets the channel associated with an internalChannel

Specified by:

getChannel in interface INetworkServerManager

Parameters:

internalChannel - internel channel

Returns:

Channel

onConnect

public Channel onConnect(ConnectionManager connectionManager,
 InetSocketAddress address,
 Object internalChannel)

handles a connection from a client

Specified by:

onConnect in interface IServerManager

Parameters:

connectionManager - IServer

address - of the client

internalChannel - internal channel object

Returns:

the channel, if the connection was accepted; null otherwise

onDisconnect

public void onDisconnect(ConnectionManager server,
 Object internalChannel)

Removes stored parts of message for this channel at the decoder.

Specified by:

onDisconnect in interface IServerManager

Parameters:

internalChannel - the channel to clear

server - ConnectionManager

onMessage

public void onMessage(ConnectionManager server,
 Object internalChannel,
 Message msg)

This method is called when data is received from a socket channel

Specified by:

onMessage in interface IServerManager

Parameters:

server - NioServer

internalChannel - internal channel object

msg - a Message