org.apache.mina.core.service

Class AbstractIoAcceptor

java.lang.Object

org.apache.mina.core.service.AbstractIoService

org.apache.mina.core.service.AbstractIoAcceptor

All Implemented Interfaces:

IoAcceptor, IoService

Direct Known Subclasses:

AbstractPollingIoAcceptor, NioDatagramAcceptor, VmPipeAcceptor

public abstract class AbstractIoAcceptor
extends AbstractIoService
implements IoAcceptor

A base implementation of IoAcceptor.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractIoAcceptor.AcceptorOperationFuture

Nested classes/interfaces inherited from class org.apache.mina.core.service.AbstractIoService

AbstractIoService.ServiceOperationFuture

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.Object	bindLock The lock object which is acquired while bind or unbind operation is performed.
private java.util.Set<java.net.SocketAddress>	boundAddresses
private java.util.List<java.net.SocketAddress>	defaultLocalAddresses
private boolean	disconnectOnUnbind
private java.util.List<java.net.SocketAddress>	unmodifiableDefaultLocalAddresses

Fields inherited from class org.apache.mina.core.service.AbstractIoService

disposalLock, sessionConfig

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractIoAcceptor(IoSessionConfig sessionConfig, java.util.concurrent.Executor executor) Constructor for AbstractIoAcceptor.

Method Summary

Modifier and Type	Method and Description
void	bind() Binds to the default local address(es) and start to accept incoming connections.
void	bind(java.lang.Iterable<? extends java.net.SocketAddress> localAddresses) Binds to the specified local addresses and start to accept incoming connections.
void	bind(java.net.SocketAddress... addresses) Binds to the specified local addresses and start to accept incoming connections.
void	bind(java.net.SocketAddress localAddress) Binds to the specified local address and start to accept incoming connections.
void	bind(java.net.SocketAddress firstLocalAddress, java.net.SocketAddress... addresses) Binds to the specified local addresses and start to accept incoming connections.
protected abstract java.util.Set<java.net.SocketAddress>	bindInternal(java.util.List<? extends java.net.SocketAddress> localAddresses) Starts the acceptor, and register the given addresses
private void	checkAddressType(java.net.SocketAddress a)
java.net.SocketAddress	getDefaultLocalAddress() Returns the default local address to bind when no argument is specified in IoAcceptor.bind() method.
java.util.List<java.net.SocketAddress>	getDefaultLocalAddresses() Returns a List of the default local addresses to bind when no argument is specified in IoAcceptor.bind() method.
java.net.SocketAddress	getLocalAddress() Returns the local address which is bound currently.
java.util.Set<java.net.SocketAddress>	getLocalAddresses() Returns a Set of the local addresses which are bound currently.
boolean	isCloseOnDeactivation() Returns true if and only if all clients are closed when this acceptor unbinds from all the related local address (i.e.
void	setCloseOnDeactivation(boolean disconnectClientsOnUnbind) Sets whether all client sessions are closed when this acceptor unbinds from all the related local addresses (i.e.
void	setDefaultLocalAddress(java.net.SocketAddress localAddress) Sets the default local address to bind when no argument is specified in IoAcceptor.bind() method.
void	setDefaultLocalAddresses(java.lang.Iterable<? extends java.net.SocketAddress> localAddresses) Sets the default local addresses to bind when no argument is specified in IoAcceptor.bind() method.
void	setDefaultLocalAddresses(java.util.List<? extends java.net.SocketAddress> localAddresses) Sets the default local addresses to bind when no argument is specified in IoAcceptor.bind() method.
void	setDefaultLocalAddresses(java.net.SocketAddress firstLocalAddress, java.net.SocketAddress... otherLocalAddresses) Sets the default local addresses to bind when no argument is specified in IoAcceptor.bind() method.
java.lang.String	toString()
void	unbind() Unbinds from all local addresses that this service is bound to and stops to accept incoming connections.
void	unbind(java.lang.Iterable<? extends java.net.SocketAddress> localAddresses) Unbinds from the specified local addresses and stop to accept incoming connections.
void	unbind(java.net.SocketAddress localAddress) Unbinds from the specified local address and stop to accept incoming connections.
void	unbind(java.net.SocketAddress firstLocalAddress, java.net.SocketAddress... otherLocalAddresses) Unbinds from the specified local addresses and stop to accept incoming connections.
protected abstract void	unbind0(java.util.List<? extends java.net.SocketAddress> localAddresses) Implement this method to perform the actual unbind operation.

Methods inherited from class org.apache.mina.core.service.AbstractIoService

addListener, broadcast, dispose, dispose, dispose0, executeWorker, executeWorker, finishSessionInitialization0, getActivationTime, getFilterChain, getFilterChainBuilder, getHandler, getListeners, getManagedSessionCount, getManagedSessions, getScheduledWriteBytes, getScheduledWriteMessages, getSessionDataStructureFactory, getStatistics, initSession, isActive, isDisposed, isDisposing, removeListener, setFilterChainBuilder, setHandler, setSessionDataStructureFactory

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.mina.core.service.IoAcceptor

newSession

Methods inherited from interface org.apache.mina.core.service.IoService

addListener, broadcast, dispose, dispose, getActivationTime, getFilterChain, getFilterChainBuilder, getHandler, getManagedSessionCount, getManagedSessions, getScheduledWriteBytes, getScheduledWriteMessages, getSessionConfig, getSessionDataStructureFactory, getStatistics, getTransportMetadata, isActive, isDisposed, isDisposing, removeListener, setFilterChainBuilder, setHandler, setSessionDataStructureFactory

Field Detail

defaultLocalAddresses

private final java.util.List<java.net.SocketAddress> defaultLocalAddresses

unmodifiableDefaultLocalAddresses

private final java.util.List<java.net.SocketAddress> unmodifiableDefaultLocalAddresses

boundAddresses

private final java.util.Set<java.net.SocketAddress> boundAddresses

disconnectOnUnbind

private boolean disconnectOnUnbind

bindLock

protected final java.lang.Object bindLock

The lock object which is acquired while bind or unbind operation is performed. Acquire this lock in your property setters which shouldn't be changed while the service is bound.

Constructor Detail

AbstractIoAcceptor

protected AbstractIoAcceptor(IoSessionConfig sessionConfig,
                             java.util.concurrent.Executor executor)

Constructor for AbstractIoAcceptor. You need to provide a default session configuration and an Executor for handling I/O events. If null Executor is provided, a default one will be created using Executors.newCachedThreadPool().

Parameters:

sessionConfig - the default configuration for the managed IoSession

executor - the Executor used for handling execution of I/O events. Can be null.

See Also:

AbstractIoService(IoSessionConfig, Executor)

Method Detail

getLocalAddress

public java.net.SocketAddress getLocalAddress()

Returns the local address which is bound currently. If more than one address are bound, only one of them will be returned, but it's not necessarily the firstly bound address.

Specified by:

getLocalAddress in interface IoAcceptor

getLocalAddresses

public final java.util.Set<java.net.SocketAddress> getLocalAddresses()

Returns a Set of the local addresses which are bound currently.

Specified by:

getLocalAddresses in interface IoAcceptor

getDefaultLocalAddress

public java.net.SocketAddress getDefaultLocalAddress()

Returns the default local address to bind when no argument is specified in IoAcceptor.bind() method. Please note that the default will not be used if any local address is specified. If more than one address are set, only one of them will be returned, but it's not necessarily the firstly specified address in IoAcceptor.setDefaultLocalAddresses(List).

Specified by:

getDefaultLocalAddress in interface IoAcceptor

setDefaultLocalAddress

public final void setDefaultLocalAddress(java.net.SocketAddress localAddress)

Sets the default local address to bind when no argument is specified in IoAcceptor.bind() method. Please note that the default will not be used if any local address is specified.

Specified by:

setDefaultLocalAddress in interface IoAcceptor

getDefaultLocalAddresses

public final java.util.List<java.net.SocketAddress> getDefaultLocalAddresses()

Returns a List of the default local addresses to bind when no argument is specified in IoAcceptor.bind() method. Please note that the default will not be used if any local address is specified.

Specified by:

getDefaultLocalAddresses in interface IoAcceptor

setDefaultLocalAddresses

public final void setDefaultLocalAddresses(java.util.List<? extends java.net.SocketAddress> localAddresses)

Sets the default local addresses to bind when no argument is specified in IoAcceptor.bind() method. Please note that the default will not be used if any local address is specified.

Specified by:

setDefaultLocalAddresses in interface IoAcceptor

setDefaultLocalAddresses

public final void setDefaultLocalAddresses(java.lang.Iterable<? extends java.net.SocketAddress> localAddresses)

Sets the default local addresses to bind when no argument is specified in IoAcceptor.bind() method. Please note that the default will not be used if any local address is specified.

Specified by:

setDefaultLocalAddresses in interface IoAcceptor

setDefaultLocalAddresses

public final void setDefaultLocalAddresses(java.net.SocketAddress firstLocalAddress,
                                           java.net.SocketAddress... otherLocalAddresses)

Sets the default local addresses to bind when no argument is specified in IoAcceptor.bind() method. Please note that the default will not be used if any local address is specified.

Specified by:

setDefaultLocalAddresses in interface IoAcceptor

isCloseOnDeactivation

public final boolean isCloseOnDeactivation()

Returns true if and only if all clients are closed when this acceptor unbinds from all the related local address (i.e. when the service is deactivated).

Specified by:

isCloseOnDeactivation in interface IoAcceptor

setCloseOnDeactivation

public final void setCloseOnDeactivation(boolean disconnectClientsOnUnbind)

Sets whether all client sessions are closed when this acceptor unbinds from all the related local addresses (i.e. when the service is deactivated). The default value is true.

Specified by:

setCloseOnDeactivation in interface IoAcceptor

bind

public final void bind()
                throws java.io.IOException

Binds to the default local address(es) and start to accept incoming connections.

Specified by:

bind in interface IoAcceptor

Throws:

java.io.IOException - if failed to bind

bind

public final void bind(java.net.SocketAddress localAddress)
                throws java.io.IOException

Binds to the specified local address and start to accept incoming connections.

Specified by:

bind in interface IoAcceptor

Parameters:

localAddress - The SocketAddress to bind to

Throws:

java.io.IOException - if failed to bind

bind

public final void bind(java.net.SocketAddress... addresses)
                throws java.io.IOException

Binds to the specified local addresses and start to accept incoming connections. If no address is given, bind on the default local address.

Specified by:

bind in interface IoAcceptor

Parameters:

addresses - The SocketAddresses to bind to

Throws:

java.io.IOException - if failed to bind

bind

public final void bind(java.net.SocketAddress firstLocalAddress,
                       java.net.SocketAddress... addresses)
                throws java.io.IOException

Binds to the specified local addresses and start to accept incoming connections. If no address is given, bind on the default local address.

Specified by:

bind in interface IoAcceptor

Parameters:

firstLocalAddress - The first address to bind to

addresses - The SocketAddresses to bind to

Throws:

java.io.IOException - if failed to bind

bind

public final void bind(java.lang.Iterable<? extends java.net.SocketAddress> localAddresses)
                throws java.io.IOException

Binds to the specified local addresses and start to accept incoming connections.

Specified by:

bind in interface IoAcceptor

Throws:

java.io.IOException - if failed to bind

unbind

public final void unbind()

Unbinds from all local addresses that this service is bound to and stops to accept incoming connections. All managed connections will be closed if disconnectOnUnbind property is true. This method returns silently if no local address is bound yet.

Specified by:

unbind in interface IoAcceptor

unbind

public final void unbind(java.net.SocketAddress localAddress)

Unbinds from the specified local address and stop to accept incoming connections. All managed connections will be closed if disconnectOnUnbind property is true. This method returns silently if the default local address is not bound yet.

Specified by:

unbind in interface IoAcceptor

unbind

public final void unbind(java.net.SocketAddress firstLocalAddress,
                         java.net.SocketAddress... otherLocalAddresses)

Unbinds from the specified local addresses and stop to accept incoming connections. All managed connections will be closed if disconnectOnUnbind property is true. This method returns silently if the default local addresses are not bound yet.

Specified by:

unbind in interface IoAcceptor

unbind

public final void unbind(java.lang.Iterable<? extends java.net.SocketAddress> localAddresses)

Unbinds from the specified local addresses and stop to accept incoming connections. All managed connections will be closed if disconnectOnUnbind property is true. This method returns silently if the default local addresses are not bound yet.

Specified by:

unbind in interface IoAcceptor

bindInternal

protected abstract java.util.Set<java.net.SocketAddress> bindInternal(java.util.List<? extends java.net.SocketAddress> localAddresses)
                                                               throws java.lang.Exception

Starts the acceptor, and register the given addresses

Returns:

the Set of the local addresses which is bound actually

Throws:

java.lang.Exception

unbind0

protected abstract void unbind0(java.util.List<? extends java.net.SocketAddress> localAddresses)
                         throws java.lang.Exception

Implement this method to perform the actual unbind operation.

Throws:

java.lang.Exception

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

checkAddressType

private void checkAddressType(java.net.SocketAddress a)