读写分离下的数据同步方法和装置.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN113761049A(43)申请公布日2021.12.07(21)申请号202010461501.5(22)申请日2020.05.27(71)申请人北京沃东天骏信息技术有限公司地址100176北京市北京经济技术开发区科创十一街18号院2号楼4层A402室申请人北京京东世纪贸易有限公司(72)发明人张帅(74)专利代理机构中原信达知识产权代理有限责任公司11219代理人张效荣冯培培(51)Int.Cl.G06F16/27(2019.01)G06F16/2455(2019.01)G06F9/54(2006.01)权利要求书2页说明书11页附图4页(54)发明名称读写分离下的数据同步方法和装置(57)摘要本发明公开了一种读写分离下的数据同步方法和装置，涉及计算机技术领域。其中，该方法包括：在接收到第一应用的写请求后，根据所述写请求对主数据库执行写库事务，并在完成所述写库事务后将所述写请求对应的第一业务数据保存至缓存中；在将所述写请求对应的第一业务数据保存至缓存成功以后，通过消息队列向第二应用发送第一通知消息，以使所述第二应用在接收到所述第一通知消息后发出读请求；在接收到第二应用的读请求后，根据所述读请求从所述缓存中读取所述第一业务数据。通过以上步骤，能够缩短数据访问一致的延迟时间，降低在从数据库中读取到脏数据的概率。CN113761049ACN113761049A权利要求书1/2页1.一种读写分离下的数据同步方法，其特征在于，所述方法包括：在接收到第一应用的写请求后，根据所述写请求对主数据库执行写库事务，并在完成所述写库事务后将所述写请求对应的第一业务数据保存至缓存中；在将所述写请求对应的第一业务数据保存至缓存成功以后，通过消息队列向第二应用发送第一通知消息，以使所述第二应用在接收到所述第一通知消息后发出读请求；在接收到第二应用的读请求后，根据所述读请求从所述缓存中读取所述第一业务数据。2.根据权利要求1所述的方法，其特征在于，所述方法还包括：在将所述写请求对应的第一业务数据保存至缓存失败以后，对从数据库进行轮询，以获取从数据库中的数据版本号；在主数据库中的数据版本号与所述从数据库中的数据版本号一致的情况下，通过消息队列向第二应用发送第二通知消息，以使所述第二应用在接收到所述第二通知消息后发出读请求。3.根据权利要求2所述的方法，其特征在于，所述数据版本号为数据插入或更新的时间；所述方法还包括：在所述对从数据库进行轮询，以获取从数据库中的数据版本号的步骤之后，对所述从数据库中的数据版本号和主数据库中的数据版本号的单位进行归一化处理。4.根据权利要求1所述的方法，其特征在于，所述方法还包括：在完成所述写库事务后，将所述缓存中的第二业务数据删除；其中，所述第二业务数据为第二应用对上一次写请求对应的第一业务数据进行处理所得到的数据。5.根据权利要求2所述的方法，其特征在于，所述对从数据库进行轮询，以获取从数据库中的数据版本号的步骤是在轮询任务触发后执行的；所述方法还包括：在将所述写请求对应的第一业务数据保存至缓存失败以后，生成轮询任务，并在预设时间内将所述轮询任务添加至本地阻塞式队列中；在到达所述轮询任务的执行时间时，从所述本地阻塞式队列中获取所述轮询任务并执行。6.根据权利要求5所述的方法，其特征在于，所述方法还包括：在预设时间内未能将所述轮询任务添加至本地阻塞式队列的情况下，将所述轮询任务添加至远程阻塞式队列；在到达所述轮询任务的执行时间时，从所述远程阻塞式队列中获取所述轮询任务并执行。7.一种读写分离下的数据同步装置，其特征在于，所述装置包括：写请求处理模块，用于在接收到第一应用的写请求后，根据所述写请求对主数据库执行写库事务，并在完成所述写库事务后将所述写请求对应的第一业务数据保存至缓存中；通知模块，用于在将所述写请求对应的第一业务数据保存至缓存成功以后，通过消息队列向第二应用发送第一通知消息，以使所述第二应用在接收到所述第一通知消息后发出读请求；读请求处理模块，用于在接收到第二应用的读请求后，根据所述读请求从所述缓存中读取所述第一业务数据。8.根据权利要求7所述的装置，其特征在于，所述装置还包括：担保模块，用于在将所述写请求对应的第一业务数据保存至缓存失败以后，对从数据库进行轮询，以获取从数据库中的数据版本号；还用于在主数据库中的数据版本号与所述2CN113761049A权利要求书2/2页从数据库中的数据版本号一致的情况下，通过消息队列向第二应用发送第二通知消息，以使所述第二应用在接收到所述第二通知消息后发出读请求。9.一种电子设备，其特征在于，包括：一个或多个处理器；存储装置，用于存储一个或多个程序，当所述一个或多个程序被所述一个或多个处理器执行，使