Class MemcachedConnector

java.lang.Object

com.google.code.yanf4j.core.impl.AbstractController

com.google.code.yanf4j.nio.impl.NioController

com.google.code.yanf4j.nio.impl.SocketChannelController

net.rubyeye.xmemcached.impl.MemcachedConnector

All Implemented Interfaces:

Controller, ControllerLifeCycle, SelectionKeyHandler, Connector

public class MemcachedConnector
extends SocketChannelController
implements Connector

Connected session manager

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	MemcachedConnector.InnerControllerStateListener	Inner state listenner,manage session monitor.
(package private) class	MemcachedConnector.SessionMonitor	Session monitor for healing sessions.

Field Summary

Fields

Modifier and Type	Field	Description
private BufferAllocator	bufferAllocator
private final CommandFactory	commandFactory
private int	connectionPoolSize
private boolean	enableHealSession
private boolean	failureMode
private final FlowControl	flowControl
private long	healSessionInterval
private final MemcachedOptimizer	optimiezer
protected Protocol	protocol
private final Random	random
private final Set<InetSocketAddress>	removedAddrSet
protected MemcachedSessionComparator	sessionComparator
protected MemcachedSessionLocator	sessionLocator
protected final ConcurrentHashMap<InetSocketAddress, Queue<Session>>	sessionMap
private final MemcachedConnector.SessionMonitor	sessionMonitor
private boolean	shuttingDown
private final ConcurrentHashMap<InetSocketAddress, List<Session>>	standbySessionMap
private final DelayQueue<ReconnectRequest>	waitingQueue

Fields inherited from class SocketChannelController

soLingerOn

Fields inherited from class NioController

selectorManager, selectorPoolSize

Fields inherited from class AbstractController

codecFactory, configuration, dispatchMessageDispatcher, dispatchMessageThreadCount, handler, handleReadWriteConcurrently, localSocketAddress, log, readEventDispatcher, readThreadCount, sessionSet, sessionTimeout, socketOptions, soTimeout, started, stateListeners, statistics, statisticsInterval, writeEventDispatcher, writeThreadCount

Constructor Summary

Constructors

Constructor	Description
MemcachedConnector(Configuration configuration, MemcachedSessionLocator locator, MemcachedSessionComparator comparator, BufferAllocator allocator, CommandFactory commandFactory, int poolSize, int maxQueuedNoReplyOperations)

Method Summary

Modifier and Type	Method	Description
private void	addMainSession(Session session, InetSocketAddress lastReolvedAddr, InetSocketAddressWrapper addrWrapper)
void	addSession(Session session)
private void	addStandbySession(Session session, InetSocketAddress mainNodeAddress, InetSocketAddress lastResolvedMainAddr, InetSocketAddressWrapper addrWrapper)
void	addToWatingQueue(ReconnectRequest request)
protected Queue<WriteMessage>	buildQueue()	Build write queue for session
protected NioSession	buildSession(SocketChannel sc)
private void	cancelKey(SelectionKey key)
void	closeChannel(Selector selector)
Future<Boolean>	connect(InetSocketAddressWrapper addressWrapper)
protected MemcachedTCPSession	createSession(SocketChannel socketChannel, InetSocketAddressWrapper wrapper)
protected void	doStart()	Inner startup
final Session	findSessionByKey(String key)
private MemcachedSession	findStandbySession(MemcachedSession session)
BufferAllocator	getBufferAllocator()
long	getHealSessionInterval()
FlowControl	getNoReplyOpsFlowControl()	Returns the noreply operations flow control manager.
Protocol	getProtocol()
Queue<ReconnectRequest>	getReconnectRequestQueue()
Collection<InetSocketAddress>	getServerAddresses()
final Queue<Session>	getSessionByAddress(InetSocketAddress addr)	Get session by InetSocketAddress
List<Session>	getSessionListBySocketAddress(InetSocketAddress inetSocketAddress)
Set<Session>	getSessionSet()
List<Session>	getStandbySessionListByMainNodeAddr(InetSocketAddress addr)	Returns main node's standby session list.
void	onConnect(SelectionKey key)
void	quitAllSessions()	Make all connection sending a quit command to memcached
private void	removeMainSession(Session session)
void	removeReconnectRequest(InetSocketAddress inetSocketAddress)
void	removeSession(Session session)
private void	removeStandbySession(Session session, InetSocketAddress mainNodeAddr)
Session	send(Command msg)
void	setBufferAllocator(BufferAllocator allocator)
final void	setConnectionPoolSize(int poolSize)
void	setEnableHealSession(boolean enableHealSession)
void	setFailureMode(boolean failureMode)
final void	setHealSessionInterval(long healConnectionInterval)
void	setMergeFactor(int mergeFactor)
void	setOptimizeGet(boolean optimiezeGet)
void	setOptimizeMergeBuffer(boolean optimizeMergeBuffer)
void	setSessionComparator(MemcachedSessionComparator sessionComparator)
void	setSessionLocator(MemcachedSessionLocator sessionLocator)
void	shuttingDown()
final void	updateSessions()

Methods inherited from class SocketChannelController

configureSocketChannel, dispatchReadEvent, dispatchWriteEvent, setSoLinger

Methods inherited from class NioController

bind, buildSessionConfig, closeSelectionKey, getSelectorManager, getSelectorPoolSize, initialSelectorManager, onRead, onWrite, setSelectorPoolSize, start0, stop0

Methods inherited from class AbstractController

addStateListener, bind, checkStatisticsForRestart, getCodecFactory, getConfiguration, getDispatchMessageThreadCount, getHandler, getLocalSocketAddress, getPort, getReadThreadCount, getReceiveThroughputLimit, getSendThroughputLimit, getSessionIdleTimeout, getSessionTimeout, getSocketOption, getSoTimeout, getStatistics, getWriteThreadCount, isHandleReadWriteConcurrently, isStarted, notifyAllSessionClosed, notifyException, notifyReady, notifyStarted, notifyStopped, onAccept, registerSession, removeStateListener, setCodecFactory, setConfiguration, setDispatchMessageThreadCount, setHandler, setHandleReadWriteConcurrently, setLocalSocketAddress, setReadThreadCount, setReceiveThroughputLimit, setSendThroughputLimit, setSessionIdleTimeout, setSessionTimeout, setSocketOption, setSocketOptions, setSoTimeout, setWriteThreadCount, start, stop, unregisterSession

Methods inherited from class Object

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

Methods inherited from interface Connector

setSocketOptions

Methods inherited from interface Controller

addStateListener, getCodecFactory, getDispatchMessageThreadCount, getHandler, getLocalSocketAddress, getPort, getReadThreadCount, getReceiveThroughputLimit, getSendThroughputLimit, getSessionIdleTimeout, getSessionTimeout, getSoTimeout, getStatistics, getWriteThreadCount, isHandleReadWriteConcurrently, isStarted, removeStateListener, setCodecFactory, setDispatchMessageThreadCount, setHandler, setHandleReadWriteConcurrently, setLocalSocketAddress, setReadThreadCount, setReceiveThroughputLimit, setSendThroughputLimit, setSessionIdleTimeout, setSessionTimeout, setSocketOption, setSoTimeout, setWriteThreadCount, start, stop

Methods inherited from interface SelectionKeyHandler

onAccept

Field Details

waitingQueue

private final DelayQueue<ReconnectRequest> waitingQueue

bufferAllocator

private BufferAllocator bufferAllocator

removedAddrSet

private final Set<InetSocketAddress> removedAddrSet

optimiezer

private final MemcachedOptimizer optimiezer

healSessionInterval

private long healSessionInterval

connectionPoolSize

private int connectionPoolSize

protocol

protected Protocol protocol

enableHealSession

private boolean enableHealSession

commandFactory

private final CommandFactory commandFactory

failureMode

private boolean failureMode

standbySessionMap

private final ConcurrentHashMap<InetSocketAddress, List<Session>> standbySessionMap

flowControl

private final FlowControl flowControl

shuttingDown

private volatile boolean shuttingDown

sessionLocator

protected MemcachedSessionLocator sessionLocator

sessionComparator

protected MemcachedSessionComparator sessionComparator

sessionMap

protected final ConcurrentHashMap<InetSocketAddress, Queue<Session>> sessionMap

random

private final Random random

sessionMonitor

private final MemcachedConnector.SessionMonitor sessionMonitor

Constructor Details

MemcachedConnector

public MemcachedConnector(Configuration configuration,
 MemcachedSessionLocator locator,
 MemcachedSessionComparator comparator,
 BufferAllocator allocator,
 CommandFactory commandFactory,
 int poolSize,
 int maxQueuedNoReplyOperations)

Method Details

shuttingDown

public void shuttingDown()

setSessionLocator

public void setSessionLocator(MemcachedSessionLocator sessionLocator)

Specified by:

setSessionLocator in interface Connector

setSessionComparator

public void setSessionComparator(MemcachedSessionComparator sessionComparator)

Specified by:

setSessionComparator in interface Connector

setEnableHealSession

public void setEnableHealSession(boolean enableHealSession)

Specified by:

setEnableHealSession in interface Connector

getReconnectRequestQueue

public Queue<ReconnectRequest> getReconnectRequestQueue()

Specified by:

getReconnectRequestQueue in interface Connector

getSessionSet

public Set<Session> getSessionSet()

Specified by:

getSessionSet in interface Connector

Overrides:

getSessionSet in class AbstractController

setHealSessionInterval

public final void setHealSessionInterval(long healConnectionInterval)

Specified by:

setHealSessionInterval in interface Connector

getHealSessionInterval

public long getHealSessionInterval()

Specified by:

getHealSessionInterval in interface Connector

setOptimizeGet

public void setOptimizeGet(boolean optimiezeGet)

Specified by:

setOptimizeGet in interface Connector

setOptimizeMergeBuffer

public void setOptimizeMergeBuffer(boolean optimizeMergeBuffer)

Specified by:

setOptimizeMergeBuffer in interface Connector

getProtocol

public Protocol getProtocol()

addSession

public void addSession(Session session)

addMainSession

private void addMainSession(Session session,
 InetSocketAddress lastReolvedAddr,
 InetSocketAddressWrapper addrWrapper)

addStandbySession

private void addStandbySession(Session session,
 InetSocketAddress mainNodeAddress,
 InetSocketAddress lastResolvedMainAddr,
 InetSocketAddressWrapper addrWrapper)

getSessionListBySocketAddress

public List<Session> getSessionListBySocketAddress(InetSocketAddress inetSocketAddress)

removeReconnectRequest

public void removeReconnectRequest(InetSocketAddress inetSocketAddress)

Specified by:

removeReconnectRequest in interface Connector

updateSessions

public final void updateSessions()

Specified by:

updateSessions in interface Connector

removeSession

public void removeSession(Session session)

Specified by:

removeSession in interface Connector

removeMainSession

private void removeMainSession(Session session)

removeStandbySession

private void removeStandbySession(Session session,
 InetSocketAddress mainNodeAddr)

doStart

protected void doStart()
                throws IOException

Description copied from class: NioController

Inner startup

Specified by:

doStart in class NioController

Throws:

IOException

onConnect

public void onConnect(SelectionKey key)
               throws IOException

Specified by:

onConnect in interface SelectionKeyHandler

Overrides:

onConnect in class AbstractController

Throws:

IOException

cancelKey

private void cancelKey(SelectionKey key)
                throws IOException

Throws:

IOException

createSession

protected MemcachedTCPSession createSession(SocketChannel socketChannel,
 InetSocketAddressWrapper wrapper)

addToWatingQueue

public void addToWatingQueue(ReconnectRequest request)

Specified by:

addToWatingQueue in interface Connector

connect

public Future<Boolean> connect(InetSocketAddressWrapper addressWrapper)

Specified by:

connect in interface Connector

closeChannel

public void closeChannel(Selector selector)
                  throws IOException

Specified by:

closeChannel in interface SelectionKeyHandler

Throws:

IOException

send

public Session send(Command msg)
             throws MemcachedException

Specified by:

send in interface Connector

Throws:

MemcachedException

findStandbySession

private MemcachedSession findStandbySession(MemcachedSession session)

getStandbySessionListByMainNodeAddr

public List<Session> getStandbySessionListByMainNodeAddr(InetSocketAddress addr)

Returns main node's standby session list.

Specified by:

getStandbySessionListByMainNodeAddr in interface Connector

Parameters:

addr -

Returns:

findSessionByKey

public final Session findSessionByKey(String key)

getSessionByAddress

public final Queue<Session> getSessionByAddress(InetSocketAddress addr)

Get session by InetSocketAddress

Specified by:

getSessionByAddress in interface Connector

Parameters:

addr -

Returns:

setConnectionPoolSize

public final void setConnectionPoolSize(int poolSize)

Specified by:

setConnectionPoolSize in interface Connector

setMergeFactor

public void setMergeFactor(int mergeFactor)

Specified by:

setMergeFactor in interface Connector

getNoReplyOpsFlowControl

public FlowControl getNoReplyOpsFlowControl()

Description copied from interface: Connector

Returns the noreply operations flow control manager.

Specified by:

getNoReplyOpsFlowControl in interface Connector

Returns:

buildSession

protected NioSession buildSession(SocketChannel sc)

Overrides:

buildSession in class SocketChannelController

buildQueue

protected Queue<WriteMessage> buildQueue()

Build write queue for session

Overrides:

buildQueue in class AbstractController

Returns:

getBufferAllocator

public BufferAllocator getBufferAllocator()

quitAllSessions

public void quitAllSessions()

Description copied from interface: Connector

Make all connection sending a quit command to memcached

Specified by:

quitAllSessions in interface Connector

setFailureMode

public void setFailureMode(boolean failureMode)

Specified by:

setFailureMode in interface Connector

setBufferAllocator

public void setBufferAllocator(BufferAllocator allocator)

Specified by:

setBufferAllocator in interface Connector

getServerAddresses

public Collection<InetSocketAddress> getServerAddresses()