基于CORBA的異步消息中間件的研究.pdf

1、中間件是位于硬件、操作系統(tǒng)平臺(tái)和應(yīng)用程序之間的通用服務(wù)系統(tǒng)，具有標(biāo)準(zhǔn)的程序接口和協(xié)議，可實(shí)現(xiàn)不同硬件和操作系統(tǒng)平臺(tái)上的數(shù)據(jù)共享和應(yīng)用互操作。之前有不少是基于COM/DCOM的異步或者同步消息中間件，本文重點(diǎn)研究了基于CORBA的異步消息中間件，利用CORBA技術(shù)開(kāi)發(fā)了一個(gè)異步消息中間件，實(shí)現(xiàn)了客戶(hù)間的通信。 首先，利用Delphi6建立一個(gè)工程，實(shí)現(xiàn)服務(wù)器功能，接著建立一個(gè)實(shí)現(xiàn)客戶(hù)端訪問(wèn)的工程。在服務(wù)器端和客戶(hù)端編寫(xiě)基本的調(diào)用方

2、法，客戶(hù)端通過(guò)調(diào)用服務(wù)器端的方法進(jìn)行消息的發(fā)送與接收。 接著，在服務(wù)器端定義一個(gè)消息隊(duì)列，該消息隊(duì)列是根據(jù)FIFO的原則進(jìn)行操作的。并且用戶(hù)都有其全局唯一的ID。當(dāng)客戶(hù)端之間發(fā)送消息時(shí)，服務(wù)器端首先接收到消息發(fā)送者發(fā)送的消息，然后把它們存儲(chǔ)在消息隊(duì)列中，消息隊(duì)列中存儲(chǔ)的不但有消息內(nèi)容，還有消息發(fā)送者與接收者的ID號(hào)，等待消息接收者的接收請(qǐng)求。當(dāng)消息接收者登錄客戶(hù)端向服務(wù)器發(fā)送接收請(qǐng)求后，消息隊(duì)列根據(jù)消息接收者的ID號(hào)在消息隊(duì)列中

3、進(jìn)行搜索，如果有該用戶(hù)的消息，從消息隊(duì)列中取出并發(fā)送回客戶(hù)端。 最后，在消息隊(duì)列中實(shí)現(xiàn)了一個(gè)重新排列消息隊(duì)列的算法。當(dāng)消息接收者接收完消息后，消息隊(duì)列要把已經(jīng)取出的消息進(jìn)行刪除，然后重新排列消息隊(duì)列，以便滿(mǎn)足FIFO原則。在消息隊(duì)列重排算法中，當(dāng)消息取出后，每取出的兩條消息之間的消息前移，把駐留在消息隊(duì)列中的消息分段進(jìn)行前移，每移動(dòng)一次，后面移動(dòng)的消息前移的位數(shù)增加一位。 通過(guò)以上的工程建立，算法實(shí)現(xiàn)，就可以實(shí)現(xiàn)用戶(hù)間的