一種消息處理的方法、裝置、電子設(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ù)器的高可用性。?? |
