[發(fā)明專利]一種防原消息干擾的方法及裝置

有效

• 申請?zhí)枺?/td>: 201310750769.0
• 申請日: 2013-12-31
• 公開（公告）號: CN103684738B
• 公開（公告）日: 2017-06-13
• 發(fā)明（設(shè)計）人: 季旻;苗艷超;楊浩;張攀勇
• 申請（專利權(quán)）人: 曙光信息產(chǎn)業(yè)股份有限公司;無錫城市云計算中心有限公司
• 主分類號: H04L7/00
• 分類號: H04L7/00;H04L1/00
• 代理公司: 北京新知遠方知識產(chǎn)權(quán)代理事務(wù)所(普通合伙)11397
• 代理人: 徐彩華

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

本發(fā)明涉及通信技術(shù)領(lǐng)域，尤其涉及一種防原消息干擾的方法及裝置。

背景技術(shù)

現(xiàn)有的分布式系統(tǒng)中，節(jié)點間通常采用多條網(wǎng)絡(luò)通道，實現(xiàn)并發(fā)傳輸以提升網(wǎng)絡(luò)傳輸性能，并增強網(wǎng)絡(luò)傳輸?shù)聂敯粜浴?/p>

在一種分布式系統(tǒng)中，當(dāng)客戶端需要將指定頁面的數(shù)據(jù)發(fā)送給數(shù)據(jù)服務(wù)器時，需要向數(shù)據(jù)服務(wù)器發(fā)送消息，以通知數(shù)據(jù)服務(wù)器處理指定頁面的數(shù)據(jù)。如果消息發(fā)送超時，將重新發(fā)送指定頁面的數(shù)據(jù)，由于在兩次消息發(fā)送的間隔里，允許指定頁面的數(shù)據(jù)被更新，所以重傳消息中指定頁面的數(shù)據(jù)相對于原消息中相同指定頁面的數(shù)據(jù)可能會有所更新，導(dǎo)致內(nèi)容不同。這種情況下，對于數(shù)據(jù)服務(wù)器而言，就不允許其在接收重傳消息后，再接收處理原消息，否則將導(dǎo)致原消息覆蓋重傳消息；但是允許數(shù)據(jù)服務(wù)器在接收原消息后，再接收重傳消息。

由于采用多條網(wǎng)絡(luò)通道，網(wǎng)絡(luò)通道的異常會導(dǎo)致原消息在重傳消息之后被接收，引發(fā)原消息干擾問題。為了避免該問題，目前通常采用時間戳和時間同步相結(jié)合的方法，具體方案是：在分布式系統(tǒng)各節(jié)點上部署時間同步軟件，實現(xiàn)各節(jié)點間時間同步；節(jié)點在接收消息后，計算消息的過期時間(消息的發(fā)送時間戳加上消息超時時間)，并與接收端本地時間相比較，若判定消息過期則丟棄該消息。由于重傳消息在原消息超時之后發(fā)送，若接收端在接收重傳消息之后接收原消息，鑒于節(jié)點間時間同步，必定能夠判定原消息過期并丟棄，從而避免原消息干擾問題。

現(xiàn)有采用的時間戳和時間同步相結(jié)合的方案，要在分布式系統(tǒng)的各個節(jié)點上部署時間同步軟件，部署代價較高，且要求分布式系統(tǒng)各節(jié)點的時鐘頻率完全一致，對硬件要求較高，一旦部分節(jié)點的時鐘頻率出現(xiàn)問題，需要進行時鐘同步處理，主要包括兩種情況：1)節(jié)點時鐘受同步影響往前調(diào)，會導(dǎo)致接收其它節(jié)點的過期消息(時間前調(diào)導(dǎo)致判定消息不過期)，從而造成原消息干擾；2)節(jié)點時鐘受同步影響往后調(diào)，對于標準時鐘的節(jié)點而言，該節(jié)點發(fā)送的原消息和重傳消息的時間間隔并未到達超時時限，導(dǎo)致其它節(jié)點無法準確判定該節(jié)點發(fā)送的消息是否過期，進而引發(fā)原消息干擾問題。

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

本發(fā)明針對上述問題，提出了一種防原消息干擾的方法及裝置，可替代現(xiàn)有時間戳和時間同步相結(jié)合的方案，消除對時間同步軟件的依賴，并降低分布式系統(tǒng)的部署代價和時鐘硬件要求，有效消除原消息干擾的問題。

在一個方面，本發(fā)明提供了一種防原消息干擾的方法，其包括：

接收原消息，所述原消息中包含發(fā)送所述原消息時發(fā)送節(jié)點的當(dāng)前CPU計數(shù)器時間和所述原消息超時時對應(yīng)的發(fā)送節(jié)點CPU計數(shù)器時間；

根據(jù)收到所述原消息之后的在后消息中的發(fā)送節(jié)點當(dāng)前CPU計數(shù)器時間，判斷所述原消息是否超時，若確定所述原消息超時，則丟棄所述原消息；否則，接收所述原消息。

在另一個方面，本發(fā)明提供了一種防原消息干擾裝置，其包括：

接收單元，用于接收原消息，所述原消息中包含發(fā)送所述原消息時發(fā)送節(jié)點的當(dāng)前CPU計數(shù)器時間和所述原消息超時時對應(yīng)的發(fā)送節(jié)點CPU計數(shù)器時間；

處理單元，用于根據(jù)收到所述原消息之后的在后消息中的發(fā)送節(jié)點當(dāng)前CPU計數(shù)器時間，判斷所述原消息是否超時，若確定所述原消息超時，則丟棄所述原消息；否則，接收所述原消息。

本發(fā)明提供了一種防原消息干擾的方法及裝置，通過選擇CPU計數(shù)器時間作為節(jié)點間的計時機制和防原消息干擾協(xié)議，避免了節(jié)點間對時間同步軟件的依賴，可替代現(xiàn)有時間戳和時間同步相結(jié)合的方案，消除對時間同步軟件的依賴，并降低分布式系統(tǒng)的部署代價和時鐘硬件要求，有效消除原消息干擾的問題。

附圖說明

下面將參照附圖描述本發(fā)明的具體實施例，其中：

圖1為本發(fā)明實施例提供的一種防原消息干擾的方法流程圖。

圖2為本發(fā)明實施例提供的一種防原消息干擾的方法中節(jié)點主動連接時的節(jié)點啟動時生存期確立流程圖。

圖3為本發(fā)明實施例提供的一種防原消息干擾的方法中節(jié)點被動連接時的節(jié)點啟動時生存期確立流程圖。

圖4為本發(fā)明實施例提供的一種防原消息干擾的方法中防原消息干擾協(xié)議處理流程圖。

圖5為本發(fā)明實施例提供的一種防原消息干擾裝置的示意圖。

具體實施方式

為了使本發(fā)明的技術(shù)方案及優(yōu)點更加清楚明白，以下結(jié)合附圖對本發(fā)明的示例性實施例進行進一步詳細的說明，顯然，所描述的實施例僅是本發(fā)明的一部分實施例，而不是所有實施例的窮舉。

如圖1所示，本發(fā)明實施例提供了一種防原消息干擾的方法，其包括如下步驟：