[發(fā)明專利]一種數(shù)據(jù)的獲取方法、服務(wù)器及相關(guān)系統(tǒng)

在審

• 申請?zhí)枺?/td>: 201910267904.3
• 申請日: 2019-04-03
• 公開（公告）號: CN111782412A
• 公開（公告）日: 2020-10-16
• 發(fā)明（設(shè)計(jì)）人: 王猛;張書澔;王茂
• 申請（專利權(quán)）人: 阿里巴巴集團(tuán)控股有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 北京思格頌知識產(chǎn)權(quán)代理有限公司 11635
• 代理人: 潘珺

1.一種數(shù)據(jù)的獲取方法，其特征在于，包括：

在自身client任務(wù)啟動后，判斷自身client任務(wù)是否為當(dāng)前向第三方服務(wù)器獲取數(shù)據(jù)的主進(jìn)程；所述主進(jìn)程為當(dāng)前時(shí)刻可向所述第三方服務(wù)器獲取數(shù)據(jù)的唯一進(jìn)程；

當(dāng)判斷結(jié)果為是時(shí)，連接所述第三方服務(wù)器并請求獲取數(shù)據(jù)；

當(dāng)每條數(shù)據(jù)消息到達(dá)時(shí)，判斷自身client任務(wù)是否仍然為所述主進(jìn)程；當(dāng)判斷為是，則獲取該數(shù)據(jù)并處理。

2.如權(quán)利要求1所述的方法，其特征在于，所述判斷自身client任務(wù)是否為當(dāng)前向第三方服務(wù)器獲取數(shù)據(jù)的主進(jìn)程，包括：

查詢主進(jìn)程列表中主進(jìn)程的標(biāo)識，確定自身是否為所述主進(jìn)程；

所述主進(jìn)程列表中的主進(jìn)程，通過下述方式預(yù)先得到：

在當(dāng)前在線的各client任務(wù)的列表中，查詢所述各client任務(wù)上線的時(shí)間；

確定上線時(shí)間最新的client任務(wù)為所述主進(jìn)程。

3.如權(quán)利要求2所述的方法，其特征在于，還包括：所述各client任務(wù)的列表，通過下述方式獲得：

向選主服務(wù)器訂閱選主服務(wù)；

接收并記錄選主服務(wù)器發(fā)送的集群服務(wù)器中各服務(wù)器已上線的各client任務(wù)的標(biāo)識及上線時(shí)間。

4.如權(quán)利要求3所述的方法，其特征在于，在自身client任務(wù)啟動后，還包括：向所述選主服務(wù)器發(fā)布自身client任務(wù)的標(biāo)識。

5.如權(quán)利要求1所述的方法，其特征在于，當(dāng)每條數(shù)據(jù)消息到達(dá)時(shí)，獲取該數(shù)據(jù)并處理之后，還包括：

判斷當(dāng)前自身client任務(wù)的處理時(shí)長是否超過預(yù)設(shè)的第一時(shí)長閾值，若否，則轉(zhuǎn)向獲取下個(gè)數(shù)據(jù)消息的步驟，若是，則退出。

6.如權(quán)利要求1所述的方法，其特征在于，在連接所述第三方服務(wù)器并請求獲取數(shù)據(jù)之后，還包括：

判斷等待數(shù)據(jù)消息到達(dá)的時(shí)間是否超過預(yù)設(shè)的第二時(shí)長閾值，若超過，則退出，若未超過，則轉(zhuǎn)向執(zhí)行所述判斷自身client任務(wù)是否仍然為所述主進(jìn)程的步驟。

7.如權(quán)利要求1-6任一項(xiàng)所述的方法，其特征在于，所述自身client任務(wù)是通過下述方式啟動的：

由預(yù)設(shè)的調(diào)度服務(wù)器從所述服務(wù)器集群中調(diào)度而啟動的；或由預(yù)設(shè)的調(diào)度服務(wù)器判斷作為主進(jìn)程的client任務(wù)完成或者退出后重新從所述集群服務(wù)器中調(diào)度而啟動的。

8.一種數(shù)據(jù)獲取服務(wù)器，其特征在于，包括：

判斷模塊，用于在自身client任務(wù)啟動后，判斷自身client任務(wù)是否為當(dāng)前向第三方服務(wù)器獲取數(shù)據(jù)的主進(jìn)程；所述主進(jìn)程為當(dāng)前時(shí)刻可向所述第三方服務(wù)器獲取數(shù)據(jù)的唯一進(jìn)程；以及在當(dāng)每條數(shù)據(jù)消息到達(dá)時(shí)，判斷自身client任務(wù)是否仍然為所述主進(jìn)程；

連接模塊，用于連接所述第三方服務(wù)器；

請求模塊，用于向所述第三方服務(wù)器獲取數(shù)據(jù)；

數(shù)據(jù)獲取模塊，用于當(dāng)所述判斷模塊判斷自身client任務(wù)仍然為主進(jìn)程時(shí)，獲取該數(shù)據(jù)并處理。

9.如權(quán)利要求10所述的服務(wù)器，其特征在于，還包括：

查詢模塊，用于向主進(jìn)程確定查詢主進(jìn)程列表中主進(jìn)程的標(biāo)識，確定自身是否為所述主進(jìn)程；

主進(jìn)程確定模塊，用于在當(dāng)前在線的各client任務(wù)的列表中，查詢所述各client任務(wù)上線的時(shí)間；確定上線時(shí)間最新的client任務(wù)為所述主進(jìn)程。

10.如權(quán)利要求8所述的服務(wù)器，其特征在于，所述判斷模塊，還用于當(dāng)每條數(shù)據(jù)消息到達(dá)時(shí)，獲取該數(shù)據(jù)并處理之后，判斷當(dāng)前自身client任務(wù)的client任務(wù)是否超過預(yù)設(shè)的第一時(shí)長閾值；

所述數(shù)據(jù)獲取模塊，還用于當(dāng)所述判斷模塊判斷為否時(shí)，執(zhí)行獲取下個(gè)數(shù)據(jù)消息的步驟，否則，退出。