CoroutineWorker 中的实时数据观察者

问题描述

我有一个定期执行的 Worker。它连接到 BLE 设备并从中同步数据。连接是由观察者完成的。 doWork 调用 syncRides()。 syncRides 创建了一个observeForever，并在建立连接时启动连接，调用 BleClient.runBleSync()。

我担心的是每 15 分钟调用一次“observeForever”（最少的 WorkManager 时间）并且创建未删除的 observeForever。问题是 BleWorker 没有 LifecycleOwner 来创建“BleClient.connectionStatus.observe”而不是“BleClient.connectionStatus.observeForever”。我的问题是我是否应该担心使用observeForever 并每15 分钟触发一次。或者，也许您可​​以提出更好的选择，例如添加和删除观察者。

此外，在没有 GlobalScope.launch(Dispatchers.Main) 的情况下运行时，会出现此函数无法在后台线程上运行的错误。那么在 Worker 中运行时 Dispatchers.Main 是什么意思？

class BleWorker(appContext: Context,workerParams: WorkerParameters) : CoroutineWorker(appContext,workerParams) {

override suspend fun doWork(): Result {

    return try {
        try {
            RLog.d("Run work manager")
            syncRides()
            val output: Data = workDataOf("KEY_RESULT" to 1)
            Result.success(output)
        } catch (e: Exception) {
            RLog.d("exception in doWork ${e.message}")
            Result.failure()
        }
    } catch (e: Exception) {
        RLog.d("exception in doWork ${e.message}")
        Result.failure()
    }
}


private suspend fun syncRides() {

    GlobalScope.launch(Dispatchers.Main) {

        val bleDevice = SharedPreferenceHelper.getBleMac()
        if (bleDevice != null && BleClient.connectionStatus.value == BleClient.ConnectionStatus.NOT_CONNECTED) {
            BleClient.connect(bleDevice)
        }

        BleClient.connectionStatus.observeForever {
            RLog.d("Observing $it")

            when (it) {
                BleClient.ConnectionStatus.CONNECTED -> {
                    GlobalScope.launch(Dispatchers.IO) {
                        RLog.d("Running sync")
                        BleClient.runBleSync()
                    }
                }
                else -> {
                    RLog.d("No status")
                }
            }
        }
    }
}

BleClient：

 object BleClient {

 val connectionStatus = MutableLiveData(ConnectionStatus.NOT_CONNECTED)

 fun connect(mac: String) {
//do some magic         
 connectionStatus.postValue(ConnectionStatus.CONNECTED)
 }
}

解决方法

我假设该应用程序通过蓝牙连接到另一台设备上的任何同步数据。如果我的假设是正确的，首先，您应该将同步过程卸载到前台服务，因为该过程需要很长时间。您仍然可以使用 WorkManager 进行调度。在前台服务中，您应该连接 BLE 并同步数据。为此，有不同的选择。如果你需要使用 observable 来观察连接状态，你应该使用 MutableSharedFlow 而不是 MutableLiveData，这样你就可以观察你在 Service 类中创建的生命周期范围的变化。但是，在我看来，更好的做法是将 connect() 函数转换为可挂起的函数。为此，您可以使用 suspendCoroutine builder 进行转换。另外，如果同时从不同的线程调用 connect 函数，则必须使用 lock 来避免多个连接。 Kotlin Coroutines 为此提供了非阻塞锁。将 connect() 函数转换为挂起函数后，您可以以线性方式实现您的逻辑，这很容易且不需要任何类型的观察。