[發(fā)明專(zhuān)利]在線(xiàn)數(shù)據(jù)處理系統(tǒng)生成方法、裝置及設(shè)備

有效

• 申請(qǐng)?zhí)枺?/td>: 201810611809.6
• 申請(qǐng)日: 2018-06-14
• 公開(kāi)（公告）號(hào): CN110609707B
• 公開(kāi)（公告）日: 2021-11-02
• 發(fā)明（設(shè)計(jì)）人: 張旭東
• 申請(qǐng)（專(zhuān)利權(quán)）人: 北京嘀嘀無(wú)限科技發(fā)展有限公司
• 主分類(lèi)號(hào): G06F9/38
• 分類(lèi)號(hào): G06F9/38
• 代理公司: 北京同立鈞成知識(shí)產(chǎn)權(quán)代理有限公司 11205
• 代理人: 楊澤;劉芳

1.一種在線(xiàn)數(shù)據(jù)處理系統(tǒng)生成方法，其特征在于，包括：

接收用于構(gòu)建在線(xiàn)數(shù)據(jù)處理系統(tǒng)的配置信息；其中，所述配置信息包括多個(gè)邏輯構(gòu)件各自的標(biāo)識(shí)以及所述多個(gè)邏輯構(gòu)件的串行/并行關(guān)系，所述邏輯構(gòu)件為預(yù)先構(gòu)建的具有預(yù)定數(shù)據(jù)處理功能的程序語(yǔ)句的集合；

根據(jù)所述多個(gè)邏輯構(gòu)件各自的標(biāo)識(shí)調(diào)用對(duì)應(yīng)的邏輯構(gòu)件；

為調(diào)用的多個(gè)所述邏輯構(gòu)件分別分配線(xiàn)程池，以構(gòu)成所述多個(gè)邏輯構(gòu)件各自對(duì)應(yīng)的處理單元；

基于所述串行/并行關(guān)系，利用所述多個(gè)邏輯構(gòu)件各自對(duì)應(yīng)的處理單元生成所述在線(xiàn)數(shù)據(jù)處理系統(tǒng)。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述為調(diào)用的多個(gè)所述邏輯構(gòu)件分別分配線(xiàn)程池，以構(gòu)成所述多個(gè)邏輯構(gòu)件各自對(duì)應(yīng)的處理單元，包括：

分別構(gòu)建每一所述邏輯構(gòu)件對(duì)應(yīng)的待處理任務(wù)隊(duì)列以及該邏輯構(gòu)件對(duì)應(yīng)的線(xiàn)程池；

根據(jù)每一所述邏輯構(gòu)件、該邏輯構(gòu)件對(duì)應(yīng)的所述待處理任務(wù)隊(duì)列以及所述線(xiàn)程池構(gòu)建該邏輯構(gòu)件對(duì)應(yīng)的處理單元。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述根據(jù)每一所述邏輯構(gòu)件、該邏輯構(gòu)件對(duì)應(yīng)的所述待處理任務(wù)隊(duì)列以及所述線(xiàn)程池構(gòu)建該邏輯構(gòu)件對(duì)應(yīng)的處理單元，包括：

構(gòu)建所述線(xiàn)程池中的線(xiàn)程與所述待處理任務(wù)隊(duì)列之間的監(jiān)測(cè)關(guān)系，以使所述線(xiàn)程池中的線(xiàn)程監(jiān)測(cè)所述待處理任務(wù)隊(duì)列中是否存在邏輯請(qǐng)求；所述邏輯請(qǐng)求用于調(diào)用對(duì)應(yīng)的處理單元的邏輯構(gòu)件進(jìn)行數(shù)據(jù)處理；

構(gòu)建所述線(xiàn)程池中的線(xiàn)程與所述邏輯構(gòu)件之間的調(diào)用關(guān)系，以使所述線(xiàn)程池中的線(xiàn)程在監(jiān)測(cè)到所述待處理任務(wù)隊(duì)列中存在所述邏輯請(qǐng)求時(shí)，根據(jù)所述邏輯請(qǐng)求調(diào)用相應(yīng)的邏輯構(gòu)件進(jìn)行數(shù)據(jù)處理。

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述基于所述串行/并行關(guān)系，利用所述多個(gè)邏輯構(gòu)件各自對(duì)應(yīng)的處理單元生成所述在線(xiàn)數(shù)據(jù)處理系統(tǒng)，包括：

根據(jù)所述串行/并行關(guān)系分別加載各所述處理單元的配置文件，以生成所述在線(xiàn)數(shù)據(jù)處理系統(tǒng)。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述根據(jù)所述多個(gè)邏輯構(gòu)件各自的標(biāo)識(shí)調(diào)用對(duì)應(yīng)的邏輯構(gòu)件，還包括：

確定各所述邏輯構(gòu)件對(duì)應(yīng)的邏輯請(qǐng)求結(jié)構(gòu)體和處理結(jié)果結(jié)構(gòu)體；其中，所述邏輯請(qǐng)求結(jié)構(gòu)體用于識(shí)別對(duì)應(yīng)的邏輯構(gòu)件的邏輯請(qǐng)求，所述處理結(jié)果結(jié)構(gòu)體用于識(shí)別對(duì)應(yīng)的邏輯構(gòu)件返回的數(shù)據(jù)處理結(jié)果。

6.一種基于權(quán)利要求1-5任一項(xiàng)所述方法生成的在線(xiàn)數(shù)據(jù)處理系統(tǒng)的數(shù)據(jù)處理方法，其特征在于，包括：

接收用戶(hù)輸入的待處理數(shù)據(jù)；

根據(jù)所述多個(gè)邏輯構(gòu)件的串行/并行關(guān)系生成多個(gè)邏輯請(qǐng)求；

根據(jù)每一所述邏輯請(qǐng)求調(diào)用相應(yīng)的邏輯構(gòu)件進(jìn)行數(shù)據(jù)處理；

接收各所述邏輯構(gòu)件基于所述邏輯請(qǐng)求返回的數(shù)據(jù)處理結(jié)果；

對(duì)各所述數(shù)據(jù)處理結(jié)果進(jìn)行合并，得到最終的數(shù)據(jù)處理結(jié)果。

7.一種在線(xiàn)數(shù)據(jù)處理系統(tǒng)生成裝置，其特征在于，包括：

配置信息接收模塊，用于接收用于構(gòu)建在線(xiàn)數(shù)據(jù)處理系統(tǒng)的配置信息；其中，所述配置信息包括多個(gè)邏輯構(gòu)件各自的標(biāo)識(shí)以及所述多個(gè)邏輯構(gòu)件的串行/并行關(guān)系，所述邏輯構(gòu)件為預(yù)先構(gòu)建的具有預(yù)定數(shù)據(jù)處理功能的程序語(yǔ)句的集合；

邏輯構(gòu)件調(diào)用模塊，用于根據(jù)所述多個(gè)邏輯構(gòu)件各自的標(biāo)識(shí)調(diào)用對(duì)應(yīng)的邏輯構(gòu)件；

處理單元構(gòu)建模塊，用于為調(diào)用的多個(gè)所述邏輯構(gòu)件分別分配線(xiàn)程池，以構(gòu)成所述多個(gè)邏輯構(gòu)件各自對(duì)應(yīng)的處理單元；

在線(xiàn)系統(tǒng)生成模塊，用于基于所述串行/并行關(guān)系，利用所述多個(gè)邏輯構(gòu)件各自對(duì)應(yīng)的處理單元生成所述在線(xiàn)數(shù)據(jù)處理系統(tǒng)。

8.根據(jù)權(quán)利要求7所述的裝置，其特征在于，所述處理單元構(gòu)建模塊包括：

隊(duì)列線(xiàn)程構(gòu)建子模塊，用于分別構(gòu)建每一所述邏輯構(gòu)件對(duì)應(yīng)的待處理任務(wù)隊(duì)列以及該邏輯構(gòu)件對(duì)應(yīng)的線(xiàn)程池；

處理單元構(gòu)建子模塊，用于根據(jù)每一所述邏輯構(gòu)件、該邏輯構(gòu)件對(duì)應(yīng)的所述待處理任務(wù)隊(duì)列以及所述線(xiàn)程池構(gòu)建該邏輯構(gòu)件對(duì)應(yīng)的處理單元。