← 返回列表
一种多线程数据实时同步方法、设备及介质
摘要文本
本申请公开了一种多线程数据实时同步方法、设备及介质,方法包括:通过生产者确定业务信息对应的消息数据,发送到数据同步服务组件,获得对应的生产者消息流水数据,并发布消息定时发送线程的监听事件,通过信号量控制线程数量方式唤醒消息定时发送线程,将消息数据发送到对应消息同步主题的消息队列中,确定消费者订阅主题,拉取消息队列中的消息数据,对消息数据进行消费,并保存消费者消息流水数据。实现多线程数据实时同步,并实现在单个实例执行相关操作,防止出现并发问题而导致的数据不一致,从而保证数据同步的正确性,并且添加消息定时发送线程,对未发送的消息进行补偿发送,以确保数据操作的原子性以及顺序一致性。
申请人信息
- 申请人:浪潮智慧科技有限公司; 浪潮(山东)农业互联网有限公司
- 申请人地址:250101 山东省济南市自由贸易试验区济南片区浪潮路1036号S01楼
- 发明人: 浪潮智慧科技有限公司; 浪潮(山东)农业互联网有限公司
专利详细信息
| 项目 | 内容 |
|---|---|
| 专利名称 | 一种多线程数据实时同步方法、设备及介质 |
| 专利类型 | 发明申请 |
| 申请号 | CN202311257941.9 |
| 申请日 | 2023/9/26 |
| 公告号 | CN117370457A |
| 公开日 | 2024/1/9 |
| IPC主分类号 | G06F16/27 |
| 权利人 | 浪潮智慧科技有限公司; 浪潮(山东)农业互联网有限公司 |
| 发明人 | 王涛 |
| 地址 | 山东省济南市自由贸易试验区济南片区浪潮路1036号S01楼; 山东省济南市高新区浪潮路1036号S01楼25层 |
专利主权项内容
1.一种多线程数据实时同步方法,其特征在于,包括:通过生产者确定业务信息对应的消息数据,将所述消息数据发送到数据同步服务组件;通过所述数据同步服务组件获得所述消息数据对应的生产者消息流水数据,并发布消息定时发送线程的监听事件;启动消息定时发送线程的监听器,通过信号量控制线程数量方式唤醒消息定时发送线程,以定时拉取所述生产者消息流水数据;遍历所述生产者消息流水数据,基于不同的数据类型,将所述消息数据从所述数据同步组件发送到对应消息同步主题的消息队列中,并基于所述消息同步主题更新所述生产者消息流水数据;确定消费者订阅所述消息同步主题,通过所述消费者拉取所述消息同步主题的消息队列中的消息数据,根据所述生产者消息流水数据中的消息发送顺序,对所述消息数据进行消费,并保存消费者消息流水数据。