[發(fā)明專利]消息消費(fèi)方法、裝置、計(jì)算機(jī)設(shè)備和存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202010221369.0
• 申請(qǐng)日: 2020-03-26
• 公開（公告）號(hào): CN111427708A
• 公開（公告）日: 2020-07-17
• 發(fā)明（設(shè)計(jì)）人: 任超超
• 申請(qǐng)（專利權(quán)）人: 中國平安財(cái)產(chǎn)保險(xiǎn)股份有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54;G06F8/71;G06F16/172
• 代理公司: 廣州華進(jìn)聯(lián)合專利商標(biāo)代理有限公司 44224
• 代理人: 唐彩琴

1.一種消息消費(fèi)方法，其特征在于，所述方法包括：

根據(jù)數(shù)據(jù)源的名稱從預(yù)存消費(fèi)規(guī)則配置文件中獲取相應(yīng)消息消費(fèi)規(guī)則；所述消息消費(fèi)規(guī)則包括需要消費(fèi)的消息的起止時(shí)間，所述起止時(shí)間根據(jù)消息到達(dá)消息中間件的預(yù)估時(shí)間設(shè)定；

根據(jù)所述消息消費(fèi)規(guī)則，從消息中間件中查找在所述起止時(shí)間內(nèi)到達(dá)所述消息中間件的消息，并對(duì)其進(jìn)行消費(fèi)；

將已消費(fèi)的所述消息存儲(chǔ)到目標(biāo)文件，并設(shè)置所述起止時(shí)間為所述目標(biāo)文件的名稱。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述根據(jù)數(shù)據(jù)源的名稱從預(yù)存消費(fèi)規(guī)則配置文件中獲取相應(yīng)消息消費(fèi)規(guī)則步驟包括：

根據(jù)數(shù)據(jù)源的名稱從預(yù)存消費(fèi)規(guī)則配置文件中獲取消息進(jìn)入的應(yīng)用程序接口、消息輸出的應(yīng)用程序接口、對(duì)消息的輸入輸出進(jìn)行處理的可執(zhí)行文件；

其中，所述消息進(jìn)入的應(yīng)用程序接口、消息輸出的應(yīng)用程序接口、對(duì)消息的輸入輸出進(jìn)行處理的可執(zhí)行文件配置了相應(yīng)消息消費(fèi)規(guī)則；其中，所述消息輸出的應(yīng)用程序接口配置了需要消費(fèi)的消息的起止時(shí)間。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述消息輸出的應(yīng)用程序接口配置了保存所述消息的文件的命名方式、保存所述消息的單個(gè)文件大小和保存所述消息的文件的目錄；

所述將已消費(fèi)的所述消息存儲(chǔ)到目標(biāo)文件，并設(shè)置所述起止時(shí)間為所述目標(biāo)文件的名稱步驟包括：

將所述消費(fèi)的消息按照所述保存所述消息的文件的命名方式、保存所述消息的單個(gè)文件大小和保存所述消息的文件的目錄存儲(chǔ)到目標(biāo)文件，所述保存所述消息的文件的命名方式包括設(shè)置所述起止時(shí)間為所述目標(biāo)文件的名稱。

4.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述消息進(jìn)入的應(yīng)用程序接口配置了需要消費(fèi)的消息的通信協(xié)議；

所述根據(jù)所述消息消費(fèi)規(guī)則，從消息中間件中查找在所述起止時(shí)間內(nèi)到達(dá)所述消息中間件的消息，并對(duì)其進(jìn)行消費(fèi)步驟包括：

根據(jù)所述需要消費(fèi)的消息的通信協(xié)議與對(duì)應(yīng)的消息中間件進(jìn)行通信；

根據(jù)所述消息消費(fèi)規(guī)則，從所述消息中間件中查找在所述起止時(shí)間內(nèi)到達(dá)所述消息中間件的消息，并對(duì)其進(jìn)行消費(fèi)。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述根據(jù)所述消息消費(fèi)規(guī)則，從消息中間件中查找在所述起止時(shí)間內(nèi)到達(dá)所述消息中間件的消息，并對(duì)其進(jìn)行消費(fèi)步驟包括：

根據(jù)所述消息消費(fèi)規(guī)則，從消息中間件中查詢開始消費(fèi)的消息的位置和結(jié)束消費(fèi)的消息的位置；所述消息按照到達(dá)所述消息中間件的時(shí)間的先后順序在所述消息中間件依次排序；

依次對(duì)所述開始消費(fèi)的消息的位置和所述結(jié)束消費(fèi)的消息的位置之間的消息進(jìn)行消費(fèi)。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，所述依次對(duì)所述開始消費(fèi)的消息的位置和所述結(jié)束消費(fèi)的消息的位置之間的消息進(jìn)行消費(fèi)的步驟之后，包括：

記錄每個(gè)所述消費(fèi)的消息的大小和/或統(tǒng)計(jì)所述消費(fèi)的消息的條數(shù)。

7.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述將已消費(fèi)的所述消息存儲(chǔ)到目標(biāo)文件，并設(shè)置所述起止時(shí)間為所述目標(biāo)文件的名稱步驟包括：

將所述消費(fèi)的消息按照預(yù)設(shè)文件大小或者預(yù)設(shè)條數(shù)存儲(chǔ)到文本文件，所述文本文件存儲(chǔ)預(yù)設(shè)文件大小的消息或者預(yù)設(shè)條數(shù)的消息，并設(shè)置所述起止時(shí)間為所述文本文件的名稱。

8.一種消息消費(fèi)裝置，其特征在于，所述裝置包括：

消息消費(fèi)規(guī)則獲取模塊，用于根據(jù)數(shù)據(jù)源的名稱從預(yù)存消費(fèi)規(guī)則配置文件中獲取相應(yīng)消息消費(fèi)規(guī)則；所述消息消費(fèi)規(guī)則包括需要消費(fèi)的消息的起止時(shí)間，所述起止時(shí)間根據(jù)消息到達(dá)消息中間件的預(yù)估時(shí)間設(shè)定；

消費(fèi)模塊，用于根據(jù)所述消息消費(fèi)規(guī)則，從消息中間件中查找在所述起止時(shí)間內(nèi)到達(dá)所述消息中間件的消息，并對(duì)其進(jìn)行消費(fèi)；

存儲(chǔ)模塊，用于將已消費(fèi)的所述消息存儲(chǔ)到目標(biāo)文件，并設(shè)置所述起止時(shí)間為所述目標(biāo)文件的名稱。

9.一種計(jì)算機(jī)設(shè)備，包括存儲(chǔ)器和處理器，所述存儲(chǔ)器存儲(chǔ)有計(jì)算機(jī)程序，其特征在于，所述處理器執(zhí)行所述計(jì)算機(jī)程序時(shí)實(shí)現(xiàn)權(quán)利要求1至7中任一項(xiàng)所述方法的步驟。

10.一種計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，其上存儲(chǔ)有計(jì)算機(jī)程序，其特征在于，所述計(jì)算機(jī)程序被處理器執(zhí)行時(shí)實(shí)現(xiàn)權(quán)利要求1至7中任一項(xiàng)所述的方法的步驟。