[發明專利]地震道數據的獲取方法、主節點服務器及工作節點服務器

有效

• 申請號: 201611055460.X
• 申請日: 2016-11-25
• 公開（公告）號: CN106790389B
• 公開（公告）日: 2020-09-08
• 發明（設計）人: 趙長海;文佳敏;杜吉國;王增波;冉賢華;尚民強
• 申請（專利權）人: 中國石油天然氣集團公司;中國石油集團東方地球物理勘探有限責任公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 李輝

1.一種分布式系統中地震道數據的獲取方法，所述分布式系統中包括主節點服務器和至少一個工作節點服務器，各個所述工作節點服務器中分別存儲至少一個數據塊，各個所述數據塊中包含至少一個地震道的數據，其特征在于，所述主節點服務器中包括與各個所述工作節點服務器一一對應的本地隊列，所述本地隊列用于保存對應的地震道編號，所述方法包括：

所述主節點服務器接收地震道數據獲取請求，所述地震道數據獲取請求中包括目標地震道的地震道編號；

所述主節點服務器根據所述地震道編號，確定所述目標地震道對應的目標數據塊；

所述主節點服務器確定存儲所述目標數據塊的目標工作節點服務器，并將所述地震道編號存放于與所述目標工作節點服務器相對應的目標本地隊列中；

所述主節點服務器從各個本地隊列中確定存放地震道編號數量最多的待轉移本地隊列；

當所述待轉移本地隊列中的地震道編號數量大于任務中封裝的地震道編號數量時，所述主節點服務器確定所述待轉移本地隊列對應的待轉移的地震道編號數量；

當所述待轉移的地震道編號數量大于任務中封裝的地震道編號數量時，所述主節點服務器從所述待轉移本地隊列中取出已存放的一個地震道編號，并將取出的地震道編號重新存放至另一個本地隊列中，所述另一個本地隊列對應的工作節點服務器中存儲的數據塊包含所述取出的地震道編號對應的地震道數據；

所述主節點服務器重復上述從所述待轉移本地隊列中取出地震道編號并重新存放的步驟，直至取出的地震道編號的數量達到所述待轉移的地震道編號數量為止；

響應于所述目標工作節點服務器發來的任務獲取請求，所述主節點服務器向所述目標工作節點服務器提供包含所述地震道編號的任務；

所述主節點服務器接收所述目標工作節點服務器反饋的包含所述目標地震道數據的地震數據包。

2.根據權利要求1所述的方法，其特征在于，所述主節點服務器根據所述地震道編號，確定所述目標地震道對應的目標數據塊具體包括：

所述主節點服務器按照下述公式，確定所述地震道編號對應的偏移量：

σ＝N×L

其中，σ表示所述偏移量，N表示所述地震道編號，N為大于或者等于1的整數，L表示地震道的數據長度；

所述主節點服務器基于所述偏移量，按照下述公式確定所述目標地震道對應的目標數據塊的編號：

其中，k表示所述目標數據塊的編號，M表示各個數據塊的長度，表示向上取整運算符；

相應地，所述主節點服務器確定存儲所述目標數據塊的目標工作節點服務器具體包括：

根據預先確定的數據塊的編號與工作節點服務器之間的關聯關系，所述主節點服務器確定所述目標數據塊的編號關聯的目標工作節點服務器。

3.根據權利要求1所述的方法，其特征在于，所述主節點服務器按照下述公式確定所述待轉移本地隊列對應的待轉移的地震道編號數量：

D＝T_max-T_ave

其中，D表示所述待轉移的地震道編號數量，T_max表示所述待轉移本地隊列中存放的地震道編號的數量，T_ave表示所有本地隊列中存放的地震道編號的平均數量。

4.根據權利要求1所述的方法，其特征在于，所述主節點服務器將取出的地震道編號重新存放至另一個本地隊列中具體包括：

所述主節點服務器確定所述取出的地震道編號對應的備份數據塊；

所述主節點服務器查詢存儲所述備份數據塊的至少一個備份工作節點服務器，并獲取各個備份工作節點服務器對應的本地隊列中已存放的地震道編號的數量；

所述主節點服務器將所述取出的地震道編號存放于地震道編號的數量最少的備份工作節點服務器對應的本地隊列中。

5.根據權利要求1所述的方法，其特征在于，在所述主節點服務器接收所述目標工作節點服務器反饋的包含所述目標地震道數據的地震數據包之后，所述方法還包括：

所述主節點服務器將接收的地震數據包存儲于數據緩沖區中。