Package net.rubyeye.xmemcached.impl

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

Author:

dennis

Field Summary

Fields

Modifier and Type	Field	Description
protected Protocol	protocol
protected MemcachedSessionComparator	sessionComparator
protected MemcachedSessionLocator	sessionLocator
protected ConcurrentHashMap<InetSocketAddress,Queue<Session>>	sessionMap

Fields inherited from class com.google.code.yanf4j.nio.impl.SocketChannelController

soLingerOn

Fields inherited from class com.google.code.yanf4j.nio.impl.NioController

selectorManager, selectorPoolSize

Fields inherited from class com.google.code.yanf4j.core.impl.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
void	addSession(Session session)
void	addToWatingQueue(ReconnectRequest request)
protected Queue<WriteMessage>	buildQueue()	Build write queue for session
protected NioSession	buildSession(SocketChannel sc)
void	closeChannel(Selector selector)
Future<Boolean>	connect(InetSocketAddressWrapper addressWrapper)
protected MemcachedTCPSession	createSession(SocketChannel socketChannel, InetSocketAddressWrapper wrapper)
protected void	doStart()	Inner startup
Session	findSessionByKey(String key)
BufferAllocator	getBufferAllocator()
long	getHealSessionInterval()
FlowControl	getNoReplyOpsFlowControl()	Returns the noreply operations flow control manager.
Protocol	getProtocol()
Queue<ReconnectRequest>	getReconnectRequestQueue()
Collection<InetSocketAddress>	getServerAddresses()
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
void	removeReconnectRequest(InetSocketAddress inetSocketAddress)
void	removeSession(Session session)
Session	send(Command msg)
void	setBufferAllocator(BufferAllocator allocator)
void	setConnectionPoolSize(int poolSize)
void	setEnableHealSession(boolean enableHealSession)
void	setFailureMode(boolean failureMode)
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()
void	updateSessions()

Methods inherited from class com.google.code.yanf4j.nio.impl.SocketChannelController

configureSocketChannel, dispatchReadEvent, dispatchWriteEvent, setSoLinger

Methods inherited from class com.google.code.yanf4j.nio.impl.NioController

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

Methods inherited from class com.google.code.yanf4j.core.impl.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 java.lang.Object

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

Methods inherited from interface net.rubyeye.xmemcached.networking.Connector

setSocketOptions

Methods inherited from interface com.google.code.yanf4j.core.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 com.google.code.yanf4j.nio.SelectionKeyHandler

onAccept

Field Detail

protocol

protected Protocol protocol

sessionLocator

protected MemcachedSessionLocator sessionLocator

sessionComparator

protected MemcachedSessionComparator sessionComparator

sessionMap

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

Constructor Detail

MemcachedConnector

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

Method Detail

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)

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

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

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

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()