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

龙图腾网获悉北京流金岁月科技有限公司申请的专利一种基于消息队列及同步处理的数据库处理方法及系统获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN119474221B 。

龙图腾网通过国家知识产权局官网在2025-07-25发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202510057113.3，技术领域涉及：G06F16/27；该发明授权一种基于消息队列及同步处理的数据库处理方法及系统是由孟庆国;王俭;刘诗源设计研发完成，并于2025-01-14向国家知识产权局提交的专利申请。

本一种基于消息队列及同步处理的数据库处理方法及系统在说明书摘要公布了：本发明涉及数据处理技术领域，公开了一种基于消息队列及同步处理的数据库处理方法及系统，该方法包括：当数据库主库发生数据变动时，调用ActiveMQ的API插入数据变动信息；采集数据变动信息确定消息队列时长，采集所有数据变动信息构建为消息数据链；获得每一数据变动信息的重要性数据将消息数据链拆分并组合为新消息数据链；提取优先处理数据链中每一数据变动消息的特征向量确定处理时长，根据处理时长获得最终消息数据链；将最终消息数据链添加到Redis的List数据结构中，按最终消息数据链顺序获得分布式锁进行消息处理。本申请实现了根据业务需求动态调整消息处理策略，提高了数据同步的效率和准确性，确保高并发环境下能够实现数据同步。

本发明授权一种基于消息队列及同步处理的数据库处理方法及系统在权利要求书中公布了：1.一种基于消息队列及同步处理的数据库处理方法，其特征在于，包括： 采集数据库主库的数据信息，当所述数据库主库发生数据变动时，调用ActiveMQ的API插入数据变动信息； 采集所述数据变动信息并根据所述变动信息确定消息队列时长，采集所述消息队列时长内所有数据变动信息，构建消息数据链； 采用神经网络模型对所述消息数据链中每一数据变动信息进行分析，获得每一所述数据变动信息的重要性数据，根据所述重要性数据将所述消息数据链拆分并组合为新消息数据链，所述新消息数据链包括优先处理数据链和非优先处理数据链； 提取所述优先处理数据链中每一数据变动消息的特征向量，根据所述特征向量确定每一所述数据变动消息的处理时长，根据所述处理时长对所述优先处理数据链进行排序，获得最终消息数据链； 将所述最终消息数据链添加到Redis的List数据结构中，按所述最终消息数据链顺序获得分布式锁进行消息处理； 根据所述处理时长对所述优先处理数据链进行排序，获得最终消息数据链时，还包括： 确定所述优先处理数据链中每一数据变动信息的处理时长； 当判定所述优先处理数据链中不存在同类变动数据时，根据所述处理时长由高到低对所述优先处理数据链进行排序，获得最终消息数据链； 当判定所述优先处理数据链中存在同类变动数据时，根据同类变动数据中每一数据变动信息的处理时长获得每一同类变动数据的处理总时长，根据所述处理总时长由高到低，且所述同类变动数据中处理时长由高到低对所述优先处理数据链进行排序，获得最终消息数据链； 确定所述优先处理数据链中每一数据变动信息的处理时长时，包括： 将所述特征向量与历史数据集进行比对，根据比对结果确定每一所述数据变动信息的处理时长； 当所述历史数据集中存在与所述特征向量的相似度大于相似度阈值的数据时，以最大相似度对应的历史数据的历史处理时长作为所述数据变动信息的处理时长； 当所述历史数据集中不存在与所述特征向量的相似度大于相似度阈值的数据时，选取所述历史数据集中与所述特征向量的相似度大于a%且小于相似度阈值的数据建立类比集合，根据所述类比集合确定所述数据变动信息的处理时长； 根据所述类比集合确定所述数据变动信息的处理时长时，包括： 确定所述类比集合中历史处理时长的中位数； 将所有所述历史处理时长中大于所述中位数的历史处理时长进行提取，构建第一数据集； 将所有所述历史处理时长中小于所述中位数的历史处理时长进行提取，构建第二数据集； 根据所述第一数据集和第二数据集确定所述数据变动信息的处理时长； 其中，T表示数据变动信息的处理时长，N表示第一数据集中历史处理时长的数量，Ti表示第一数据集中第i历史处理时长，T0表示类比集合中历史处理时长的中位数，M表示第二数据集中历史处理时长的数量，Tj表示第二数据集中第j历史处理时长。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人北京流金岁月科技有限公司，其通讯地址为：100041 北京市石景山区和平西路60号院1号楼B座1801；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。