[發明專利]基于可配置領域事件的訂閱發布方法、系統以及介質

在審

• 申請號: 202211596104.4
• 申請日: 2022-12-13
• 公開（公告）號: CN115878348A
• 公開（公告）日: 2023-03-31
• 發明（設計）人: 劉軍;許龍潮;宋恒
• 申請（專利權）人: 南京希音電子商務有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F21/57
• 代理公司: 廣州幫專高智知識產權代理事務所(特殊普通合伙) 44674
• 代理人: 胡洋

1.一種基于可配置領域事件的訂閱發布方法，其特征在于，包括如下步驟：

步驟1：定義每個領域事件類型，并記錄每個領域事件的基本屬性；

步驟2：定義領域事件發布渠道，確定平臺系統發布領域事件的每個發布渠道；

步驟3：配置領域事件訂閱，根據每個業務系統對領域事件的關注度，將匹配關注度的業務系統訂閱配置到相應的領域事件；

步驟4：配置領域事件發布渠道，根據每個業務系統對發布渠道的期望值，將匹配期望值的發布渠道配置至相應的業務系統；

步驟5：解析領域事件訂閱配置，平臺系統生成領域事件，通過領域事件發布器解析每個領域事件訂閱配置的業務系統，獲得業務系統清單；

步驟6：發布領域事件，根據步驟5中獲得的業務系統清單讀取業務系統配置的每個發布渠道和訂閱的領域事件，將領域事件通過發布渠道發送至相應業務系統進行處理。

2.根據權利要求1所述的基于可配置領域事件的訂閱發布方法，其特征在于，定義每個領域事件類型，包括如下步驟：

步驟101：定義同一類型領域事件時，在同類型領域事件下增加子類型的定義分支。

3.根據權利要求1所述的基于可配置領域事件的訂閱發布方法，其特征在于，所述基本屬性包括領域事件的事件類型、事件ID、事件子類型、事件時間以及事件數據。

4.根據權利要求1所述的基于可配置領域事件的訂閱發布方法，其特征在于，所述發布渠道包括kafka中間件、rabbitmq中間件以及http接口。

5.根據權利要求1所述的基于可配置領域事件的訂閱發布方法，其特征在于，所述關注度為不同業務系統對于不同領域事件的關注程度，用于過濾同業務系統無關的領域事件。

6.根據權利要求1所述的基于可配置領域事件的訂閱發布方法，其特征在于，所述期望值為不同業務系統對于不同發布渠道進行預選擇的期望程度，用于選擇領域事件的發布渠道。

7.一種基于可配置領域事件的訂閱發布系統，其特征在于，用于執行如權利要求1-6任一項所述的基于可配置領域事件的訂閱發布方法，所述發布系統包括：

領域事件定義模塊，用于定義每個領域事件類型，并記錄每個領域事件的基本屬性；

發布渠道定義模塊，用于定義領域事件發布渠道，確定平臺系統發布領域事件的每個發布渠道；

領域事件訂閱配置模塊，用于根據每個業務系統對發布渠道的期望值，將匹配期望值的發布渠道配置至相應的業務系統；

發布渠道配置模塊，用于根據每個業務系統對發布渠道的期望值，將匹配期望值的發布渠道配置至相應的業務系統；

訂閱配置解析模塊，用于通過領域事件發布器解析每個領域事件訂閱配置的業務系統，獲得業務系統清單；

領域事件發布模塊，用于讀取業務系統配置的每個發布渠道和訂閱的領域事件，將領域事件通過發布渠道發送至相應業務系統進行處理。

8.一種計算機可讀存儲介質，其特征在于，所述計算機可讀存儲介質上存儲有計算機指令，所述計算機指令在被處理器執行時，使所述處理器執行如權利要求1-6任一項所述的方法。