產(chǎn)品概述
MPS1.0——消息推送系統(tǒng)(Message Push System)產(chǎn)品,是在互動電視平臺以及智能終端上衍生的信息交互產(chǎn)品。系統(tǒng)采用服務(wù)無狀態(tài)設(shè)計,各能力部件均支持水平橫向擴展;采用標準MQTT協(xié)議實現(xiàn)消息發(fā)送,具備數(shù)據(jù)量小、靈活、高效、易于使用的優(yōu)點;具備強大的消息管控機制、靈活的消息策略、多種推送機制及算法等功能;具備各類統(tǒng)計報表和監(jiān)控功能,通過消息推送系統(tǒng)能夠使平臺消息準確、快速、安全送達用戶端,提高用戶在使用具體業(yè)務(wù)中的人性化體驗,也可通過對接第三方平臺進行第三方消息送,如國家應(yīng)急廣播平臺,通過消息系統(tǒng)可滿足國家應(yīng)急廣播標準體系中要求的廣電網(wǎng)絡(luò)通道覆蓋。
產(chǎn)品規(guī)格
支持流量切換,自動屏蔽故障節(jié)點,當出現(xiàn)單點故障時,可從集群中剔除,當節(jié)點恢復(fù)后,可自動重連恢復(fù)使用;
支持消息發(fā)布全周期加/解密處理,采用國密算法,保障數(shù)據(jù)完整性;
系統(tǒng)擁有強大的消息管控機制,可暫停/發(fā)布消息,控制各類型消息的發(fā)布,控制各發(fā)送通道的關(guān)閉開啟,控制各類終端消息的接收;
支持透傳消息,即第三方業(yè)務(wù)系統(tǒng)可將消息對接平臺后,將消息投遞給其他業(yè)務(wù)系統(tǒng);
支持對接國家應(yīng)急廣播平臺并符合其標準《GDJ 079-2018 應(yīng)急廣播系統(tǒng)總體技術(shù)規(guī)范》、《GDJ 086-2018 有線數(shù)字電視應(yīng)急廣播技術(shù)規(guī)范》、《GDJ 081-2018 應(yīng)急廣播安全保護技術(shù)規(guī)范 數(shù)字簽名》、《GDJ 082-2018 應(yīng)急廣播消息格式規(guī)范》等;
單臺8核CPU、32G內(nèi)配置支持高達20萬MQTT長鏈接,支持消息推送高達20000TPS,采用離線消息方式保證消息到達率99.99%以上;
產(chǎn)品特性
系統(tǒng)須采用服務(wù)無狀態(tài)設(shè)計,各能力部件均支持水平橫向擴展,便于后期擴容
系統(tǒng)各個子部件均用拆分設(shè)計、服務(wù)化、組件化。各個子系統(tǒng)之間均通過4層/7層通訊協(xié)議交互,集群部署,保障服務(wù)可靠性
系統(tǒng)采用多種異步消息隊列,實現(xiàn)服務(wù)解耦、流量削峰和緩沖,并可實時查看隊列任務(wù),操作隊列中正在/等待發(fā)送的消息任務(wù)
系統(tǒng)采取并發(fā)設(shè)計,可并發(fā)獲取數(shù)據(jù)
系統(tǒng)須支持流量切換,以自動屏蔽故障機器,當一臺或者多臺邏輯層服務(wù)器宕機時,請求可提交到集群中的任意可用服務(wù)器,而且所有邏輯層服務(wù)器須支持可用狀態(tài)實時監(jiān)測,當發(fā)現(xiàn)服務(wù)器不可用時,可從集群中剔除,當服務(wù)器恢復(fù)可用后,可自動重連恢復(fù)使用,確保系統(tǒng)的可用性
系統(tǒng)支持消息發(fā)布全周期加/解密處理,采用國密算法,保障數(shù)據(jù)完整性
系統(tǒng)支持完善的操作日志,能夠?qū)γ總€操作員每次操作有詳細的記錄
系統(tǒng)支持完善接口日志,能夠詳細記錄每個外部業(yè)務(wù)系統(tǒng)接口請求狀態(tài)
系統(tǒng)采用輕量級MQTT協(xié)議用于消息發(fā)送,具備數(shù)據(jù)量小、靈活、高效、易于使用,適用于消息數(shù)據(jù)交換,最大程度減少帶寬壓力
系統(tǒng)消息推送采取服務(wù)端即時主動向終端推送消息的方式,大大提升即時性。
系統(tǒng)支持用戶離線消息,保障消息百分百到達
系統(tǒng)支持單向通道、雙向通道、蘋果通道等三種下發(fā)通道,單向通道對接廣電復(fù)用器,雙向通道是基于雙向網(wǎng)絡(luò)TCP協(xié)議,可支持NAT公網(wǎng)環(huán)境,蘋果通道對接蘋果服務(wù)
系統(tǒng)支持完善的權(quán)限機制,可為接入的第三方業(yè)務(wù)系統(tǒng)采取多樣的業(yè)務(wù)與發(fā)送機制配置,可配置不同系統(tǒng)系統(tǒng)能使用的模板、可發(fā)送的消息類型、可使用的通道等權(quán)限
系統(tǒng)擁有強大的消息管控機制,可暫停/發(fā)布消息,控制各類型消息的發(fā)布,控制各發(fā)送通道的關(guān)閉開啟,控制各類終端消息的接收
系統(tǒng)擁有完善靈活的免打擾策略,可設(shè)置不同用戶、區(qū)域、分組是否免收消息
系統(tǒng)擁有完善靈活的免打擾時間,可設(shè)置不同時間段、時間點不允許下發(fā)消息。當免打擾時間過去后,系統(tǒng)自動補發(fā)消息
系統(tǒng)擁有兩種推送機制,根據(jù)算法,自動為不同目標用戶量的消息匹配對應(yīng)的推送機制,最大化加速消息下發(fā)速度
系統(tǒng)支持模板消息,可提前下發(fā)模板到終端后,后續(xù)直接使用模板發(fā)送消息
系統(tǒng)支持自動校驗非法敏感詞,支持消息的審核與駁回
系統(tǒng)支持接入多種類型的終端設(shè)備,機頂盒,移動手機應(yīng)用,平板,蘋果手機等
系統(tǒng)支持文本、指令、網(wǎng)頁跳轉(zhuǎn)、頻道跳轉(zhuǎn)、視頻跳轉(zhuǎn)等多種類型的消息格式
系統(tǒng)支持消息優(yōu)先級,按照消息的優(yōu)先級進行消息投遞
系統(tǒng)支持投遞定時消息,即到達指定時間后,消息自動投遞,無需人為干預(yù)
系統(tǒng)支持接入多種類型的自定義用戶組與用戶關(guān)系,做到針對不同類型用戶的精準投遞
系統(tǒng)支持透傳消息,即第三方業(yè)務(wù)系統(tǒng)可將消息對接平臺后,將消息投遞給其他業(yè)務(wù)系統(tǒng)
針對機頂盒,系統(tǒng)支持定義頻道白名單/黑名單。即相應(yīng)頻道下是否呈現(xiàn)消息
系統(tǒng)支持接口接入消息進行發(fā)送,同時提供友好的界面化系統(tǒng)方便用戶下發(fā)消息
系統(tǒng)擁有完善的監(jiān)控系統(tǒng),可實時界面化監(jiān)控查看平臺各服務(wù)器、應(yīng)用健康狀態(tài),方便運維
系統(tǒng)擁有完善的業(yè)務(wù)監(jiān)控能力,可實時界面化監(jiān)控消息下發(fā)全流程、消息平臺業(yè)務(wù)性能指標
產(chǎn)品體系結(jié)構(gòu)
消息系統(tǒng)平臺在架構(gòu)設(shè)計時,遵循組件化,服務(wù)化架構(gòu),每個系統(tǒng)部件對應(yīng)不同的層次,完成各自不同的系統(tǒng)功能。從系統(tǒng)架構(gòu)層次上主要分為4層。系統(tǒng)接入層主要由負載均衡服務(wù)器提供集群負載理由、單向廣播通道提供單向數(shù)據(jù)播發(fā)、蘋果通道提供IOS設(shè)備數(shù)據(jù)播發(fā)以及長連接服務(wù)提供雙向通道數(shù)據(jù)播發(fā)。在序列化層主要由Redis消息隊列、Beanstalked優(yōu)先級隊列提供數(shù)據(jù)得異步序列化傳遞任務(wù)。業(yè)務(wù)邏輯層則主要提供消息系統(tǒng)平臺對外提供的業(yè)務(wù)。數(shù)據(jù)庫存儲層主要由內(nèi)存型數(shù)據(jù)庫Redis以及關(guān)系型數(shù)據(jù)庫Mysql提供服務(wù)。
消息系統(tǒng)平臺整體業(yè)務(wù)細分可分為:第三方消息接入、系統(tǒng)及消息監(jiān)控統(tǒng)計、第三方權(quán)限管理、多通道消息推送、用戶信息維護、消息維護等。每個業(yè)務(wù)均由各自的管理業(yè)務(wù)及業(yè)務(wù)能力組件配合完成,對外提供業(yè)務(wù)能力。