如果運行測試失敗，可以使用下面的JAVAGROUP方法測試機器的多目傳輸性：

啟動多目接收器：

java org.javagroups.tests.McastReceiverTest -mcast_addr 224.10.10.10 -port 5555

啟動多目傳輸器：

java org.javagroups.tests.McastSenderTest -mcast_addr 224.10.10.10 -port 5555

這樣你在McastSenderTest窗口中輸入內(nèi)容，應該在McastReceiverWindow中可以看到結(jié)果。如果看不到結(jié)果，在McastSenderTest運行參數(shù)中加入-ttl 32，如果還不行，可以修改多目地址再試試（注意避開系統(tǒng)保留用的多目地址）；如果還不行，就去問問網(wǎng)管吧！

2.4.4 對tomcat-javagroups的修改

tomcat-javagroups.jar中的org.apache.catalina.session.ReplicatedSession類的removeAttribute方法會導致stackoverflow錯誤，請按下面的代碼對其進行修改：

public void removeAttribute(String name, boolean notify, boolean jgnotify) {

        super.removeAttribute(name);

        if ( jgnotify )

        {

            SessionMessage msg =

  new SessionMessage(notify?SessionMessage.EVT_ATTRIBUTE_REMOVED_WNOTIFY:SessionMessage.
                                 EVT_ATTRIBUTE_REMOVED_WONOTIFY,

                                                              null,

                                                              getId(),

                                                              name,

                                                              null,

                                                              null);

            sendMessage(msg);

        }

    }

     public void removeAttribute(String name, boolean notify) {

        removeAttribute(name,notify,true);

}

3 jetspeed集群

    我們現(xiàn)在知道了如何配置、甚至擁有一個集群環(huán)境，接下來本文分析Jetspeed的集群現(xiàn)狀，主要包括repository和Session數(shù)據(jù)；為了使分析具有目的，在分析Jetspeed的集群現(xiàn)狀之前，先講述了集群需求和RunData對象。讀者可以用集群環(huán)境來驗證和調(diào)試Jetspeed的集群功能。

3.1 集群要求

《Memory Session Replication》一文中講述了支持集群的應用程序需注意的要點，現(xiàn)在對關于應用系統(tǒng)開發(fā)時應注意的事項總結(jié)如下：

   
1. 保存在Session中的對象必須實現(xiàn)java.io.Serializable接口；
      
2. 從session中獲取對象修改后必須用session.setAttribute方法重置session中的屬性，因為只有setAttribute能導致session復制。
      
   
3. Java VM不支持類變量的序列化，所以要注意failover不能依賴類變量；
      
4. 保證各個服務實體的配置完全一樣；
      
5. 保證session狀態(tài)是唯一決定當前任務狀態(tài)的東西，臨時文件、類變量等會使得錯誤恢復難以實現(xiàn)、行為可能琢磨不定；
      
6. 利用request.setAttribute()保存當前請求級的狀態(tài)，減少服務實體間通信次數(shù)。
      
7. 盡量不要在session中保存大對象，提高服務實體間通信性能。

 

3.2 RunData對象

RunData對象概念來自于Turbine，在Jetspeed中RunData對象的類型是DefaultJetspeedRunData，這個類擴展了Turbine中的DefaultTurbineRunData類。Jetspeed系統(tǒng)接到用戶瀏覽器的URL請求，進行計算和信息處理，最后返回給瀏覽器HTTP代碼流的整個過程中的代碼都可以訪問同一個RunData對象。所以RunData對象是Jetspeed系統(tǒng)中各個代碼模塊共享信息的機制。

3.3 Jetspeed的Repository

    Repository 一般指一個軟件系統(tǒng)賴以啟動、運行的持久性環(huán)境，包括啟動Repository和運行Repository兩部分。啟動Repository用于決定系統(tǒng)啟動時的參數(shù)，系統(tǒng)運行時不會改變它，如果改變了這些參數(shù)，軟件系統(tǒng)必須重新啟動；運行Repository指實時影響軟件系統(tǒng)業(yè)務操作的參數(shù)，這些參數(shù)可以被用戶或管理員當系統(tǒng)在線時改變?，F(xiàn)在的趨勢是：盡量減少啟動Repository，而擴大運行Repository；針對Repository的修改最好能使用管理性框架，比如SNMP和JMX。Jetspeed的repository主要在Xreg、psml和Properties文件中實現(xiàn)。

   
1. Xreg是jetspeed的注冊表，用于登記portlet、control、controller、skin、mediatype等原始資源的定義，jetspeed中缺省地把它實現(xiàn)為文件形式，各種類型有自己的注冊表文件；
      
   
2. Psml 是門戶結(jié)構標記語言的簡稱，用于組織xreg中的原始資源形成一個對門戶視圖的定義，當用戶使用桌面瀏覽器訪問jetspeed系統(tǒng)時，這個系統(tǒng)根據(jù)用戶的URL定位一個Psml文檔，接著解釋這個文檔形成HTML代碼流返回給瀏覽器，瀏覽器展現(xiàn)這個代碼流從而形成視窗化的門戶視圖。Jetspeed中包括了對psml的數(shù)據(jù)庫和文件兩種實現(xiàn)方式；
      
   
3. Properties定義了Jetspeed的重要服務及其參數(shù)，目前只有文件實現(xiàn)方式。

 

Jetspeed的啟動Repository主要在Properties文件中，運行Repository在xreg和psml中。文件形式的實現(xiàn)大大阻礙了jetspeed支持集群的能力和表現(xiàn)，因為現(xiàn)在很少的應用服務器集群能在一個文件系統(tǒng)上運行，如果Repository需要在運行時改變，就必須同步多個服務實體上的文件，這是一個相當麻煩的問題。如果Repository支持數(shù)據(jù)庫實現(xiàn)形式，Jetspeed可以充分利用數(shù)據(jù)庫的存儲和同步機制實現(xiàn)同一個Repository服務于多個Jetspeed。所以要想 jetspeed支持集群、擁有更佳表現(xiàn)，對Repository的數(shù)據(jù)庫化是一個不可忽視的任務。

支持數(shù)據(jù)庫的集群配置如下圖：

src="/tea/image/section/13739.gif" width=500 align=baseline vspace=5
border=0>

這個圖顯示了在數(shù)據(jù)庫集群環(huán)境下的jetspeed集群配置，數(shù)據(jù)庫負載均衡器實現(xiàn)數(shù)據(jù)庫集群的單一影像，例子有weblogic server中的multipool datasource，sql server 基于的windows 2000集群的單一集群IP，ORACLE RAC 的支持多連接地址的thin jdbc driver。

3.4 Jetspeed的Session數(shù)據(jù)

    支持集群必須使得各個服務實體針對某個任務的執(zhí)行環(huán)境是相同的，對于jetspeed來說就是針對各個URL請求，session的數(shù)據(jù)能在各個jetspeed上復制。這些session被同一個sessionid所標識，這些標識可能來自瀏覽器的cookies或URL中。我們首先用一個velocityportlet來顯示Jetspeed的session中到底保存了什么數(shù)據(jù)，這個portlet的注冊名字為SessionPortlet。

3.4.1 SessionPortlet

SessionPortlet是一個velocityPortlet，其類名可以是CustomizerVelocityPortlet或VelocityPortlet，一般情況下沒有必要開發(fā)一個新的portlet class。關于如何開發(fā)部署portlet的教程可見參考部分，現(xiàn)在我們分注冊、控制助手、portlet模版和運行來講述這個portlet。

3.4.1.1 注冊

SessionPortlet用于顯示目前的session數(shù)據(jù)。它在xreg中的注冊代碼為：

3.4.1.2 控制助手Action

portlets.SessionAction是Velocityportlet模版portlet的控制助手，在velocity解釋模版前執(zhí)行：

public class SessionAction extends VelocityPortletAction {

	protected void buildNormalContext( VelocityPortlet portlet,

				Context context,

				RunData rundata )

	{

		Map map = new HashMap();

		Enumeration enumeration = rundata.getSession().getAttributeNames();

		while (enumeration.hasMoreElements()) {

			Object key = (Object) enumeration.nextElement();

			Object value = (Object)rundata.getSession().getAttribute(key.toString());

			map.put(key, value);

		}

		context.put("sessions",map);

	}

}

從上面的代碼可以看出，這個控制助手在模版的模型(ＭＶＣ中的M)環(huán)境中設置了一個保存了session數(shù)據(jù)的map數(shù)據(jù)結(jié)構。

3.4.1.3 portlet模版

SessionPortlet的模版文件是session.vm(ＭＶＣ中的V)，這個文件的內(nèi)容如下：

#foreach( $key in $sessions.keySet() )

	
Key: $key -> Value: $sessions.get($key)


#end

3.4.1.4 定制psml和運行SessionPortlet

用admin/jetspeed或turbine/turbine帳號／口令登錄到jetspeed系統(tǒng)后，可以在velocity.legend portlet分類中找到SessionPortlet，把它加入到你的psml中后可以看到SessionPortlet顯示的session數(shù)據(jù)（你可以多多點擊其它的URL，盡量地使jetspeed在session中多放一些數(shù)據(jù)）：

src="/tea/image/section/13740.gif" width=500 align=baseline vspace=5
border=0>

從上面的session快照可以看出，Jetspeed的session數(shù)據(jù)主要分為兩類：BaseJetspeedUser和JetspeedHttpStateManagerService$StateEntry，下面我們就分別來看看這兩個類的情況。

src="/tea/image/section/13741.gif" width=500 align=baseline vspace=5
border=0>

3.4.2 BaseJetspeedUser

我們從《Session數(shù)據(jù)類圖（部分）》可以看出BaseJetspeedUser實現(xiàn)了serializable接口。另外分析這個類及其父類的代碼可了解到這個類的成員也實現(xiàn)了serializable接口。所以可以初步得出這個類是集群安全的。

DefaultTurbineRundata實現(xiàn)了這個類型的session數(shù)據(jù)的操作接口：

   
• 保存user對象到session中，這個方法登錄后由TurbineAuthentication的login調(diào)用，登錄前由JetspeedSessionValidator的doPerform調(diào)用，它們同時會調(diào)用DefaultTurbineRundata的setUser方法：
       
         
         
           
         
         
       

  public void save()   {     session.putValue(User.SESSION_KEY, (Object) user ); } public void setUser(User user) {   this.user = user; }

  
     
• 從session中獲取user對象數(shù)據(jù)，這個方法由JetspeedSessionValidator的doPerform調(diào)用：
       
         
         
           
         
         
       

  public void populate()   {     user = getUserFromSession();     if ( user != null )     {         user.setLastAccessDate();         user.incrementAccessCounter();         user.incrementAccessCounterForSession();     }   }   public User getUserFromSession()   {     return getUserFromSession(session);   } 　　public static User getUserFromSession(HttpSession session)   {     try     {         return (User) session.getValue(User.SESSION_KEY);     }     catch ( ClassCastException e )     {         return null;     }   }

  
     
• 刪除session中的用戶數(shù)據(jù)，目前沒地方調(diào)用：
       
         
         
           
         
         
       

  public boolean removeUserFromSession()   {     return removeUserFromSession(session);   }     public static boolean removeUserFromSession(HttpSession session)   {     try     {         session.removeValue(User.SESSION_KEY);     }     catch ( Exception e )     {         return false;     }     return true; }

  
     

 

3.4.2.1 用戶登錄

用戶在jetspeed的首頁中輸入用戶名和口令，接著點擊登錄(login)按鈕，可以激活JLoginUser.doPerfom->TurbineAuthentication.login->DefaultTurbineRundata.save->JetspeedSessionValidator.doPerform-> DefaultTurbineRundata.populate系列步驟。

如果properties配置中的配置項automatic.logon.enable 的值為true，JLoginUser.doPerfom還會設置瀏覽器cookies：username 和logincookie。username是成功登錄的用戶名, logincookie是一個隨機值，會保存到用戶數(shù)據(jù)庫中。

當用戶訪問jetspeed的首頁時，JetspeedSessionValidator.doPerform檢查RunData對象中的當前用戶，如果沒有登錄而且automatic.logon.enable 的值為true，它會從cookies中獲取username 和logincookie，再從用戶數(shù)據(jù)庫中查尋用戶的logincookie，如果它們相等則調(diào)用下面的代碼設置RunData的用戶數(shù)據(jù)：

data.setUser(user);

user.setHasLoggedIn(new Boolean(true));

user.updateLastLogin();

data.save();

至于針對不同的用戶，首頁中顯示的portlet由缺省screen模版中調(diào)用JetspeedTool的方法（有一套PSML定位算法）來決定。

3.4.2.2 當session過期之后顯示匿名用戶的主頁

當session過期，Turbine.doget首先會創(chuàng)建新的session，接著激活JetspeedSessionValidator.doPerform-> JetspeedSecurity.getAnonymousUser->DefaultTurbineRundata.save系列步驟。

JetspeedSessionValidator.doPerform會設置缺省screen模版。

3.4.2.3 用戶登出

當用戶登錄之后，點擊Jetspeed系統(tǒng)右上角的登出(logout)按鈕，可以激活JLogOut.doPerform-> TurbineAuthentication.logout-> TurbineAuthentication.getAnonymousUser-> DefaultTurbineRundata.save系列步驟。

TurbineAuthentication.getAnonymousUser從數(shù)據(jù)庫中得到匿名用戶的用戶數(shù)據(jù)（根據(jù)properties配置中user.anonymous項）。

如果properties配置中配置項automatic.logon.enable 的值為true，JLogOut.doPerform還會刪除瀏覽器和當前request的cookies：username 和logincookie，防止后面的JetspeedSessionValidator拿著先前的用戶數(shù)據(jù)自動登錄。JLogOut.doPerform最后設置data的缺省screen模版。

3.4.3 JetspeedHttpStateManagerService$StateEntry

我們從《Session數(shù)據(jù)的類圖（部分）》可以看出StateEntry沒有實現(xiàn)了Serializable接口。把它放到session的屬性中不是集群安全的。Serializable接口只是個標志接口，它不擁有任何函數(shù)和數(shù)據(jù)成員，

為了使其集群安全化，首先必須讓StateEntry實現(xiàn)Serializable接口。

DefaultJetspeedRunData擁有下列對StateEntry類型的session數(shù)據(jù)操作接口：

   
• 用戶session接口，獲取保存用戶session數(shù)據(jù)的SessionState。這個SessionState保存的session數(shù)據(jù)以"org.apache.jetspeed.services.statemanager.JetspeedHttpStateManagerService"+ sessionID為key。
       
         
         
           
         
         
       

  public SessionState getUserSessionState()   {     StateManagerService service = (StateManagerService)TurbineServices           .getInstance().getService(StateManagerService.SERVICE_NAME);     if (service == null) return null;     return service.getSessionState(getSession().getId());   }

  
     
• request的Session接口，獲取保存當前request session數(shù)據(jù)的SessionState。這個SessionState保存的session數(shù)據(jù)以"org.apache.jetspeed.services.statemanager.JetspeedHttpStateManagerService"+ (sessionID和profileID組成的pageSessionID)為key。
     
       
         
         
         
       
     

  public SessionState getPageSessionState()   {     StateManagerService service = (StateManagerService)TurbineServices           .getInstance().getService(StateManagerService.SERVICE_NAME);     if (service == null) return null;     return service.getSessionState(getPageSessionId());   }

  
     
• Portlet的Session接口，獲取保存Portlet session數(shù)據(jù)的SessionState。這個SessionState保存的session數(shù)據(jù)以"org.apache.jetspeed.services.statemanager.JetspeedHttpStateManagerService"+ pageSessionID+portletID為key。
     
       
         
         
         
       
     

  public SessionState getPortletSessionState(String id)   {     // get the StateManagerService     StateManagerService service = (StateManagerService)TurbineServices           .getInstance().getService(StateManagerService.SERVICE_NAME);     if (service == null) return null;     String pageInstanceId = getPageSessionId();     return service.getSessionState(pageInstanceId + id);   }

  
     

 

3.4.3.1 類圖

src="/tea/image/section/13742.gif" width=500 align=baseline vspace=5
border=0>

BaseStateManagerService有一個類型為Map的成員變量m_httpSessions，以Thread對象為key，HttpSession對象為值。HttpSession對象中屬性的key 是前面DefaultJetspeedRunData的StateEntry類型的session數(shù)據(jù)操作接口的key，屬性的值為StateEntry對象。StateEntry對象的成員變量m_key保存操作接口的key，成員變量m_map是一個Map對象，以后面我們要講的setAttribute方法的name參數(shù)為 key，value參數(shù)為值。

3.4.3.2 初始化

下面的順序圖是一個簡圖，主要用于解釋BaseStateManagerService的成員變量m_httpSessions的映射如何被填充和清除。

src="/tea/image/section/13743.gif" width=500 align=baseline vspace=5
border=0>

Turbine是一個servlet，其doGet方法是jetspeed系統(tǒng)的入口。

   
• 填充
       
  
       

  Turbine請求JetspeedRunDataService生成RunData對象，JetspeedRunDataService調(diào)用HttpServiceRequest的getSession(true)方法獲取與當前請求對應的httpSession對象（以true為參數(shù)，getSession在當前session無效時會返回一個新的httpSession對象，否則返回先前請求的httpSession對象），JetspeedRunDataService接著調(diào)用JetspeedHttpStateManagerService的setCurrentContext(httpSession對象)方法，這個方法會以當前的Thread為key，參數(shù)httpSession對象為值填充BaseStateManagerService的成員變量m_httpSessions。

  
     
• 清除
       

  doGet方法填充了m_httpSessions，并作了好多事情之后，在即將退出之前調(diào)用了JetspeedRunDataService的putRunData(data)方法，這個方法再調(diào)用JetspeedHttpStateManagerService的clearCurrentContext()方法刪除BaseStateManagerService的成員變量m_httpSessions中以當前Thread為key的Map項。
  
          下圖顯示了m_httpSessions對象經(jīng)過初始化后的內(nèi)存狀態(tài)快照，體現(xiàn)了m_httpSessions對象保留的Thread-〉HttpSession的映射關系。

  
     

 

src="/tea/image/section/13744.gif" width=500 align=baseline vspace=5
border=0>

3.4.3.3 屬性操作

當DefaultJetspeedRunData通過session操作接口獲取SessionState之后，其它就可以使用SessionState對象的成員方法操作狀態(tài)屬性了。這兩個方法是：

public void setAttribute( String name, Object value );

public void removeAttribute( String name );

src="/tea/image/section/13745.gif" width=500 align=baseline vspace=5
border=0>

在從RunData對象處獲取sessionState對象后，jetspeed代碼可以調(diào)用這個對象的屬性操作方法。

   
• setAttribute(name,value)操作的大概步驟是：
       

  (1) 主要步驟：

  
       

  1.1sessionState對象利用自己的key，結(jié)合參數(shù)name,value調(diào)用JetspeedHttpStateManagerService的setAttribute(key,name,value)方法；

  
       

  1.1.1JetspeedHttpStateManagerService調(diào)用自己的getState(key)方法在參數(shù)key的幫助下獲取保存在當前線程session中的StateEntry對象的m_map變量，這個過程由1.1.1.1-1.1.1.4組成；

  
       

  1.1.2得到StateEntry對象的m_map變量后，JetspeedHttpStateManagerService接著先處理m_map中的先前的參數(shù)name對應的屬性值，再設置參數(shù)name對應的屬性值新值為參數(shù)value。

  
       

  (2) 候選步驟：

  
       

  1.1.1a 如果session中沒有相應的StateEntry對象，則先生成并往一個session中加入一個。

  
     
• getAttribute(name)操作的大概步驟是：
       

  (1) 主要步驟：
       

  2.1sessionState對象利用自己的key，結(jié)合參數(shù)name調(diào)用JetspeedHttpStateManagerService的getAttribute(key,name)方法；

  
       

  2.1.1JetspeedHttpStateManagerService調(diào)用自己的getState(key)方法在參數(shù)key的幫助下獲取保存在當前線程session中的StateEntry對象的m_map變量；

  
       

  2.1.2得到StateEntry對象的m_map變量后，JetspeedHttpStateManagerService接著調(diào)用m_map對象的get(name)方法獲取屬性值。

  
     

 

下圖體現(xiàn)了這些方法執(zhí)行后HttpSession對象保留的key-> StateEntry對象以及StateEntry對象的Name->Value的映射關系。

src="/tea/image/section/13746.gif" width=500 align=baseline vspace=5
border=0>

3.5 修改建議

(1) 實現(xiàn)數(shù)據(jù)庫形式的repository。根據(jù)前面的集群需求第五條，必須把repository數(shù)據(jù)庫化才能使得集群下的各個jetspeed的資源視圖相同。

(2) StateEntry。根據(jù)前面的集群需求第一條，必須讓StateEntry實現(xiàn)Serializable接口。目前StateEntry是一個內(nèi)部類，為了讓JVM的Serializer設施能順利創(chuàng)建StateEntry對象，最好把其public化。

(3) setAttribute要重設session屬性。根據(jù)前面的集群需求第二條，session對象的setAttribute是導致復制的引子，我們必須在改變session屬性后調(diào)用session對象的setAttribute方法重置session屬性，如下圖所示。

src="/tea/image/section/13747.gif" width=500 align=baseline vspace=5
border=0>

雖然Jetspeed中這樣模式的代碼如下：

   
• 更改JetspeedHttpStateManagerService的setAttribute方法。

 

對下面類中的doXXX方法按照這個模式進行修改。

   
• controllers.MultiColumnControllerAction；
     
• portlets.CustomizeSetAction；
     
• controllers.RowColumnControllerAction；
     
• 注意StateEntry中的值的序列性。

 

4 總結(jié)

    可以這樣說，目前的jetspeed在設計和實現(xiàn)時沒有考慮集群環(huán)境下的運行情況，本文的分析突出了jetspeed支持集群的主要癥結(jié)、但不一定完善，甚至有不正確的地方，另外一個主要內(nèi)容是分析jetspeed保存在session對象中的數(shù)據(jù)。希望本文有助于大家加深對集群的理解，有助于提醒大家在設計和開發(fā)軟件系統(tǒng)時"keep clustering in mind"。

參考資料

   
   
• 
  target=_blank>Memory Session Replication描述了集群的session 復制原理。
     
• Apache 2.x + Tomcat 4.x 描述了如何利用jk配置集群的負載均衡。
     
• target=_blank>Jk和jk2的文檔講述了相應的配置細節(jié)。
     
• target=_blank>Bea weblogic 8.1 描述了j2ee應用的集群配置與實現(xiàn)。
     
• target=_blank>教程告訴你如何寫jetspeed portlet。
     
• 《Java Pitfalls中文版》 item 23 描述了java 對象序列化的詳細過程。
     
• 在配javagroup時，盡量避開
  target=_blank>保留用多目地址。

 

本文轉(zhuǎn)載自target=_blank>IBM developerWorks，版權歸IBM developerWorks和原作者所有。