Android ListView中使用RxJava：如何跟踪每行的Observable？

嘿，我之前在做Android ListView结合RxJava的场景时，也踩过类似的坑，给你分享下具体的解决方案和注意点：

1. 移除指定行的按钮观察者 #

核心思路是用ViewHolder来管理每个item的订阅Disposable，因为ListView回收View时会复用ViewHolder，我们可以在复用前先销毁旧的订阅：

首先，在自定义的ViewHolder里添加一个Disposable变量，用来存储当前按钮的订阅实例：

static class MyViewHolder extends ViewHolder {
    Button itemButton;
    Disposable buttonDisposable; // 存储当前按钮的订阅

    public MyViewHolder(View itemView) {
        super(itemView);
        itemButton = itemView.findViewById(R.id.item_button);
    }
}

然后在getView(...)方法中，复用ViewHolder时先检查并销毁旧订阅，再创建新的订阅：

@Override
public View getView(int position, View convertView, ViewGroup parent) {
    MyViewHolder holder;
    if (convertView == null) {
        convertView = LayoutInflater.from(context).inflate(R.layout.list_item, parent, false);
        holder = new MyViewHolder(convertView);
        convertView.setTag(holder);
    } else {
        holder = (MyViewHolder) convertView.getTag();
        // 复用前先销毁旧的订阅，避免内存泄漏和重复订阅
        if (holder.buttonDisposable != null && !holder.buttonDisposable.isDisposed()) {
            holder.buttonDisposable.dispose();
        }
    }

    // 获取当前item的数据
    ItemData data = getItem(position);
    // 订阅PublishSubject，处理按钮逻辑
    holder.buttonDisposable = publishSubject
            .filter(obj -> obj.equals(data.getId())) // 根据item标识过滤事件
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(obj -> {
                // 处理按钮点击或其他逻辑
                Toast.makeText(context, "按钮点击：" + data.getName(), Toast.LENGTH_SHORT).show();
            });

    return convertView;
}

这样每次View被回收复用的时候，旧的订阅会被及时销毁，不会残留无用的观察者。

2. 跟踪指定行的按钮是否已添加到PublishSubject中 #

其实不需要直接去跟踪PublishSubject里的观察者列表，我们可以通过ViewHolder的Disposable状态来判断当前item的订阅状态：

• 如果holder.buttonDisposable != null && !holder.buttonDisposable.isDisposed()，说明当前item的按钮已经有活跃的订阅
• 在复用ViewHolder时，我们已经强制销毁了旧订阅，所以每次绑定新数据时都会创建新的订阅，不会出现重复添加的问题

另外，也可以给你的数据模型（比如ItemData）添加一个isSubscribed标记，但这种方式不如用ViewHolder管理Disposable可靠，因为数据和View的绑定是动态的，ViewHolder更贴近View的生命周期。

3. 其他需要注意的事项 #

• 内存泄漏防护：在宿主组件（Activity/Fragment）销毁时，一定要调用publishSubject.onComplete()，或者统一销毁所有订阅。比如在Activity的onDestroy()方法中：

  @Override
  protected void onDestroy() {
      super.onDestroy();
      if (adapter != null && adapter.publishSubject != null) {
          adapter.publishSubject.onComplete();
      }
  }
  

• 避免持有强引用：Adapter中如果需要引用Context，尽量用WeakReference<Context>，防止因Adapter持有Activity引用导致内存泄漏。
• 线程调度：处理UI相关的逻辑（比如按钮点击后的Toast、更新UI）时，一定要用observeOn(AndroidSchedulers.mainThread())，避免在子线程操作UI。
• 数据与订阅的匹配：当Adapter的数据发生变化时（比如调用notifyDataSetChanged()），要确保所有ViewHolder的订阅都被正确清理和重新绑定，避免出现订阅和数据不匹配的情况。
• 替代方案考虑：如果你的项目版本允许，建议用RecyclerView替代ListView，RecyclerView的onBindViewHolder()和onViewRecycled()方法能更清晰地处理View回收时的订阅清理逻辑，比如在onViewRecycled()中直接销毁ViewHolder的Disposable。

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