[發(fā)明專利]用于系列服務(wù)消息處理的方法、設(shè)備和系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 200710006577.3
• 申請(qǐng)日: 2007-02-06
• 公開(kāi)（公告）號(hào): CN101242392A
• 公開(kāi)（公告）日: 2008-08-13
• 發(fā)明（設(shè)計(jì)）人: 田瑞雄;胡進(jìn)鋒;楊博;陸薇;于策
• 申請(qǐng)（專利權(quán)）人: 國(guó)際商業(yè)機(jī)器公司
• 主分類號(hào): H04L29/02
• 分類號(hào): H04L29/02;H04L29/06;H04L12/58;H04L12/28;H04L12/56
• 代理公司: 北京市金杜律師事務(wù)所
• 代理人: 王茂華

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

本發(fā)明涉及信息技術(shù)領(lǐng)域，更具體地說(shuō)，本發(fā)明涉及一種用于系列服務(wù)消息處理的方法、設(shè)備和系統(tǒng)。

背景技術(shù)

在一些重要的行業(yè)中，例如在電信業(yè)和銀行業(yè)中，需要對(duì)業(yè)務(wù)進(jìn)行實(shí)時(shí)處理。例如，在電信業(yè)中，一些典型應(yīng)用要求95％的時(shí)間響應(yīng)延遲要小于20毫秒，并且在最差的情況下，響應(yīng)延遲要小于40毫秒。

“實(shí)時(shí)”不僅僅意味著快速處理，而且意味著“可靠地和可預(yù)測(cè)地響應(yīng)現(xiàn)實(shí)世界事件的能力”。因此，與速度相比，“實(shí)時(shí)”更關(guān)注及時(shí)。

當(dāng)采用通常的Java平臺(tái)實(shí)現(xiàn)需要實(shí)時(shí)處理的應(yīng)用時(shí)，可預(yù)測(cè)地控制應(yīng)用的執(zhí)行是面臨的主要困難，其中的一個(gè)原因是Java平臺(tái)的自動(dòng)內(nèi)存管理(垃圾收集)的不可預(yù)測(cè)性。

為了能夠在實(shí)時(shí)處理領(lǐng)域中采用Java技術(shù)，Sun公司發(fā)布了Java實(shí)時(shí)系統(tǒng)(Java?RTS)。Java?RTS是Java實(shí)時(shí)規(guī)范(RTSJ)的第一個(gè)商業(yè)實(shí)現(xiàn)。Java?RTS使得實(shí)時(shí)應(yīng)用程序的開(kāi)發(fā)者能夠利用Java語(yǔ)言生態(tài)系統(tǒng)的優(yōu)勢(shì)，同時(shí)盡力實(shí)現(xiàn)了實(shí)時(shí)應(yīng)用程序執(zhí)行的可預(yù)測(cè)性。

另外，IBM公司提供了一種新的實(shí)時(shí)垃圾收集器，稱作Metronome。利用該垃圾收集器，即使在最差的情況下，垃圾收集引起的消息處理停頓時(shí)間也小于1毫秒。

上述Java?RTS和Metronome雖能改進(jìn)服務(wù)消息處理延遲的可預(yù)測(cè)性，但很大程度地降低了服務(wù)消息處理的吞吐率。

因此，在實(shí)時(shí)處理領(lǐng)域中，需要提供一種解決方案，使得不但能夠改進(jìn)服務(wù)消息處理延遲的可預(yù)測(cè)性，同時(shí)也能夠維持較高的服務(wù)消息的吞吐率。

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

本發(fā)明的一個(gè)目的是提供一種解決方案，使得在實(shí)現(xiàn)實(shí)時(shí)應(yīng)用時(shí)，即使采用Java平臺(tái)，也能夠改進(jìn)服務(wù)消息處理延遲的可預(yù)測(cè)性，同時(shí)維持較高的服務(wù)消息處理的吞吐率。

為了上述目的，本發(fā)明提出了一種系列服務(wù)消息的處理方法，所述系列服務(wù)消息由多個(gè)服務(wù)消息組成，其中至少兩個(gè)服務(wù)器實(shí)例提供對(duì)所述系列服務(wù)消息的實(shí)時(shí)處理，并且存儲(chǔ)所述系列服務(wù)消息提供的信息和處理所述系列服務(wù)消息得到的結(jié)果。所述方法包括步驟：判定所述至少兩個(gè)服務(wù)器實(shí)例中的至少一個(gè)服務(wù)器實(shí)例將出現(xiàn)對(duì)所述系列服務(wù)消息的實(shí)時(shí)處理產(chǎn)生影響的行為，以及將所述系列服務(wù)消息中的后續(xù)服務(wù)消息分派到除所述至少一個(gè)服務(wù)器實(shí)例之外的其他服務(wù)器實(shí)例，以保證消息處理延時(shí)不受所述行為的影響。

本發(fā)明還提出了一種用于系列服務(wù)消息的處理的設(shè)備，所述系列服務(wù)消息由多個(gè)服務(wù)消息組成，其中至少兩個(gè)服務(wù)器實(shí)例提供對(duì)所述系列服務(wù)消息的實(shí)時(shí)處理，并且存儲(chǔ)所述系列服務(wù)消息提供的信息和處理所述系列服務(wù)消息得到的結(jié)果。所述設(shè)備包括：調(diào)度器，用于判定所述至少兩個(gè)服務(wù)器實(shí)例中的至少一個(gè)服務(wù)器實(shí)例將出現(xiàn)對(duì)所述系列服務(wù)消息的實(shí)時(shí)處理產(chǎn)生影響的行為，以及分派器，用于將所述系列服務(wù)消息中的后續(xù)服務(wù)消息分派到除所述至少一個(gè)服務(wù)器實(shí)例之外的其他服務(wù)器實(shí)例，以保證消息處理延時(shí)不受所述行為的影響。

此外，本發(fā)明還提出了一種系列服務(wù)消息的處理系統(tǒng)，所述系列服務(wù)消息由多個(gè)服務(wù)消息組成，其中至少兩個(gè)服務(wù)器實(shí)例提供對(duì)所述系列服務(wù)消息的實(shí)時(shí)處理，并且存儲(chǔ)所述系列服務(wù)消息提供的信息和處理所述系列服務(wù)消息得到的結(jié)果，并且在所述至少兩個(gè)服務(wù)器實(shí)例中由虛擬機(jī)管理內(nèi)存。所述系統(tǒng)包括：調(diào)度器，用于判定所述至少兩個(gè)服務(wù)器實(shí)例中的至少一個(gè)服務(wù)器實(shí)例將出現(xiàn)對(duì)所述系列服務(wù)消息的實(shí)時(shí)處理產(chǎn)生影響的行為，路由策略數(shù)據(jù)庫(kù)，用于存儲(chǔ)路由策略，在判定所述至少兩個(gè)服務(wù)器實(shí)例中的至少一個(gè)服務(wù)器實(shí)例將出現(xiàn)對(duì)所述系列服務(wù)消息的實(shí)時(shí)處理產(chǎn)生影響的行為后，所述調(diào)度器在所述路由策略數(shù)據(jù)庫(kù)中修改路由策略，以避免將后續(xù)服務(wù)消息分派到所述至少一個(gè)服務(wù)器實(shí)例，分派器，用于通過(guò)訪問(wèn)路由策略數(shù)據(jù)庫(kù)，將所述系列服務(wù)消息中的后續(xù)服務(wù)消息分派到除所述至少一個(gè)服務(wù)器實(shí)例之外的其他服務(wù)器實(shí)例，保證消息處理延時(shí)不受所述行為的影響，至少兩個(gè)虛擬機(jī)監(jiān)視器，分別位于所述至少兩個(gè)服務(wù)器實(shí)例的每一個(gè)上，用于向所述調(diào)度器提供用于判定所述至少兩個(gè)服務(wù)器實(shí)例中的至少一個(gè)服務(wù)器實(shí)例將出現(xiàn)對(duì)所述系列服務(wù)消息的實(shí)時(shí)處理產(chǎn)生影響的行為的信息，以及內(nèi)存數(shù)據(jù)庫(kù)，用于存儲(chǔ)所述系列服務(wù)消息提供的信息和處理所述系列服務(wù)消息得到的結(jié)果。

本發(fā)明還提出了用于實(shí)現(xiàn)上述方法的計(jì)算機(jī)程序產(chǎn)品。

根據(jù)本發(fā)明，通過(guò)精心調(diào)度服務(wù)消息的分派，避免把服務(wù)消息分派到出現(xiàn)對(duì)服務(wù)消息的實(shí)時(shí)處理產(chǎn)生影響的行為的服務(wù)器實(shí)例，可以消除上述行為對(duì)服務(wù)消息的實(shí)時(shí)處理的影響，同時(shí)避免其他改善服務(wù)消息處理延時(shí)方法所導(dǎo)致的服務(wù)消息吞吐率的顯著下降。