[發明專利]一種基于異步的聲明式的微服務調度方法

有效

• 申請號: 202010082191.6
• 申請日: 2020-02-07
• 公開（公告）號: CN111611089B
• 公開（公告）日: 2023-06-27
• 發明（設計）人: 于樹松;周志明;陶冶;楊寧;石碩;宮會麗;丁香乾;侯瑞春;孟宇
• 申請（專利權）人: 中國海洋大學
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F8/71
• 代理公司: 青島聯智專利商標事務所有限公司 37101
• 代理人: 邵新華

1.一種基于異步的聲明式的微服務調度方法，其特征在于，包括：

以編寫配置文件的方式構建組合型微服務，在配置文件中定義構成所述組合型微服務所需的所有微服務之間的調用關系；

在訪問者請求訪問所述組合型微服務時，利用調度中心加載所述組合型微服務所對應的配置文件；

通過調度中心解析所述組合型微服務的構成，生成具有包含關系的組合型微服務結構樹；

對結構樹中所包含的微服務進行異步調用；

將滿足調用條件的微服務送入流水線執行；

所述調度中心在將某一微服務送入流水線執行時，在此微服務中增加一個引用計數參數；所述引用計數參數在此微服務每次被調用時自動加1，在此微服務每次執行完畢后自動減1；當所述引用計數參數等于零時，調度中心將此微服務退出流水線；

匯總流水線中的微服務執行完畢后產生的返回結果，寫回緩存。

2.根據權利要求1所述的基于異步的聲明式的微服務調度方法，其特征在于，所述配置文件按照DSL語言規則編寫，在所述配置文件中采用以下邏輯結構描述各微服務之間的調用關系：

name：命名，用于為組合型微服務命名；

serial：串行，用于上級微服務調用下級微服務；

parallel：并行，用于同級微服務間的調用；

condition：分支，用于對符合條件的微服務進行調用；

jump：循環，用于在條件成立的情況下跳轉到指定的微服務循環執行；

break：跳出，用于跳出循環；

start：開始，用于在指定端口和hostname下發布組合型微服務；hostname為域名、ip或者主機名；

wait：等待，用于等待某一條件滿足后進行下一步微服務調用；

end：結束，用于結束微服務的執行。

3.根據權利要求1所述的基于異步的聲明式的微服務調度方法，其特征在于，在所述組合型微服務結構樹中，父節點表示組合型微服務，葉子節點表示單一型微服務；在所述對結構樹中所包含的微服務進行異步調用的過程中，包括：

解析葉子節點；

從作為葉子節點的微服務中解析出運行參數齊全的微服務，形成獨立無依賴的微服務，直接調用；

將需要其他微服務提供參數或者需要條件判斷的微服務，形成有依賴的微服務，在其調用條件滿足時再行調用。

4.根據權利要求3所述的基于異步的聲明式的微服務調度方法，其特征在于，在所述將滿足調用條件的微服務送入流水線執行的過程中，包括：

將獨立無依賴的微服務直接送入流水線執行；

對于有依賴的微服務，在等待其所依賴的微服務執行完畢后，通知調度中心，由調度中心傳遞參數，并在參數滿足判斷條件后，送入流水線執行。

5.根據權利要求4所述的基于異步的聲明式的微服務調度方法，其特征在于，所述調度中心利用多條流水線分別執行微服務，每一個微服務流水線操作是一個獨立的的進程。

6.根據權利要求5所述的基于異步的聲明式的微服務調度方法，其特征在于，所述多條流水線部署到不同的主機中，負責相關邏輯業務操作；或者在同一主機部署多條不同的流水線操作；多條流水線操作異步執行，微服務在空閑的流水線操作中執行，使多個微服務并行執行。

7.根據權利要求1至6中任一項所述的基于異步的聲明式的微服務調度方法，其特征在于，所述調度中心在調用某一微服務時，對傳入此微服務的參數是否已使用過進行判斷，若使用過所述參數，則將所述參數在首次傳入此微服務時此微服務所生成的返回結果直接反饋給調用者；若未使用過所述參數，則將所述參數傳入此微服務執行，并將此微服務的返回結果與所述參數一起寫回緩存。