[發(fā)明專利]消息處理方法和裝置

有效

• 申請?zhí)枺?/td>: 201710982048.0
• 申請日: 2017-10-20
• 公開（公告）號: CN110069514B
• 公開（公告）日: 2021-08-17
• 發(fā)明（設(shè)計）人: 田野
• 申請（專利權(quán)）人: 北京京東尚科信息技術(shù)有限公司;北京京東世紀(jì)貿(mào)易有限公司
• 主分類號: G06F16/245
• 分類號: G06F16/245;G06F16/22;G06F16/242;G06F16/903;G06F9/448
• 代理公司: 北京英賽嘉華知識產(chǎn)權(quán)代理有限責(zé)任公司 11204
• 代理人: 王達(dá)佐;馬曉亞

本申請公開了消息處理方法和裝置。該方法的一具體實施方式包括：接收包括消息主題、消息鍵和消息值的待處理的消息；查詢與消息主題相關(guān)聯(lián)的數(shù)據(jù)庫；獲取與消息主題相關(guān)聯(lián)的預(yù)設(shè)的處理流程，其中，處理流程與至少一個消息處理公式相對應(yīng)，用于使用至少一個消息處理公式、消息鍵和消息值對消息進(jìn)行處理；基于處理流程、消息鍵和消息值執(zhí)行至少一個消息處理公式得到執(zhí)行結(jié)果；根據(jù)執(zhí)行結(jié)果對所查詢到的數(shù)據(jù)庫執(zhí)行數(shù)據(jù)庫操作。該實施方式減少了手工操作從而提高了消息處理的效率。

技術(shù)領(lǐng)域

本申請涉及計算機(jī)技術(shù)領(lǐng)域，具體涉及報表技術(shù)領(lǐng)域，尤其涉及消息處理方法和裝置。

背景技術(shù)

現(xiàn)有的報表后臺邏輯開發(fā)如果涉及到消息的處理，首先需要接入消息，然后根據(jù)接入的消息內(nèi)容編寫代碼來處理消息，最后把處理好的消息插入或者更新到MySQL(一種通用的關(guān)系型數(shù)據(jù)庫管理系統(tǒng))數(shù)據(jù)庫或者Elasticsearch(一種通用的搜索服務(wù)器)中，完成業(yè)務(wù)邏輯的開發(fā)。

目前報表主要由開發(fā)人員手工開發(fā)調(diào)用，然后反復(fù)調(diào)試并修正，消息處理的效率較低。

發(fā)明內(nèi)容

本申請實施例的目的在于提出一種改進(jìn)的消息處理方法和裝置，來解決以上背景技術(shù)部分提到的技術(shù)問題。

第一方面，本申請實施例提供了一種消息處理方法，該方法包括：接收包括消息主題、消息鍵和消息值的待處理的消息；查詢與消息主題相關(guān)聯(lián)的數(shù)據(jù)庫；獲取與消息主題相關(guān)聯(lián)的預(yù)設(shè)的處理流程，其中，處理流程與至少一個消息處理公式相對應(yīng)，用于使用至少一個消息處理公式、消息鍵和消息值對消息進(jìn)行處理；基于處理流程、消息鍵和消息值執(zhí)行至少一個消息處理公式得到執(zhí)行結(jié)果；根據(jù)執(zhí)行結(jié)果對所查詢到的數(shù)據(jù)庫執(zhí)行數(shù)據(jù)庫操作。

在一些實施例中，在接收包括消息主題、消息鍵和消息值的待處理的消息之后，該方法還包括：利用預(yù)設(shè)的正則表達(dá)式解析消息的消息主題和至少一個消息鍵值對；對于至少一個消息鍵值對中每個消息鍵值對，從該消息鍵值對中分離出消息鍵和消息值，并按照預(yù)定格式將消息主題和該消息鍵值對中的消息鍵組合成公式詞素，然后根據(jù)公式詞素和該消息鍵值對中的消息值生成第一哈希表。

在一些實施例中，在執(zhí)行至少一個消息處理公式得到執(zhí)行結(jié)果之前，該方法還包括：確定至少一個消息處理公式的公式類型，其中，公式類型包括以下至少一項：函數(shù)類型、賦值類型、四則運算類型；根據(jù)確定出的公式類型和至少一個消息處理公式生成第二哈希表。

在一些實施例中，執(zhí)行至少一個消息處理公式得到執(zhí)行結(jié)果，包括：對于第二哈希表中的每條消息處理公式，如果該消息處理公式的公式類型是四則運算類型，則將該消息處理公式轉(zhuǎn)換成后綴表達(dá)式，并利用后綴表達(dá)式得到執(zhí)行結(jié)果，并將執(zhí)行結(jié)果保存到第一哈希表中。

在一些實施例中，執(zhí)行至少一個消息處理公式得到執(zhí)行結(jié)果，包括：對于第二哈希表中的每條消息處理公式，如果該消息處理公式的公式類型是函數(shù)類型，則利用java反射方法得到執(zhí)行結(jié)果，并將執(zhí)行結(jié)果保存到第一哈希表中。

在一些實施例中，至少一個消息處理公式包括函數(shù)名、輸入?yún)?shù)和輸出參數(shù)；以及利用java反射方法得到執(zhí)行結(jié)果，包括：利用java反射方法實例化函數(shù)名對應(yīng)的類；基于輸入?yún)?shù)和第一哈希表中各公式詞素對應(yīng)的消息值，調(diào)用類的執(zhí)行方法，將執(zhí)行結(jié)果輸出到輸出參數(shù)，并將輸出參數(shù)保存到第一哈希表中。

在一些實施例中，執(zhí)行至少一個消息處理公式得到執(zhí)行結(jié)果，包括：對于第二哈希表中的每條消息處理公式，如果該消息處理公式的公式類型是賦值類型，則將該消息處理公式一側(cè)的計算結(jié)果作為執(zhí)行結(jié)果，并將執(zhí)行結(jié)果保存到第一哈希表中。

在一些實施例中，根據(jù)執(zhí)行結(jié)果對所查詢到的數(shù)據(jù)庫執(zhí)行數(shù)據(jù)庫操作，包括：獲取與處理流程相關(guān)聯(lián)的數(shù)據(jù)庫交互公式；利用java反射方法執(zhí)行數(shù)據(jù)庫交互公式以實現(xiàn)以下至少一項操作：增加、修改、刪除、查詢。