无需轮询：从Service向Activity推送数据的最优实现方案

Great question—high-frequency data push between Service and Activity is a common scenario for real-time dashboards, and you’re right to avoid polling and question Broadcast’s suitability here. Let’s break down the options and the standard approaches:

为什么不推荐Broadcast（包括LocalBroadcastManager） #

首先直接给出结论：普通全局Broadcast和已废弃的LocalBroadcastManager都不适合你的高频场景：

• 全局Broadcast是跨应用的，系统会做序列化/反序列化操作，每秒数十次的推送会带来明显性能开销，甚至导致UI卡顿。
• LocalBroadcastManager虽然是应用内通信，但Google已在AndroidX中标记为废弃，且本质还是基于Intent的通信，同样有序列化开销，高频下效率不如直接方法调用。

推荐的三种实现方案 #

1. Bound Service + 回调接口（经典高效方案） #

这是性能最优的方案，因为是直接的方法调用，没有任何序列化开销，适合每秒数十次的高频推送。核心思路是Activity绑定Service后，通过自定义接口注册回调，Service收到数据时主动调用回调方法通知Activity。

代码示例：

第一步：定义回调接口

interface DataUpdateListener {
    fun onNewCsvLineReceived(csvLine: String)
}

第二步：实现Bound Service

class DataSyncService : Service() {
    private var listener: DataUpdateListener? = null

    // 绑定Service时返回Binder实例
    override fun onBind(intent: Intent): IBinder = LocalBinder()

    inner class LocalBinder : Binder() {
        fun getService(): DataSyncService = this@DataSyncService
    }

    // 供Activity注册/注销回调
    fun setDataUpdateListener(listener: DataUpdateListener?) {
        this.listener = listener
    }

    // 模拟蓝牙/TCP收到数据后的处理逻辑
    private fun onReceivedData(csvLine: String) {
        // 确保在主线程回调（因为要更新UI）
        Handler(Looper.getMainLooper()).post {
            listener?.onNewCsvLineReceived(csvLine)
        }
    }

    // 其他蓝牙/TCP连接逻辑...
}

第三步：Activity绑定Service并接收回调

class DashboardActivity : AppCompatActivity(), DataUpdateListener {
    private var dataService: DataSyncService? = null
    private var isServiceBound = false

    private val serviceConnection = object : ServiceConnection {
        override fun onServiceConnected(className: ComponentName, service: IBinder) {
            val binder = service as DataSyncService.LocalBinder
            dataService = binder.getService()
            dataService?.setDataUpdateListener(this@DashboardActivity)
            isServiceBound = true
        }

        override fun onServiceDisconnected(arg0: ComponentName) {
            dataService?.setDataUpdateListener(null)
            dataService = null
            isServiceBound = false
        }
    }

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_dashboard)
        // 绑定Service
        Intent(this, DataSyncService::class.java).also { intent ->
            bindService(intent, serviceConnection, Context.BIND_AUTO_CREATE)
        }
    }

    override fun onDestroy() {
        super.onDestroy()
        if (isServiceBound) {
            dataService?.setDataUpdateListener(null)
            unbindService(serviceConnection)
            isServiceBound = false
        }
    }

    override fun onNewCsvLineReceived(csvLine: String) {
        // 解析CSV并更新仪表盘UI
        parseAndUpdateDashboard(csvLine)
    }

    private fun parseAndUpdateDashboard(csvLine: String) {
        // UI更新逻辑（已在主线程，可直接操作控件）
        // ...
    }
}

2. LiveData + ViewModel（Jetpack推荐方案） #

如果你的项目使用Android Jetpack组件，这是标准推荐实现。LiveData自带生命周期感知能力，能自动处理屏幕旋转等配置变更场景，无需手动管理绑定状态，且性能接近回调接口。

代码示例：

第一步：Service中定义LiveData

class DataSyncService : Service() {
    // 用MutableLiveData存储实时CSV数据
    val liveCsvData = MutableLiveData<String>()

    private fun onReceivedData(csvLine: String) {
        // 子线程中用postValue，主线程用setValue
        liveCsvData.postValue(csvLine)
    }

    // 其他蓝牙/TCP连接逻辑...

    override fun onBind(intent: Intent): IBinder? = null
}

第二步：Activity观察LiveData

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

        // 启动Service（如果未启动）
        startService(Intent(this, DataSyncService::class.java))

        // 通过ServiceConnection获取Service实例，然后观察LiveData
        val serviceConnection = object : ServiceConnection {
            override fun onServiceConnected(className: ComponentName, service: IBinder) {
                val dataService = (service as DataSyncService.LocalBinder).getService()
                dataService.liveCsvData.observe(this@DashboardActivity) { csvLine ->
                    parseAndUpdateDashboard(csvLine)
                }
            }

            override fun onServiceDisconnected(arg0: ComponentName) {}
        }
        bindService(Intent(this, DataSyncService::class.java), serviceConnection, Context.BIND_AUTO_CREATE)
    }

    private fun parseAndUpdateDashboard(csvLine: String) {
        // UI更新逻辑
        // ...
    }
}

3. EventBus（第三方简化方案） #

如果你的应用组件间通信逻辑复杂，可以考虑使用GreenRobot的EventBus等第三方库。它通过注解简化事件订阅/发布，但会增加依赖，且需注意及时取消订阅避免内存泄漏。高频场景下性能尚可，但不如原生方案轻量。

方案对比与选择 #

标准实现结论 #

• 如果你使用Jetpack，LiveData + ViewModel是Google官方推荐的标准方案，兼顾性能和开发效率。
• 如果追求极致性能或项目未使用Jetpack，Bound Service + 回调接口是经典的高效实现。
• 绝对避免使用普通Broadcast或LocalBroadcastManager处理高频数据推送。

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