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

有效

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

1.一種基于Lua腳本語(yǔ)言的消息處理方法，其特征在于，包括：

采用靜態(tài)編譯語(yǔ)言，從消息中間件中獲取原始數(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腳本語(yǔ)言，通過(guò)調(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ù)處理失敗，則通過(guò)調(diào)取的數(shù)據(jù)信息中的數(shù)據(jù)回滾接口將原始數(shù)據(jù)回滾到所述內(nèi)存隊(duì)列中。

2.根據(jù)權(quán)利要求1所述的基于Lua腳本語(yǔ)言的消息處理方法，其特征在于，所述采用Lua腳本語(yǔ)言，通過(guò)調(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ī)解析器上；

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

3.根據(jù)權(quán)利要求1所述的基于Lua腳本語(yǔ)言的消息處理方法，其特征在于，各原始數(shù)據(jù)均具有唯一的身份識(shí)別標(biāo)識(shí)，

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

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

根據(jù)所述身份識(shí)別標(biāo)識(shí)，重新從消息中間件中獲取對(duì)應(yīng)的原始數(shù)據(jù)，并將重新獲取的原始數(shù)據(jù)暫存到所述內(nèi)存隊(duì)列中。

4.根據(jù)權(quán)利要求1-3中任一項(xiàng)所述的基于Lua腳本語(yǔ)言的消息處理方法，其特征在于，還包括：

監(jiān)控所述內(nèi)存隊(duì)列中各原始數(shù)據(jù)的當(dāng)前數(shù)量；

判斷所述當(dāng)前數(shù)量是否達(dá)到數(shù)量閾值；

如果達(dá)到則停止從消息中間件中獲取原始數(shù)據(jù)；否則繼續(xù)監(jiān)控。

5.一種基于Lua腳本語(yǔ)言的消息處理系統(tǒng)，其特征在于，包括：

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

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

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

存儲(chǔ)單元，與所述處理單元連接，用于在所述處理單元數(shù)據(jù)處理成功時(shí)，將數(shù)據(jù)處理得到的結(jié)果數(shù)據(jù)存儲(chǔ)；

回滾單元，與所述處理單元連接，用于在所述處理單元數(shù)據(jù)處理失敗時(shí)，通過(guò)調(diào)取的數(shù)據(jù)信息中的數(shù)據(jù)回滾接口將原始數(shù)據(jù)回滾到所述內(nèi)存隊(duì)列中。

6.根據(jù)權(quán)利要求5所述的基于Lua腳本語(yǔ)言的消息處理系統(tǒng)，其特征在于，所述處理單元包括：

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

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

7.根據(jù)權(quán)利要求5所述的基于Lua腳本語(yǔ)言的消息處理系統(tǒng)，其特征在于，各原始數(shù)據(jù)均具有唯一的身份識(shí)別標(biāo)識(shí)；

所述回滾單元包括：

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

重新獲取模塊，用于根據(jù)所述身份識(shí)別標(biāo)識(shí)，重新從消息中間件中獲取對(duì)應(yīng)的原始數(shù)據(jù)，并將重新獲取的原始數(shù)據(jù)暫存到所述內(nèi)存隊(duì)列中。