[發明專利]一種動態擴容的方法及終端

有效

• 申請號: 202110068609.2
• 申請日: 2021-01-19
• 公開（公告）號: CN112764679B
• 公開（公告）日: 2022-04-12
• 發明（設計）人: 劉德建;林偉;郭玉湖;陳宏
• 申請（專利權）人: 福建天泉教育科技有限公司
• 主分類號: G06F3/06
• 分類號: G06F3/06
• 代理公司: 福州市博深專利事務所(普通合伙) 35214
• 代理人: 張明

1.一種動態擴容的方法，其特征在于，包括步驟：

S1、創建邏輯主題，并建立所述邏輯主題與kafka中的第一物理主題的第一映射關系；

S2、接收擴容信息，根據所述擴容信息在kafka中建立第二物理主題并建立所述第二物理主題與所述邏輯主題的第二映射關系；

S3、根據所述第一映射關系及所述第二映射關系進行目標消息的寫入或讀取；

所述S3中所述根據所述第一映射關系及所述第二映射關系進行目標消息的讀取具體為：

接收消息讀取信號，所述消息讀取信號包括目標消息條數；

獲取所述第一物理主題及所述第二物理主題相加的總數目；

根據所述總數目均分所述目標消息條數得到目標數目；

根據所述目標數目分別從所述第一物理主題和所述第二物理主題中獲取對應條數的目標消息。

2.根據權利要求1所述的一種動態擴容的方法，其特征在于，所述第一物理主題關聯一個或多個第一分區，所述第二物理主題關聯一個或多個第二分區；

所述S1具體為：

創建邏輯主題，并分別建立所述邏輯主題與所述第一物理主題中每一第一分區的第一映射關系；

所述S2具體為：

接收擴容信息，根據所述擴容信息在kafka中建立第二物理主題并分別建立所述邏輯主題與所述第二物理主題中每一第二分區的第二映射關系；

所述S3具體為：

根據所述第一映射關系及所述第二映射關系通過所述第一分區或所述第二分區進行目標消息的寫入或讀取。

3.根據權利要求1所述的一種動態擴容的方法，其特征在于，所述S1具體為：創建一個邏輯主題，并建立所述邏輯主題與kafka中的第一物理主題的第一映射關系；

所述S3具體為：

將所述第一映射關系及所述第二映射關系合并并按預設規則進行排序得到排序結果；

根據所述排序結果得到各個映射關系的第一標號，所述映射關系包括所述第一映射關系及所述第二映射關系；

根據所述第一標號，通過所述邏輯主題進行目標消息的寫入或讀取。

4.根據權利要求3所述的一種動態擴容的方法，其特征在于，所述S3中所述根據所述第一標號，通過所述邏輯主題進行目標消息的寫入包括：

接收消息寫入信號，所述消息寫入信號包括目標消息；

獲取所述目標消息的標識符，對所述標識符取模得到第二標號；

獲取所述第一標號中與所述第二標號相同的目標標號，并獲取所述目標標號對應的目標映射關系；

根據所述目標映射關系獲取目標物理主題，通過所述邏輯主題將所述目標消息寫入所述目標物理主題。

5.一種動態擴容的終端，包括存儲器、處理器及存儲在所述存儲器上并可在所述處理器上運行的計算機程序，其特征在于，所述處理器執行所述計算機程序時實現以下步驟：

S1、創建邏輯主題，并建立所述邏輯主題與kafka中的第一物理主題的第一映射關系；

S2、接收擴容信息，根據所述擴容信息在kafka中建立第二物理主題并建立所述第二物理主題與所述邏輯主題的第二映射關系；

S3、根據所述第一映射關系及所述第二映射關系進行目標消息的寫入或讀取；

所述S3中所述根據所述第一映射關系及所述第二映射關系進行目標消息的讀取具體為：

接收消息讀取信號，所述消息讀取信號包括目標消息條數；

獲取所述第一物理主題及所述第二物理主題相加的總數目；

根據所述總數目均分所述目標消息條數得到目標數目；

根據所述目標數目分別從所述第一物理主題和所述第二物理主題中獲取對應條數的目標消息。