[發明專利]一種主/從架構的低耦合的分布式流式計算系統有效
| 申請號： | 201811057446.2 | 申請日： | 2018-09-11 |
| 公開（公告）號： | CN109327509B | 公開（公告）日： | 2022-01-18 |
| 發明（設計）人： | 鄒復好;李開;熊饒饒;劉鵬坤;孫斌 | 申請（專利權）人： | 武漢魅瞳科技有限公司 |
| 主分類號： | H04L67/1042 | 分類號： | H04L67/1042;H04L67/1008;H04L67/1097;H04L67/02;H04L67/55;H04L67/133;H04L43/0817;H04L43/10;H04L41/0668 |
| 代理公司： | 武漢藍寶石專利代理事務所(特殊普通合伙) 42242 | 代理人： | 廉海濤 |
| 地址： | 430000 湖北省武漢市東湖新技術*** | 國省代碼： | 湖北;42 |
| 權利要求書： | 查看更多 | 說明書： | 查看更多 |
| 摘要： | |||
| 搜索關鍵詞： | 一種 架構 耦合 分布式 計算 系統 | ||
1.一種主/從架構的低耦合的分布式流式計算系統，其特征在于，包括：分布式服務環境、集群管理主節點、集群的工作從節點、集群的業務處理節點；
所述分布式服務環境包括：Zookeeper集群模塊、負載均衡模塊、分布式服務通信模塊以及分布式服務部署模塊；
所述Zookeeper集群模塊用于存儲分布式節點的運行狀態、負載狀態、任務執行狀態；
所述負載均衡模塊用于實現任務的負載均衡；
所述分布式服務通信模塊用于實現分布式環境下的節點之間直接的通信，以及流處理中間結果的推送，以實現低耦合特性；
所述分布式服務部署模塊用于采用容器技術實現分布式服務的部署，采并用統一的RestfulAPI接口用于容器服務間的通信；
所述集群管理主節點用于管理集群節點的運行狀態，并向各個集群的工作從節點分發任務；所述集群管理主節點用于負責分布式系統任務調度、負載均衡，管理集群節點的運行狀態，任務的分發，機器的任務負載狀態和任務的進度管理；
所述集群的工作從節點用于執行所述集群管理主節點分發的任務，并將任務執行的中間結果在Kafka中緩存；
所述集群的業務處理節點用于消費Kafka中產生的消息，并得到業務結果。
2.根據權利要求1所述的主/從架構的低耦合的分布式流式計算系統，其特征在于，所述主/從架構的低耦合的分布式流式計算系統 還包括：
API網關節點，所述API網關節點用于為外部提供API服務或者WebSocket服務。
3.根據權利要求2所述的主/從架構的低耦合的分布式流式計算系統，其特征在于，所述API網關節點采用了SSL加密和標準的RestfulAPI的方式來保證結果的安全獲取。
4.根據權利要求1所述的主/從架構的低耦合的分布式流式計算系統，其特征在于，所述分布式服務通信模塊還用于實現流數據的傳輸。
5.根據權利要求1所述的主/從架構的低耦合的分布式流式計算系統，其特征在于，所述集群管理主節點包括：
備份模塊和監控模塊，所述備份模塊采用Zookeeper的Watch機制來進行主從備份，當主節點任務失敗時，備份節點立刻進行工作狀態；
所述監控模塊采用Zookeeper的心跳機制來實時監控從節點的工作狀態。
6.根據權利要求1所述的主/從架構的低耦合的分布式流式計算系統，其特征在于，所述集群的工作從節點還用于將節點狀態保存在Zookeeper中。
7.根據權利要求1所述的主/從架構的低耦合的分布式流式計算系統，其特征在于，所述集群的業務處理節點還用于將流式數據的結果實時推送到WebSocket中，以使所述流式數據的結果顯示到前端瀏覽器上。
該專利技術資料僅供研究查看技術是否侵權等信息，商用須獲得專利權人授權。該專利全部權利屬于武漢魅瞳科技有限公司，未經武漢魅瞳科技有限公司許可，擅自商用是侵權行為。如果您想購買此專利、獲得商業授權和技術合作，請聯系【客服】
本文鏈接：http://www.szxzyx.cn/pat/books/201811057446.2/1.html，轉載請聲明來源鉆瓜專利網。
