简易版 从中间表(middle)到自己系统业务库(our),同步 利用单生产者(从 middle 表读数据),多消费者(同步数据到our库)处理 技术栈:
- LinkedBlockingQueue
- ThreadPoolExecutor
- Mybatis
- HikariCP
- MySQL
说明: 读数据不会太耗时,所以用单线程,处理数据,则会比较耗时,所以采用多线程
使用方法:
- 新建 middle 库 导入 middle.sql
- 新建 our 库导入 our.sql
- 启动 main
同步状态 10I 第三方系统把数据入库 10D 处理中 10F 处理完成 10E处理失败
只有10I状态的数据才能被同步到 our 库