[發(fā)明專利]數(shù)據(jù)傳輸方法、裝置和服務(wù)器

有效

• 申請(qǐng)?zhí)枺?/td>: 201410746563.5
• 申請(qǐng)日: 2014-12-08
• 公開（公告）號(hào): CN104468399B
• 公開（公告）日: 2020-01-17
• 發(fā)明（設(shè)計(jì)）人: 楊濤;侯金軒
• 申請(qǐng)（專利權(quán)）人: 北京奇虎科技有限公司;奇智軟件(北京)有限公司
• 主分類號(hào): H04L12/861
• 分類號(hào): H04L12/861
• 代理公司: 11348 北京鼎佳達(dá)知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙)
• 代理人: 王偉鋒;劉鐵生

1.一種數(shù)據(jù)傳輸方法，其包括：

在第一服務(wù)器所處的地理位置，接收來自所述第一服務(wù)器的待發(fā)送至第二服務(wù)器的數(shù)據(jù)，所述第二服務(wù)器和所述第一服務(wù)器位于不同地理位置；

將所述數(shù)據(jù)存放到預(yù)設(shè)的隊(duì)列中；

其中，所述隊(duì)列的數(shù)量為多個(gè)，多個(gè)所述隊(duì)列用于存放待發(fā)送至所述第二服務(wù)器上進(jìn)行多種計(jì)算任務(wù)的數(shù)據(jù)；

將所述數(shù)據(jù)存放到預(yù)設(shè)的隊(duì)列中，具體包括：

根據(jù)待使用所述數(shù)據(jù)的計(jì)算任務(wù)，從多個(gè)所述隊(duì)列中選擇存放所述數(shù)據(jù)的隊(duì)列，其中，所述計(jì)算任務(wù)可以由所述第二服務(wù)器識(shí)別；

從所述隊(duì)列中獲取所述數(shù)據(jù)，并將所述數(shù)據(jù)發(fā)送到所述第二服務(wù)器；

判斷所述數(shù)據(jù)是否成功發(fā)送到所述第二服務(wù)器；

在所述數(shù)據(jù)發(fā)送失敗時(shí)，重新從所述隊(duì)列中獲取所述數(shù)據(jù)并進(jìn)行發(fā)送。

2.根據(jù)權(quán)利要求1所述的方法，其中，還包括：

在所述數(shù)據(jù)發(fā)送成功時(shí)，從所述隊(duì)列中刪除所述數(shù)據(jù)。

3.根據(jù)權(quán)利要求1所述的方法，其中，判斷所述數(shù)據(jù)是否成功發(fā)送到所述第二服務(wù)器，具體包括：

接收所述第二服務(wù)器發(fā)送的用于通知所述數(shù)據(jù)發(fā)送成功的消息；

如果自發(fā)送所述數(shù)據(jù)后的預(yù)設(shè)時(shí)間段內(nèi)沒有接收到所述消息，判斷所述數(shù)據(jù)發(fā)送失??；

如果自發(fā)送所述數(shù)據(jù)后的所述預(yù)設(shè)時(shí)間段內(nèi)接收到所述消息，判斷所述數(shù)據(jù)發(fā)送成功。

4.根據(jù)權(quán)利要求1所述的方法，其中，在根據(jù)待使用所述數(shù)據(jù)的計(jì)算任務(wù)，從多個(gè)所述隊(duì)列中選擇存放所述數(shù)據(jù)的隊(duì)列之前，還包括：

根據(jù)所述數(shù)據(jù)的屬性，識(shí)別待使用所述數(shù)據(jù)的計(jì)算任務(wù)。

5.根據(jù)權(quán)利要求4所述的方法，其中，所述數(shù)據(jù)的屬性包括所述數(shù)據(jù)的類型、字段、數(shù)據(jù)量的一種或多種。

6.根據(jù)權(quán)利要求1所述的方法，其中，在接收來自所述第一服務(wù)器的待發(fā)送至第二服務(wù)器的數(shù)據(jù)，所述第二服務(wù)器和所述第一服務(wù)器位于不同地理位置之前，還包括：

所述第一服務(wù)器從與所述第一服務(wù)器位于相同地理位置的包含多個(gè)第三服務(wù)器的集群接收所述數(shù)據(jù)。

7.根據(jù)權(quán)利要求1至6中任一項(xiàng)所述的方法，其中，接收所述第一服務(wù)器發(fā)送的數(shù)據(jù)，具體包括：

實(shí)時(shí)接收所述第一服務(wù)器發(fā)送的數(shù)據(jù)，并記錄在預(yù)設(shè)的日志文件中；

將所述數(shù)據(jù)存放到預(yù)設(shè)的隊(duì)列中，具體包括：

從所述日志文件中提取所述數(shù)據(jù)，并存放到預(yù)設(shè)隊(duì)列中。

8.一種數(shù)據(jù)傳輸裝置，其包括：

數(shù)據(jù)接收模塊，用于在第一服務(wù)器所處的地理位置，接收來自所述第一服務(wù)器的待發(fā)送至第二服務(wù)器的數(shù)據(jù)，所述第二服務(wù)器和所述第一服務(wù)器位于不同地理位置；

隊(duì)列存放模塊，用于將所述數(shù)據(jù)存放到預(yù)設(shè)的隊(duì)列中；

其中，所述隊(duì)列的數(shù)量為多個(gè)，多個(gè)所述隊(duì)列用于存放待發(fā)送至所述第二服務(wù)器上進(jìn)行多種計(jì)算任務(wù)的數(shù)據(jù)；

所述隊(duì)列存放模塊根據(jù)待使用所述數(shù)據(jù)的計(jì)算任務(wù)，從多個(gè)所述隊(duì)列中選擇存放所述數(shù)據(jù)的隊(duì)列，其中，所述計(jì)算任務(wù)可以由所述第二服務(wù)器識(shí)別；

數(shù)據(jù)發(fā)送模塊，用于從所述隊(duì)列中獲取所述數(shù)據(jù)，并將所述數(shù)據(jù)發(fā)送到所述第二服務(wù)器；

判斷模塊，用于判斷所述數(shù)據(jù)是否成功發(fā)送到所述第二服務(wù)器；

在所述數(shù)據(jù)發(fā)送失敗時(shí)，所述數(shù)據(jù)發(fā)送模塊重新從所述隊(duì)列中獲取所述數(shù)據(jù)并進(jìn)行發(fā)送。

9.根據(jù)權(quán)利要求8所述的裝置，其中，還包括：

數(shù)據(jù)刪除模塊，用于在所述數(shù)據(jù)發(fā)送成功時(shí)，從所述隊(duì)列中刪除所述數(shù)據(jù)。

10.根據(jù)權(quán)利要求8所述的裝置，其中，

所述判斷模塊接收所述第二服務(wù)器發(fā)送的用于通知所述數(shù)據(jù)發(fā)送成功的消息；

如果自發(fā)送所述數(shù)據(jù)后的預(yù)設(shè)時(shí)間段內(nèi)沒有接收到所述消息，所述判斷模塊判斷所述數(shù)據(jù)發(fā)送失??；

如果自發(fā)送所述數(shù)據(jù)后的所述預(yù)設(shè)時(shí)間段內(nèi)接收到所述消息，所述判斷模塊判斷所述數(shù)據(jù)發(fā)送成功。