基于插件兼容的通信方法、装置、设备及存储介质.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN114265638A(43)申请公布日2022.04.01(21)申请号202111601989.8(22)申请日2021.12.24(71)申请人北京天融信网络安全技术有限公司地址100085北京市海淀区上地东路1号院3号楼四层申请人北京天融信科技有限公司北京天融信软件有限公司(72)发明人徐飞飞(74)专利代理机构北京超凡宏宇专利代理事务所(特殊普通合伙)11463代理人杨奇松(51)Int.Cl.G06F9/445(2018.01)G06F9/54(2006.01)权利要求书2页说明书7页附图2页(54)发明名称基于插件兼容的通信方法、装置、设备及存储介质(57)摘要本申请提供一种基于插件兼容的通信方法、装置、设备及存储介质，其中，基于插件兼容的通信方法包括:当检测到上层应用程序需与下层通信模块进行数据交互时，获取所述用于实现上层应用程序与下层通信模块通信的通信插件的类型标识；根据所述通信插件的类型标识创建插件实例；调用所述插件实例的通信函数，与所述下层通信模块的kafka消息队列进行通信。本申请能够在兼容不同版本的插件的前提下，实现上层应用程序与kafka消息队通信，并使上下层应用不感知所引用的插件类型，摒弃了系统运行环境不同对版本的要求不同，最大限度的保证了历史项目、与当前开发项目的版本一致性，不至于同时维护多个版本，降低版本维护的复杂性。CN114265638ACN114265638A权利要求书1/2页1.一种基于插件兼容的通信方法，其特征在于，所述方法还包括：当检测到上层应用程序需与下层通信模块进行数据交互时，获取所述用于实现上层应用程序与下层通信模块通信的通信插件的类型标识；根据所述通信插件的类型标识创建插件实例；调用所述插件实例的通信函数，与所述下层通信模块的kafka消息队列进行通信。2.如权利要求1所述的方法，其特征在于，所述插件实例的通信函数包括消息发送函数和消息接收函数；以及，所述调用所述插件实例的通信函数，与所述下层通信模块的kafka消息队列进行通信，包括：基于所述消息发送函数向所述kafka消息队发送消息；基于所述消息接收函数接收所述kafka消息队发送的消息。3.如权利要求2所述的方法，其特征在于，在所述基于所述消息接收函数接收所述kafka消息队发送的消息之后，所述方法还包括：对所述kafka消息队发送的消息进行数据序列化处理，以使得所述kafka消息队发送的消息的数据格式匹配所述上层应用程序的数据格式。4.如权利要求3所述的方法，其特征在于，所述对所述kafka消息队发送的消息进行数据序列化处理，包括：根据通信插件的类型标识确定数据序列化处理模块；调用所述数据序列化处理模块对所述kafka消息队发送的消息进行数据序列化处理。5.如权利要求4所述的方法，其特征在于，所述kafka消息队发送的消息包括消息内容、消息主题、消息分片、消息偏移量和消息时间戳；以及，所述调用所述数据序列化处理模块对所述kafka消息队发送的消息进行数据序列化处理，包括：调用所述数据序列化处理模块对所述消息内容、所述消息主题、所述消息分片、所述消息偏移量和所述消息时间戳进行数据序列化处理。6.如权利要求1所述的方法，其特征在于，所述插件的类型标识为pykafka、confluent_kafka中的一种。7.一种基于插件兼容的通信装置，其特征在于，所述装置包括：获取模块，用于当检测到上层应用程序需与下层通信模块进行数据交互时，获取所述用于实现上层应用程序与下层通信模块通信的通信插件的类型标识；实例创建模块，用于根据所述通信插件的类型标识创建插件实例；通信模块，用于调用所述插件实例的通信函数，与所述下层通信模块的kafka消息队列进行通信。8.如权利要求7所述的装置，其特征在于，所述插件实例的通信函数包括消息发送函数和消息接收函数；以及，所述通信模块包括：发送子模块，用于基于所述消息发送函数向所述kafka消息队发送消息；接收子模块，用于基于所述消息接收函数接收所述kafka消息队发送的消息。9.一种基于插件兼容的通信设备，其特征在于，所述设备包括：2CN114265638A权利要求书2/2页存储有可执行程序代码的存储器；与所述存储器耦合的处理器；所述处理器调用所述存储器中存储的所述可执行程序代码，执行如权利要求1‑6任一项所述的基于插件兼容的通信方法。10.一种存储介质，其特征在于，所述存储介质存储有计算机指令，所述计算机指令被调用时，用于执行如权利要求1‑6任一项所述的基于插件兼容的通信方法。3CN114265638A说明书1/7页基于插件兼容的通信方法、装置、设备及存储介质技术领域[0001]本申请涉及计算机技术领域，具体而言，涉及一种基于