黑羽的个人博客
·
关于定时任务和一些其他异步任务的随想
💡
原文中文，约3000字，阅读约需8分钟。
📝
内容提要
随着定时任务和新需求的增加，部署时可能会中断正在运行的任务，影响业务。为避免此问题，需要设计一个支持中断和恢复的框架，确保任务上下文的保存和幂等性。可以利用RxJava实现异步流式执行，简化复杂逻辑，同时保证数据的一致性和可靠性。
🎯
关键要点
-
随着定时任务和新需求的增加，部署时可能会中断正在运行的任务，影响业务。
-
需要设计一个支持中断和恢复的框架，确保任务上下文的保存和幂等性。
-
使用页面监控当前正在运行的任务，避免在任务执行时进行部署。
-
长时间运行的任务可能会被中断，导致业务问题，如用户扣款失败。
-
代码需要经过幂等性设计，避免重复执行。
-
建议定义接口强制实现中断和恢复逻辑，确保代码的健壮性。
-
Java的`InterruptedException`需要处理，以便在中断时及时退出。
-
可以使用Kotlin的协程实现中断和恢复，但需要修改字节码。
-
RxJava可以实现异步流式执行，简化复杂逻辑，保证数据一致性和可靠性。
-
通过响应式流的方式传递运行数据，可以在任务中断时保存执行信息。
-
数据库操作应使用事务来保证多次执行的可靠性。
-
计划单独写一个库封装支持中断的操作，适用于特定任务场景。
❓
延伸问答
如何避免定时任务在部署时被中断？
可以通过页面监控当前正在运行的任务，确保在任务执行时不进行部署。
什么是任务的幂等性设计？
幂等性设计确保同一任务多次执行时不会产生不同的结果，避免重复执行导致的业务问题。
RxJava如何帮助实现异步流式执行？
RxJava通过响应式编程模型，允许代码以消费者的形式异步流式执行，简化复杂逻辑并保证数据一致性。
如何设计支持中断和恢复的任务框架？
可以定义一个接口，强制实现中断和恢复逻辑，并保存任务上下文以便后续恢复执行。
长时间运行的任务被中断会有什么影响？
长时间运行的任务被中断可能导致业务问题，如用户扣款失败和订单违约。
如何处理Java中的InterruptedException？
在Java中，必须捕获InterruptedException，以便在任务被中断时及时退出并清理环境。
➡️
