[發(fā)明專利]消息處理方法、裝置、設(shè)備及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202011193625.6
• 申請(qǐng)日: 2020-10-30
• 公開（公告）號(hào): CN112422408A
• 公開（公告）日: 2021-02-26
• 發(fā)明（設(shè)計(jì)）人: 宗子夢(mèng);蒙德鑫
• 申請(qǐng)（專利權(quán)）人: 百果園技術(shù)（新加坡）有限公司
• 主分類號(hào): H04L12/58
• 分類號(hào): H04L12/58
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

1.一種消息處理方法，其特征在于，應(yīng)用于消息傳輸系統(tǒng)中的消息接收方，所述方法包括：

接收消息發(fā)送方發(fā)送的第一消息，其中，所述第一消息中包含所述消息發(fā)送方確定的第一重發(fā)標(biāo)記，重發(fā)標(biāo)記用于表示對(duì)應(yīng)的消息內(nèi)容是否為重復(fù)發(fā)送；

根據(jù)所述第一重發(fā)標(biāo)記判斷所述第一消息中的消息內(nèi)容是否由所述消息發(fā)送方重復(fù)發(fā)送；

若否，則省略針對(duì)所述第一消息的消息內(nèi)容的查重處理。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述重發(fā)標(biāo)記的取值為同一消息內(nèi)容的發(fā)送次數(shù)；

所述根據(jù)所述第一重發(fā)標(biāo)記判斷所述第一消息中的消息內(nèi)容是否由所述消息發(fā)送方重復(fù)發(fā)送，包括：

當(dāng)所述第一重發(fā)標(biāo)記對(duì)應(yīng)的取值等于1時(shí)，確定所述第一消息中的消息內(nèi)容由所述消息發(fā)送方首次發(fā)送；

當(dāng)所述第一重發(fā)標(biāo)記對(duì)應(yīng)的取值大于1時(shí)，確定所述第一消息中的消息內(nèi)容由所述消息發(fā)送方重復(fù)發(fā)送。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，在所述根據(jù)所述第一重發(fā)標(biāo)記判斷所述第一消息中的消息內(nèi)容是否由所述消息發(fā)送方重復(fù)發(fā)送之后，還包括：

若是，則針對(duì)所述第一消息的消息內(nèi)容進(jìn)行查重處理。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述第一消息中還包含所述消息發(fā)送方確定的第一消息身份標(biāo)識(shí)，其中，消息身份標(biāo)識(shí)用于唯一標(biāo)記消息內(nèi)容；

所述針對(duì)所述第一消息的消息內(nèi)容進(jìn)行查重處理，包括：

判斷已接收的消息中是否存在所述第一消息身份標(biāo)識(shí)，若不存在，則確定所述第一消息的消息內(nèi)容在歷次被所述消息發(fā)送方發(fā)送時(shí)均未被成功接收，對(duì)所述第一消息進(jìn)行存儲(chǔ)。

5.根據(jù)權(quán)利要求4所述的方法，其特征在于，在判斷已接收的消息中是否存在所述第一消息身份標(biāo)識(shí)之后，還包括：

若存在，則確定所述第一消息的消息內(nèi)容在歷次被所述消息發(fā)送方發(fā)送時(shí)至少一次被成功接收，丟棄所述第一消息。

6.根據(jù)權(quán)利要求4或5所述的方法，其特征在于，所述判斷已接收的消息中是否存在所述第一消息身份標(biāo)識(shí)，包括：

獲取所述第一消息身份標(biāo)識(shí)中的第一預(yù)設(shè)字段上的第一數(shù)值；

查詢預(yù)設(shè)存儲(chǔ)系統(tǒng)中的位圖BITMAP數(shù)據(jù)中是否包含所述第一數(shù)值對(duì)應(yīng)的鍵；

若不包含，則確定已接收的消息中不存在所述第一消息身份標(biāo)識(shí)。

相應(yīng)的，在所述對(duì)所述第一消息進(jìn)行存儲(chǔ)之后，還包括：

根據(jù)所述第一數(shù)值創(chuàng)建對(duì)應(yīng)的第一鍵，并將所述第一消息身份標(biāo)識(shí)中的第二預(yù)設(shè)字段上的第二數(shù)值作為所述第一鍵對(duì)應(yīng)的第一偏移量，將所述第一偏移量對(duì)應(yīng)的值置為第一預(yù)設(shè)值，其中，所述第一消息身份標(biāo)識(shí)由所述第一預(yù)設(shè)字段和所述第二預(yù)設(shè)字段組成。

7.根據(jù)權(quán)利要求6所述的方法，其特征在于，在所述查詢預(yù)設(shè)存儲(chǔ)系統(tǒng)中的BITMAP數(shù)據(jù)中是否包含所述第一數(shù)值對(duì)應(yīng)的鍵之后，還包括：

若包含，則獲取所述第一消息身份標(biāo)識(shí)中的第二預(yù)設(shè)字段上的第二數(shù)值；

判斷查詢到的所述第一數(shù)值對(duì)應(yīng)的鍵中，與所述第二數(shù)值相同的偏移量的值是否為第一預(yù)設(shè)值，若為第一預(yù)設(shè)值，則確定已接收的消息中存在所述第一消息身份標(biāo)識(shí)，若為第二預(yù)設(shè)值，則確定已接收的消息中不存在所述第一消息身份標(biāo)識(shí)。

8.根據(jù)權(quán)利要求7所述的方法，其特征在于，對(duì)于任意兩個(gè)不同的消息身份標(biāo)識(shí)，第一概率大于第二概率，其中，第一概率為兩個(gè)第一預(yù)設(shè)字段的取值相同的概率，第二概率為兩個(gè)第二預(yù)設(shè)字段的取值相同的概率。

9.根據(jù)權(quán)利要求6所述的方法，其特征在于，在所述根據(jù)所述第一數(shù)值創(chuàng)建對(duì)應(yīng)的第一鍵的同時(shí)還包括：

根據(jù)所述第一消息對(duì)應(yīng)的發(fā)送時(shí)間設(shè)置所述第一鍵的生存時(shí)間。

10.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述消息傳輸系統(tǒng)為跨區(qū)域部署的分布式系統(tǒng)，在每個(gè)區(qū)域部署至少一個(gè)消息發(fā)送方，在至少一個(gè)區(qū)域部署消息接收方，所述消息接收方中用于存儲(chǔ)消息的預(yù)設(shè)存儲(chǔ)系統(tǒng)為分布式緩存集群。