一种基于消息队列及同步处理的数据库处理方法及系统

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