如何在Activity中检索FirebaseCloudMessaging服务通过协程Channel发送的广播消息？

我来帮你梳理下问题并给出可行的解决方案～首先得指出你当前代码里的几个关键问题，这也是Activity拿不到数据的核心原因：

• 每次收到消息都新建一个Channel，Activity根本无法获取这个动态创建的Channel实例，之前的Channel也会被直接丢弃
• 使用GlobalScope是不推荐的，它的生命周期不受控，很容易引发内存泄漏
• runBlocking在这里完全没必要，还会阻塞onMessageReceived的线程，影响消息处理效率

下面给你两种常用且可靠的实现方案，你可以根据自己的技术栈和需求选择：

方案一：使用SharedFlow（协程友好推荐） #

SharedFlow是Kotlin协程提供的热流，非常适合这种跨组件的消息广播场景，支持多个订阅者同时接收消息。

1. 创建全局消息管理单例 #

先做一个全局的消息管理器，用来持有SharedFlow实例，确保Service和Activity能共享同一个数据源：

object FcmMessageManager {
    // MutableSharedFlow用来发送消息，replay=1表示新订阅者会收到最近的一条消息
    private val _messageFlow = MutableSharedFlow<String>(replay = 1)
    // 对外暴露只读的SharedFlow，避免外部随意发送消息
    val messageFlow = _messageFlow.asSharedFlow()

    // 发送消息的挂起函数
    suspend fun sendMessage(message: String) {
        _messageFlow.emit(message)
    }
}

2. 修改FCM Service的代码 #

在onMessageReceived里调用管理器的发送方法，注意要用合适的CoroutineScope，不要用GlobalScope：

override fun onMessageReceived(remoteMessage: RemoteMessage) {
    val messageBody = remoteMessage.notification?.body ?: return
    // 使用IO线程处理消息发送，避免阻塞主线程
    CoroutineScope(Dispatchers.IO).launch {
        FcmMessageManager.sendMessage(messageBody)
    }
}

3. 在Activity中接收消息 #

用lifecycleScope结合repeatOnLifecycle来收集Flow，确保和Activity生命周期绑定，避免内存泄漏：

class YourTargetActivity : AppCompatActivity() {
    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.your_activity_layout)

        lifecycleScope.launch {
            // 只有当Activity处于STARTED状态时才收集消息，避免后台时不必要的资源消耗
            repeatOnLifecycle(Lifecycle.State.STARTED) {
                FcmMessageManager.messageFlow.collect { message ->
                    // 在这里处理消息，比如更新UI、显示Toast等
                    Toast.makeText(this@YourTargetActivity, "收到消息：$message", Toast.LENGTH_SHORT).show()
                }
            }
        }
    }
}

方案二：使用LiveData（简单易上手） #

如果你还没接触协程，LiveData是更简单的选择，它天生和Android生命周期绑定，不用担心内存泄漏：

1. 创建全局消息管理单例 #

object FcmMessageManager {
    private val _messageLiveData = MutableLiveData<String>()
    // 对外暴露只读的LiveData
    val messageLiveData = _messageLiveData as LiveData<String>

    // 发送消息，用postValue确保在后台线程也能更新LiveData
    fun sendMessage(message: String) {
        _messageLiveData.postValue(message)
    }
}

2. 修改FCM Service的代码 #

override fun onMessageReceived(remoteMessage: RemoteMessage) {
    val messageBody = remoteMessage.notification?.body ?: return
    FcmMessageManager.sendMessage(messageBody)
}

3. 在Activity中接收消息 #

直接观察LiveData即可：

class YourTargetActivity : AppCompatActivity() {
    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.your_activity_layout)

        FcmMessageManager.messageLiveData.observe(this) { message ->
            Toast.makeText(this, "收到消息：$message", Toast.LENGTH_SHORT).show()
        }
    }
}

额外提醒 #

• 如果你的App在后台运行，FCM默认会把通知消息直接展示在系统通知栏，不会触发onMessageReceived。如果需要后台也能处理消息，要发送数据消息（或者同时包含通知和数据的消息），并且在AndroidManifest里配置对应的Intent过滤。
• 不管用哪种方案，都要确保消息管理器是单例，这样Service和Activity才能共享同一个实例传递数据。

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