[發明專利]一種信息推送方法及裝置

有效

• 申請號: 201510046830.2
• 申請日: 2015-01-30
• 公開（公告）號: CN104615702B
• 公開（公告）日: 2020-05-15
• 發明（設計）人: 劉忠旭;戚海洋;王春磊
• 申請（專利權）人: 五八有限公司
• 主分類號: G06F16/953
• 分類號: G06F16/953;H04L29/08
• 代理公司: 工業和信息化部電子專利中心 11010
• 代理人: 梁軍

本發明公開了一種信息推送方法及裝置，其中，該方法包括：獲取推送任務，對推送任務進行解析，并分發解析后的推送任務至消息總線；通過消息總線獲取解析后的推送任務，并根據解析后的推送任務構建推送消息；將構建好的推送消息通過推送通道進行推送。本發明采用先分發后構建的模式，將解析后的推送任務分發至消息總線，構建過程中，可以通過消息總線來獲取推送任務，以構建推送消息，并將構建后的推送消息直接通過推送通道進行推送，省去了通過代理分發推送消息的過程，解決了現有技術中，推送系統構建cron是單點運行，其處理過程是先構建后再分發，因此消息分發效率低，且存在單點掛機風險的問題。

技術領域

本發明涉及通訊領域，特別是涉及一種信息推送方法及裝置。

背景技術

無線app客戶端上瀏覽的信息是主動從服務器上拉取，或者由服務端主動推送消息到客戶端上。這種主動推送的消息目的是喚醒app客戶端，以及提高app活躍指數的一個重要途徑。隨著app客戶端數量增多，如何確保服務端準確、高效的在短時間內將信息推送給客戶端變得越來越困難。

現有推送系統提供了一種高效、準確的推送服務，并將整個推送進度透明的展示到后臺。給產品運營提供清晰的數據的同時，更有效的提高了app客戶端的活躍指數。

如圖1所示，為現有的推送系統，操作者利用后臺(推送web)將推送任務寫入推送數據庫，推送構建cron(計劃任務)利用數據接口讀取推送數據庫中存儲的推送任務，根據推送任務利用數據接口讀取信息數據庫中存儲的相關推送目標的信息，并構建推送信息，通過消息總線將推送信息推送至推送代理，推送代理根據推送中包含的推送目標的信息從數據庫獲取推送目標的詳細信息，推送代理調取推送通道，分發消息，實現信息的推送。

但現有技術中的推送系統存在很多問題，例如，由于推送構建cron單點運行，因此推送消息構建效率低；現有的模式為推送消息先構建后再分發，因此消息分發效率低；單機構建存在單點掛機風險；構建進度無法監控，無法知曉，且對推送構建cron以及推送代理缺少監控，無報錯機制。

發明內容

本發明提供了一種信息推送方法及裝置，用以解決現有技術中，推送系統構建cron是單點運行，其處理過程是先構建后再分發，因此消息分發效率低，且存在單點掛機風險的問題。

為解決上述技術問題，一方面，本發明提供一種信息推送方法，包括：獲取推送任務，對所述推送任務進行解析，并分發解析后的推送任務至消息總線；通過所述消息總線獲取所述解析后的推送任務，并根據所述解析后的推送任務構建推送消息；將構建好的推送消息通過推送通道進行推送。

進一步，獲取推送任務，對所述推送任務進行解析，并分發解析后的推送任務至消息總線包括：獲取所述推送任務，其中，所述推送任務包括但不限于下列內容的部分或全部：業務類型、任務執行時間、任務執行方式、任務計劃推送數量；對所述推送任務進行解析，并將解析后的推送任務按照推送目標拆分為多條消息，其中，所述消息中攜帶有推送目標信息；分發所述多條消息至所述消息總線。

進一步，分發解析后的推送任務至消息總線之后，還包括：對所述推送任務的解析進度和/或所述解析后的推送任務的分發進度進行統計，并將統計結果進行上報。

進一步，所述方法還包括：監測對所述推送任務的調度時間是否大于第一預設時間，其中，所述調度時間為所述推送任務的獲取時間與解析開始時間之差；在所述調度時間大于所述第一預設時間的情況下，進行告警。

進一步，通過所述消息總線獲取所述解析后的推送任務，并根據所述解析后的推送任務構建推送消息包括：監聽所述消息總線，從所述消息總線獲取所述消息；獲取所述消息中的所述推送目標信息，并根據所述推送目標信息構建所述推送消息。

進一步，所述方法還包括：監測對所述消息的處理時間是否大于第二預設時間，其中，所述處理時間為所述消息的獲取時間與監聽到所述消息的時間之差；在所述處理時間大于所述第二預設時間的情況下，進行告警。