数据同步方法、装置和系统.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN112765277A(43)申请公布日2021.05.07(21)申请号202110115796.5(22)申请日2021.01.28(71)申请人树根互联股份有限公司地址510000广东省广州市海珠区琶洲大道东路3号303-309房(72)发明人邹磊赵静潘永高(74)专利代理机构北京超凡宏宇专利代理事务所(特殊普通合伙)11463代理人李莎(51)Int.Cl.G06F16/27(2019.01)G06F16/23(2019.01)G06Q10/08(2012.01)权利要求书2页说明书8页附图3页(54)发明名称数据同步方法、装置和系统(57)摘要本发明的实施例提供了一种数据同步方法、装置和系统，涉及数据处理技术领域。通过数据同步单元实时监听数据库中的库存数据，在监听到库存数据存在变化量时，读取库存数据的变化量，根据库存数据的变化量，计算得到当前库存量，将当前库存量同步到每个数据查询单元，如此，实现了库存数据的同步，并且保证了数据同步的实时性，可以有效避免超卖、超买的问题。CN112765277ACN112765277A权利要求书1/2页1.一种数据同步方法，其特征在于，应用于数据同步系统，所述数据同步系统包括数据同步单元、数据库以及至少一个数据查询单元；所述方法包括：所述数据同步单元实时监听所述数据库中的库存数据，在监听到所述库存数据存在变化量时，读取所述库存数据的变化量；所述数据同步单元根据所述库存数据的变化量，计算得到当前库存量，将所述当前库存量同步到每个所述数据查询单元。2.根据权利要求1所述的数据同步方法，其特征在于，所述数据同步系统还包括分布式队列服务单元，所述将所述当前库存量同步到每个所述数据查询单元的步骤包括：所述数据同步单元将所述当前库存量写入到所述分布式队列服务单元；所述分布式队列服务单元通过发布订阅机制，将所述当前库存量推送到各所述数据查询单元。3.根据权利要求1所述的数据同步方法，其特征在于，所述数据同步系统还包括数据写入单元，所述方法还包括：所述数据写入单元获取用户端发起的订单请求；根据所述订单请求，得到所述订单请求对应的库存数据的变化量；将所述订单请求对应的库存数据的变化量写入到所述数据库。4.根据权利要求3所述的数据同步方法，其特征在于，在将所述订单请求对应的库存数据的变化量写入到所述数据库之前，所述方法还包括：所述数据写入单元分析所述订单请求是否为合法请求以及所述订单请求对应的库存数据的变化量是否满足库存需求；若所述订单请求为合法请求且所述订单请求对应的库存数据的变化量满足库存需求，将所述订单请求对应的库存数据的变化量写入到所述数据库。5.根据权利要求1所述的数据同步方法，其特征在于，在将所述当前库存量同步到每个所述数据查询单元后，所述方法还包括：各所述数据查询单元根据所述当前库存量，更新本地存储的库存数据。6.根据权利要求5所述的数据同步方法，其特征在于，所述方法还包括：所述数据查询单元接收用户端发送的数据查询请求；根据所述数据查询请求，将更新后的库存数据发送到所述用户端。7.一种数据同步方法，其特征在于，应用于数据同步单元，所述方法包括：实时监听数据库中的库存数据，在监听到所述库存数据存在变化量时，读取所述库存数据的变化量；根据所述库存数据的变化量，计算得到当前库存量，将所述当前库存量同步到每个数据查询单元。8.一种数据同步装置，其特征在于，应用于数据同步单元，所述装置包括数据监听模块、数据读取模块以及数据同步模块；所述数据监听模块用于实时监听数据库中的库存数据，在监听到所述库存数据存在变化量时，所述数据读取模块用于读取所述库存数据的变化量；所述数据同步模块用于根据所述库存数据的变化量，计算得到当前库存量，将所述当前库存量同步到每个数据查询单元。2CN112765277A权利要求书2/2页9.一种数据同步系统，其特征在于，包括数据同步单元、数据库以及至少一个数据查询单元；所述数据同步单元用于实时监听所述数据库中的库存数据，在监听到所述库存数据存在变化量时，读取所述库存数据的变化量；所述数据同步单元用于根据所述库存数据的变化量，计算得到当前库存量，将所述当前库存量同步到每个所述数据查询单元。10.根据权利要求9所述的数据同步系统，其特征在于，所述数据同步系统还包括分布式队列服务单元；所述数据同步单元用于将所述当前库存量写入到分布式队列服务单元；所述分布式队列服务单元用于通过发布订阅机制，将所述当前库存量推送到各所述数据查询单元。3CN112765277A说明书1/8页数据同步方法、装置和系统技术领域[0001]本发明涉及数据技术领域，具体而言，涉及一种数据同步方法、装置和系统。背景技术[0002]近年来，随着互联