如何使用Kotlin Flow获取Android设备位置更新？

可以通过callbackFlow将基于回调的LocationManager API转换成Kotlin Flow，既能保留原有功能，又能利用Flow的响应式特性，还能自动管理监听生命周期，避免内存泄漏。

核心封装代码 #

先封装一个扩展函数，把位置更新逻辑转换成Flow：

import android.location.Location
import android.location.LocationListener
import android.location.LocationManager
import android.os.Bundle
import kotlinx.coroutines.channels.awaitClose
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.callbackFlow
import kotlinx.coroutines.flow.tryEmit

// 自定义异常，标记位置提供者被禁用的情况
class LocationProviderDisabledException(provider: String) : Exception("位置提供者 $provider 已被禁用")

fun LocationManager.locationUpdates(
    provider: String,
    minTime: Long,
    minDistance: Float
): Flow<Location> = callbackFlow {
    // 创建LocationListener，将位置更新发送到Flow
    val listener = object : LocationListener {
        override fun onLocationChanged(location: Location) {
            // 发送最新位置，tryEmit不会阻塞线程
            tryEmit(location)
        }

        override fun onStatusChanged(provider: String?, status: Int, extras: Bundle?) {}
        override fun onProviderEnabled(provider: String) {}
        override fun onProviderDisabled(provider: String) {
            // 位置提供者被禁用时，关闭Flow并传递异常
            close(LocationProviderDisabledException(provider))
        }
    }

    // 先发送最后已知位置（如果存在），和原有逻辑保持一致
    getLastKnownLocation(provider)?.let { tryEmit(it) }

    try {
        // 注册位置更新监听
        requestLocationUpdates(provider, minTime, minDistance, listener)
    } catch (e: SecurityException) {
        // 权限不足时关闭Flow
        close(e)
    }

    // 当Flow被取消时，移除监听，避免内存泄漏
    awaitClose {
        removeUpdates(listener)
    }
}

使用示例 #

在Activity/Fragment或ViewModel中调用这个Flow：

import android.Manifest
import android.content.Context
import android.location.LocationManager
import android.widget.Toast
import androidx.lifecycle.lifecycleScope
import kotlinx.coroutines.launch

// 示例：在Activity中启动位置更新
private fun startLocationUpdates() {
    val locationManager = getSystemService(Context.LOCATION_SERVICE) as LocationManager

    // 检查位置权限（原有逻辑应已处理，这里做提示）
    if (checkSelfPermission(Manifest.permission.ACCESS_FINE_LOCATION) != android.content.pm.PackageManager.PERMISSION_GRANTED &&
        checkSelfPermission(Manifest.permission.ACCESS_COARSE_LOCATION) != android.content.pm.PackageManager.PERMISSION_GRANTED
    ) {
        Toast.makeText(this, "请授予位置权限", Toast.LENGTH_SHORT).show()
        return
    }

    // 启动收集位置更新
    lifecycleScope.launch {
        locationManager.locationUpdates(
            LocationManager.NETWORK_PROVIDER,
            MIN_TIME_BW_UPDATES,
            MIN_DISTANCE_CHANGE_FOR_UPDATES.toFloat()
        ).catch { exception ->
            // 集中处理异常
            when (exception) {
                is SecurityException -> Toast.makeText(this@MainActivity, "位置权限不足", Toast.LENGTH_SHORT).show()
                is LocationProviderDisabledException -> Toast.makeText(this@MainActivity, exception.message, Toast.LENGTH_SHORT).show()
                else -> Toast.makeText(this@MainActivity, "位置更新失败", Toast.LENGTH_SHORT).show()
            }
        }.collect { location ->
            // 处理位置更新，和原有逻辑完全一致
            val latitude = location.latitude
            val longitude = location.longitude
            updateLatitudeLongitude(latitude, longitude)
            updateLocation(location)
        }
    }
}

关键说明 #

• 生命周期自动管理：使用lifecycleScope（Activity/Fragment）或viewModelScope（ViewModel）时，组件销毁会自动取消Flow，触发awaitClose中的removeUpdates，彻底避免内存泄漏。
• 异常集中处理：通过Flow的catch操作符统一处理权限、提供者禁用等异常，比原有回调的零散try-catch更清晰。
• 扩展性更强：可以在collect前添加Flow操作符，比如filter过滤无效位置、map转换位置格式，适配更多业务场景。
• 兼容原有逻辑：保留了发送最后已知位置的行为，和你原来的代码效果完全一致。

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