[發(fā)明專利]一種分布式系統(tǒng)的調(diào)用方法和裝置

在審

• 申請?zhí)枺?/td>: 201410645287.3
• 申請日: 2014-11-06
• 公開（公告）號: CN105635231A
• 公開（公告）日: 2016-06-01
• 發(fā)明（設計）人: 李俊奎
• 申請（專利權(quán)）人: 阿里巴巴集團控股有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L29/06
• 代理公司: 北京博思佳知識產(chǎn)權(quán)代理有限公司 11415
• 代理人: 林祥

技術領域

本申請涉及通信技術領域，尤其涉及一種分布式系統(tǒng)的調(diào)用方法和裝置。

背景技術

分布式系統(tǒng)通常由能夠?qū)崿F(xiàn)不同功能的服務器或服務器集成組成，各個 服務器或服務器集群之間通過調(diào)用實現(xiàn)相互交互。上游節(jié)點發(fā)送調(diào)用消息， 并等待下游節(jié)點在處理完成之后的反饋。如果下游節(jié)點處理超時，則會造成 下游節(jié)點中大量計算資源的浪費。

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

有鑒于此，本申請?zhí)峁┮环N分布式系統(tǒng)的調(diào)用方法和裝置，以解決下游 節(jié)點處理超時所導致的計算資源的浪費。

具體地，本申請是通過如下技術方案實現(xiàn)的：

一種分布式系統(tǒng)的調(diào)用方法，所述方法包括：

從上游節(jié)點發(fā)送的第一調(diào)用消息中獲取第一超時時間；

在對所述第一調(diào)用消息進行處理的過程中，判斷對所述第一調(diào)用消息進 行處理所消耗的時間是否已超過所述第一超時時間；

如果對所述第一調(diào)用消息進行處理所消耗的時間已超過所述第一超時時 間，則停止對所述第一調(diào)用消息進行處理。

進一步地，如果對所述第一調(diào)用消息進行處理所消耗的時間已超過所述 第一超時時間，則停止對下游節(jié)點的調(diào)用。

進一步地，所述方法還包括：

如果對所述第一調(diào)用消息進行處理所消耗的時間沒有超過所述第一超時 時間，則在完成對所述第一調(diào)用消息的處理后，向下游節(jié)點發(fā)送第二調(diào)用消 息，并在所述第二調(diào)用消息中攜帶第二超時時間。

進一步地，所述方法還包括：

判斷是否在所述第二超時時間內(nèi)接收到下游節(jié)點返回的處理完成的消息；

如果沒有在所述第二超時時間內(nèi)接收到下游節(jié)點返回的處理完成的消息， 則確認超時。

進一步地，所述第二超時時間是第一調(diào)用剩余時間和預設的第二調(diào)用超 時時間中的較小值，其中，所述第一調(diào)用剩余時間等于所述第一超時時間減 去完成對所述第一調(diào)用消息的處理所消耗的時間。

進一步地，所述判斷對所述第一調(diào)用消息進行處理所消耗的時間是否已 超過所述第一超時時間包括：

在執(zhí)行完對所述第一調(diào)用消息進行處理過程中的每個步驟后，判斷當前 對所述第一調(diào)用消息進行處理所消耗的時間是否已超過所述第一超時時間；

所述停止對所述第一調(diào)用消息進行處理包括：

停止執(zhí)行對所述第一調(diào)用消息進行處理過程中的下一個步驟。

一種分布式系統(tǒng)的調(diào)用裝置，所述裝置包括：

時間獲取單元，從上游節(jié)點發(fā)送的第一調(diào)用消息中獲取第一超時時間；

第一判斷單元，在對所述第一調(diào)用消息進行處理的過程中，判斷對所述 第一調(diào)用消息進行處理所消耗的時間是否已超過所述第一超時時間；

第一處理單元，在對所述第一調(diào)用消息進行處理所消耗的時間已超過所 述第一超時時間時，停止對所述第一調(diào)用消息進行處理。

進一步地，所述第一處理單元，在對所述第一調(diào)用消息進行處理所消耗 的時間已超過所述第一超時時間時，停止對下游節(jié)點的調(diào)用。

進一步地，所述裝置還包括：

下游調(diào)用單元，在對所述第一調(diào)用消息進行處理所消耗的時間沒有超過 所述第一超時時間時，在完成對所述第一調(diào)用消息的處理后，向下游節(jié)點發(fā) 送第二調(diào)用消息，并在所述第二調(diào)用消息中攜帶第二超時時間。

進一步地，所述裝置還包括：

第二判斷單元，判斷是否在所述第二超時時間內(nèi)接收到下游節(jié)點返回的 處理完成的消息；

第二處理單元，在沒有在所述第二超時時間內(nèi)接收到下游節(jié)點返回的處 理完成的消息時，確認超時。

進一步地，所述第二超時時間是第一調(diào)用剩余時間和預設的第二調(diào)用超 時時間中的較小值，其中，所述第一調(diào)用剩余時間等于所述第一超時時間減 去完成對所述第一調(diào)用消息的處理所消耗的時間。

進一步地，所述第一判斷單元，具體在執(zhí)行完對所述第一調(diào)用消息進行 處理過程中的每個步驟后，判斷當前對所述第一調(diào)用消息進行處理所消耗的 時間是否已超過所述第一超時時間；

所述第一處理單元，在對所述第一調(diào)用消息進行處理所消耗的時間已超 過所述第一超時時間時，具體停止執(zhí)行對所述第一調(diào)用消息進行處理過程中 的下一個步驟。