如何手动终止DataX启动后的异源数据同步任务？

开心一刻 刚刚和老婆吵架，气到不行，想离婚 女儿突然站出来劝解道：难道你们就不能打一顿孩子消消气，非要闹离婚吗？ 我和老婆同时看向女儿，各自挽起了衣袖 女儿补充道：弟弟那么小，打他，他又不会记仇 需求背景 项目基于 DataX 来实现异源之间的数据离线同步，我对 Datax 进行了一些梳理与改造 异构数据源同步之数据同步 → datax 改造，有点意思 异构数据源同步之数据同步 → datax 再改造，开始触及源码 异构数据源同步之数据同步 → DataX 使用细节 异构数据源数据同步 → 从源码分析 DataX 敏感信息的加解密 异源数据同步 → DataX 为什么要支持 kafka？ 异源数据同步 → 如何获取 DataX 已同步数据量？ 本以为离线同步告一段落，不会再有新的需求，可打脸来的非常快，产品经理很快找到我，说了如下一段话 昨天我在测试开发环境试用了一下离线同步功能，很好的实现了我提的需求，给你点赞！ 但是使用过程中我遇到个情况，有张的表的数据量很大，一开始我没关注其数据量，所以配置了全量同步，启动同步后迟迟没有同步完成，我才意识到表的数据量非常大，一查才知道 2 亿多条数据，我想终止同步却发现没有地方可以进行终止操作 所以需要加个功能：同步中的任务可以进行终止操作 这话术算是被产品经理给玩明白了，先对我进行肯定，然后指出使用中的痛点，针对该痛点提出新的功能，让我一点反驳的余地都没有；作为一个讲道理的开发人员，面对一个很合理的需求，我们还是很乐意接受的，你们说是不是？ 需求一接，问题就来了 如何终止同步 思考这个问题之前，我们先来回顾下 DataX 的启动；还记得我们是怎么集成 DataX 的吗，异构数据源同步之数据同步 → datax 再改造，开始触及源码 中有说明，新增 qsl-datax-hook 模块，该模块中通过命令 Process process = Runtime.getRuntime().exec(realCommand); realCommand 就是启动 DataX 的 java 命令，类似 java -server -Xms1g -Xmx1g -XX:+HeapDumpOnOutOfMemoryError -Ddatax.home=/datax -classpath /datax/lib/* com.alibaba.datax.core.Engine -mode standalone -jobid -1 -job job.json 来启动 DataX，也就是给 DataX 单独启动一个 java 进程；那么如何停止 DataX，思路是不是就有了？问题是不是就转换成了 如何终止 java 进程 终止进程 如何终止进程，这个我相信你们都会 Linux：kill -9 pid Win：cmd.exe /c taskkill /PID pid /F /T 但这有个前提，需要知道 DataX 的 java 进程的 pid，而 JDK8 中 Process 的方法如下 是没有提供获取 pid 的方法，在不调整 JDK 版本的情况下，我们如何获取 DataX 进程的 pid？不同的操作系统获取方式不一样，我们分别对 Linux 和 Win 进行实现 Linux 实现就比较简单了，仅仅基于 JDK 就可以实现 Field field = process.getClass().getDeclaredField("pid"); field.setAccessible(true); int pid = field.getInt(process); 通过反射获取 process 实现类的成员变量 pid 的值；这段代码，你们应该都能看懂吧 Win Win 系统下，则需要依赖第三方工具 oshi <dependency> <groupId>com.github.oshi</groupId> <artifactId>oshi-core</artifactId> <version>6.6.5</version> </dependency> 获取 pid 实现如下 Field field = process.getClass().getDeclaredField("handle"); field.setAccessible(true); long handle = field.getLong(process); WinNT.HANDLE winntHandle = new WinNT.HANDLE(); winntHan