一種消息處理的方法、裝置、電子設(shè)備及存儲介質(zhì)

基本信息

申請?zhí)?/td> CN202110059422.6 申請日 -
公開(公告)號 CN112380040B 公開(公告)日 2021-05-07
申請公布號 CN112380040B 申請公布日 2021-05-07
分類號 G06F9/54(2006.01)I;G06F9/50(2006.01)I 分類 -
發(fā)明人 李磊 申請(專利權(quán))人 北京美攝網(wǎng)絡(luò)科技有限公司
代理機(jī)構(gòu) 北京潤澤恒知識產(chǎn)權(quán)代理有限公司 代理人 莎日娜
地址 100195北京市海淀區(qū)西四環(huán)北路131號院1號樓5層501號
法律狀態(tài) -

摘要

摘要 本發(fā)明公開了一種消息處理的方法、裝置、電子設(shè)備及存儲介質(zhì)。所述方法包括:基于go語言,分別編譯接口Dockers的接口和功能Dockers的接口;所述接口Dockers通過所述接口Dockers的接口,接收多個待處理的消息;其中,每個所述待處理的消息攜帶標(biāo)簽;所述接口Dockers將多個所述消息分配至多個不同的接口服務(wù)器;每個所述接口服務(wù)器將所述消息轉(zhuǎn)換成kafka消息;每個所述接口服務(wù)器根據(jù)所述消息的標(biāo)簽,將所述kafka消息發(fā)送至與所述標(biāo)簽對應(yīng)的所述功能Dockers;所述功能Dockers的接口接收所述多個不同的接口服務(wù)器各自發(fā)送的所述kafka消息,并根據(jù)所述kafka消息執(zhí)行相應(yīng)的操作。采用本發(fā)明的技術(shù)方案可以在提高服務(wù)器架構(gòu)的接口性能的同時(shí),實(shí)現(xiàn)接口服務(wù)器的高可用性。??