使用RxJava与Otto EventBus向Activity发送事件未被接收问题求助

嘿，我来帮你搞定这个Otto+RxJava的事件接收问题！结合你的技术栈（Android Studio 3.2 Canary 8、Otto 1.3.8、RxJava 1.3.7、Kotlin 1.2.31），我来拆解问题根源和最优解决方案：

问题核心原因 #

你遇到的问题本质上有两个关键点：

1. Otto的线程特性：Otto默认会在事件发送的线程执行订阅者的回调方法。如果在RxJava的IO线程直接发事件，不仅可能导致UI操作报错（因为不在主线程），更关键的是如果Bus实例有问题，或者订阅者的线程匹配不上，就会收不到事件。
2. Bus实例一致性：Otto的订阅和发送必须基于同一个Bus实例，如果Activity和后台任务用了不同的Bus对象，事件肯定“传不过去”。

最优解决方案 #

1. 先确保Bus是全局单例（最关键的一步！） #

这是新手用Otto最容易踩的坑——别在每个类里new Bus！创建一个全局单例的Bus，保证所有组件用的是同一个实例：

object BusProvider {
    // 用ThreadEnforcer.MAIN强制所有事件发送必须在主线程，避免线程错误
    private val bus = Bus(ThreadEnforcer.MAIN)

    fun getBus(): Bus = bus
}

然后在Activity里正确注册/取消订阅（一定要在生命周期方法里做，避免内存泄漏）：

class YourActivity : AppCompatActivity() {
    override fun onStart() {
        super.onStart()
        BusProvider.getBus().register(this)
    }

    override fun onStop() {
        super.onStop()
        BusProvider.getBus().unregister(this)
    }

    // 订阅事件的方法，必须满足：public、单参数、带@Subscribe注解
    @Subscribe
    fun onTaskFinished(event: TaskFinishedEvent) {
        // 这里可以安全更新UI，因为Bus强制了主线程执行
        tvResult.text = event.result
    }
}

2. 在RxJava中切换到主线程发送事件 #

如果你的后台任务在IO线程执行，一定要用RxJava的observeOn(AndroidSchedulers.mainThread())切换到主线程后再发送事件：

Observable.fromCallable {
    // 这里是IO线程的后台任务逻辑
    fetchDataFromNetwork()
}
.subscribeOn(Schedulers.io()) // 指定后台任务在IO线程执行
.observeOn(AndroidSchedulers.mainThread()) // 切换到主线程处理结果
.subscribe({ result ->
    // 在主线程发送Otto事件
    BusProvider.getBus().post(TaskFinishedEvent(result))
}, { error ->
    // 处理错误，也可以发送错误事件
    BusProvider.getBus().post(TaskFailedEvent(error.message))
})

3. 检查事件类和订阅方法的规范 #

最后再确认你的事件类和订阅方法符合Otto要求：

• 事件类必须是具体的类（不能是接口/抽象类），比如用Kotlin数据类：

  data class TaskFinishedEvent(val result: String)
  data class TaskFailedEvent(val errorMsg: String?)
  

• 订阅方法必须是public（Kotlin默认就是public）、只有一个参数（对应事件类型）、标注@Subscribe注解。

额外小建议 #

Otto其实已经停止维护很多年了（最后一次更新是2015年），如果项目允许的话，建议替换为GreenRobot EventBus（功能更全，线程模式更灵活）或者用RxJava自己实现RxBus，和你的现有技术栈更契合。不过如果要继续用Otto，上面的方案完全能解决你的问题。

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