(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211065959.4 (22)申请日 2022.08.31 (71)申请人 北京字跳网络技 术有限公司 地址 100190 北京市海淀区紫金 数码园4号 楼2层0207 (72)发明人 李飞　刘发宾　刘朝勇　朱承才　 (74)专利代理 机构 北京风雅颂专利代理有限公 司 11403 专利代理师 王刚 (51)Int.Cl. G06F 16/27(2019.01) G06F 9/54(2006.01) (54)发明名称 消息处理方法、 装置、 电子设备及存 储介质 (57)摘要 本申请提供一种消息处理方法、 装置、 电子 设备及存储介质， 利用基于回调函数构建的同步 插件完成了同步消息的生 成， 避免了对数据库原 有代码的修改， 减少了同步消息生成过程中代码 的修改量； 通过同步插件或同步组件生成同步消 息， 解决了由于单一同步消息生成数据链的工作 异常， 带来的同步消息断流问题， 从而提高了同 步消息生 成的稳定性； 根据口令对同步消息进行 处理， 通过口令中同步消息的处理状态对重复的 同步消息进行标记， 实现了重复同步消息的辨 别， 进而保证了同步消息 重复时服 务的幂等 性。 权利要求书2页 说明书12页 附图5页 CN 115422294 A 2022.12.02 CN 115422294 A 1.一种消息处 理方法， 其特 征在于， 包括： 获取数据库的数据操作集； 根据所述数据操作集构建回调函数， 所述回调函数用于生成同步插件输出的同步消 息； 将所述回调函数的响应数据作为所述同步消息 。 2.根据权利要求1所述的处理方法， 其特征在于， 所述根据 所述数据操作集构建回调函 数， 包括： 获取所述数据操作集中每 个数据操作对应的回调容器， 得到回调容器集； 选择所述回调容器集中的至少一个回调容器作为初始回调函数； 根据所述数据操作集设置所述初始回调函数的注入时机； 将所述初始回调函数注 册为所述回调函数。 3.一种消息处 理方法， 其特 征在于， 所述方法包括： 同步获取 数据库的变更 数据； 利用同步插 件和/或同步组件根据所述变更 数据生成同步消息； 将所述同步消息发送到同步消息队列以供消息使用方处 理。 4.根据权利要求3所述的处理方法， 其特征在于， 在所述利用同步插件和/或同步组件 根据所述变更 数据生成同步消息之前， 包括： 通过所述同步插 件向所述同步组件发送获取请求； 利用所述同步组件根据 所述获取请求获取所述同步组件的工作状态， 并发送所述工作 状态到所述同步插件， 以供所述同步插件根据所述工作状态确定利用所述同步插件或所述 同步组件根据所述变更数据生成所述同步消息， 其中， 所述工作状态包括正常状态和异常 状态。 5.根据权利要求4所述的处理方法， 其特征在于， 所述通过所述同步插件向所述同步组 件发送获取请求， 包括： 通过所述同步插件以预先设置的第一时间间隔为周期向所述同步组件发送所述获取 请求。 6.根据权利要求4所述的处理方法， 其特征在于， 所述利用同步插件和/或同步组件根 据所述变更 数据生成同步消息， 包括： 响应于确定所述工作状态为正常状态， 利用所述同步组件根据 所述变更数据生成同步 消息； 响应于确定所述工作状态为异常状态， 利用所述同步插件根据 所述变更数据生成同步 消息。 7.根据权利要求6所述的处理方法， 其特征在于， 所述利用所述同步插件根据 所述变更 数据生成同步消息， 包括： 将所述同步插 件中的回调函数按照数据操作进行分类， 得到分类结果； 根据所述变更 数据对应的数据操作从所述分类结果中选择至少一个回调函数； 根据所述选择的回调函数对应的注入时机顺序获取 所述回调函数的响应数据； 将所述响应数据合并作为所述同步消息 。 8.根据权利要求6所述的处理方法， 其特征在于， 在利用同步插件根据 所述变更数据生权　利　要　求　书 1/2 页 2 CN 115422294 A 2成同步消息之后， 还 包括： 响应于确定所述工作状态从所述异常状态转换为所述正常状态， 利用所述同步插件和 所述同步组件根据所述同步消息生成口令， 并将所述口令发送到消息队列以供所述消息使 用方判断所述同步消息的处 理状态。 9.根据权利要求8所述的处理方法， 其特征在于， 所述将所述同步消息发送到同步消息 队列以供消息使用方处 理之后， 所述方法还 包括： 利用所述消息使用方接收所述同步消息和所述同步消息对应的 口令； 采用所述消息使用方根据所述口令对所述同步消息进行处 理。 10.根据权利要求9所述的处理方法， 所述采用所述消息使用方根据 所述口令对所述同 步消息进行处 理， 包括： 采用所述消息使用方根据所述口令的口令状态判断所述同步消息的处理状态， 得到处 理结果； 采用所述消息使用方根据所述处 理结果对所述同步消息进行处 理。 11.根据权利要求10所述的处理方法， 其特征在于， 所述采用所述消息使用方根据 所述 处理结果对所述同步消息进行处 理， 包括： 响应于确定所述处理结果为未处理， 采用所述消息使用方根据 所述同步消息进行业务 处理， 将所述同步消息对应的口令状态设置为已处理， 并将所述口令状态存储到口令数据 库中， 其中， 所述口令数据库中的数据根据预 先设置的第二时间 间隔定时同步到数据库中； 响应于确定所述处 理结果为已处理， 采用所述消息使用方放弃处 理所述同步消息 。 12.一种消息处 理装置， 其特 征在于， 包括： 获取模块， 被 配置为获取 数据库的数据操作集； 构建模块， 被配置为根据所述数据操作集构建回调函数， 所述回调函数用于生成同步 插件输出的同步消息； 消息模块， 被 配置为将所述回调函数的响应数据作为所述同步消息 。 13.一种消息处 理装置， 其特 征在于， 包括： 同步模块， 被 配置为同步获取 数据库的变更 数据； 生成模块， 被 配置为利用同步插 件和/或同步组件根据所述变更 数据生成同步消息； 发送模块， 被 配置为将所述同步消息发送到同步消息队列以供消息使用方处 理。 14.一种电子设备， 其特征在于， 包括存储器、 处理器及存储在所述存储器上并可由所 述处理器执行的计算机程序， 所述处理器执行所述计算机程序时实现如权利要求1至11任 意一项所述的方法。 15.一种非暂态计算机可读存储介质， 其特征在于， 所述非暂态计算机可读存储介质存 储计算机指令， 所述计算机指令用于使计算机执 行权利要求1至1 1任一所述方法。权　利　要　求　书 2/2 页 3 CN 115422294 A 3