Skip to content

Latest commit

 

History

History
27 lines (18 loc) · 622 Bytes

README.md

File metadata and controls

27 lines (18 loc) · 622 Bytes

简易版 从中间表(middle)到自己系统业务库(our),同步 利用单生产者(从 middle 表读数据),多消费者(同步数据到our库)处理 技术栈:

  • LinkedBlockingQueue
  • ThreadPoolExecutor
  • Mybatis
  • HikariCP
  • MySQL

说明: 读数据不会太耗时,所以用单线程,处理数据,则会比较耗时,所以采用多线程

使用方法:

  • 新建 middle 库 导入 middle.sql
  • 新建 our 库导入 our.sql
  • 启动 main

同步状态 10I 第三方系统把数据入库 10D 处理中 10F 处理完成 10E处理失败

只有10I状态的数据才能被同步到 our 库