Kotlin项目多独立定时任务异常排查：执行周期不符、仅执行一次及HTTP请求异常处理咨询

先梳理下你遇到的几个核心问题的根源：

1. 第一个任务间隔不符预期：你用了scheduleAtFixedRate，它是固定速率调度——以上一次任务的开始时间计算下一次执行点。如果login()的同步请求耗时（比如10秒）占用了部分周期，就会导致两次任务结束的实际间隔变短（比如你看到的20秒）。
2. 第二个任务仅执行一次：updateOrdersState()抛出的SocketTimeoutException是未捕获异常，而Timer的线程是单线程的，一旦任务抛出未捕获异常，整个Timer会直接终止，后续任务自然不再执行。另外你嵌套创建Timer的写法完全没必要，反而容易造成资源管理混乱。
3. 异常处理：必须捕获HTTP请求的所有异常，否则会直接中断定时任务的生命周期。

修正后的代码方案 #

1. 切换到固定延迟调度模式 #

把第一个任务的scheduleAtFixedRate换成scheduleWithFixedDelay，它会以上一次任务的结束时间为起点计算下一次执行间隔，能严格保证两次任务的实际间隔符合你的预期。

2. 简化第二个任务的调度逻辑 #

不需要嵌套Timer，直接给scheduleWithFixedDelay设置initialDelay=5000，就能实现延迟5秒后开始周期性执行的需求。

3. 添加异常捕获逻辑 #

在login()和updateOrdersState()中捕获所有可能的异常，避免未捕获异常终止定时任务线程，同时添加日志记录方便排查问题。

修正后的定时任务代码

import kotlin.concurrent.scheduleWithFixedDelay
import kotlin.concurrent.timerTask

// 第一个任务：延迟1秒后启动，每30秒执行一次（以上次任务结束时间算间隔）
Timer().scheduleWithFixedDelay(timerTask { login() }, 1000, 30 * 1000)

// 第二个任务：延迟5秒后启动，每20秒执行一次（以上次任务结束时间算间隔）
Timer().scheduleWithFixedDelay(timerTask { updateOrdersState() }, 5_000, 20 * 1000)

带异常捕获的HTTP请求方法

import okhttp3.OkHttpClient
import okhttp3.Request
import okhttp3.Response
import java.net.SocketTimeoutException

fun login() {
    val loginRequestURL = "${Config.instance.loginApiUrl}/importAPILogist.php"
    val request = Request.Builder()
        .url(loginRequestURL)
        .get()
        .build()
    val httpClient = OkHttpClient()
    try {
        val loginResponse: Response = httpClient.newCall(request).execute()
        loginResponse.close() // 记得关闭响应体避免资源泄漏
    } catch (e: SocketTimeoutException) {
        logger.error("Login请求超时", e)
    } catch (e: Exception) {
        logger.error("Login请求失败", e)
    }
}

fun updateOrdersState() {
    logger.info("updateOrdersState:")
    val someRequestURL = "${Config.instance.someApiUrl}/exportAPI"
    val request = Request.Builder()
        .url(someRequestURL)
        .get()
        .build()
    val httpClient = OkHttpClient()
    try {
        val response: Response = httpClient.newCall(request).execute()
        response.close() // 及时关闭响应体
    } catch (e: SocketTimeoutException) {
        logger.error("更新订单状态请求超时", e)
    } catch (e: Exception) {
        logger.error("更新订单状态请求失败", e)
    }
}

额外优化建议 #

• 复用OkHttpClient实例：每次创建OkHttpClient会消耗额外资源，建议全局初始化一个实例（比如在Config类中），所有HTTP请求共享这个实例。
• 考虑使用Kotlin协程调度：如果你的项目已经引入协程，推荐用kotlinx.coroutines实现定时任务，它比Timer更灵活，异常处理也更友好，不会因为单个任务异常导致整个调度器终止。示例：

import kotlinx.coroutines.*
import kotlinx.coroutines.delay

fun startTasks() = CoroutineScope(Dispatchers.IO).launch {
    // 第一个任务
    launch {
        delay(1000)
        while (isActive) {
            login()
            delay(30 * 1000)
        }
    }

    // 第二个任务
    launch {
        delay(5000)
        while (isActive) {
            updateOrdersState()
            delay(20 * 1000)
        }
    }
}

内容的提问来源于stack exchange，提问作者Alexei