丨manager組件tomcatsession管理機(jī)制解析

樣。今天我們就從Session的創(chuàng)建、Session的清理以及Session的通知這幾個(gè)方面來了解Tomcat的Session管理機(jī)制。SessionTomcatContextManagerSession。默認(rèn)實(shí)現(xiàn)類為StandardManager。下面我們通過它的接口來了解一下StandardManager的功能：publicinterfaceManagerpublicContextpublicvoidsetContext(ContextpublicSessionIdGeneratorpublicvoidsetSessionIdGenerator(SessionIdGeneratorpubliclongpublicvoidsetSessionCounter(longpublicintpublicvoidsetMaxActive(intpublicintpubliclongpublicvoidsetExpiredSessions(longpublicintpublicintpublicvoidsetSessionMaxAliveTime(intpublicintgetSessiopublicintgetSessionCreapublicintpublicvoidadd(SessionpublicvoidchangeSessionId(SessionpublicvoidchangeSessionId(Sessionsession,StringpublicSessionpublicSessioncreateSession(StringpublicSessionfindSession(Stringid)throwspublicSession[]publicvoidload()throwsClassNotFoundException,publicvoidremove(Sessionpublicvoidremove(Sessionsession,booleanpublicvoidaddPropertyChangeListener(PropertyChangeListenerpublicvoidremovePropertyChangeListener(PropertyChangeListenerpublicvoidunload()throwspublicvoidpublicbooleanwillAttributeDistribute(Stringname,Object34Sessionloadunload法，它們的作用是分別是將Session持久化到介質(zhì)和從介質(zhì)加載Session。當(dāng)我們調(diào)用HttpServletRequest.getSession(true)時(shí)，這個(gè)參數(shù)true的意思Session，TomcatHttpServletRequest，Tomcatorg.apach但這并不是我們拿到的Request，Tomcat為了避免把一些實(shí)現(xiàn)細(xì)節(jié)出來，還有基于RequestRequestFacade，我們可以通過代碼來理1publicclassRequestimplementsHttpServletRequestpublicclassRequestFacadeimplementsHttpServletRequestprotectedRequestrequest=3publicHttpSessiongetSession(booleancreate)return 7因此我們拿到的Request類其實(shí)是RequestFacade，RequestFacade的getSession方法調(diào)用的是Request類的getSession方法，我們繼續(xù)來看SessionContextcontext=if(context==null)return45Managermanager=if(manager==null)return9session=從上面的代碼可以看出，RequestContextContextSession管理器Manager，這樣通過Context組件就能拿到Manager組件，最后由Manager組件來創(chuàng)建Session。StandardManager，StandardManagerManagerBase，這個(gè)createSession方法定義在ManagerBase中，StandardManager直接重用這個(gè)方ManagerBase的createSessionpublicSessioncreateSession(StringsessionId)//首先判斷Session數(shù)量是不是到了最大值，最大Sessionif((maxActiveSessions>=0)(getActiveSessions()>=maxActiveSessions))thrownewTooManyActiveSession //重用或者創(chuàng)建一個(gè)新的Session對象，請注意在Tomcat中就是//它是HttpSession的具體實(shí)現(xiàn)類，而HttpSession是ServletSessionsession=//初始化新Sessionsession.setMaxInactiveInterval(getContext().getSessionTimeout()*Stringid=if(id==null)id= session.setId(id);//這里會(huì)將Session添加到ConcurrentHashMap //將創(chuàng)建時(shí)間添加到LinkedList //主要還是方便清理過期 SessionTimingtiming=newSessionTiming(session.getCreationTime(), synchronized(sessionCreationTiming) return371protectedMap<String,Session>sessions=new請注意Session的具體實(shí)現(xiàn)類是tandardession，Sanardession同時(shí)實(shí)現(xiàn)了javax.ervlethttp.HtpSession和org.apche.caalina.ession接口，并且對程序員的是tandardessionFaae外觀類，保證了tandardession的安全，避免了程序員調(diào)用其內(nèi)部方法進(jìn)行不當(dāng)操作。Stanaression的成員變量如下：publicclassStandardSessionimplementsHttpSession,Session,SerializableprotectedConcurrentMap<String,Object>attributes=newprotectedlongcreationTime=protectedtransientvolatilebooleanexpiring=protectedtransientStandardSessionFacadefacade=protectedStringid=protectedvolatilelonglastAccessedTime=protectedtransientArrayList<SessionListener>listeners=newprotectedtransientManagermanager=protectedvolatileintmaxInactiveInterval=-protectedvolatilebooleanisNew=protectedvolatilebooleanisValid=protectedtransientMap<String,Object>notes=newprotectedtransientPrincipalprincipal=15Session我們再來看看Tomat是如何清理過期的Session。在Tomcat熱加載和熱部署的文章里，我講到容器組件會(huì)開啟一個(gè)ConaierBackrondProcessor線程，調(diào)用自己以及子容器的akgrounProess進(jìn)行一些邏輯的處理，和Lifecye一樣，這個(gè)動(dòng)作也是具有傳遞性的，也就是說子容器還會(huì)把這個(gè)動(dòng)作傳遞給自己的子容器。你可以參考下圖來理解這個(gè)過程。其中父容器會(huì)遍歷所有的子容器并調(diào)用其backgroundProcess方法，而StandardContextStandardManagerbackgroundProcessSessionStandardManagerbackgroundProcesspublicvoidbackgroundProcess()// piresFrequency默認(rèn)值為6，而backgroundProcess默認(rèn)每隔10scount=(count+1)%procesif(count==0)//默認(rèn)每隔60s執(zhí)行一次Session678*單線程處理，不存程安全問publicvoid pires()//獲取所有的Sessionsessions[]=intexpireHere=0for(inti=0;i<sessions.length;i++)//Session的過期是在isValid()22

if(sessions[i]!=null&&{}}backgroundProcess由Tomcat線程調(diào)用，默認(rèn)是每隔10秒調(diào)用一次，但是SessionSessionCPUbackgroundProcess方法中做了取模處理，backgroundProcess6Session清理，也就是說Session清理每60秒執(zhí)行一次。Session通按照Servlet規(guī)范，在Session的生命周期過程中，要將通知者，Servlet規(guī)范定義了Session的器接口：publicinterfaceHttpSessionListenerextendsEventListener//SessionpublicdefaultvoidsessionCreated(HttpSessionEventse)}5//SessionpublicdefaultvoidsessionDestroyed(HttpSessionEventse)}9注意到這兩個(gè)方法的參數(shù)都是HttpSessionEvent，所以Tomcat需要先創(chuàng)建HttpSessionEvent對象，然后遍歷Context內(nèi)部的LifecycleListener，并且判斷是否為HttpSessionListenerHttpSessionListenersessionCreated方法進(jìn)行通知。這些事情都是在Session的setId方法中完成的：2publicvoidsetId(Stringid,booleannotify)//如果這個(gè)id已經(jīng)存在，先從Managerif((this.id!=null)&&(manager!=789this.id=//添加新的if(manager!=//這里面完成了if(notify)19}從代碼我們看到setId方法調(diào)用 lNew方法， publicvoidlNew()2//通知fireSessionEvent(Session.SESSION_CREATED_EVENT,5//獲取Context內(nèi)部的LifecycleListener并判斷是否為Contextcontext=Objectlisteners[]=if(listeners!=null&&listeners.length>0)//創(chuàng)建HttpSessionEventevent=newfor(inti=0;i<listeners.length;i++)//判斷是否是if(!(listeners[i]instanceofHttpSessionListenerlistener=(HttpSessionListener)//context.fireContainerEvent("beforeSessionCreated",//觸發(fā)SessionCreated//context.fireContainerEvent(