买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网获悉中冠智云(北京)科技有限公司申请的专利基于逻辑时钟的MongoDB双向数据同步方法及系统获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN120011445B 。

龙图腾网通过国家知识产权局官网在2025-10-24发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202411928339.8，技术领域涉及：G06F16/27；该发明授权基于逻辑时钟的MongoDB双向数据同步方法及系统是由陈明坤;赵靖靖设计研发完成，并于2024-12-25向国家知识产权局提交的专利申请。

本基于逻辑时钟的MongoDB双向数据同步方法及系统在说明书摘要公布了：本发明提供基于逻辑时钟的MongoDB双向数据同步方法及系统，方法包括：变更数据流中接收数据，使相同库表的变更数据都写入到相同分区下；源端内部维护递增id，将id赋值给变更数据；源端定期执行检查点；目标端消费同步过来的数据，按递增id去重；Mongo表新增dc列；通过逻辑时钟探测写冲突，按冲突解决策略处理；选择主节点实例监听变更数据流，获取主节点实例的最新状态。本发明实现了MongoDB的双向数据同步，保证数据同步的一致性，解决双写冲突问题；保证数据同步的可靠性；保证数据同步的实时性；保证高可用性，单一或者少数节点实例故障不会影响数据的正常同步，为业务服务异地双活、高可用建设提供了有力支撑。

本发明授权基于逻辑时钟的MongoDB双向数据同步方法及系统在权利要求书中公布了：1.基于逻辑时钟的MongoDB双向数据同步方法，其特征在于，包括： S1、通过Mongo同步服务mongo-sync-service从mongodb的变更数据流中接收数据，将database.collection作为kafka集群消息的key，通过key对消息进行分区，使得相同库表的变更数据都写入到kafka相同的topic分区下，保证消息的有序传递； S2、源端Mongo同步服务的内部维护一个自动递增id，监听变更数据流时，每监听到一条数据，所述自动递增id就加1，并将自动递增id赋值给变更数据，将所述变更数据发送至kafka；源端Mongo同步服务定期执行checkpoint，将最新的自动递增id和变更数据流的resumeToken发送到kafka的指定的topic分区下；目标端Mongo同步服务消费所述源端Mongo同步服务同步过来的kafka数据，并按照所述自动递增id进行去重；目标端Mongo同步服务完成一批数据的写入后，提交偏移量； S3、Mongo表新增dc列，将所述dc列交由应用端维护；Mongo同步服务通过所述dc列的值判断变更数据是通过客户端写入的，还是外部环境同步过来的； S4、通过逻辑时钟探测写冲突，Mongo表中设置createTime列，使用所述createTime列表示某个消息的写入时间，所述createTime列的列值的趋势递增；通过对比createTime列的列值判断是否可能存在冲突，并按照冲突解决策略进行处理； S5、采用akka集群构建Mongo同步服务，使用akkaclustersingleton从akka集群中选择一个实例作为主节点，所述主节点监听Mongo的变更数据流，并推送到kafka，同时主节点还定期执行checkpoint，将自动递增id、resumeToken以及最新接收时间戳的信息发送至kafka的一个指定的topic中；所述主节点外的其它所有实例都持续地消费该指定的topic，获取主节点实例的最新状态。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人中冠智云(北京)科技有限公司，其通讯地址为：100011 北京市东城区安定门外大街138号15层A座1702-02；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

以上内容由龙图腾AI智能生成。