[發(fā)明專利]一種基于Lua腳本語言的消息處理方法及系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 201810071299.8
• 申請(qǐng)日: 2018-01-25
• 公開（公告）號(hào): CN108279988B
• 公開（公告）日: 2021-07-23
• 發(fā)明（設(shè)計(jì)）人: 郝忠秀;任文越
• 申請(qǐng)（專利權(quán)）人: 微夢創(chuàng)科網(wǎng)絡(luò)科技（中國）有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54
• 代理公司: 北京卓嵐智財(cái)知識(shí)產(chǎn)權(quán)代理事務(wù)所(特殊普通合伙) 11624
• 代理人: 任漱晨

本發(fā)明實(shí)施例提供一種基于Lua腳本語言的消息處理方法及系統(tǒng)，所述基于Lua腳本語言的消息處理方法包括：采用靜態(tài)編譯語言，從消息中間件中獲取原始數(shù)據(jù)，并將獲取到的原始數(shù)據(jù)暫存到內(nèi)存隊(duì)列中，所述內(nèi)存隊(duì)列中封裝有多組數(shù)據(jù)信息，每組數(shù)據(jù)信息包括相對(duì)應(yīng)的原始數(shù)據(jù)、獲取消息的應(yīng)用程序接口以及數(shù)據(jù)回滾接口；從內(nèi)存隊(duì)列中調(diào)取數(shù)據(jù)信息，并將調(diào)取的數(shù)據(jù)信息從內(nèi)存隊(duì)列中刪除；采用Lua腳本語言，通過調(diào)取的數(shù)據(jù)信息中的應(yīng)用程序接口對(duì)調(diào)取的數(shù)據(jù)信息中的原始數(shù)據(jù)進(jìn)行數(shù)據(jù)處理；如果數(shù)據(jù)處理成功，則將數(shù)據(jù)處理得到的結(jié)果數(shù)據(jù)存儲(chǔ)；如果數(shù)據(jù)處理失敗，則通過調(diào)取的數(shù)據(jù)信息中的數(shù)據(jù)回滾接口將原始數(shù)據(jù)回滾到內(nèi)存隊(duì)列中，從而確保數(shù)據(jù)不丟失。

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

本發(fā)明涉及Lua數(shù)據(jù)處理技術(shù)領(lǐng)域，特別是涉及一種基于Lua腳本語言的消息處理方法及系統(tǒng)。

背景技術(shù)

現(xiàn)有技術(shù)中在消息處理過程一般是由Kafka等消息隊(duì)列中間件作為數(shù)據(jù)接收與存儲(chǔ)端，消息處理指的是從Kafka等消息隊(duì)列中間件中獲取數(shù)據(jù)，做相應(yīng)的數(shù)據(jù)處理后將結(jié)果存儲(chǔ)到相應(yīng)的存儲(chǔ)中。現(xiàn)有技術(shù)中對(duì)于每個(gè)消息處理業(yè)務(wù)都需要實(shí)現(xiàn)：從Kafka等消息隊(duì)列中獲取取數(shù)據(jù)、相應(yīng)處理數(shù)據(jù)、將數(shù)據(jù)存儲(chǔ)到對(duì)應(yīng)存儲(chǔ)、提供對(duì)應(yīng)API(ApplicationProgram Interface，應(yīng)用程序接口)獲取處理數(shù)據(jù)等幾個(gè)步驟。對(duì)于大部分需求可能僅僅是在處理數(shù)據(jù)方式上和數(shù)據(jù)返回方式是有所不同，其他幾個(gè)步驟基本一致。

如上介紹的現(xiàn)有技術(shù)采用每個(gè)消息處理業(yè)務(wù)都實(shí)現(xiàn)從消息隊(duì)列中間件中獲取數(shù)據(jù)、處理數(shù)據(jù)、返回處理結(jié)果等幾個(gè)過程，由于每個(gè)處理業(yè)務(wù)都有自己的一些業(yè)務(wù)邏輯特點(diǎn)，沒有辦法抽象復(fù)用模塊，所以導(dǎo)致在消息處理業(yè)務(wù)方面代碼復(fù)用性、可擴(kuò)展性差，增加開發(fā)成本。另外一個(gè)是現(xiàn)有技術(shù)在消息處理方面使用靜態(tài)編譯語言在開發(fā)和部署升級(jí)上面效率比較低，開發(fā)維護(hù)成本高。而且，在處理過程中，由于處理過程出現(xiàn)異常情況，導(dǎo)致數(shù)據(jù)丟失，使得數(shù)據(jù)處理安全度比較低。

在實(shí)現(xiàn)本發(fā)明過程中，發(fā)明人發(fā)現(xiàn)現(xiàn)有技術(shù)中至少存在如下問題：

在消息處理方面使用靜態(tài)編譯語言的過程中，數(shù)據(jù)容易丟失，使得數(shù)據(jù)處理不安全。

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

本發(fā)明實(shí)施例提供一種基于Lua腳本語言的消息處理方法及系統(tǒng)，可提高數(shù)據(jù)處理的安全性。

一方面，本發(fā)明實(shí)施例提供了一種基于Lua腳本語言的消息處理方法，包括：

采用靜態(tài)編譯語言，從消息中間件中獲取原始數(shù)據(jù)，并將獲取到的原始數(shù)據(jù)暫存到內(nèi)存隊(duì)列中，其中，所述內(nèi)存隊(duì)列中封裝有多組數(shù)據(jù)信息，每組數(shù)據(jù)信息包括相對(duì)應(yīng)的原始數(shù)據(jù)、獲取消息的應(yīng)用程序接口以及數(shù)據(jù)回滾接口；

從所述內(nèi)存隊(duì)列中調(diào)取數(shù)據(jù)信息，并將調(diào)取的數(shù)據(jù)信息從所述內(nèi)存隊(duì)列中刪除；

采用Lua腳本語言，通過調(diào)取的數(shù)據(jù)信息中的應(yīng)用程序接口對(duì)調(diào)取的數(shù)據(jù)信息中的原始數(shù)據(jù)進(jìn)行數(shù)據(jù)處理；

如果數(shù)據(jù)處理成功，則將數(shù)據(jù)處理得到的結(jié)果數(shù)據(jù)存儲(chǔ)；如果數(shù)據(jù)處理失敗，則通過調(diào)取的數(shù)據(jù)信息中的數(shù)據(jù)回滾接口將原始數(shù)據(jù)回滾到所述內(nèi)存隊(duì)列中。

可選的，所述采用Lua腳本語言，通過調(diào)取的數(shù)據(jù)信息中的應(yīng)用程序接口對(duì)調(diào)取的數(shù)據(jù)信息中的原始數(shù)據(jù)進(jìn)行數(shù)據(jù)處理，具體包括：

將調(diào)取的數(shù)據(jù)信息中的原始數(shù)據(jù)、應(yīng)用程序接口及數(shù)據(jù)回滾接口綁定到Lua虛擬機(jī)解析器上；

通過Lua數(shù)據(jù)處理程序調(diào)用所述應(yīng)用程序接口，對(duì)所述Lua虛擬機(jī)解析器上綁定的原始數(shù)據(jù)進(jìn)行數(shù)據(jù)處理。

可選的，各原始數(shù)據(jù)均具有唯一的身份識(shí)別標(biāo)識(shí)，

所述通過調(diào)取的數(shù)據(jù)信息中的數(shù)據(jù)回滾接口將原始數(shù)據(jù)回滾到所述內(nèi)存隊(duì)列中，具體包括：

通過所述原始數(shù)據(jù)對(duì)應(yīng)的數(shù)據(jù)回滾接口，將原始數(shù)據(jù)的身份識(shí)別標(biāo)識(shí)回滾到所述內(nèi)存隊(duì)列中；