分布式数据服务的处理方法、系统、设备及存储介质
摘要文本
本发明公开了一种分布式数据服务的处理方法、系统、设备及存储介质，其中处理方法包括应用服务模块从接收到的写服务请求中获取业务数据，并在业务数据中增加同步状态字段和全局ID后作为目标业务数据，分别存入分布式缓存、本地存储器和消息队列；异步服务模块通过监听消息队列，并从异步消息获取目标业务数据后入库，及成功入库后更新目标业务数据的同步状态字段，并将更新后的目标业务数据更新到分布式缓存；工作进程模块定时轮询本地存储器的数据，并根据全局ID获取分布式缓存中对应数据以及判断同步状态字段是否已更新，若是则删除本地数据，若否则向消息队列重发。本发明能有效地保证每次的写数据服务请求都能无遗漏地得到响应。 详见官网：www.macrodatas.cn
申请人信息
- 申请人:北京京东尚科信息技术有限公司; 北京京东世纪贸易有限公司
- 申请人地址:100195 北京市海淀区杏石口路65号西杉创意园四区11号楼东段1-4层西段1-4层
- 发明人: 北京京东尚科信息技术有限公司; 北京京东世纪贸易有限公司
专利详细信息
| 项目 | 内容 |
|---|---|
| 专利名称 | 分布式数据服务的处理方法、系统、设备及存储介质 |
| 专利类型 | 发明授权 |
| 申请号 | CN201810542086.9 |
| 申请日 | 2018年5月30日 |
| 公告号 | CN110633320B |
| 公开日 | 2024年1月12日 |
| IPC主分类号 | G06F16/27 |
| 权利人 | 北京京东尚科信息技术有限公司; 北京京东世纪贸易有限公司 |
| 发明人 | 王巍; 王飞 |
| 地址 | 北京市海淀区杏石口路65号西杉创意园四区11号楼东段1-4层西段1-4层; 北京市大兴区北京经济技术开发区科创十一街18号C座2层201室 |
专利主权项内容
1.一种分布式数据服务的处理方法，其特征在于，包括：应用服务模块接收客户端发起的写数据服务请求，并从所述写数据服务请求中获取业务数据；所述应用服务模块在所述业务数据中增加同步状态字段，并初始化所述同步状态字段；所述应用服务模块生成所述业务数据的全局ID，并将所述全局ID增加到所述业务数据中；所述应用服务模块将已加入所述同步状态字段和所述全局ID的所述业务数据作为目标业务数据分别异步存入分布式缓存和本地存储器，以及将所述目标业务数据作为异步消息向消息队列发送；异步服务模块监听所述消息队列，并在监听到异步消息后，从所述异步消息中获取出所述目标业务数据，将所述目标业务数据异步写入关系型数据库中，并在写入完成后将所述目标业务数据中的同步状态字段的内容进行更新，及将已更新所述同步状态字段的所述目标业务数据更新到所述分布式缓存中，所述异步服务模块具有幂等性；工作进程模块定时读取所述本地存储器中的目标业务数据，根据读取到的所述目标业务数据的全局ID读取所述分布式缓存中的缓存数据，判断所读取到的所述缓存数据的同步状态字段是否已更新，若是则删除所述本地存储器中的所述目标业务数据，若否则将所述本地存储器中的所述目标业务数据作为异步消息向所述消息队列发送。。微信公众号马克数据网