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

2021-10-21 03:25:02

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

Java代码 Tomcat的Session管理(二) - Session后台处理 Tomcat的Session管理(二) - Session后台处理
  1. protected void threadStart() {   
  2.     if (thread != null)   
  3.         return;   
  4.     if (backgroundProcessorDelay 0)   
  5.         return;   
  6.        
  7.     threadDone = false;   
  8.     String threadName = "ContainerBackgroundProcessor[" + toString() + "]";   
  9.     // 开启后台的监控线程   
  10.     thread = new Thread(new ContainerBackgroundProcessor(), threadName);   
  11.     thread.setDaemon(true);   
  12.     thread.start();   
  13.   
  14. }  
protected void threadStart() { if (thread != null) return; if (backgroundProcessorDelay
这个方法启动了一个ContainerBackgroundProcessor类的线程，这个类重写的#run()方法中包括了对Session的有效性监控。具体的细节就不详细陈述了。每隔一段时间，此线程就会启动一次并调用了ManageBase的#backgroundProcess()方法。其源代码如下：

Java代码 Tomcat的Session管理(二) - Session后台处理 Tomcat的Session管理(二) - Session后台处理
  1. public void backgroundProcess() {   
  2.     count = (count + 1) % proces***piresFrequency;   
  3.     if (count == 0)   
  4.         proces***pires();   
  5. }  
public void backgroundProcess() { count = (count + 1) % proces***piresFrequency; if (count == 0) proces***pires(); }

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

Java代码 Tomcat的Session管理(二) - Session后台处理 Tomcat的Session管理(二) - Session后台处理
  1. public void proces***pires() {   
  2.     // 现在的时间   
  3.     long timeNow = System.currentTimeMillis();   
  4.     // 所有的Session对象   
  5.     Session sessions[] = findSessions();   
  6.     int expireHere = 0;   
  7.   
  8.     if (log.isDebugEnabled())   
  9.         log.debug("Start expire sessions " + getName() + " at " + timeNow + " sessioncount "  
  10.                 + sessions.length);   
  11.     for (int i = 0; i 
  12.         // 判断并设定Session是否失效   
  13.         if (sessions[i] != null && !sessions[i].isValid()) {   
  14.             expireHere++;   
  15.         }   
  16.     }   
  17.     long timeEnd = System.currentTimeMillis();   
  18.     if (log.isDebugEnabled())   
  19.         log.debug("End expire sessions " + getName() + " processingTime " + (timeEnd - timeNow)   
  20.                 + " expired sessions: " + expireHere);   
  21.     processingTime += (timeEnd - timeNow);   
  22.   
  23. }  
public void proces***pires() { // 现在的时间 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
此方法最终调用了isValid()去判断和设定Session是否失效，源代码如下所示：

Java代码 Tomcat的Session管理(二) - Session后台处理 Tomcat的Session管理(二) - Session后台处理
  1. public boolean isValid() {   
  2.     // 是否过期   
  3.     if (this.expiring) {   
  4.         return true;   
  5.     }   
  6.     // 是否有效   
  7.     if (!this.isValid) {   
  8.         return false;   
  9.     }   
  10.     // 正在使用中并且访问数大于0   
  11.     if (ACTIVITY_CHECK && accessCount.get() > 0) {   
  12.         return true;   
  13.     }   
  14.   
  15.     if (maxInactiveInterval >= 0) {   
  16.         // 判断Session是否过期   
  17.         long timeNow = System.currentTimeMillis();   
  18.         int timeIdle = (int) ((timeNow - thisAccessedTime) / 1000L);   
  19.         if (timeIdle >= maxInactiveInterval) {   
  20.             // 设定Session过期   
  21.             expire(true);   
  22.         }   
  23.     }   
  24.   
  25.     return (this.isValid);   
  26. }  
上一篇：SQL优化常用方法50


下一篇：linux监控命令