基于ActiveMQ的大批量数据同步方法
基本信息
申请号 | CN201711202922.0 | 申请日 | - |
公开(公告)号 | CN107911462A | 公开(公告)日 | 2018-04-13 |
申请公布号 | CN107911462A | 申请公布日 | 2018-04-13 |
分类号 | H04L29/08 | 分类 | 电通信技术; |
发明人 | 季超;赵文军;刘本中;吴迎春;胡明慧;宋炜伟 | 申请(专利权)人 | 南京联创信息科技有限公司 |
代理机构 | 南京钟山专利代理有限公司 | 代理人 | 南京信通科技有限责任公司;南京联创信息科技有限公司 |
地址 | 210036 江苏省南京市鼓楼区集慧路18号联创科技大厦16层 | ||
法律状态 | - |
摘要
摘要 | 本发明公开了一种基于ActiveMQ的大批量数据同步方法,包含以下步骤:通过NetworkConnector配置ActiveMQ服务端与服务端之间的通信,把大量的消息生产者和消息的消费者客户端以及被NetworkConnector连接的多个互相透传消息的服务器整合;生产者客户端读取本地数据,发送给本地MQ服务器S1,本地MQ消息服务器通过NetworkConnector透传消息至消费平台MQ服务器SP1,将队列数据通过配置策略交由各自连接的消费者处理,完成数据同步;同步过程中,如果出现数据错误或者同步失败的情况,将错误消息通过双向MQ服务器发回省侧,省侧监听错误或失败数据进行再次发送或者数据修复。本发明解决了多个消息供应商高并发调用为服务同步数据时对为服务造成过大压力,影响其他微服务的正常运转的问题。 |
