系統(tǒng)介紹 ???????????????????????????????????????????????

xStream多通道流式數(shù)據(jù)處理系統(tǒng)是一個適用于復(fù)雜應(yīng)用場景的高性能、高并發(fā)、高可靠性、高可伸縮性的分布式實時數(shù)據(jù)處理系統(tǒng)?？梢酝瑫r為應(yīng)用于不同業(yè)務(wù)場景的邊緣計算設(shè)備提供點狀及流式數(shù)據(jù)的采集、存儲、分析、計算等服務(wù)。只需普通的、由廉價PC組成的計算集群，無需單獨購買價格昂貴、性能優(yōu)越的服務(wù)器，xStream針對邊緣計算設(shè)備的并發(fā)接入數(shù)量（集群）即可輕松達(dá)到十萬以上級，實時數(shù)據(jù)的處理能力（集群）達(dá)百萬級每秒。

系統(tǒng)特色 ????????????????????????????????????????????????

xStream中的“x”指代任意的應(yīng)用場景（無限），從環(huán)境在線監(jiān)測到環(huán)境移動執(zhí)法、環(huán)保用電監(jiān)管，再到實時視頻監(jiān)控、甚或其它非環(huán)境類的更為復(fù)雜的場景均能任意擴(kuò)展，任意配置——各業(yè)務(wù)場景間既可高度耦合，亦可松散耦合及至實現(xiàn)更為嚴(yán)格的業(yè)務(wù)、數(shù)據(jù)隔離。Stream指代從邊緣計算設(shè)備到用戶端流動的實時數(shù)據(jù)流：按時間序列采集的點狀數(shù)據(jù)以及音、視頻、圖片等流式數(shù)據(jù)。無論是點數(shù)據(jù)還是流式數(shù)據(jù)，xStream系統(tǒng)均根據(jù)事先制定的業(yè)務(wù)規(guī)則實時處理，處理結(jié)果存入分布式NoSQL數(shù)據(jù)庫。

xStream部署環(huán)境簡單，OS為Linux CentOS 7及以上版本，至少三臺普通PC，每臺PC安裝Cassandra數(shù)據(jù)庫及MySQL數(shù)據(jù)庫，建立數(shù)據(jù)庫集群。

系統(tǒng)優(yōu)勢 ????????????????????????????????????????????????

1）低成本，高性能。無需購買昂貴的服務(wù)器，只需三臺以上的普通PC，使用開源、免費的linux服務(wù)器系統(tǒng)centOS組建計算集群即可獲得極佳的處理性能。

?2）可伸縮性。系統(tǒng)建設(shè)初期接入設(shè)備較少時，集群節(jié)點三臺即可，當(dāng)接入設(shè)備逐漸增多，數(shù)據(jù)量極速增長時，只需繼續(xù)采購PC，橫向增加集群節(jié)點即可大幅提升系統(tǒng)處理性能，增加節(jié)點數(shù)量無上限。

?3）高可靠性。當(dāng)數(shù)據(jù)庫集群出現(xiàn)單個甚至多個節(jié)點宕機(jī)或者因磁盤故障出現(xiàn)數(shù)據(jù)損壞時，其它正常節(jié)點仍能提供可靠的數(shù)據(jù)存儲及訪問服務(wù)，故障節(jié)點一旦被修復(fù)重新加入集群，數(shù)據(jù)自動同步，無需人工干預(yù)。

?4）完全自主知識產(chǎn)權(quán)的虛擬網(wǎng)絡(luò)容災(zāi)系統(tǒng)。集群內(nèi)所有網(wǎng)絡(luò)節(jié)點綁定同一個虛擬地址，當(dāng)單個或多個網(wǎng)絡(luò)節(jié)點宕機(jī)時，系統(tǒng)自動切換網(wǎng)絡(luò)服務(wù)到正常節(jié)點，確保數(shù)據(jù)接入、WEB、APP等關(guān)鍵服務(wù)不受影響，實現(xiàn)7x24小時無人值守。

?5）完全自主知識產(chǎn)權(quán)的高性能實時庫。采用高效的哈希存儲算法，有效降低碰撞率，百億條以上數(shù)據(jù)記錄的檢索時間穩(wěn)定在微秒級。

?6）高并發(fā)、多通道數(shù)據(jù)采集服務(wù)。系統(tǒng)采用異步通訊架構(gòu)，能夠充分發(fā)揮CPU多核處理器的能力，TCP并發(fā)鏈接數(shù)達(dá)到十萬以上級。

?7）多場景并發(fā)數(shù)據(jù)采集能力。系統(tǒng)可以提供任意多個、采用不同通訊協(xié)議的通訊通道為不同應(yīng)用場景下的邊緣計算設(shè)備提供數(shù)據(jù)接入服務(wù)。

?8）分布式日志系統(tǒng)。登錄到任意一個集群節(jié)點均可實時查看xStream在整個集群內(nèi)的整體運行狀態(tài)，系統(tǒng)管理員可據(jù)此監(jiān)控并排查系統(tǒng)故障隱患，確保系統(tǒng)運行處于最佳狀態(tài)。