[發明專利]一種數據傳輸方法和裝置及數據發送、接收方法和裝置

有效

• 申請號: 201010139755.1
• 申請日: 2010-03-23
• 公開（公告）號: CN102202076A
• 公開（公告）日: 2011-09-28
• 發明（設計）人: 鄭德樂
• 申請（專利權）人: 深圳市金蝶中間件有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L29/06;H04L1/00
• 代理公司: 北京三高永信知識產權代理有限責任公司 11138
• 代理人: 鄭光

技術領域

本發明涉及計算機技術領域，特別涉及一種數據傳輸方法和裝置及數據發送、接收方法和裝置。

背景技術

現有技術中為了保證數據傳輸的可靠性，是以犧牲性能為代價的。現有技術中，實現分布式事務的關鍵就是兩階段提交協議。在此協議中，一個或多個資源管理器的活動均由一個稱為事務協調器的單獨軟件組件來控制。此協議中的五個步驟如下：

1、應用程序調用事務協調器中的提交方法；

2、第一階段：事務協調器將聯絡事務中涉及的每個資源管理器，并通知它們準備提交事務；

3、為了以肯定的方式響應準備階段，資源管理器必須將自己置于以下狀態：確保能在被要求提交事務時提交事務，或在被要求回滾事務時回滾事務；大多數資源管理器會將包含其計劃更改的日記文件(或等效文件)寫入持久存儲區中；如果資源管理器無法準備事務，它會以一個否定響應來回應事務協調器；

4、事務協調器收集來自資源管理器的所有響應；

5、第二階段，事務協調器將事務的結果通知給每個資源管理器；如果任一資源管理器做出否定響應，則事務協調器會將一個回滾命令發送給事務中涉及的所有資源管理器；如果資源管理器都做出肯定響應，則事務協調器會指示所有的資源管理器提交事務；一旦通知資源管理器提交，此后的事務就不能失敗了；通過以肯定的方式響應第一階段，每個資源管理器均已確保，如果以后通知它提交事務，則事務不會失敗。

在實現本發明的過程中，發明人發現現有技術至少存在以下問題：

如利用事務的兩階段提交，需要大量的事務日志，由于涉及到兩個節點，還需要一個全局事務協調器。同時，這種實現方式比較復雜。如果消息持久化源不支持事務，那么需要自己實現事務協調器、表決器、提交及回滾的大量代碼。

發明內容

為了解決現有技術中在數據傳輸方式存在的為了提高數據的可靠性導致傳輸效率低的問題，本發明實施例提供了一種數據傳輸方法和裝置及數據發送、接收方法和裝置。所述技術方案如下：

本發明實施例提出了一種數據傳輸方法，包括：

向接收端發送數據直到接收端確認收到；

當所述接收端接收到所述數據后，使所述數據不可用；如果接收端重復收到同一數據，則只保留一個數據；

向接收端發送確認消息直到接收端確認收到；

當所述接收端接收到所述確認消息后，使所述數據可用。

作為上述技術方案的優選，所述方法具體為：

101、發送端讀取數據的狀態標識，如果所述數據被標識為未發送，則進入步驟102；如果所述數據被標識為已發送，則進入步驟103；如果所述數據被標識為已確認，則將該數據刪除，步驟結束；

102、發送端發送數據；如果接收端未接收到該數據，則返回步驟101；否則將所述數據標識為發送；接收端使所述數據不可用；如果接收端重復收到同一數據，則只保留一個數據；

103、發送端發送確認消息；如果接收端未接收到該確認消息，則返回步驟101；否則將所述數據標識為已確認；接收端使所述數據可用。

本發明實施例提出了一種數據傳輸裝置，包括發送端和接收端，

所述發送端包括：

發送模塊，用于向接收端發送數據直到接收端確認收到；并用于向接收端發送確認消息直到接收端確認收到。

所述接收端包括：

接收模塊，用于接收所述發送端發送的數據和確認消息；當所述接收端接收到所述數據后，使所述數據不可用；如果接收端重復收到同一數據，則只保留一個數據；當所述接收端接收到所述確認消息后，使所述數據可用。

作為上述技術方案的優選，所述發送端包括：

狀態判斷模塊，用于讀取數據的狀態標識，如果數據被標識為未發送，將所述數據發送到數據發送模塊；如果數據被標識為已發送，則激活確認消息發送模塊；如果數據被標識為已確認，則刪除所述數據；

數據發送模塊，用于將數據發送到接收端；當接收端接收到所述數據后，將所述數據標識為已發送；

確認消息發送模塊，用于將與所述數據對應的確認消息發送到接收端；當接收端接收到所述確認消息后，將所述數據標識為已確認；

所述接收端包括：

數據接收模塊，用于接收發送端發送的數據，當接收到該數據后，使所述數據不可用；如果接收端重復收到同一數據，則只保留一個數據；

確認消息接收模塊，用于接收發送端發送的確認消息，當接收到該確認消息后，使所述數據可用。

本發明實施例提出了一種數據發送方法，包括：

向接收端發送數據直到接收端確認收到；

向接收端發送確認消息直到接收端確認收到。