[發(fā)明專利]一種持久化消息的發(fā)布方法及系統(tǒng)

有效

• 申請?zhí)枺?/td>: 201210162372.5
• 申請日: 2012-05-23
• 公開（公告）號: CN103428072B
• 公開（公告）日: 2017-03-08
• 發(fā)明（設(shè)計）人: 樂以長;封素石;張云
• 申請（專利權(quán)）人: 北京大學;北大方正集團有限公司;方正國際軟件（北京）有限公司
• 主分類號: H04L12/58
• 分類號: H04L12/58
• 代理公司: 北京天悅專利代理事務(wù)所(普通合伙)11311
• 代理人: 田明,任曉航

1.一種持久化消息的發(fā)布方法，包括以下步驟：

(1)消息接收裝置接收消息發(fā)送端發(fā)送到數(shù)據(jù)交換服務(wù)器的實時消息，并將所述實時消息持久化到非易失性存儲設(shè)備；

(2)持久化消息讀取裝置讀取持久化到非易失性存儲設(shè)備上的持久化消息；

(3)持久化消息發(fā)布裝置將所述持久化消息存入消息隊列中；在將持久化消息存入消息隊列之前，判斷消息隊列是否為忙，如果消息隊列為忙，持久化消息發(fā)布裝置將會暫停運行并進入等待狀態(tài)，等待消息隊列發(fā)送的空閑通知；

(4)消息轉(zhuǎn)發(fā)單元提取消息隊列中的消息后，將消息轉(zhuǎn)發(fā)給消息接收端，消息隊列將向持久化消息發(fā)布裝置發(fā)送通知事件，通知所述持久化消息發(fā)布裝置終止等待；

(5)持久化消息發(fā)布裝置從等待語句的下一條語句繼續(xù)執(zhí)行，繼續(xù)往消息隊列發(fā)布消息。

2.如權(quán)利要求1所述的一種持久化消息的發(fā)布方法，其特征在于：每個消息接收端對應(yīng)唯一的持久化消息發(fā)布裝置，用于向所述消息接收端對應(yīng)的消息隊列發(fā)布持久化消息。

3.如權(quán)利要求1所述的一種持久化消息的發(fā)布方法，其特征在于：每個消息接收端對應(yīng)唯一的消息隊列，用于存放消息發(fā)送端發(fā)送的實時消息和持久化消息發(fā)布裝置發(fā)布的持久化消息。

4.如權(quán)利要求1、2或3所述的一種持久化消息的發(fā)布方法，其特征在于：步驟(3)中，所述持久化消息發(fā)布裝置暫停運行并進入等待狀態(tài)時，持久化消息發(fā)布裝置將會一直等待，直到接收到消息隊列的空閑通知，繼續(xù)發(fā)布持久化消息。

5.如權(quán)利要求1、2或3所述的一種持久化消息的發(fā)布方法，其特征在于：步驟(3)中，消息轉(zhuǎn)發(fā)單元在從消息隊列提取消息并釋放出內(nèi)存空間后，消息隊列立即向持久化消息發(fā)布裝置發(fā)送空閑通知，通知持久化消息發(fā)布裝置可以繼續(xù)向消息隊列發(fā)布持久化消息。

6.如權(quán)利要求1、2或3所述的一種持久化消息的發(fā)布方法，其特征在于：步驟(3)中，消息轉(zhuǎn)發(fā)單元在從消息隊列提取消息之前將鎖定消息隊列，在從消息隊列提取消息之后將解除對消息隊列的鎖定。

7.如權(quán)利要求1所述的一種持久化消息的發(fā)布方法，其特征在于該方法包括以下步驟：

步驟1、從非易失性存儲設(shè)備上加載持久化的消息列表；

步驟2、如果得到的消息列表為空，表示沒有持久化的消息，則進入步驟10；否則進入步驟3;

步驟3、持久化消息讀取裝置讀取非易失性存儲設(shè)備上的第一條持久化消息；

步驟4、持久化消息發(fā)布裝置判斷消息隊列是否為忙，如果消息隊列為忙則執(zhí)行步驟5；否則執(zhí)行步驟7；

步驟5、持久化消息發(fā)布裝置暫停運行并進入等待狀態(tài)，等待消息隊列的空閑通知；

步驟6、持久化消息發(fā)布裝置接收到消息隊列的空閑通知后繼續(xù)程序的執(zhí)行過程，進入步驟7；

步驟7、持久化消息發(fā)布裝置鎖定消息隊列，然后將持久化消息放入所述消息隊列中，放入完成后解除對消息隊列的鎖定；

步驟8、持久化消息發(fā)布裝置判斷非易失性存儲設(shè)備上是否有下一條未發(fā)布的消息，如果有未發(fā)布的消息則執(zhí)行步驟9；否則執(zhí)行步驟10；

步驟9、持久化消息讀取裝置讀取非易失性存儲設(shè)備上的下一條持久化消息；然后進入步驟4；

步驟10、持久化消息發(fā)布裝置完成本次消息發(fā)布，停止運行。

8.一種持久化消息的發(fā)布系統(tǒng)，包括數(shù)據(jù)交換服務(wù)器、消息發(fā)送端、消息接收端，其特征在于，所述的數(shù)據(jù)交換服務(wù)器包括以下裝置：

消息接收裝置：用于接收消息發(fā)送端發(fā)送到數(shù)據(jù)交換服務(wù)器的實時消息，并將所述實時消息持久化到非易失性存儲設(shè)備；

持久化消息讀取裝置：用于讀取持久化到非易失性存儲設(shè)備上的持久化消息；

持久化消息發(fā)布裝置：用于將持久化消息讀取裝置讀取的持久化消息發(fā)布到消息隊列，在將持久化消息存入消息隊列之前，判斷消息隊列是否為忙，如果消息隊列為忙，持久化消息發(fā)布裝置將會暫停運行并進入等待狀態(tài)，等待消息隊列發(fā)送的空閑通知；

消息隊列：用于在內(nèi)存中存放消息接收端有待轉(zhuǎn)發(fā)的實時消息和持久化消息，消息在被提取時會向持久化消息發(fā)布裝置發(fā)送空閑通知；

消息轉(zhuǎn)發(fā)單元：用于從消息隊列提取消息并將消息轉(zhuǎn)發(fā)給消息接收端。