[發(fā)明專利]一種持久化消息的發(fā)布方法及系統(tǒng)有效
| 申請?zhí)枺?/td> | 201210162372.5 | 申請日： | 2012-05-23 |
| 公開（公告）號： | CN103428072B | 公開（公告）日： | 2017-03-08 |
| 發(fā)明（設(shè)計）人： | 樂以長;封素石;張云 | 申請（專利權(quán)）人： | 北京大學(xué);北大方正集團有限公司;方正國際軟件（北京）有限公司 |
| 主分類號： | H04L12/58 | 分類號： | H04L12/58 |
| 代理公司： | 北京天悅專利代理事務(wù)所(普通合伙)11311 | 代理人： | 田明,任曉航 |
| 地址： | 100871*** | 國省代碼： | 北京;11 |
| 權(quán)利要求書： | 查看更多 | 說明書： | 查看更多 |
| 摘要： | |||
| 搜索關(guān)鍵詞： | 一種 持久 消息 發(fā)布 方法 系統(tǒng) | ||
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ā)給消息接收端。
該專利技術(shù)資料僅供研究查看技術(shù)是否侵權(quán)等信息，商用須獲得專利權(quán)人授權(quán)。該專利全部權(quán)利屬于北京大學(xué);北大方正集團有限公司;方正國際軟件（北京）有限公司，未經(jīng)北京大學(xué);北大方正集團有限公司;方正國際軟件（北京）有限公司許可，擅自商用是侵權(quán)行為。如果您想購買此專利、獲得商業(yè)授權(quán)和技術(shù)合作，請聯(lián)系【客服】
本文鏈接：http://www.17sss.com.cn/pat/books/201210162372.5/1.html，轉(zhuǎn)載請聲明來源鉆瓜專利網(wǎng)。
- 將發(fā)布數(shù)據(jù)發(fā)布至不同發(fā)布主機的系統(tǒng)及其方法
- 一種技術(shù)出版物內(nèi)容發(fā)布系統(tǒng)及方法
- 音/視頻流發(fā)布方法、流媒體服務(wù)器、發(fā)布端及流媒體系統(tǒng)
- 一種分布式代碼版本發(fā)布系統(tǒng)及方法
- 內(nèi)容發(fā)布方法、裝置、計算機設(shè)備以及可讀存儲介質(zhì)
- 文件發(fā)布方法和系統(tǒng)、發(fā)布服務(wù)器和文件生成裝置
- 軟件的發(fā)布質(zhì)量管理系統(tǒng)、方法以及裝置
- 信息發(fā)布方法、裝置、電子設(shè)備及計算機可讀存儲介質(zhì)
- 信息發(fā)布方法及裝置、存儲介質(zhì)、終端
- 服務(wù)發(fā)布方法及裝置、服務(wù)器、存儲介質(zhì)
