流式數(shù)據(jù)處理方法、系統(tǒng)、電子設(shè)備及存儲(chǔ)介質(zhì)

基本信息

申請(qǐng)?zhí)?/td> CN201910017652.9 申請(qǐng)日 -
公開（公告）號(hào) CN109766363A 公開（公告）日 2021-06-11
申請(qǐng)公布號(hào) CN109766363A 申請(qǐng)公布日 2021-06-11
分類號(hào) G06F16/2455 分類 計(jì)算；推算；計(jì)數(shù);
發(fā)明人 韓朝永 申請(qǐng)（專利權(quán)）人 北京江融信科技有限公司
代理機(jī)構(gòu) 北京天盾知識(shí)產(chǎn)權(quán)代理有限公司 代理人 張彩珍
地址 100080 北京市海淀區(qū)蘇州街55號(hào)3層01-A441
法律狀態(tài) -

摘要

摘要 本發(fā)明提供一種流式數(shù)據(jù)處理方法、系統(tǒng)、電子設(shè)備及存儲(chǔ)介質(zhì)，每個(gè)計(jì)算節(jié)點(diǎn)與多個(gè)客戶端節(jié)點(diǎn)連接；每個(gè)數(shù)據(jù)緩存節(jié)點(diǎn)與多個(gè)客戶端節(jié)點(diǎn)連接，每個(gè)數(shù)據(jù)緩存節(jié)點(diǎn)與多個(gè)計(jì)算節(jié)點(diǎn)連接；每個(gè)客戶端節(jié)點(diǎn)與多個(gè)數(shù)據(jù)緩存節(jié)點(diǎn)連接，每個(gè)客戶端節(jié)點(diǎn)與多個(gè)數(shù)據(jù)緩存節(jié)點(diǎn)連接；當(dāng)一個(gè)數(shù)據(jù)緩存節(jié)點(diǎn)或計(jì)算節(jié)點(diǎn)或客戶端節(jié)點(diǎn)宕機(jī)后，正常的計(jì)算節(jié)點(diǎn)和/或數(shù)據(jù)緩存節(jié)點(diǎn)和/或客戶端節(jié)點(diǎn)在檢測(cè)n次后未收到宕機(jī)的數(shù)據(jù)緩存節(jié)點(diǎn)的回饋，則將該宕機(jī)的數(shù)據(jù)緩存節(jié)點(diǎn)或計(jì)算節(jié)點(diǎn)或客戶端節(jié)點(diǎn)宕機(jī)踢出集群。通過上述計(jì)算節(jié)點(diǎn)、數(shù)據(jù)緩存節(jié)點(diǎn)和客戶端節(jié)點(diǎn)的去中心化的連接方式，不存在單點(diǎn)故障，保證了該數(shù)據(jù)處理系統(tǒng)系統(tǒng)的高可用性。