[發(fā)明專利]一種提高消息服務(wù)器處理效率的方法

無效

• 申請?zhí)枺?/td>: 200610089366.6
• 申請日: 2006-06-21
• 公開（公告）號: CN101094167A
• 公開（公告）日: 2007-12-26
• 發(fā)明（設(shè)計(jì)）人: 魏國強(qiáng);方馬;田珂
• 申請（專利權(quán)）人: 中興通訊股份有限公司
• 主分類號: H04L12/56
• 分類號: H04L12/56;H04Q11/00
• 代理公司: 北京律誠同業(yè)知識產(chǎn)權(quán)代理有限公司
• 代理人: 梁揮;徐金國

技術(shù)領(lǐng)域

本發(fā)明涉及J2EE應(yīng)用服務(wù)器，特別是涉及JMS消息服務(wù)器，主要應(yīng)用在電信網(wǎng)絡(luò)管理領(lǐng)域。

背景技術(shù)

近十幾年，電信網(wǎng)絡(luò)管理技術(shù)飛速發(fā)展。J2EE(Java?2?EnterpriseEdition)應(yīng)用服務(wù)器在電信網(wǎng)絡(luò)管理中的使用日趨廣泛，JMS(JavaMessaging?Service)消息服務(wù)器是J2EE應(yīng)用服務(wù)器的一個重要組成部分，通常用在異步處理上。在電信網(wǎng)絡(luò)管理領(lǐng)域往往需要實(shí)時處理大量的異步上報(bào)的數(shù)據(jù)，則容易出現(xiàn)性能瓶頸。

通常使用J2EE應(yīng)用服務(wù)器技術(shù)構(gòu)建的電信網(wǎng)管使用JMS的方式如下：接收到網(wǎng)元上報(bào)的信息，轉(zhuǎn)換為一定的格式，然后發(fā)送到消息主題上。網(wǎng)元上報(bào)的數(shù)據(jù)的大小通常是變化的，有些小，有些大。將這些消息轉(zhuǎn)換成JMS消息的時是作為JMS消息的有效載荷，會導(dǎo)致JMS消息大小變化。在消息比較小的情況下，通過網(wǎng)絡(luò)發(fā)送到消息服務(wù)器上進(jìn)行處理的時候，消息太小會導(dǎo)致網(wǎng)絡(luò)調(diào)用頻繁。JMS消息服務(wù)器接收到消息后，需要對每條消息進(jìn)行處理，因此處理負(fù)擔(dān)也增加。

基于目前一些應(yīng)用服務(wù)器中JMS的實(shí)現(xiàn)，如果能提出一種打包發(fā)送的方法，將多條消息合并到一條消息里面，就可以大幅提供JMS消息的發(fā)送和接收效率以及JMS消息服務(wù)器的處理效率。目前還沒有查到使用類似提高JMS處理效率的方法。

發(fā)明內(nèi)容

本發(fā)明所要解決的技術(shù)問題是提供一種提高消息服務(wù)器處理效率的方法，解決現(xiàn)有應(yīng)用服務(wù)器的JMS實(shí)現(xiàn)技術(shù)沒有對消息進(jìn)行預(yù)處理，不能進(jìn)打包發(fā)送，處理效率較低的技術(shù)問題。

為達(dá)到上述目的，本發(fā)明提供了一種提高消息服務(wù)器處理效率的方法，其特點(diǎn)在于，在消息發(fā)送端，打包模塊對相同信息源發(fā)出的類似的原始消息打包到一個打包消息中，并將所述打包消息經(jīng)消息服務(wù)器發(fā)送到消息接收端，在消息接收端通過解包模塊將所述打包消息還原出所述原始消息，并將所述原始消息傳遞給消息接收者。

上述的方法，其特點(diǎn)在于，通過將所述打包模塊和所述解包模塊分別設(shè)置在所述消息服務(wù)器的發(fā)送接口和接收接口的內(nèi)側(cè)，使所述消息服務(wù)器保持對外暴露標(biāo)準(zhǔn)的接口。

上述的方法，其特點(diǎn)在于，通過將所述打包模塊和所述解包模塊分別設(shè)置在所述消息服務(wù)器的發(fā)送接口和接收接口的外側(cè)，使對消息的打包和解包能適用于不同的消息服務(wù)器。

上述的方法，其特點(diǎn)在于，所述消息發(fā)送端的處理流程進(jìn)一步包括如下步驟：

步驟A，用戶獲取所述發(fā)送接口的信息，同時為用戶創(chuàng)建一個延時任務(wù)；

步驟B，在達(dá)到所述延時任務(wù)的延時后，所述延時任務(wù)啟動，為用戶創(chuàng)建緩存隊(duì)列和定時任務(wù)；

步驟C，在用戶利用所述發(fā)送接口發(fā)送原始消息的過程中，如果所述延時任務(wù)已經(jīng)啟動，則所述原始消息被存儲到所述緩存隊(duì)列中；如果所述延時任務(wù)沒有啟動，則直接將所述原始消息發(fā)送到所述消息服務(wù)器；

步驟D，在所述定時任務(wù)啟動后定時去讀取所述緩存隊(duì)列中的原始消息，并將所述緩存隊(duì)列中所有的原始消息打包成一個打包消息，然后將所述打包消息發(fā)送到所述消息服務(wù)器。

上述的方法，其特點(diǎn)在于，在所述步驟D中所述打包的方式是采用對象序列化到內(nèi)存，在進(jìn)行網(wǎng)絡(luò)傳輸?shù)臅r候，只傳輸內(nèi)存中的二進(jìn)制的映像。

上述的方法，其特點(diǎn)在于，在所述步驟D中，對內(nèi)存中的數(shù)據(jù)再實(shí)施通用的壓縮算法進(jìn)行壓縮后傳輸，進(jìn)一步提供傳送效率。

上述的方法，其特點(diǎn)在于，在所述步驟D中，通過標(biāo)準(zhǔn)位區(qū)分消息是原始消息還是打包消息，還通過標(biāo)準(zhǔn)位區(qū)分消息是否經(jīng)過了壓縮處理。

上述的方法，其特點(diǎn)在于，對于需要支持過濾器的情況，分析原始消息的消息頭，確保對過濾器特性一致的原始消息才打包到一個大的打包消息里面；對于過濾器特性不一致的原始消息則分開打包。

上述的方法，其特點(diǎn)在于，所述消息接收端的處理流程進(jìn)一步包括如下步驟：

步驟a，接收端的用戶通過所述解包模塊在所述消息服務(wù)器注冊為消息消費(fèi)者；

步驟b，所述解包模塊接收到消息后區(qū)分收到的消息是原始消息還是打包消息，并將所述原始消息直接傳遞給對應(yīng)的消息消費(fèi)者，將所述打包消息通過對象反序列化的方式還原成原始消息，并將還原的原始消息傳遞給對應(yīng)的消息消費(fèi)者。

上述的方法，其特點(diǎn)在于，在所述步驟b中，如果接收到的消息經(jīng)過了壓縮，則在進(jìn)行對象反序列化前，先進(jìn)行解壓縮。

本發(fā)明的技術(shù)效果在于：

對于生成周期大于延時周期的發(fā)生者，消息直接發(fā)送到緩存隊(duì)列，發(fā)送效率高；

如果原始發(fā)送的消息比較小，在一定的網(wǎng)絡(luò)條件下，如以太網(wǎng)，這種打包發(fā)送提高了網(wǎng)絡(luò)傳輸?shù)男剩?/p>