Android ViewPager+Fragment与RxJava：Fragment创建后传递PublishSubject的方法

这个问题我之前帮不少开发者踩过坑，核心就是要找对Fragment创建完成后和Activity安全通信的时机，既要避免空指针，又要保证订阅能及时生效。给你几个实用的方案，按需选择：

利用Fragment的onAttach()生命周期方法——这个方法会在Fragment成功附加到Activity时调用，此时Activity实例已经存在，完全可以安全传递Subject。

步骤1：在MainActivity中定义接收Subject的方法 #

class MainActivity : AppCompatActivity() {
    private lateinit var viewPager: ViewPager
    private var fragment1Subject: PublishSubject<Any>? = null
    private var fragment2Subject: PublishSubject<Any>? = null

    // 接收Fragment1的Subject并订阅
    fun attachFragment1Subject(subject: PublishSubject<Any>) {
        fragment1Subject = subject
        subject.subscribe { event ->
            // 处理来自Fragment1的事件
            Log.d("MainActivity", "收到Fragment1事件：$event")
        }
    }

    // 接收Fragment2的Subject并订阅
    fun attachFragment2Subject(subject: PublishSubject<Any>) {
        fragment2Subject = subject
        subject.subscribe { event ->
            // 处理来自Fragment2的事件
            Log.d("MainActivity", "收到Fragment2事件：$event")
        }
    }

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main)
        viewPager = findViewById(R.id.viewPager)
        viewPager.adapter = MyPagerAdapter(supportFragmentManager)
    }

    inner class MyPagerAdapter(fm: FragmentManager) : FragmentPagerAdapter(fm) {
        override fun getItem(position: Int): Fragment = if (position == 0) Fragment1() else Fragment2()
        override fun getCount(): Int = 2
    }
}

步骤2：在Fragment中传递Subject到Activity #

class Fragment1 : Fragment() {
    // 初始化Fragment的PublishSubject
    private val mySubject = PublishSubject.create<Any>()

    override fun onAttach(context: Context) {
        super.onAttach(context)
        // 确保上下文是MainActivity，避免类型转换异常
        if (context is MainActivity) {
            context.attachFragment1Subject(mySubject)
        }
    }

    // 示例：发送事件的方法
    private fun sendEventToActivity() {
        mySubject.onNext("Fragment1的测试事件")
    }
}

这个方案的优势是简单直接，Fragment一绑定到Activity就能完成订阅，不会出现空指针问题。

如果想让代码更解耦，同时避免Fragment直接依赖Activity，推荐使用共享ViewModel——ViewModel的生命周期和Activity绑定，Activity和Fragment可以共享同一个ViewModel实例，Fragment创建后直接往ViewModel的Subject里发送事件，Activity提前订阅即可。

步骤1：创建共享ViewModel #

class SharedViewModel : ViewModel() {
    // 提前定义两个Fragment对应的Subject
    val fragment1Subject = PublishSubject.create<Any>()
    val fragment2Subject = PublishSubject.create<Any>()
}

步骤2：在MainActivity中订阅ViewModel的Subject #

class MainActivity : AppCompatActivity() {
    private lateinit var viewModel: SharedViewModel

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main)
        
        // 获取和Fragment共享的ViewModel实例
        viewModel = ViewModelProvider(this)[SharedViewModel::class.java]

        // 提前订阅两个Subject，Fragment创建后发送事件就能收到
        viewModel.fragment1Subject.subscribe { event ->
            Log.d("MainActivity", "收到Fragment1事件：$event")
        }

        viewModel.fragment2Subject.subscribe { event ->
            Log.d("MainActivity", "收到Fragment2事件：$event")
        }

        val viewPager = findViewById(R.id.viewPager)
        viewPager.adapter = MyPagerAdapter(supportFragmentManager)
    }

    inner class MyPagerAdapter(fm: FragmentManager) : FragmentPagerAdapter(fm) {
        override fun getItem(position: Int): Fragment = if (position == 0) Fragment1() else Fragment2()
        override fun getCount(): Int = 2
    }
}

步骤3：在Fragment中使用ViewModel的Subject发送事件 #

class Fragment1 : Fragment() {
    private lateinit var viewModel: SharedViewModel

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        // 获取和Activity共享的ViewModel实例
        viewModel = ViewModelProvider(requireActivity())[SharedViewModel::class.java]
    }

    // 示例：发送事件的方法
    private fun sendEventToActivity() {
        viewModel.fragment1Subject.onNext("Fragment1的测试事件")
    }
}

这个方案是最推荐的：既解耦了Fragment和Activity，又能在配置变化（比如屏幕旋转）时保留Subject的状态，不会丢失订阅。

如果你的需求是切换到某个页面时才订阅该Fragment的Subject，可以通过监听ViewPager的页面变化事件，获取当前显示的Fragment实例，再订阅它的Subject。

代码示例 #

class MainActivity : AppCompatActivity() {
    private lateinit var viewPager: ViewPager
    private lateinit var pagerAdapter: MyPagerAdapter

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main)
        viewPager = findViewById(R.id.viewPager)
        pagerAdapter = MyPagerAdapter(supportFragmentManager)
        viewPager.adapter = pagerAdapter

        // 监听ViewPager页面切换
        viewPager.addOnPageChangeListener(object : ViewPager.OnPageChangeListener {
            override fun onPageScrolled(position: Int, positionOffset: Float, positionOffsetPixels: Int) {}

            override fun onPageSelected(position: Int) {
                // 通过Tag获取ViewPager中缓存的Fragment实例（注意Tag的格式）
                val fragmentTag = "android:switcher:${viewPager.id}:$position"
                val currentFragment = supportFragmentManager.findFragmentByTag(fragmentTag)
                
                // 订阅当前Fragment的Subject
                when (currentFragment) {
                    is Fragment1 -> {
                        currentFragment.mySubject.subscribe { event ->
                            Log.d("MainActivity", "收到Fragment1事件：$event")
                        }
                    }
                    is Fragment2 -> {
                        currentFragment.mySubject.subscribe { event ->
                            Log.d("MainActivity", "收到Fragment2事件：$event")
                        }
                    }
                }
            }

            override fun onPageScrollStateChanged(state: Int) {}
        })
    }

    inner class MyPagerAdapter(fm: FragmentManager) : FragmentPagerAdapter(fm) {
        override fun getItem(position: Int): Fragment = if (position == 0) Fragment1() else Fragment2()
        override fun getCount(): Int = 2
    }
}

注意：这里不要直接调用pagerAdapter.getItem(position)，因为它会返回新的Fragment实例，而ViewPager中实际显示的是缓存的实例，所以必须用findFragmentByTag获取正确的实例。

总结一下：

• 追求架构解耦和稳定性：选方案二（共享ViewModel）
• 简单场景快速实现：选方案一（生命周期回调）
• 需要页面切换时动态订阅：选方案三（ViewPager页面监听）

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