[發明專利]集群環境下的任務分發方法和裝置

在審

• 申請號: 202010987114.5
• 申請日: 2020-09-18
• 公開（公告）號: CN112115202A
• 公開（公告）日: 2020-12-22
• 發明（設計）人: 李楠;馮玉;陳榮基
• 申請（專利權）人: 北京人大金倉信息技術股份有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F9/48;G06F9/46
• 代理公司: 北京開陽星知識產權代理有限公司 11710
• 代理人: 安偉

1.一種集群環境下的任務分發方法，其特征在于，用于采用集群架構的數據庫系統中的客戶端，所述方法包括：

獲取集群配置信息，根據所述集群配置信息建立與各個數據節點的連接接口；

接收用戶輸入的任務，根據所述任務的類型和預先設定的分發策略選擇所述數據節點作為任務處理節點；

將所述任務通過與所述任務處理節點對應的連接接口發送給所述任務處理節點。

2.根據權利要求1所述的集群環境下的任務分發方法，其特征在于，

所述集群架構為主從集群架構，所述數據節點包括一主要節點；

根據所述任務的類型和預先設定的分發策略選擇所述數據節點作為任務處理節點，包括：

在所述任務為寫任務，或者所述任務處在事務并且所述事務已經執行寫任務的情況下，將所述主要節點作為所述任務處理節點；

在所述任務為事務內的讀任務并且所述事務未執行過寫任務，或者所述任務為讀任務并且所述任務處在事務外的情況下，采用輪詢算法在所有所述數據節點中選定一數據節點作為所述任務處理節點；以及，

在所述任務類型為其他任務情況下，將所有所述數據節點作為所述任務處理節點。

3.根據權利要求2所述的集群環境下的任務分發方法，其特征在于，所述集群配置信息包括各個所述數據節點的預設權重；

采用輪詢算法在所述數據節點中選定所述任務處理節點，包括：

求取各個所述數據節點的歷史選擇權重之和，作為總權重；

求取執行上一次任務的所述數據節點的歷史選擇權重與總權重之差，作為執行上一次任務的所述數據節點新的歷史選擇權重；

求取各個數據節點的所述歷史選擇權重和預設權重之和，作為各個所述數據節點的當前選擇權重；

將最大的所述當前選擇權重對應的所述數據節點作為所述任務處理節點。

4.根據權利要求1所述的集群環境下的任務分發方法，其特征在于，還包括：建立與客戶端上層驅動連接的連接句柄；

接收用戶輸入的任務，包括：采用所述連接句柄接收所述上層驅動下傳的所述任務。

5.根據權利要求1所述的集群環境下的任務分發方法，其特征在于，獲取集群配置信息，根據所述集群配置信息建立與各個數據節點的連接接口，包括：

采用連接函數獲取所述集群配置信息，以及，根據所述集群配置信息建立與各個所述數據節點的連接接口。

6.一種集群環境下的任務分發裝置，其特征在于，用于采用集群架構的數據庫系統中的客戶端，所述裝置包括：

接口建立單元，用于獲取集群配置信息，根據所述集群配置信息建立與各個數據節點的連接接口；

任務處理節點選擇單元，用于接收用戶輸入的任務，根據所述任務的類型和預先設定的分發策略選擇所述數據節點作為任務處理節點；

任務發送單元，用于將所述任務通過與所述任務處理節點對應的連接接口發送給所述任務處理節點。

7.根據權利要求6所述的集群環境下的任務分發裝置，其特征在于，

所述集群架構為主從集群架構，所述數據節點包括一主要節點；

所述任務處理節點選擇單元用于，在所述任務為寫任務，或者所述任務處在事務并且所述事務已經執行寫任務的情況下，將所述主要節點作為所述任務處理節點；

在所述任務為事務內的讀任務并且所述事務未執行過寫任務，或者所述任務為讀任務并且所述任務處在事務外的情況下，采用輪詢算法在所有所述數據節點中選定一數據節點作為所述任務處理節點；以及，

在所述任務類型為其他任務的情況下，將所有所述數據節點作為所述任務處理節點。