[發(fā)明專利]一種消息處理方法、裝置及電子設(shè)備

在審

• 申請?zhí)枺?/td>: 201911207207.5
• 申請日: 2019-11-29
• 公開（公告）號: CN112882841A
• 公開（公告）日: 2021-06-01
• 發(fā)明（設(shè)計(jì)）人: 王雅嫻
• 申請（專利權(quán)）人: 北京金山云網(wǎng)絡(luò)技術(shù)有限公司;北京金山云科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F11/07
• 代理公司: 北京柏杉松知識產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11413
• 代理人: 項(xiàng)京;丁蕓

1.一種消息處理方法，其特征在于，所述方法包括：

獲取消息隊(duì)列中消息的隊(duì)列信息，其中，所述隊(duì)列信息至少包括：任一消息在所述消息隊(duì)列中的偏移量；

當(dāng)對任一消息處理失敗時(shí)，向所述消息隊(duì)列發(fā)送所述消息隊(duì)列中所有被連續(xù)處理成功的消息中的最大偏移量，以使所述消息隊(duì)列將所述最大偏移量的下一偏移量確定為當(dāng)前處理失敗的消息的偏移量；

接收所述消息隊(duì)列發(fā)送的消息，以進(jìn)行消息處理，其中，該消息是所述消息隊(duì)列中所述最大偏移量的下一偏移量對應(yīng)的消息，以完成對所述當(dāng)前處理失敗的消息的消費(fèi)處理。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

當(dāng)對任一消息處理成功時(shí)，對該消息的偏移量進(jìn)行記錄，以得到所述消息隊(duì)列中所有被連續(xù)處理處理成功的消息的最大偏移量。

3.根據(jù)權(quán)利要求1或2所述的方法，其特征在于，所述當(dāng)對任一消息處理失敗時(shí)，向所述消息隊(duì)列發(fā)送所述消息隊(duì)列中所有被連續(xù)處理成功的消息中的最大偏移量，包括：

當(dāng)對任一消息處理失敗時(shí)，啟動預(yù)設(shè)的定時(shí)周期；

按照所述定時(shí)周期，將所記錄的所有被連續(xù)處理成功的消息中的最大偏移量發(fā)送至所述消息隊(duì)列。

4.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述消息隊(duì)列為多個(gè)，所述隊(duì)列信息還包括：所述消息隊(duì)列的標(biāo)識信息，所述標(biāo)識信息用于區(qū)分不同的消息隊(duì)列，每個(gè)消息隊(duì)列對應(yīng)一組數(shù)據(jù)結(jié)構(gòu)，所述數(shù)據(jù)結(jié)構(gòu)用于記錄所述隊(duì)列信息；

當(dāng)對任一消息處理成功時(shí)，對該消息的偏移量進(jìn)行記錄，包括：

在對任一消息處理成功時(shí)，根據(jù)所述消息隊(duì)列的標(biāo)識信息確定該被處理成功的消息所處的消息隊(duì)列；

將當(dāng)前被處理成功的消息的偏移量記錄到與該消息所處的消息隊(duì)列對應(yīng)數(shù)據(jù)結(jié)構(gòu)的隊(duì)列信息中。

5.根據(jù)權(quán)利要求4所述的方法，其特征在于，每組所述數(shù)據(jù)結(jié)構(gòu)至少包括當(dāng)前數(shù)據(jù)結(jié)構(gòu)和歷史數(shù)據(jù)結(jié)構(gòu)；所述當(dāng)前數(shù)據(jù)結(jié)構(gòu)用于存儲成功處理當(dāng)前消息時(shí)的偏移量，所述歷史數(shù)據(jù)結(jié)構(gòu)用于存儲所述當(dāng)前消息之前成功被處理的消息的偏移量；

所述在將當(dāng)前被處理成功的消息的偏移量記錄到與該消息所處的消息隊(duì)列對應(yīng)數(shù)據(jù)結(jié)構(gòu)的隊(duì)列信息中，包括：

在對所述任一消息處理成功時(shí)，將該消息的偏移量記錄到與該消息所處的消息隊(duì)列對應(yīng)的當(dāng)前數(shù)據(jù)結(jié)構(gòu)中，以更新所述當(dāng)前數(shù)據(jù)結(jié)構(gòu)中成功處理的當(dāng)前消息的偏移量；

以及，根據(jù)該消息的偏移量所述歷史數(shù)據(jù)結(jié)構(gòu)中當(dāng)前消息之前成功被處理的消息的偏移量。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，所述當(dāng)對任一消息處理失敗時(shí)，向所述消息隊(duì)列發(fā)送所述消息隊(duì)列中所有被連續(xù)處理成功的消息中的最大偏移量，包括：

當(dāng)對任一消息處理失敗時(shí)，將所述當(dāng)前數(shù)據(jù)結(jié)構(gòu)和所述歷史數(shù)據(jù)結(jié)構(gòu)中的所有消息的連續(xù)偏移量中的最大偏移量發(fā)送至該消息所處的消息隊(duì)列。

7.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述當(dāng)對任一消息處理成功時(shí)，對該消息的偏移量進(jìn)行記錄，包括：

在對任一消息處理成功時(shí)，獲取該消息的在所述消息隊(duì)列中的偏移量；

對所述消息隊(duì)列中被連續(xù)處理成功消息的偏移量排序處理，得到該消息的偏移量的排序結(jié)果；

按照所述排序結(jié)果中的順序記錄該消息的偏移量。

8.一種消息處理方法，其特征在于，所述方法包括：

向工作線程發(fā)送消息的隊(duì)列信息，其中，所述隊(duì)列信息至少包括：任一消息在消息隊(duì)列中的偏移量，以使所述工作線程通過偏移量獲取消息，以對消息進(jìn)行消費(fèi)處理；

當(dāng)對任一消息處理失敗時(shí)，接收工作線程發(fā)送的所有被連續(xù)處理成功的消息中的最大偏移量；

將所述最大偏移量的下一偏移量確定為該處理失敗的消息的偏移量；

向所述工作線程發(fā)送所述最大偏移量的下一偏移量對應(yīng)的消息，以使所述工作線程對該處理失敗的消息的消費(fèi)處理。