基于kafka與哈希共享內(nèi)存的分布式數(shù)據(jù)中心

基本信息

申請(qǐng)?zhí)?/td> CN202110705320.7 申請(qǐng)日 -
公開(kāi)（公告）號(hào) CN113407631A 公開(kāi)（公告）日 2021-09-17
申請(qǐng)公布號(hào) CN113407631A 申請(qǐng)公布日 2021-09-17
分類號(hào) G06F16/27（2019.01）I;G06F9/50（2006.01）I;G06F16/2453（2019.01）I 分類 計(jì)算；推算；計(jì)數(shù);
發(fā)明人 凌遠(yuǎn)澤;陳賢平 申請(qǐng)（專利權(quán)）人 深圳智多豚物聯(lián)技術(shù)有限公司
代理機(jī)構(gòu) 深圳市中科創(chuàng)為專利代理有限公司 代理人 彭西洋;譚雪婷
地址 518000廣東省深圳市南山區(qū)桃源街道平山社區(qū)平山一路2號(hào)南山云谷創(chuàng)業(yè)園二期9棟1層B02
法律狀態(tài) -

摘要

摘要 本發(fā)明公開(kāi)一種基于kafka與哈希共享內(nèi)存的分布式數(shù)據(jù)中心，包括：中心數(shù)據(jù)庫(kù)，其建立數(shù)據(jù)更新表并將增加/修改的數(shù)據(jù)寫(xiě)入數(shù)據(jù)更新表中；新增數(shù)據(jù)讀取服務(wù)端，其讀取數(shù)據(jù)更新表的新增數(shù)據(jù)并推送給kafka；根數(shù)據(jù)中心服務(wù)端，其在共享內(nèi)存無(wú)數(shù)據(jù)時(shí)讀取全量數(shù)據(jù)后再消費(fèi)kafka中新增的數(shù)據(jù)，其在共享內(nèi)存有數(shù)據(jù)時(shí)直接消費(fèi)kafka中新增的數(shù)據(jù)，讀取的數(shù)據(jù)寫(xiě)入共享內(nèi)存；若干頁(yè)節(jié)點(diǎn)數(shù)據(jù)中心服務(wù)端，其在共享內(nèi)存無(wú)數(shù)據(jù)時(shí)同步全量數(shù)據(jù)到自身節(jié)點(diǎn)再消費(fèi)kafka中新增的數(shù)據(jù)，其在共享內(nèi)存有數(shù)據(jù)時(shí)直接消費(fèi)kafka中新增的數(shù)據(jù)，數(shù)據(jù)存儲(chǔ)到共享內(nèi)存。本發(fā)明實(shí)現(xiàn)分布式查詢，查詢及檢驗(yàn)速率快，滿足本地業(yè)務(wù)對(duì)查詢校驗(yàn)的快速需求。