Tomcat的Session管理(二) - Session后台处理

Tomcat会开启一个后台线程每隔一段时间检查Session的有效性，这个线程是在Tomcat启动的时候当StardardEngine启动时随之启动的。可以参看StardardEngine的基类ContainerBase的#threadStart()方法：

Java代码



protected void threadStart() {

if (thread != null)

return;

if (backgroundProcessorDelay <= 0)

return;

threadDone = false;

String threadName = "ContainerBackgroundProcessor[" + toString() + "]";

// 开启后台的监控线程

thread = new Thread(new ContainerBackgroundProcessor(), threadName);

thread.setDaemon(true);

thread.start();

}

这个方法启动了一个ContainerBackgroundProcessor类的线程，这个类重写的#run()方法中包括了对Session的有效性监控。具体的细节就不详细陈述了。每隔一段时间，此线程就会启动一次并调用了ManageBase的#backgroundProcess()方法。其源代码如下：

Java代码



public void backgroundProcess() {

count = (count + 1) % processExpiresFrequency;

if (count == 0)

processExpires();

}

每隔一段时间就会调用processExpires()方法去判断Session的有效性。

Java代码



public void processExpires() {

// 现在的时间

long timeNow = System.currentTimeMillis();

// 所有的Session对象

Session sessions[] = findSessions();

int expireHere = 0;

if (log.isDebugEnabled())

log.debug("Start expire sessions " + getName() + " at " + timeNow + " sessioncount "

+ sessions.length);

for (int i = 0; i < sessions.length; i++) {

// 判断并设定Session是否失效

if (sessions[i] != null && !sessions[i].isValid()) {

expireHere++;

}

}

long timeEnd = System.currentTimeMillis();

if (log.isDebugEnabled())

log.debug("End expire sessions " + getName() + " processingTime " + (timeEnd - timeNow)

+ " expired sessions: " + expireHere);

processingTime += (timeEnd - timeNow);

}

此方法最终调用了isValid()去判断和设定Session是否失效，源代码如下所示：

Java代码



public boolean isValid() {

// 是否过期

if (this.expiring) {

return true;

}

// 是否有效

if (!this.isValid) {

return false;

}

// 正在使用中并且访问数大于0

if (ACTIVITY_CHECK && accessCount.get() > 0) {

return true;

}

if (maxInactiveInterval >= 0) {

// 判断Session是否过期

long timeNow = System.currentTimeMillis();

int timeIdle = (int) ((timeNow - thisAccessedTime) / 1000L);

if (timeIdle >= maxInactiveInterval) {

// 设定Session过期

expire(true);

}

}

return (this.isValid);

}