業務推送系統及方法

2023-04-23 11:26:56

專利名稱：業務推送系統及方法
技術領域：
本發明涉及移動通信及數據傳輸領域，尤其涉及一種業務推送系統及方法。
背景技術：
隨著無線寬帶接入技術的發展，行動網路數據接入帶寬不斷提升，促進了移動網際網路業務的蓬勃發展。推送(PUSH)業務是網絡向用戶主動提供內容及服務的一種方式，可用於電子郵件、新聞廣播、應用下載、廣告發布等。
目前一種常用的推送業務使用點到點方式實現，當應用伺服器需要向一個用戶推送數據時，通知該用戶的客戶端取數據。為了更高效的利用移動通信網絡資源，推送業務可以與網絡忙閒狀態、用戶位置、用戶業務狀態等信息相結合，由應用伺服器向網絡中的PUSH 引擎查詢是否能向一個用戶推送數據業務，當PUSH引擎確認該用戶適合進行推送時，通知用戶客戶端與應用伺服器聯繫完成數據推送。
對於如新聞、娛樂視頻、微博等內容來說，訂閱該內容的群組用戶的用戶數量可能很多，如果應用伺服器對該群組用戶中的每個用戶逐一向PUSH引擎查詢是否能對用戶進行推送，會導致PUSH引擎和應用伺服器之間信令交互頻繁、時延較長、查詢效率低下的問題。因此需要提高對群組用戶進行數據推送的效率。發明內容
本發明的目的是提出一種業務推送系統及方法，能夠減少應用戶伺服器和推送引擎之間的信令交互，提高推送效率。
為實現上述目的，本發明提供了一種業務推送系統，包括
應用伺服器，用於發出包括推送群組中所有成員用戶的標識信息的推送群組建立請求，以及發出包括待推送的群組標識的群組推送業務請求，並通過移動承載網絡向所述推送群組中的成員用戶對應的客戶端進行數據推送；
群組推送引擎，用於響應於接收到的所述推送群組建立請求，創建推送群組，為所述推送群組分配對應的群組標識，並將所述群組標識返回給請求方，以及響應於接收到的所述群組推送業務請求，根據所述群組推送業務請求中的待推送的群組標識確定推送群組，並確定所述推送群組中符合推送條件的成員用戶，然後向所述符合推送條件的成員用戶對應的客戶端發送推送通知。
進一步的，所述應用伺服器具體包括
群組創建請求單元，用於向所述群組推送引擎發出所述推送群組建立請求，所述推送群組建立請求包括所述推送群組中所有成員用戶的標識信息；
業務推送請求單元，用於向所述群組推送引擎發出所述群組推送業務請求，所述群組推送業務請求包括待推送的群組標識；
數據推送單元，用於通過移動承載網絡與所述推送群組中的成員用戶對應的客戶端進行交互，完成向所述推送群組中的成員用戶對應的客戶端的數據推送。
進一步的，所述群組推送引擎具體包括
建立請求接收單元，用於接收所述應用伺服器發出的所述推送群組建立請求；
推送群組創建單元，用於創建所述推送群組，為所述推送群組分配對應的群組標識，在所述推送群組中記錄所有成員用戶的標識信息；
群組標識通知單元，用於將所述群組標識返回給所述應用伺服器；
業務請求接收單元，用於接收所述應用伺服器發出的所述群組推送業務請求；
推送群組確定單元，用於根據所述群組推送業務請求中的待推送的群組標識確定推送群組；
推送成員確定單元，用於確定所述推送群組中符合推送條件的成員用戶；
推送通知單元，用於向所述符合推送條件的成員用戶對應的客戶端發送推送通知。
進一步的，所述推送群組建立請求還包括推送業務的信息；所述群組推送引擎還包括
策略控制觸發單元，用於將從所述應用伺服器接收到的所述推送業務的信息發送給策略控制實體，以便所述策略控制實體針對所述推送業務制定相應的服務質量QoS和計費策略。
進一步的，所述群組推送引擎還包括
推送觸發單元，用於按照預設周期或者響應於外部事件，觸發所述推送成員確定單元來判斷待推送的成員用戶中符合推送條件的成員用戶。
為實現上述目的，本發明提供了一種基於前述業務推送系統的業務推送方法，包括
應用伺服器向群組推送引擎發出推送群組建立請求，所述推送群組建立請求包括推送群組中所有成員用戶的標識信息；
所述群組推送引擎響 應於接收到的所述推送群組建立請求，創建推送群組，為所述推送群組分配對應的群組標識，並將所述群組標識返回給所述應用伺服器；
所述應用伺服器向所述群組推送引擎發出群組推送業務請求，所述群組推送業務請求包括待推送的群組標識；
所述群組推送引擎響應於接收到的所述群組推送業務請求，根據所述群組推送業務請求中的待推送的群組標識確定推送群組，並確定所述推送群組中符合推送條件的成員用戶
所述群組推送引擎向所述符合推送條件的成員用戶對應的客戶端發送推送通知；
所述應用伺服器通過移動承載網絡向所述推送群組中的成員用戶對應的客戶端進行數據推送。
進一步的，所述應用伺服器向群組推送引擎發出的推送群組建立請求還包括推送業務的信息；
所述群組推送引擎將所述推送業務的信息發送給策略控制實體，以便所述策略控制實體針對所述推送業務制定相應的服務質量QoS和計費策略。
進一步的，還包括所述群組推送引擎判斷所述推送群組中是否存在未推送的成員用戶，如果存在，則繼續確定所述未推送的成員用戶符合推送條件的成員用戶，並向所述符合推送條件的成員用戶對應的客戶端發送推送通知。
進一步的，還包括所述群組推送引擎按照預設周期或者響應於外部事件，判斷待推送的成員用戶中是否存在符合推送條件的成員用戶，並向所述符合推送條件的成員用戶對應的客戶端發送推送通知。
為實現上述目的，本發明還提供了一種業務推送系統，包括
應用伺服器，用於發出包括推送群組中所有成員用戶的標識信息的推送群組建立請求，以及發出包括待推送的群組標識的群組推送業務請求和待推送的業務數據；
群組推送引擎，用於響應於接收到的所述推送群組建立請求，創建推送群組，為所述推送群組分配對應的群組標識，並將所述群組標識返回給請求方，以及響應於接收到的所述群組推送業務請求和待推送的業務數據，緩存所述待推送的業務數據，根據所述群組推送業務請求中的待推送的群組標識確定推送群組，並確定所述推送群組中符合推送條件的成員用戶，然後向所述符合推送條件的成員用戶對應的客戶端發送推送通知，並通過移動承載網絡向所述推送群組中的成員用戶對應的客戶端進行數據推送。
進一步的，所述應用伺服器具體包括
群組創建請求單元，用於向所述群組推送引擎發出所述推送群組建立請求，所述推送群組建立請求包括所述推送群組中所有成員用戶的標識信息；
業務推送請求單元，用於向所述群組推送引擎發出所述群組推送業務請求，所述群組推送業務請求包括待推送的群組標識；
數據傳送單元，用於在發送所述群組推送業務請求的同時，向所述群組推送引擎發送待推送的業務數據。
進一步的，所述群組推送引擎具體包括
建立請求接收單元，用於接收所述應用伺服器發出的所述推送群組建立請求；
推送群組創建單元，用於創建所述推送群組，為所述推送群組分配對應的群組標識，在所述推送群組中記錄所有成員用戶的標識信息；
群組標識通知單元，用於將所述群組標識返回給所述應用伺服器；
業務請求接收單元，用於接收所述應用伺服器發出的所述群組推送業務請求；
業務數據緩存單元，用於緩存所述應用伺服器發送的待推送的業務數據；
推送群組確定單元，用於根據所述群組推送業務請求中的待推送的群組標識確定推送群組；
推送成員確定單元，用於確定所述推送群組中符合推送條件的成員用戶；
推送通知單元，用於向所述符合推送條件的成員用戶對應的客戶端發送推送通知；
數據推送單元，用於通過所述移動承載網絡向所述推送群組中的成員用戶對應的客戶端推送緩存的業務數據。
進一步的，所述推送群組建立請求還包括推送業務的信息；所述群組推送引擎還包括
策略控制觸發單元，用於將從所述應用伺服器接收到的所述推送業務的信息發送給策略控制實體，以便所述策略控制實體針對所述推送業務制定相應的服務質量QoS和計費策略。
進一步的，所述群組推送引擎還包括推送觸發單元，用於按照預設周期或者響應於外部事件，觸發所述推送成員確定單元來判斷待推送的成員用戶中符合推送條件的成員用戶。
為實現上述目的，本發明還提供了一種基於前述的業務推送系統的業務推送方法，包括
應用伺服器向群組推送引擎發出推送群組建立請求，所述推送群組建立請求包括推送群組中所有成員用戶的標識信息；
所述群組推送引擎響應於接收到的所述推送群組建立請求，創建推送群組，為所述推送群組分配對應的群組標識，並將所述群組標識返回給所述應用伺服器；
所述應用伺服器向所述群組推送引擎發出群組推送業務請求和待推送的業務數據，所述群組推送業務請求包括待推送的群組標識；
所述群組推送引擎響應於接收到的所述群組推送業務請求和待推送的業務數據， 緩存所述待推送的業務數據，根據所述群組推送業務請求中的待推送的群組標識確定推送群組，並確定所述推送群組中符合推送條件的成員用戶；
所述群組推送引擎向所述符合推送條件的成員用戶對應的客戶端發送推送通知， 並通過移動承載網絡向所述推送群組中的成員用戶對應的客戶端進行數據推送。
進一步的，所述應用伺服器向群組推送引擎發出的推送群組建立請求還包括推送業務的信息；
所述群組推送引擎將所述推送業務的信息發送給策略控制實體，以便所述策略控制實體針對所述推送業務制定相應的服務質量QoS和計費策略。
進一步的，還包括所述群組推送引擎判斷所述推送群組中是否存在未推送的成員用戶，如果存在，則繼續確定所述未推送的成員用戶符合推送條件的成員用戶，並向所述符合推送條件的成員用戶對應的客戶端發送推送通知。
進一步的，還包括所述群組推送引擎按照預設周期或者響應於外部事件，判斷待推送的成員用戶中是否存在符合推送條件的成員用戶，並向所述符合推送條件的成員用戶對應的客戶端發送推送通知。
基於上述技術方案，本發明利用群組推送引擎建立推送群組，並基於推送群組進行業務推送，相比於現有技術，可以極大的減少應用伺服器與推送引擎之間的交互次數，通過一次交互完成多個用戶的推送業務，顯著的提高推送系統的處理能力及效率。


此處所說明的附圖用來提供對本發明的進一步理解，構成本申請的一部分，本發明的示意性實施例及其說明用於解釋本發明，並不構成對本發明的不當限定。在附圖中
圖1為本發明業務推送系統實施例的一種架構示意圖。
圖2為本發明業務推送系統實施例的另一種架構示意圖。
圖3為圖1架構下的業務推送系統實施例的具體結構示意圖。
圖4為基於圖1架構下的業務推送系統的一種業務推送方法實施例的流程示意圖。
圖5為基於圖1架構下的業務推送系統的業務推送流程的信令示意圖。
圖6為圖2架構下的業務推送系統實施例的具體結構示意圖。
圖7為基於圖2架構下的業務推送系統的一種業務推送方法實施例的流程示意圖。
圖8為基於圖2架構下的業務推送系統的業務推送流程的信令示意圖。
具體實施方式
下面通過附圖和實施例，對本發明的技術方案做進一步的詳細描述。
如圖1所示，為本發明業務推送系統實施例的一種架構示意圖。在圖1中，業務推送系統包括群組推送引擎10和應用伺服器20，其中群組推送引擎10負責響應於接收到的所述推送群組建立請求，創建推送群組，為所述推送群組分配對應的群組標識，並將所述群組標識返回給請求方，以及響應於接收到的所述群組推送業務請求，根據所述群組推送業務請求中的待推送的群組標識確定推送群組，並確定所述推送群組中符合推送條件的成員用戶，然後向所述符合推送條件的成員用戶對應的客戶端發送推送通知。
應用伺服器20負責發出包括推送群組中所有成員用戶的標識信息的推送群組建立請求，還負責發出包括待推送的群組標識的群組推送業務請求，以及通過移動承載網絡向所述推送群組中的成員用戶對應的客戶端進行數據推送。
在本實施例的系統架構中，群組推送引擎10與應用伺服器20均通過移動承載網絡30與用戶終端40進行通信，在群組推送引擎10與應用伺服器20之間進行信令交互，但在這兩者並不進行推送數據的交互，而實際的推送業務的數據則由應用伺服器20通過移動承載網絡30傳遞給用戶終端40，而無需經過群組推送引擎10。這種架構中應用伺服器需要給每個用戶發送待推送的業務數據，應用伺服器的負荷較高，但對群組推送引擎的存儲容量要求較低。
在本發明中還提供了另一種業務推送系統的系統架構，如圖2所示，為本發明業務推送系統實施例的另一種架構示意圖。在圖2中業務推送系統包括群組推送引擎50和應用伺服器60。其中，群組推送引擎50負責響應於接收到的所述推送群組建立請求，創建推送群組，為所述推送群組分配對應的群組標識，並將所述群組標識返回給請求方，以及響應於接收到的所述群組推送業務請求和待推送的業務數據，緩存所述待推送的業務數據， 根據所述群組推送業務請求中的待推送的群組標識確定推送群組，並確定所述推送群組中符合推送條件的成員用戶，然後向所述符合推送條件的成員用戶對應的客戶端發送推送通知，並通過移動承載網絡向所述推送群組中的成員用戶對應的客戶端進行數據推送。
應用伺服器60負責發出包括推送群組中所有成員用戶的標識信息的推送群組建立請求，以及發出包括待推送的群組標識的群組推送業務請求和待推送的業務數據。
在本實施例的系統架構中，群組推送引擎50通過移動承載網絡30與用戶終端40 進行通信，應用伺服器60並不直接通過以東城在網絡30與用戶終端40進行通信，在群組推送引擎10與應用伺服器20之間不僅進行信令交互，在這兩者還進行推送數據的交互，而實際的推送 業務的數據則由應用伺服器20發送給群組推送引擎10進行緩存，再由群組推送引擎10通過移動承載網絡30傳遞給用戶終端40。
這種架構對群組推送引擎的要求較高，但應用伺服器只需給群組推送引擎發送一次業務數據，後續由群組推送引擎向每個用戶發送待推送的業務數據，從而減小應用伺服器一方的處理負荷。
下面針對於圖1和圖2的系統架構分別對業務推送系統和業務推送方法的各個實施例進行詳細說明。
如圖3所示，為圖1架構下的業務推送系統實施例的具體結構示意圖。在本實施例中，應用伺服器20可以具體包括群組創建請求單元21、業務推送請求單元22和數據推送單元23。其中，群組創建請求單元21負責向群組推送引擎10發出推送群組建立請求，所述推送群組建立請求包括所述推送群組中所有成員用戶的標識信息。這裡的用戶標識信息可以為客戶端ID、手機號碼或IMSI等。
業務推送請求單元22負責向所述群組推送引擎10發出所述群組推送業務請求， 所述群組推送業務請求包括待推送的群組標識。數據推送單元23負責通過移動承載網絡 30與所述推送群組中的成員用戶對應的客戶端40進行交互，完成向所述推送群組中的成員用戶對應的客戶端40的數據推送。
群組推送引擎10可以具體包括建立請求接收單元11、推送群組創建單元12、群組標識通知單元13、業務請求接收單元14、推送群組確定單元15、推送成員確定單元16和推送通知單元17。其中，建立請求接收單元11負責接收所述應用伺服器20發出的所述推送群組建立請求。推送群組創建單元12負責創建所述推送群組，為所述推送群組分配對應的群組標識，在所述推送群組中記錄所有成員用戶的標識信息。群組標識通知單元13負責將所述群組標識返回給所述應用伺服器20。
業務請求接收單元14負責接收所述應用伺服器20發出的所述群組推送業務請求。推送群組確定單元15負責根據所述群組推送業務請求中的待推送的群組標識確定推送群組。推送成員確定單元16負責確定所述推送群組中符合推送條件的成員用戶。這裡的推送條件可以與用戶位置、網絡忙閒情況或用戶目前正使用的業務等相關。例如網絡忙閒情況可通過分析網絡配置和用戶業務使用數據獲得某一時刻用戶所在的網絡負荷情況、 當前業務使用速率信息等。推送通知單元17負責向所述符合推送條件的成員用戶對應的客戶端發送推送通知。
在上述實施例中，應用伺服器發送給群組推送引擎的推送群組建立請求中還可以包括推送業務的信息，這裡的推送業務的信息可以至少包括業務名稱、業務QoS要求、伺服器地址及埠號等信息中的部分或全部。群組推送引擎對於接收到的推送業務的信息，可以通過設置的策略控制觸發單元進行處理，該策略控制觸發單元負責將從所述推送業務的信息發送給策略控制實體，以便所述策略控制實體針對所述推送業務制定相應的服務質量 QoS和計費策略。
每次推送通知均由群組推送引擎來確定要通知的成員用戶，在完成一部分成員用戶的數據推送後，群組推送引擎可以繼續判斷推送群組中是否還有沒有進行推送的成員用戶，如果有，則可以對這些未推送的成員用戶加入到待推送成員列表，以便進行補充推送。 通過這種方式可以控制推送過程分批次來 完成，這樣對於處於網絡資源緊張地區的用戶， 可以推遲到網絡空閒時再進行推送，從而分批次的完成所有成員用戶的推送工作。
另外，在行動網路中，用戶可能處於移動狀態，例如用戶從一個較忙的小區移動到一個較閒的小區，或者用戶未移動，但因為其他業務的業務狀況使得該用戶所在小區由閒到忙了，網絡會檢測到這種變化，並通過事件的方式通知給群組推送引擎，群組推送引擎就可以自身設置的推送觸發單元進行處理，即響應於外部事件，觸發推送成員確定單元來判斷待推送的成員用戶中符合推送條件的成員用戶，通過確定的待推送用戶向相應的客戶端進行推送通知。推送觸發單元除了可以響應外部事件，也可以按照一定的預設周期進行循環式的觸發，或者預設周期和外部事件響應方式並用來觸發推送成員確定單元。
如圖4所示，為基於圖1架構下的業務推送系統的一種業務推送方法實施例的流程示意圖。在本實施例中，業務推送流程包括
步驟101、應用伺服器向群組推送引擎發出推送群組建立請求，所述推送群組建立請求包括推送群組中所有成員用戶的標識信息；
步驟102、所述群組推送引擎響應於接收到的所述推送群組建立請求，創建推送群組，為所述推送群組分配對應的群組標識，並將所述群組標識返回給所述應用伺服器；
步驟103、所述應用伺服器向所述群組推送引擎發出群組推送業務請求，所述群組推送業務請求包括待推送的群組標識；
步驟104、所述群組推送引擎響應於接收到的所述群組推送業務請求，根據所述群組推送業務請求中的待推送的群組標識確定推送群組，並確定所述推送群組中符合推送條件的成員用戶；
步驟105、所述群組推送引擎向所述符合推送條件的成員用戶對應的客戶端發送推送通知；
步驟106、所述應用伺服器通過移動承載網絡向所述推送群組中的成員用戶對應的客戶端進行數據推送。
在本實施例中，應用伺服器向群組推送引擎提供建立推送群組的用戶信息，相應的也可以將推送業務的信息也提供給群組推送引擎，這個推送群組通常是與某個或某些推送業務的應用相關，也可以與推送業務不直接相關，例如按照某種分類方式而確定的具有某種相同或相關屬性的用戶群體，群組推送引擎可以這些用戶群體創建推送群組，並為創建的推送群組分配一個可唯一標識的群組標識，這個群組標識將會被返回給應用伺服器。
應用伺服器可以根據需要預先向群組推送引擎請求建立多個推送群組，可依據各種分類方式或一些業務使用情況進行建立，各群組間的成員用戶存在重複也是允許的。
當應用伺服器需要向某個推送群組推送業務數據時，可以向群組推送引擎發送群組推送業務請求，在該請求中需要包含可以直接或間接表示待推送群組的群組標識，這個群組標識是之前群組推送引擎在建立推送群組後提供給應用伺服器的。由於在群組推送引擎一側也記錄有群組標識與推送群組內的成員用戶信息的映射關係，因此群組推送引擎可以根據群組標識確定推送群組，並進而確定推送群組中有哪些成員用戶符合推送條件。
推送條件的設定可以與用戶位置、網絡忙閒狀況、用戶正在進行的業務等部分或全部因素相關，但並不僅限於這幾種因素，也可以包括其他可能的因素。群組推送引擎可以獲取這些因素，並根據預設的規則判斷某個成員用戶是否適合在本次推送，例如某個成員用戶的 位置正處於小區邊緣，或者用戶所在小區的網絡目前較忙，或者用戶正進行語音通話等，這些情況均可能不適合在當前推送，因此可考慮在下一個周期進行推送，或者待用戶的位置/網絡/業務有所改善時再進行推送。
群組推送引擎在完成本周期的推送通知後，可以判斷所述推送群組中是否存在未推送的成員用戶，如果存在，則繼續確定所述未推送的成員用戶符合推送條件的成員用戶， 並在下一周期向所述符合推送條件的成員用戶對應的客戶端發送推送通知。
另外，群組推送引擎還可以按照預設周期或者響應於外部事件，判斷待推送的成員用戶中是否存在符合推送條件的成員用戶，並向所述符合推送條件的成員用戶對應的客戶端發送推送通知。這裡的外部事件可以是用戶位置的變化、網絡忙閒狀態的變化或用戶使用的業務的變化等，這些變化中的一種或多種通過外部事件方式提供給群組推送引擎後，群組推送引擎會判斷待推送的成員用戶中是否存在符合推送條件的成員用戶，繼而繼續對符合推送條件的成員用戶對應的客戶端發送推送通知。
前面提到，應用伺服器可能向群組推送引擎發出的推送群組建立請求還包括推送業務的信息，此時群組推送引擎可以將所述推送業務的信息發送給策略控制實體，以便所述策略控制實體針對所述推送業務制定相應的服務質量QoS和計費策略。
如圖5所示，為基於圖1架構下的業務推送系統的業務推送流程的信令示意圖。在該業務推送流程中的各個步驟參見圖中文字及箭頭所表達的信息流向以及前文業務推送方法實施例中各步驟所示，這裡就不再一一詳述了。在圖5中，群組推送引擎在第一次接收到群組推送請求時，確定了用戶I客戶端作為本次的推送通知對象，並由應用伺服器與用戶I客戶端進行數據交互，以便完成業務數據的推送。在群組推送引擎在第二次確定了用戶2客戶端作為該次的推送通知對象，並由應用伺服器與用戶2客戶端進行數據交互，以便完成業務數據的推送。當完成推送群組內所有成員用戶的數據推送後，群組推送引擎最終向應用伺服器發送群組推送確認消息，在該消息中包括群組標識。
如圖6所示，為圖2架構下的業務推送系統實施例的具體結構示意圖。在本實施例中，業務推送系統中的應用伺服器60可以具體包括群組創建請求單元61、業務推送請求單元62和數據傳送單元63。其中，群組創建請求單元61負責向所述群組推送引擎50發出所述推送群組建立請求，所述推送群組建立請求包括所述推送群組中所有成員用戶的標識信息。業務推送請求單元62負責向所述群組推送引擎50發出所述群組推送業務請求， 所述群組推送業務請求包括待推送的群組標識。數據傳送單元63負責在發送所述群組推送業務請求的同時，向所述群組推送引擎50發送待推送的業務數據。
在圖6中，所述群組推送引擎50可以具體包括建立請求接收單元51、推送群組創建單元52、群組標識通知單元53、業務請求接收單元54、業務數據緩存單元55、推送群組確定單元56、推送成員確定單元57、推送通知單元58和數據推送單元59。其中，建立請求接收單元51負責接收所述應用伺服器60發出的所述推送群組建立請求。推送群組創建單元52負責創建所述推送群組，為所述推送群組分配對應的群組標識，在所述推送群組中記錄所有成員用戶的標識信息。群組標識通知單元53負責將所述群組標識返回給所述應用伺服器60。
業務請求接收單元54負責接收所述應用伺服器60發出的所述群組推送業務請求。業務數據緩存單元55負責緩存所述應用伺服器60發送的待 推送的業務數據。推送群組確定單元56負責根據所述群組推送業務請求中的待推送的群組標識確定推送群組。推送成員確定單元57負責確定所述推送群組中符合推送條件的成員用戶。推送通知單元58 負責向所述符合推送條件的成員用戶對應的客戶端發送推送通知。數據推送單元59負責通過所述移動承載網絡30向所述推送群組中的成員用戶對應的客戶端40推送緩存的業務數據。
在上述實施例中，推送群組建立請求中還可以包括推送業務的信息，群組推送引擎還可以進一步設置策略控制觸發單元，該單元負責將從所述應用伺服器接收到的所述推送業務的信息發送給策略控制實體，以便所述策略控制實體針對所述推送業務制定相應的服務質量QoS和計費策略。這裡的推送業務的信息可以至少包括業務名稱、業務QoS要求、 伺服器地址及埠號等信息中的部分或全部。
每次推送通知均由群組推送引擎來確定要通知的成員用戶，在完成一部分成員用戶的數據推送後，群組推送引擎可以繼續判斷推送群組中是否還有沒有進行推送的成員用戶，如果有，則可以對這些未推送的成員用戶加入到待推送成員列表，以便進行補充推送。 通過這種方式可以控制推送過程分批次來完成，這樣對於處於網絡資源緊張地區的用戶， 可以推遲到網絡空閒時再進行推送，從而分批次的完成所有成員用戶的推送工作。
另外，在行動網路中，用戶可能處於移動狀態，例如用戶從一個較忙的小區移動到一個較閒的小區，或者用戶未移動，但因為其他業務的業務狀況使得該用戶所在小區由閒到忙了，網絡會檢測到這種變化，並通過事件的方式通知給群組推送引擎，群組推送引擎就可以自身設置的推送觸發單元進行處理，即響應於外部事件，觸發推送成員確定單元來判斷待推送的成員用戶中符合推送條件的成員用戶，通過確定的待推送用戶向相應的客戶端進行推送通知。推送觸發單元除了可以響應外部事件，也可以按照一定的預設周期進行循環式的觸發，或者預設周期和外部事件響應方式並用來觸發推送成員確定單元。
如圖7所示，為基於圖2架構下的業務推送系統的一種業務推送方法實施例的流程示意圖。在本實施例中，業務推送流程包括
步驟201、應用伺服器向群組推送引擎發出推送群組建立請求，所述推送群組建立請求包括推送群組中所有成員用戶的標識信息；
步驟202、所述群組推送引擎響應於接收到的所述推送群組建立請求，創建推送群組，為所述推送群組分配對應的群組標識，並將所述群組標識返回給所述應用伺服器；
步驟203、所述應用伺服器向所述群組推送引擎發出群組推送業務請求和待推送的業務數據，所述群組推送業務請求包括待推送的群組標識；
步驟204、所述群組推送引擎響應於接收到的所述群組推送業務請求和待推送的業務數據，緩存所述待推送的業務數據；
步驟205、所述群組推送引擎根據所述群組推送業務請求中的待推送的群組標識確定推送群組，並確定所述推送群組中符合推送條件的成員用戶；
步驟206、所述群組推送引擎向所述符合推送條件的成員用戶對應的客戶端發送推送通知；
步驟207、所述群組推送引擎通過移動承載網絡向所述推送群組中的成員用戶對應的客戶端進行數據推送。
在本實施例中，應用伺服器向群組推送引擎提供建立推送群組的用戶信息，相應的也可以將推送業務的信息也提供給群組推送引擎，這個推 送群組通常是與某個或某些推送業務的應用相關，也可以與推送業務不直接相關，例如按照某種分類方式而確定的具有某種相同或相關屬性的用戶群體，群組推送引擎可以這些用戶群體創建推送群組，並為創建的推送群組分配一個可唯一標識的群組標識，這個群組標識將會被返回給應用伺服器。
應用伺服器可以根據需要預先向群組推送引擎請求建立多個推送群組，可依據各種分類方式或一些業務使用情況進行建立，各群組間的成員用戶存在重複也是允許的。
當應用伺服器需要向某個推送群組推送業務數據時，可以向群組推送引擎發送群組推送業務請求，在該請求中需要包含可以直接或間接表示待推送群組的群組標識，這個群組標識是之前群組推送引擎在建立推送群組後提供給應用伺服器的。由於在群組推送引擎一側也記錄有群組標識與推送群組內的成員用戶信息的映射關係，因此群組推送引擎可以根據群組標識確定推送群組，並進而確定推送群組中有哪些成員用戶符合推送條件。
推送條件的設定可以與用戶位置、網絡忙閒狀況、用戶正在進行的業務等部分或全部因素相關，但並不僅限於這幾種因素，也可以包括其他可能的因素。群組推送引擎可以獲取這些因素，並根據預設的規則判斷某個成員用戶是否適合在本次推送，例如某個成員用戶的位置正處於小區邊緣，或者用戶所在小區的網絡目前較忙，或者用戶正進行語音通話等，這些情況均可能不適合在當前推送，因此可考慮在下一個周期進行推送，或者待用戶的位置/網絡/業務有所改善時再進行推送。
群組推送引擎在完成本周期的推送通知後，可以判斷所述推送群組中是否存在未推送的成員用戶，如果存在，則繼續確定所述未推送的成員用戶符合推送條件的成員用戶， 並在下一周期向所述符合推送條件的成員用戶對應的客戶端發送推送通知。
另外，群組推送引擎還可以按照預設周期或者響應於外部事件，判斷待推送的成員用戶中是否存在符合推送條件的成員用戶，並向所述符合推送條件的成員用戶對應的客戶端發送推送通知。這裡的外部事件可以是用戶位置的變化、網絡忙閒狀態的變化或用戶使用的業務的變化等，這些變化中的一種或多種通過外部事件方式提供給群組推送引擎後，群組推送引擎會判斷待推送的成員用戶中是否存在符合推送條件的成員用戶，繼而繼續對符合推送條件的成員用戶對應的客戶端發送推送通知。
前面提到，應用伺服器可能向群組推送引擎發出的推送群組建立請求還包括推送業務的信息，此時群組推送引擎可以將所述推送業務的信息發送給策略控制實體，以便所述策略控制實體針對所述推送業務制定相應的服務質量QoS和計費策略。
如圖8所示，為基於圖2架構下的業務推送系統的業務推送流程的信令示意圖。在該業務推送流程中的各個步驟參見圖中文字及箭頭所表達的信息·流向以及前文業務推送方法實施例中各步驟所示，這裡就不再一一詳述了。在圖8中，群組推送引擎在第一次接收到群組推送請求時，確定了用戶I客戶端作為本次的推送通知對象，並由群組推送引擎與用戶I客戶端進行數據交互，以便完成業務數據的推送。在群組推送引擎在第二次確定了用戶2客戶端作為該次的推送通知對象，並由群組推送引擎與用戶2客戶端進行數據交互， 以便完成業務數據的推送。當完成推送群組內所有成員用戶的數據推送後，群組推送引擎最終向應用伺服器發送群組推送確認消息，在該消息中包括群組標識。
本領域普通技術人員可以理解實現上述方法實施例的全部或部分步驟可以通過程序指令相關的硬體來完成，前述的程序可以存儲於一計算設備的可讀取存儲介質中，該程序在執行時，執行包括上述方法實施例的步驟；而前述的存儲介質包括R0M、RAM、磁碟或者光碟等各種可以存儲程序代碼的介質。
最後應當說明的是以上實施例僅用以說明本發明的技術方案而非對其限制；儘管參照較佳實施例對本發明進行了詳細的說明，所屬領域的普通技術人員應當理解依然可以對本發明的具體實施方式
進行修改或者對部分技術特徵進行等同替換；而不脫離本發明技術方案的精神，其均應涵蓋在本發明請求保護的技術方案範圍當中。·
權利要求
1.一種業務推送系統,包括 應用伺服器，用於發出包括推送群組中所有成員用戶的標識信息的推送群組建立請求，以及發出包括待推送的群組標識的群組推送業務請求，並通過移動承載網絡向所述推送群組中的成員用戶對應的客戶端進行數據推送； 群組推送引擎，用於響應於接收到的所述推送群組建立請求，創建推送群組，為所述推送群組分配對應的群組標識，並將所述群組標識返回給請求方，以及響應於接收到的所述群組推送業務請求，根據所述群組推送業務請求中的待推送的群組標識確定推送群組，並確定所述推送群組中符合推送條件的成員用戶，然後向所述符合推送條件的成員用戶對應的客戶端發送推送通知。
2.根據權利要求1所述的業務推送系統，其中，所述應用伺服器具體包括 群組創建請求單元，用於向所述群組推送引擎發出所述推送群組建立請求，所述推送群組建立請求包括所述推送群組中所有成員用戶的標識信息； 業務推送請求單元，用於向所述群組推送引擎發出所述群組推送業務請求，所述群組推送業務請求包括待推送的群組標識； 數據推送單元，用於通過移動承載網絡與所述推送群組中的成員用戶對應的客戶端進行交互，完成向所述推送群組中的成員用戶對應的客戶端的數據推送。
3.根據權利要求2所述的業務推送系統，其中，所述群組推送引擎具體包括 建立請求接收單元，用於接收所述應用伺服器發出的所述推送群組建立請求； 推送群組創建單元，用於創建所述推送群組，為所述推送群組分配對應的群組標識，在所述推送群組中記錄所有成員用戶的標識信息； 群組標識通知單元，用於將所述群組標識返回給所述應用伺服器； 業務請求接收單元，用於接收所述應用伺服器發出的所述群組推送業務請求； 推送群組確定單元，用於根據所述群組推送業務請求中的待推送的群組標識確定推送群組； 推送成員確定單元，用於確定所述推送群組中符合推送條件的成員用戶； 推送通知單元，用於向所述符合推送條件的成員用戶對應的客戶端發送推送通知。
4.根據權利要求3所述的業務推送系統，其中，所述推送群組建立請求還包括推送業務的信息；所述群組推送引擎還包括 策略控制觸發單元，用於將從所述應用伺服器接收到的所述推送業務的信息發送給策略控制實體，以便所述策略控制實體針對所述推送業務制定相應的服務質量QoS和計費策略。
5.根據權利要求3所述的業務推送系統，其中，所述群組推送引擎還包括 推送觸發單元，用於按照預設周期或者響應於外部事件，觸發所述推送成員確定單元來判斷待推送的成員用戶中符合推送條件的成員用戶。
6.一種基於權利要求1 5任一所述的業務推送系統的業務推送方法,包括 應用伺服器向群組推送引擎發出推送群組建立請求，所述推送群組建立請求包括推送群組中所有成員用戶的標識信息； 所述群組推送引擎響應於接收到的所述推送群組建立請求，創建推送群組，為所述推送群組分配對應的群組標識，並將所述群組標識返回給所述應用伺服器；所述應用伺服器向所述群組推送引擎發出群組推送業務請求，所述群組推送業務請求包括待推送的群組標識；所述群組推送引擎響應於接收到的所述群組推送業務請求，根據所述群組推送業務請求中的待推送的群組標識確定推送群組，並確定所述推送群組中符合推送條件的成員用戶所述群組推送引擎向所述符合推送條件的成員用戶對應的客戶端發送推送通知；所述應用伺服器通過移動承載網絡向所述推送群組中的成員用戶對應的客戶端進行數據推送。
7.根據權利要求6所述的業務推送方法，其中，所述應用伺服器向群組推送引擎發出的推送群組建立請求還包括推送業務的信息； 所述群組推送引擎將所述推送業務的信息發送給策略控制實體，以便所述策略控制實體針對所述推送業務制定相應的服務質量QoS和計費策略。
8.根據權利要求6所述的業務推送方法，其中，還包括 所述群組推送引擎判斷所述推送群組中是否存在未推送的成員用戶，如果存在，則繼續確定所述未推送的成員用戶符合推送條件的成員用戶，並向所述符合推送條件的成員用戶對應的客戶端發送推送通知。
9.根據權利要求6或8所述的業務推送方法，其中，還包括 所述群組推送引擎按照預設周期或者響應於外部事件，判斷待推送的成員用戶中是否存在符合推送條件的成員用戶，並向所述符合推送條件的成員用戶對應的客戶端發送推送通知。
10.一種業務推送系統,包括 應用伺服器，用於發出包括推送群組中所有成員用戶的標識信息的推送群組建立請求，以及發出包括待推送的群組標識的群組推送業務請求和待推送的業務數據； 群組推送引擎，用於響應於接收到的所述推送群組建立請求，創建推送群組，為所述推送群組分配對應的群組標識，並將所述群組標識返回給請求方，以及響應於接收到的所述群組推送業務請求和待推送的業務數據，緩存所述待推送的業務數據，根據所述群組推送業務請求中的待推送的群組標識確定推送群組，並確定所述推送群組中符合推送條件的成員用戶，然後向所述符合推送條件的成員用戶對應的客戶端發送推送通知，並通過移動承載網絡向所述推送群組中的成員用戶對應的客戶端進行數據推送。
11.根據權利要求10所述的業務推送系統，其中，所述應用伺服器具體包括 群組創建請求單元，用於向所述群組推送引擎發出所述推送群組建立請求，所述推送群組建立請求包括所述推送群組中所有成員用戶的標識信息； 業務推送請求單元，用於向所述群組推送引擎發出所述群組推送業務請求，所述群組推送業務請求包括待推送的群組標識； 數據傳送單元，用於在發送所述群組推送業務請求的同時，向所述群組推送引擎發送待推送的業務數據。
12.根據權利要求11所述的業務推送系統，其中，所述群組推送引擎具體包括 建立請求接收單元，用於接收所述應用伺服器發出的所述推送群組建立請求； 推送群組創建單元，用於創建所述推送群組，為所述推送群組分配對應的群組標識，在所述推送群組中記錄所有成員用戶的標識信息；群組標識通知單元，用於將所述群組標識返回給所述應用伺服器； 業務請求接收單元，用於接收所述應用伺服器發出的所述群組推送業務請求； 業務數據緩存單元，用於緩存所述應用伺服器發送的待推送的業務數據； 推送群組確定單元，用於根據所述群組推送業務請求中的待推送的群組標識確定推送群組； 推送成員確定單元，用於確定所述推送群組中符合推送條件的成員用戶； 推送通知單元，用於向所述符合推送條件的成員用戶對應的客戶端發送推送通知；數據推送單元，用於通過所述移動承載網絡向所述推送群組中的成員用戶對應的客戶端推送緩存的業務數據。
13.根據權利要求12所述的業務推送系統，其中，所述推送群組建立請求還包括推送業務的信息；所述群組推送引擎還包括 策略控制觸發單元，用於將從所述應用伺服器接收到的所述推送業務的信息發送給策略控制實體，以便所述策略控制實體針對所述推送業務制定相應的服務質量QoS和計費策略。
14.根據權利要求12所述的業務推送系統，其中，所述群組推送引擎還包括 推送觸發單元，用於按照預設周期或者響應於外部事件，觸發所述推送成員確定單元來判斷待推送的成員用戶中符合推送條件的成員用戶。
15.—種基於權利要求10-14任一所述的業務推送系統的業務推送方法,包括 應用伺服器向群組推送引擎發出推送群組建立請求，所述推送群組建立請求包括推送群組中所有成員用戶的標識信息； 所述群組推送引擎響應於接收到的所述推送群組建立請求，創建推送群組，為所述推送群組分配對應的群組標識，並將所述群組標識返回給所述應用伺服器； 所述應用伺服器向所述群組推送引擎發出群組推送業務請求和待推送的業務數據，所述群組推送業務請求包括待推送的群組標識； 所述群組推送引擎響應於接收到的所述群組推送業務請求和待推送的業務數據，緩存所述待推送的業務數據，根據所述群組推送業務請求中的待推送的群組標識確定推送群組，並確定所述推送群組中符合推送條件的成員用戶； 所述群組推送引擎向所述符合推送條件的成員用戶對應的客戶端發送推送通知，並通過移動承載網絡向所述推送群組中的成員用戶對應的客戶端進行數據推送。
16.根據權利要求15所述的業務推送方法，其中，所述應用伺服器向群組推送引擎發出的推送群組建立請求還包括推送業務的信息； 所述群組推送引擎將所述推送業務的信息發送給策略控制實體，以便所述策略控制實體針對所述推送業務制定相應的服務質量QoS和計費策略。
17.根據權利要求15所述的業務推送方法，其中，還包括 所述群組推送引擎判斷所述推送群組中是否存在未推送的成員用戶，如果存在，則繼續確定所述未推送的成員用戶符合推送條件的成員用戶，並向所述符合推送條件的成員用戶對應的客戶端發送推送通知。
18.根據權利要求15或17所述的業務推送方法，其中，還包括 所述群組推送引擎按照預設周期或者響應於外部事件，判斷待推送的成員用戶中是否存 在符合推送條件的成員用戶，並向所述符合推送條件的成員用戶對應的客戶端發送推送通知。
全文摘要
本發明涉及一種業務推送系統，包括應用伺服器，用於發出包括成員用戶的標識信息的推送群組建立請求，以及發出群組推送業務請求，並通過移動承載網絡向推送群組中的成員用戶對應的客戶端進行數據推送；群組推送引擎，用於創建推送群組，為推送群組分配對應的群組標識，並將群組標識返回給請求方，以及根據群組推送業務請求中的待推送的群組標識確定推送群組，並確定推送群組中符合推送條件的成員用戶，然後向符合推送條件的成員用戶對應的客戶端發送推送通知。本發明還涉及一種業務推送方法。本發明可以極大的減少應用伺服器與推送引擎之間的交互次數，通過一次交互完成多個用戶的推送業務，顯著的提高推送系統的處理能力及效率。
文檔編號H04L29/08GK103036926SQ20111030443
公開日2013年4月10日 申請日期2011年9月29日 優先權日2011年9月29日
發明者王海寧, 畢奇, 楊峰義 申請人:中國電信股份有限公司