基于分布式架構(gòu)的數(shù)據(jù)處理方法及裝置

基本信息

申請(qǐng)?zhí)?/td> CN202010525038.6 申請(qǐng)日 -
公開(kāi)(公告)號(hào) CN111786875A 公開(kāi)(公告)日 2020-10-16
申請(qǐng)公布號(hào) CN111786875A 申請(qǐng)公布日 2020-10-16
分類號(hào) H04L12/58(2006.01)I;H04L12/863(2013.01)I 分類 電通信技術(shù);
發(fā)明人 蔣漢華 申請(qǐng)(專利權(quán))人 武漢遂意語(yǔ)聯(lián)網(wǎng)絡(luò)科技有限公司
代理機(jī)構(gòu) 北京路浩知識(shí)產(chǎn)權(quán)代理有限公司 代理人 武漢遂意語(yǔ)聯(lián)網(wǎng)絡(luò)科技有限公司
地址 430000湖北省武漢市東湖新技術(shù)開(kāi)發(fā)區(qū)高新大道999號(hào)未來(lái)科技城B2棟8樓801室
法律狀態(tài) -

摘要

摘要 本發(fā)明實(shí)施例提供一種基于分布式架構(gòu)的數(shù)據(jù)處理方法及裝置,所述方法包括:通過(guò)消息服務(wù)端接收消息生產(chǎn)端發(fā)送的第一消息并獲取第一消息的類型,若第一消息為事件類,消息服務(wù)端在消息生產(chǎn)端成功完成第一消息的業(yè)務(wù)處理后,將第一消息發(fā)送至消息消費(fèi)端,并在消息消費(fèi)端完成第一消息的業(yè)務(wù)處理后,將第一消息遷移至歷史日志庫(kù),以及刪除消息任務(wù)池中的第一消息。本發(fā)明實(shí)施例通過(guò)建立獨(dú)立的消息服務(wù)端來(lái)完成消息的數(shù)據(jù)處理服務(wù),而不需要依賴每個(gè)業(yè)務(wù)服務(wù)系統(tǒng)分別構(gòu)建自身的消息系統(tǒng),從而降低了分布式架構(gòu)中業(yè)務(wù)系統(tǒng)和消息系統(tǒng)之間的耦合性,同時(shí)根據(jù)消息的類型進(jìn)行數(shù)據(jù)處理,保證了分布式架構(gòu)中消息生產(chǎn)端和消息消費(fèi)端數(shù)據(jù)的一致性。??