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

基本信息

申請?zhí)?/td> CN202110059422.6 申請日 -
公開(公告)號 CN112380040A 公開(公告)日 2021-02-19
申請公布號 CN112380040A 申請公布日 2021-02-19
分類號 G06F9/54(2006.01)I;G06F9/50(2006.01)I 分類 計(jì)算;推算;計(jì)數(shù);
發(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的接口,接收多個(gè)待處理的消息;其中,每個(gè)所述待處理的消息攜帶標(biāo)簽;所述接口Dockers將多個(gè)所述消息分配至多個(gè)不同的接口服務(wù)器;每個(gè)所述接口服務(wù)器將所述消息轉(zhuǎn)換成kafka消息;每個(gè)所述接口服務(wù)器根據(jù)所述消息的標(biāo)簽,將所述kafka消息發(fā)送至與所述標(biāo)簽對應(yīng)的所述功能Dockers;所述功能Dockers的接口接收所述多個(gè)不同的接口服務(wù)器各自發(fā)送的所述kafka消息,并根據(jù)所述kafka消息執(zhí)行相應(yīng)的操作。采用本發(fā)明的技術(shù)方案可以在提高服務(wù)器架構(gòu)的接口性能的同時(shí),實(shí)現(xiàn)接口服務(wù)器的高可用性。??