[發(fā)明專利]延遲消息推送方法、裝置、計算機(jī)設(shè)備及存儲介質(zhì)

有效

• 申請?zhí)枺?/td>: 201810138032.6
• 申請日: 2018-02-10
• 公開（公告）號: CN108388479B
• 公開（公告）日: 2021-09-24
• 發(fā)明（設(shè)計）人: 周之浩
• 申請（專利權(quán)）人: 深圳壹賬通智能科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 深圳眾鼎專利商標(biāo)代理事務(wù)所(普通合伙) 44325
• 代理人: 陽開亮

1.一種延遲消息推送方法，其特征在于，包括：

獲取待推送消息，所述待推送消息包括消息類型和消息模板；

基于所述消息類型，將所述待推送消息緩存在與所述消息類型相對應(yīng)的目標(biāo)消息中間件上；其中，所述目標(biāo)消息中間件包括第一消息中間件和第二消息中間件，若消息類型為單條任務(wù)類型，則將待推送消息緩存在與單條任務(wù)類型相對應(yīng)的第一消息中間件上；

若消息類型為批量任務(wù)類型，采用預(yù)設(shè)的分塊算法對消息類型為批量任務(wù)類型的待推送消息進(jìn)行拆分，獲取至少兩個批量子任務(wù)消息，并將至少兩個所述批量子任務(wù)消息存儲到與批量任務(wù)類型相對應(yīng)的一個第二消息中間件上，其中，所述第二消息中間件用于對至少兩個所述批量子任務(wù)消息進(jìn)行并行處理；

根據(jù)所述消息模板確定所述待推送消息是否為延遲消息，若所述待推送消息為所述延遲消息，則將所述待推送消息緩存在所述目標(biāo)消息中間件上創(chuàng)建的延遲隊列上；

采用監(jiān)聽線程輪詢監(jiān)聽所述延遲隊列，并對所述延遲隊列中緩存的待推送消息進(jìn)行推送處理。

2.如權(quán)利要求1所述的延遲消息推送方法，其特征在于，所述延遲消息中攜帶有可推送時間；

所述采用監(jiān)聽線程輪詢監(jiān)聽所述延遲隊列，并對所述延遲隊列中緩存的待推送消息進(jìn)行推送處理，包括：

采用監(jiān)聽線程輪詢監(jiān)聽所述延遲隊列中的待推送消息，獲取目標(biāo)推送消息；

若所述目標(biāo)推送消息的消息類型為單條任務(wù)類型，則在系統(tǒng)當(dāng)前時間為所述可推送時間時，將所述目標(biāo)推送消息發(fā)送給個推服務(wù)器，以使所述個推服務(wù)器推送接收到的所述目標(biāo)推送消息；

若所述目標(biāo)推送消息的消息類型為批量任務(wù)類型，則所述目標(biāo)推送消息為目標(biāo)子任務(wù)消息，將消息狀態(tài)數(shù)據(jù)表中所述目標(biāo)子任務(wù)消息的狀態(tài)更新為待推送狀態(tài)，并在系統(tǒng)當(dāng)前時間為所述可推送時間時，將所述目標(biāo)子任務(wù)消息發(fā)送給個推服務(wù)器，以使所述個推服務(wù)器推送接收到的所述目標(biāo)子任務(wù)消息。

3.如權(quán)利要求1所述的延遲消息推送方法，其特征在于，在所述根據(jù)所述消息模板確定所述待推送消息是否為延遲消息的步驟之后，所述延遲消息推送方法還包括：

若所述待推送消息為非延遲消息，則將所述待推送消息發(fā)送給個推服務(wù)器，以使所述個推服務(wù)器實時推送接收到的所述待推送消息。

4.如權(quán)利要求1所述的延遲消息推送方法，其特征在于，所述基于所述消息類型，將所述待推送消息緩存在與所述消息類型相對應(yīng)的目標(biāo)消息中間件上，還包括：

若所述消息類型為全網(wǎng)任務(wù)類型，則所述待推送消息為非延遲消息，將所述待推送消息緩存在與所述全網(wǎng)任務(wù)類型相對應(yīng)的第三消息中間件上；

采用監(jiān)聽線程輪詢監(jiān)聽所述第三消息中間件中的待推送消息，獲取目標(biāo)推送消息，并將所述目標(biāo)推送消息發(fā)送給個推服務(wù)器，以使所述個推服務(wù)器實時推送接收到的所述目標(biāo)推送消息；

其中，所述目標(biāo)消息中間件還包括所述第三消息中間件。

5.一種延遲消息推送裝置，其特征在于，包括：

消息獲取模塊，用于獲取待推送消息，所述待推送消息包括消息類型和消息模板；

消息緩存模板，用于基于所述消息類型，將所述待推送消息緩存在與所述消息類型相對應(yīng)的目標(biāo)消息中間件上；

所述消息緩存模板，還用于若消息類型為單條任務(wù)類型，則將待推送消息緩存在與單條任務(wù)類型相對應(yīng)的第一消息中間件上；

若消息類型為批量任務(wù)類型，采用預(yù)設(shè)的分塊算法對消息類型為批量任務(wù)類型的待推送消息進(jìn)行拆分，獲取至少兩個批量子任務(wù)消息，并將至少兩個所述批量子任務(wù)消息存儲到與批量任務(wù)類型相對應(yīng)的一個第二消息中間件上，其中，所述第二消息中間件用于對至少兩個所述批量子任務(wù)消息進(jìn)行并行處理；

延遲判斷處理模塊，用于根據(jù)所述消息模板確定所述待推送消息是否為延遲消息，若所述待推送消息為所述延遲消息，則將所述待推送消息緩存在所述目標(biāo)消息中間件上創(chuàng)建的延遲隊列上；

監(jiān)聽處理模塊，用于采用監(jiān)聽線程輪詢監(jiān)聽所述延遲隊列，并對所述延遲隊列中緩存的待推送消息進(jìn)行推送處理。