Android定时通知重复文本问题：如何每次从ViewModel取新内容？

问题核心在于Worker是独立于UI生命周期的后台组件，不能依赖ViewModel；且之前仅在初始化时获取一次文本，没有每次运行时重新拉取最新状态。下面是具体的重构方案：

1. 抽离数据逻辑到Repository层 #

把ViewModel里的文本列表、DataStore索引读写逻辑单独放到TextRepository，让它成为数据的唯一来源，Worker和ViewModel都依赖它：

class TextRepository(private val dataStore: DataStore<Preferences>) {
    // 替换成你的实际文本列表，也可以从本地文件/网络加载
    private val textList = listOf("今日提醒1", "今日提醒2", "今日提醒3", "更多内容...")

    // 每次调用都会获取当前索引对应的文本，并自动更新索引到下一个
    suspend fun getNextNotificationText(): String {
        // 从DataStore读取当前索引
        val currentIndex = dataStore.data.first()[PreferencesKeys.CURRENT_NOTIFICATION_INDEX] ?: 0
        // 计算下一个索引（循环遍历列表）
        val nextIndex = (currentIndex + 1) % textList.size
        // 保存新索引到DataStore
        dataStore.edit { it[PreferencesKeys.CURRENT_NOTIFICATION_INDEX] = nextIndex }
        // 返回当前索引对应的文本
        return textList[currentIndex]
    }
}

// 定义DataStore的Key
private object PreferencesKeys {
    val CURRENT_NOTIFICATION_INDEX = intPreferencesKey("current_notification_index")
}

2. 修改Worker，直接通过Repository获取新文本 #

Worker不能用ViewModel，但可以通过依赖注入（如Hilt）或手动实例化Repository来获取最新文本：

用Hilt注入Repository的写法： #

@HiltWorker
class NotificationWorker @AssistedInject constructor(
    @Assisted context: Context,
    @Assisted params: WorkerParameters,
    private val textRepository: TextRepository
) : CoroutineWorker(context, params) {

    override suspend fun doWork(): Result {
        // 每次运行都获取新文本
        val newText = textRepository.getNextNotificationText()
        // 推送通知
        pushNotification(newText)
        return Result.success()
    }

    private fun pushNotification(contentText: String) {
        val notificationManager = NotificationManagerCompat.from(applicationContext)
        // 确保通知渠道已创建（Android 8.0+要求）
        createNotificationChannel(notificationManager)

        val notification = NotificationCompat.Builder(applicationContext, "NOTIFICATION_CHANNEL_ID")
            .setSmallIcon(R.drawable.ic_notification)
            .setContentTitle("定时提醒")
            .setContentText(contentText)
            .setPriority(NotificationCompat.PRIORITY_DEFAULT)
            .build()

        // 用时间戳当通知ID，避免覆盖旧通知（按需调整）
        notificationManager.notify(System.currentTimeMillis().toInt(), notification)
    }

    private fun createNotificationChannel(manager: NotificationManagerCompat) {
        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
            val channel = NotificationChannel(
                "NOTIFICATION_CHANNEL_ID",
                "定时提醒渠道",
                NotificationManager.IMPORTANCE_DEFAULT
            )
            manager.createNotificationChannel(channel)
        }
    }
}

不用依赖注入的写法： #

如果没用到Hilt，就在Worker里手动创建DataStore和Repository：

class NotificationWorker(context: Context, params: WorkerParameters) : CoroutineWorker(context, params) {

    override suspend fun doWork(): Result {
        val dataStore = applicationContext.createDataStore(name = "app_preferences")
        val repository = TextRepository(dataStore)
        val newText = repository.getNextNotificationText()
        pushNotification(newText)
        return Result.success()
    }

    // pushNotification和createNotificationChannel方法同上
}

3. 调整ViewModel，依赖Repository（保持UI层逻辑） #

原来的ViewModel不再处理数据逻辑，改为通过Repository获取文本，适配UI需求：

class MainViewModel(private val repository: TextRepository) : ViewModel() {
    // 如果UI需要展示最新的通知文本，可以调用这个方法
    fun loadLatestNotificationText() = viewModelScope.launch {
        val text = repository.getNextNotificationText()
        // 更新UI状态，比如用MutableStateFlow
        // _uiState.update { it.copy(currentText = text) }
    }
}

4. 确保WorkManager定时任务配置正确 #

周期性任务要保证每次Worker都能触发，并且不会重复创建：

// 创建16分钟一次的周期性任务
val periodicWork = PeriodicWorkRequestBuilder<NotificationWorker>(16, TimeUnit.MINUTES)
    .setConstraints(Constraints.Builder()
        // 根据需求设置约束，比如不低电量时运行
        .setRequiresBatteryNotLow(true)
        .build())
    .build()

// 唯一任务，避免重复添加
WorkManager.getInstance(context).enqueueUniquePeriodicWork(
    "DailyNotificationWork",
    ExistingPeriodicWorkPolicy.REPLACE,
    periodicWork
)

核心要点 #

• 绝对不要在Worker里缓存文本或索引，每次运行都要从DataStore/Repository读取最新状态
• DataStore的操作必须在协程中执行（因为data是Flow，需要用suspend方法或collect）
• 通知ID用动态值（如时间戳）可以避免新通知覆盖旧的，根据你的需求调整即可

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