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

有效

• 申請?zhí)枺?/td>: 201910098148.6
• 申請日: 2019-01-31
• 公開（公告）號: CN111510469B
• 公開（公告）日: 2023-04-25
• 發(fā)明（設(shè)計(jì)）人: 劉國棟;邱亮;曹錚錚
• 申請（專利權(quán)）人: 上海嗶哩嗶哩科技有限公司
• 主分類號: H04L67/566
• 分類號: H04L67/566;H04L67/1097;H04L67/62;H04L47/56
• 代理公司: 北京智信禾專利代理有限公司 11637
• 代理人: 劉曉楠

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

接收消息投放請求后，將接收到的消息存儲至消息存儲集群；

輪詢消息存儲集群中已過期消息，按照約定策略進(jìn)行消息的處理投遞，其中，所述輪詢消息存儲集群中已過期消息包括：采用redis?zset對應(yīng)存儲一個(gè)時(shí)間片序列，并獲取當(dāng)前時(shí)間片zset的位置，根據(jù)分布存儲值并結(jié)合過期序列zset找到當(dāng)前時(shí)間到期的所有消息id，再次進(jìn)行獲取當(dāng)前時(shí)間到期的所有消息id。

2.如權(quán)利要求1所述的消息處理方法，其特征在于，所述的消息以序列化串方式存儲，并按照“關(guān)鍵字-值”形式存儲于消息存儲集群中，所述的關(guān)鍵字為消息id，值為消息體。

3.如權(quán)利要求2所述的消息處理方法，其特征在于，所述的消息體包括：用戶投遞的消息內(nèi)容、消息到期時(shí)間戳和消息回調(diào)地址。

4.如權(quán)利要求3所述的消息處理方法，其特征在于，所述的消息體還包括消息重試策略，則所述的按照約定策略進(jìn)行消息的處理投遞進(jìn)一步包括：

消息投遞后若未收到按照約定的答復(fù)，則延遲指定的時(shí)間再次投遞消息。

5.如權(quán)利要求1所述的消息處理方法，其特征在于，所述的方法進(jìn)一步包括：

存儲消息過期時(shí)間序列，所述存儲消息過期時(shí)間序列包括：

采用redis?zset結(jié)構(gòu)組織消息，并從redis?zset中跟進(jìn)時(shí)間戳范圍獲取到期的所有消息id，根據(jù)消息id獲取消息id對應(yīng)消息體投放，其中存放消息過期時(shí)間序列的zset為過期序列zset。

6.如權(quán)利要求1所述的消息處理方法，其特征在于，還包括：

多次同時(shí)批量獲取消息，如果其中一個(gè)所述的消息已經(jīng)被消費(fèi)標(biāo)記，則當(dāng)前消費(fèi)時(shí)間根據(jù)返回的內(nèi)容不進(jìn)行處理，處理未標(biāo)記的消息id。

7.如權(quán)利要求6所述的消息處理方法，其特征在于，所述的處理未標(biāo)記的消息id后進(jìn)一步包括：

對已經(jīng)被消費(fèi)標(biāo)記的消息設(shè)定固定過期時(shí)間，當(dāng)該消息被消費(fèi)占用時(shí)間超過設(shè)定的固定過期時(shí)間后，對該消息進(jìn)行投放處理。

8.如權(quán)利要求1所述的消息處理方法，其特征在于，進(jìn)一步包括：

當(dāng)消息投放失敗后，刪除時(shí)間序列zset和過期序列zset的指定值，并根據(jù)重試策略設(shè)定新的過期時(shí)間。

9.一種消息處理裝置，包括處理器、存儲器以及存儲在所述存儲器中且被配置為由所述處理器執(zhí)行的計(jì)算機(jī)程序，其特征在于，所述的處理器執(zhí)行所述計(jì)算機(jī)程序時(shí)實(shí)現(xiàn)如權(quán)利要求1-8任一項(xiàng)所述的消息處理方法。