Package net.rubyeye.xmemcached.impl

Class KetamaMemcachedSessionLocator

java.lang.Object

net.rubyeye.xmemcached.impl.AbstractMemcachedSessionLocator

net.rubyeye.xmemcached.impl.KetamaMemcachedSessionLocator

All Implemented Interfaces:

MemcachedSessionLocator

public class KetamaMemcachedSessionLocator
extends AbstractMemcachedSessionLocator

Consistent Hash Algorithm implementation,based on TreeMap.tailMap(hash) method.

Author:

dennis

Field Summary

Fields inherited from class net.rubyeye.xmemcached.impl.AbstractMemcachedSessionLocator

failureMode

Constructor Summary

Constructors

Constructor	Description
KetamaMemcachedSessionLocator()	Create a KetamaMemcachedSessionLocator with default config.
KetamaMemcachedSessionLocator(boolean cwNginxUpstreamConsistent)	Create a KetamaMemcachedSessionLocator
KetamaMemcachedSessionLocator(List<Session> list, HashAlgorithm alg)
KetamaMemcachedSessionLocator(HashAlgorithm alg)	Create a KetamaMemcachedSessionLocator with a special hash algorithm.
KetamaMemcachedSessionLocator(HashAlgorithm alg, boolean cwNginxUpstreamConsistent)
KetamaMemcachedSessionLocator(HashAlgorithm alg, boolean cwNginxUpstreamConsistent, boolean gwhalinMemcachedJavaClientCompatibiltyConsistent)

Method Summary

Modifier and Type	Method	Description
Session	getSessionByHash(long hash)
Session	getSessionByKey(String key)	Returns a session by special key.
long	nextHash(long hashVal, String key, int tries)
void	updateSessions(Collection<Session> list)	Update sessions when session was added or removed.

Methods inherited from class net.rubyeye.xmemcached.impl.AbstractMemcachedSessionLocator

setFailureMode

Methods inherited from class java.lang.Object

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

Constructor Detail

KetamaMemcachedSessionLocator

public KetamaMemcachedSessionLocator()

Create a KetamaMemcachedSessionLocator with default config.

KetamaMemcachedSessionLocator

public KetamaMemcachedSessionLocator(boolean cwNginxUpstreamConsistent)

Create a KetamaMemcachedSessionLocator

Parameters:

cwNginxUpstreamConsistent - true if compatible with nginx up stream memcached consistent algorithm.

KetamaMemcachedSessionLocator

public KetamaMemcachedSessionLocator(HashAlgorithm alg)

Create a KetamaMemcachedSessionLocator with a special hash algorithm.

Parameters:

alg -

KetamaMemcachedSessionLocator

public KetamaMemcachedSessionLocator(HashAlgorithm alg,
                                     boolean cwNginxUpstreamConsistent)

KetamaMemcachedSessionLocator

public KetamaMemcachedSessionLocator(HashAlgorithm alg,
                                     boolean cwNginxUpstreamConsistent,
                                     boolean gwhalinMemcachedJavaClientCompatibiltyConsistent)

KetamaMemcachedSessionLocator

public KetamaMemcachedSessionLocator(List<Session> list,
                                     HashAlgorithm alg)

Method Detail

getSessionByKey

public final Session getSessionByKey(String key)

Description copied from interface: MemcachedSessionLocator

Returns a session by special key.

Returns:

getSessionByHash

public final Session getSessionByHash(long hash)

nextHash

public final long nextHash(long hashVal,
                           String key,
                           int tries)

updateSessions

public final void updateSessions(Collection<Session> list)

Description copied from interface: MemcachedSessionLocator

Update sessions when session was added or removed.

Parameters:

list - The newer sessions