📚 课程目录第1章核心概念与架构总览

1. 核心概念与架构总览：持久化队列定义、Room与WorkManager整合场景、数据流图、技术选型依据

1.1 持久化队列定义

持久化队列是一种将任务状态与元数据存储在可靠持久层（如数据库）中的任务调度机制。与内存队列不同，持久化队列保障应用进程被终止或设备重启后，未完成的任务不会丢失，能够从上次中断点继续执行。

特性	内存队列	持久化队列
存储介质	RAM（易失）	数据库/磁盘（非易失）
进程存活依赖	强依赖	弱依赖
断电恢复	丢失所有任务	自动恢复
任务追踪	无	完整状态记录
适用场景	瞬时、可丢弃	关键、可重试、需记账

持久化队列核心约束： 任务入队即落盘，状态变更原子化，消费与持久化事务边界一致。

1.2 Room + WorkManager 整合场景

在 Android 应用中，典型的整合场景是将 Room 数据库作为队列的持久化存储容器，WorkManager 作为队列的调度与执行引擎。这种组合广泛用于：

离线数据同步： 用户操作产生待同步记录，先写入 Room 队列表，WorkManager 在后台按序或按批次上传。
批量日志上报： 埋点事件存入 Room，WorkManager 在 WiFi 环境下打包上报。
多步骤业务流程： 如电商订单的创建、支付、物流状态更新，每一步作为一个队列任务，通过 WorkManager 串联。
重试与幂等保障： 网络请求失败后，Room 保存重试次数与最新错误码，WorkManager 根据退避策略重新调度。

1.3 数据流图与架构总览

1.4 技术选型依据

为什么选择 Room + WorkManager 而非其他组合？核心对比维度如下：

维度	Room + WorkManager	SQLiteOpenHelper + ThreadPool	Realm + JobScheduler
声明式SQL支持	✅ 编译期校验	⚠️ 手工拼接SQL	❌ 非关系型
生命周期感知	✅ 自动绑定	❌ 需手动管理	⚠️ 部分支持
任务持久化	✅ 默认支持	⚠️ 需自行实现	✅ 默认支持
重试/退避策略	✅ 内置	❌ 手工实现	⚠️ 受限
电源/网络约束	✅ 最佳	❌ 无法约束	⚠️ 有限
测试支持	✅ 强 (TestListenableWorker)	❌ 依赖注入困难	⚠️ 一般
Google维护状态	✅ 官推 Jetpack	✅ 稳定但低层	❌ 社区维护

选型结论： Room 提供类型安全、编译期校验的持久层，WorkManager 提供系统级调度、约束与重试策略。两者结合是 Android 官方推荐的持久化队列实现方案，适用于绝大多数需要离线能力、任务可靠执行的应用场景。

1.5 关键API快速一览

本课程后续章节将深入每个 API 的实现细节。以下是核心接口清单：

// Room 层 - DAO 定义
@Dao
interface QueueDao {
    @Insert
    suspend fun insertTask(task: QueuedTask)

    @Query("SELECT * FROM queued_tasks WHERE state = :state ORDER BY createTime ASC LIMIT 1")
    suspend fun getNextPendingTask(state: String): QueuedTask?

    @Query("UPDATE queued_tasks SET state = :newState, retryCount = retryCount + 1 WHERE id = :taskId")
    suspend fun updateState(taskId: Long, newState: String)
}

// WorkManager 层 - 入队
val workRequest = OneTimeWorkRequestBuilder<SyncWorker>()
    .setConstraints(
        Constraints.Builder()
            .setRequiredNetworkType(NetworkType.CONNECTED)
            .build()
    )
    .setBackoffCriteria(BackoffPolicy.EXPONENTIAL, 30, TimeUnit.SECONDS)
    .build()

WorkManager.getInstance(context).enqueue(workRequest)

// Worker 层 - 执行与状态回写
class SyncWorker(context: Context, params: WorkerParameters) : CoroutineWorker(context, params) {
    override suspend fun doWork(): Result {
        return try {
            val dao = AppDatabase.getInstance(applicationContext).queueDao()
            val task = dao.getNextPendingTask("PENDING") ?: return Result.success()
            // 执行任务逻辑...
            dao.updateState(task.id, "COMPLETED")
            Result.success()
        } catch (e: Exception) {
            if (runAttemptCount < 3) Result.retry() else Result.failure()
        }
    }
}

常见初始误区： 不要把 WorkManager 当作普通线程池来用。入队后任务不由应用进程直接持有，而是由 WorkManager 内部调度器根据约束和优先级决定何时触发。务必在 doWork() 中通过 DAO 查询 Room 来获取真正的任务负载，而不是把数据序列化到 inputData 中（受限于 10KB 大小限制）。

1.6 概念核对清单

持久化队列 = 任务数据 + 状态机 + 持久化存储。
Room 充当队列的存储后端，负责 CRUD 与事务保证。
WorkManager 充当调度与生命周期管理层，负责触发、重试、约束。
CoroutineWorker 是任务的实际执行单元，运行在 Dispatchers.Default 上。
整个数据流 必须保证：入队先落库 → WorkManager 调度 → Worker 消费 → 状态回写。