基于corba的java消息服務(wù)中間件的設(shè)計(jì)與優(yōu)化(編輯修改稿)
2025-07-07 22:29 本頁(yè)面
【文章內(nèi)容簡(jiǎn)介】 息隊(duì)列以及持久消息管理器。由 ORB adaptor 轉(zhuǎn)發(fā)的消息按類別分別進(jìn)入這兩個(gè)隊(duì)列中。發(fā)送消息隊(duì)列按照消息優(yōu)先級(jí)排序，使最高優(yōu)先級(jí)的消息排在最前面以盡快優(yōu)先處理。同時(shí)，持久消息管理器根據(jù)消息頭部持久屬性的值來(lái)決定是否將消息存儲(chǔ)在數(shù)據(jù)庫(kù)中。如果是，則通過(guò)數(shù)據(jù)庫(kù)連接池中的數(shù)據(jù)庫(kù)連接將持久消息存儲(chǔ)到數(shù)據(jù)庫(kù)中。當(dāng) CJMQ 由于異常原因崩潰重新啟動(dòng)后，在初始化階段會(huì)將持久消息讀入消息隊(duì)列中。 主頁(yè)： 采用何種線程策略向消息接收者發(fā)送消息對(duì)于系統(tǒng)的性能有著至關(guān)重要的影響。既可以采用一個(gè)客戶一線程， 也可以采用一個(gè)隊(duì)列一線程或者采用線程池。一個(gè)客戶一線程策略適用于客戶數(shù)較少的情況，當(dāng)客戶數(shù)很多時(shí)，大量的線程會(huì)嚴(yán)重消耗系統(tǒng)資源，導(dǎo)致系統(tǒng)性能很差；一個(gè)隊(duì)列一線程策略適用于消息較少的情況，當(dāng)隊(duì)列中消息數(shù)較多時(shí)，單線程來(lái)不及處理，導(dǎo)致系統(tǒng)傳輸消息的效率很低。我們的設(shè)計(jì)采用了線程池的策略。 dispatcher thread pool 有一個(gè)線程數(shù)上限MaxThreadNum，該參數(shù)可以由管理員配置。系統(tǒng)初始化時(shí)生成一定數(shù)目的派發(fā)線程，由調(diào)度器調(diào)度這些線程發(fā)送消息隊(duì)列中的消息，如果仍有新的消息到來(lái)而線程數(shù)不夠時(shí)，則系 統(tǒng)生成新的線程處理消息直到達(dá)到設(shè)定的 MaxThreadNum 值。這樣可以重用線程池中的線程，避免了前兩種策略的缺點(diǎn)。 基于 CORBA的 JAVA 消息服務(wù)中間件的設(shè)計(jì)與優(yōu)化 (2) Connection manager 接受客戶的建立連接的請(qǐng)求，并分配該連接一個(gè)唯一的連接標(biāo)識(shí)?？蛻粼谡?qǐng)求連接的時(shí)候，會(huì)同時(shí)發(fā)送自己的消息處理對(duì)象（ message handler object）的引用； Connection manager 將此對(duì)象引用和連接標(biāo)識(shí)存儲(chǔ)到派發(fā)緩沖和數(shù)據(jù)庫(kù)中。 主頁(yè)： Lease manager 主要有兩個(gè)功能，其一是檢測(cè)所有已建立連接的客戶是否還聯(lián)通，如果已經(jīng)斷開(kāi)則清除該客戶的連接信息；并且如果該客戶沒(méi)有持久訂閱，還將清除發(fā)送給它的消息以及應(yīng)答；其二是檢測(cè)消息隊(duì)列中的消息是否已經(jīng)過(guò)期，如果過(guò)期則清除該消息。 4 CJMQ 消息派發(fā)機(jī)制的優(yōu)化 單位時(shí)間內(nèi)的消息吞吐量是衡量 MOM系統(tǒng)性能的一個(gè)重要指標(biāo)，而消息派發(fā)機(jī)制對(duì)該性能影響很大。這一節(jié)主要闡述我們?cè)谠O(shè)計(jì) CJMQ時(shí)對(duì)其消息派發(fā)機(jī)制的優(yōu)化。 問(wèn)題：在點(diǎn)對(duì)點(diǎn)模型中，多個(gè)派發(fā)線程會(huì)同時(shí)訪問(wèn)派發(fā)緩沖（存放客戶 連接標(biāo)識(shí)和其消息處理對(duì)象的引用）以便將消息分別派發(fā)給某個(gè)接收者。同時(shí)新建連接或者關(guān)閉連接也會(huì)導(dǎo)致對(duì)派發(fā)緩沖的更改（增加或者刪除）。為了同步，傳統(tǒng)的做法是采用鎖機(jī)制，當(dāng)?shù)谝粋€(gè)線程訪問(wèn)緩沖時(shí)，首先對(duì)該緩沖加鎖，然后再對(duì)緩沖中的數(shù)據(jù)進(jìn)行處理，處理完畢后解鎖，以便使其他線程可以訪問(wèn)該緩沖。如果緩沖加鎖，則任何其他線程都必須等待，直到解鎖為止。在 CJMQ 的實(shí)現(xiàn)中如果采用鎖機(jī)制，會(huì)導(dǎo)致派發(fā)線程訪問(wèn)的串行，嚴(yán)重影響系統(tǒng)性能。 主頁(yè)： 優(yōu)化：用讀 /寫鎖同步多線程對(duì)派發(fā)緩沖的訪問(wèn)?？紤]到在點(diǎn)對(duì)點(diǎn)模型中派發(fā)操作主要是讀取派發(fā)緩沖中的 消息處理對(duì)象引用，然后調(diào)用它的發(fā)送消息接口，而并不更改（增加和刪除）派發(fā)緩沖。對(duì)于這一類操作，可以使用讀鎖；對(duì)于更改派發(fā)緩沖的操作，可以使用寫鎖。讀鎖可以并發(fā)，
試題試卷相關(guān)推薦
鄂ICP備17016276號(hào)-1