基于分布式架構(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ù)的一致性。?? |
