public class MongoSessionIdManager extends AbstractSessionIdManager
Theory is that we really only need the session id manager for the local instance so we have something to scavenge on, namely the list of known ids
This class has a timer that runs a periodic scavenger thread to query for all id's known to this node whose precalculated expiry time has passed.
These found sessions are then run through the invalidateAll(id) method that is a bit hinky but is supposed to notify all handlers this id is now DOA and ought to be cleaned up. this ought to result in a save operation on the session that will change the valid field to false (this conjecture is unvalidated atm)
Modifier and Type | Class and Description |
---|---|
protected class |
MongoSessionIdManager.Purger
Purger
|
protected class |
MongoSessionIdManager.Scavenger
Scavenger
|
AbstractLifeCycle.AbstractLifeCycleListener
LifeCycle.Listener
Modifier and Type | Field and Description |
---|---|
protected boolean |
_ownScheduler |
protected Scheduler.Task |
_purgerTask |
protected Scheduler.Task |
_scavengerTask |
protected Scheduler |
_scheduler |
protected Server |
_server |
protected Set<String> |
_sessionsIds
the collection of session ids known to this manager
|
_random, _reseed, _weakRandom, _workerAttr, _workerName
Constructor and Description |
---|
MongoSessionIdManager(Server server) |
MongoSessionIdManager(Server server,
com.mongodb.DBCollection sessions) |
Modifier and Type | Method and Description |
---|---|
void |
addSession(HttpSession session)
Add a session to the list of known sessions for a given ID.
|
protected void |
doStart() |
protected void |
doStop() |
void |
expireAll(String sessionId)
Expire this session for all contexts that are sharing the session
id.
|
long |
getPurgeInvalidAge() |
int |
getPurgeLimit() |
long |
getPurgeValidAge() |
int |
getScavengeBlockSize() |
com.mongodb.DBCollection |
getSessions() |
boolean |
idInUse(String sessionId)
Searches database to find if the session id known to mongo, and is it valid
|
void |
idle() |
void |
invalidateAll(String sessionId)
Remove the session id from the list of in-use sessions.
|
boolean |
isPurgeEnabled() |
protected void |
purge()
Purge is a process that cleans the mongodb cluster of old sessions that are no
longer valid.
|
protected void |
purgeFully()
Purge is a process that cleans the mongodb cluster of old sessions that are no
longer valid.
|
void |
removeSession(HttpSession session)
Remove session from the list of known sessions for a given ID.
|
void |
renewSessionId(String oldClusterId,
String oldNodeId,
HttpServletRequest request)
Change the existing session id.
|
protected void |
scavenge()
Scavenge is a process that periodically checks the tracked session
ids of this given instance of the session id manager to see if they
are past the point of expiration.
|
protected void |
scavengeBlock(long atTime,
Set<String> ids)
Check a block of session ids for expiry and thus scavenge.
|
protected void |
scavengeFully()
ScavengeFully will expire all sessions.
|
void |
setPurge(boolean purge) |
void |
setPurgeDelay(long purgeDelay) |
void |
setPurgeInvalidAge(long purgeValidAge)
sets how old a session is to be persisted past the point it is
no longer valid
|
void |
setPurgeLimit(int purgeLimit)
The maximum number of items to return from a purge query.
|
void |
setPurgeValidAge(long purgeValidAge)
sets how old a session is to be persist past the point it is
considered no longer viable and should be removed
NOTE: set this value to 0 to disable purging of valid sessions
|
void |
setScavengeBlockSize(int size)
When scavenging, the max number of session ids in the query.
|
void |
setScavengePeriod(long scavengePeriod)
The period in seconds between scavenge checks.
|
getClusterId, getNodeId, getRandom, getReseed, getWorkerName, initRandom, newSessionId, newSessionId, setRandom, setReseed, setWorkerName
addLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, setStopTimeout, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addLifeCycleListener, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop
protected Server _server
protected Scheduler _scheduler
protected boolean _ownScheduler
protected Scheduler.Task _scavengerTask
protected Scheduler.Task _purgerTask
public MongoSessionIdManager(Server server) throws UnknownHostException, com.mongodb.MongoException
UnknownHostException
com.mongodb.MongoException
public MongoSessionIdManager(Server server, com.mongodb.DBCollection sessions)
protected void scavenge()
protected void scavengeBlock(long atTime, Set<String> ids)
atTime
- purge at timeids
- set of session idsprotected void scavengeFully()
protected void purge()
protected void purgeFully()
public com.mongodb.DBCollection getSessions()
public boolean isPurgeEnabled()
public void setPurge(boolean purge)
public void setScavengePeriod(long scavengePeriod)
scavengePeriod
- the scavenge period in secondspublic void setScavengeBlockSize(int size)
size
- the scavenge block sizepublic int getScavengeBlockSize()
public void setPurgeLimit(int purgeLimit)
purgeLimit
- the purge limitpublic int getPurgeLimit()
public void setPurgeDelay(long purgeDelay)
public long getPurgeInvalidAge()
public void setPurgeInvalidAge(long purgeValidAge)
purgeValidAge
- the purge valid agepublic long getPurgeValidAge()
public void setPurgeValidAge(long purgeValidAge)
purgeValidAge
- the purge valid ageprotected void doStart() throws Exception
doStart
in class AbstractSessionIdManager
Exception
protected void doStop() throws Exception
doStop
in class AbstractSessionIdManager
Exception
public boolean idInUse(String sessionId)
sessionId
- The session ID without any cluster node extensionpublic void addSession(HttpSession session)
SessionIdManager
session
- The sessionpublic void removeSession(HttpSession session)
SessionIdManager
session
- the session to removepublic void invalidateAll(String sessionId)
sessionId
- The session ID without any cluster node extensionSessionIdManager.invalidateAll(java.lang.String)
public void expireAll(String sessionId)
sessionId
- the session idpublic void idle()
public void renewSessionId(String oldClusterId, String oldNodeId, HttpServletRequest request)
SessionIdManager
renewSessionId
in interface SessionIdManager
renewSessionId
in class AbstractSessionIdManager
oldClusterId
- the old cluster idoldNodeId
- the old node idrequest
- the request containing the sessionCopyright © 1995-2016 Webtide. All Rights Reserved.