如何用RxJava2遍历自定义对象列表并执行指定操作？

嘿，别担心，RxJava2的运算符其实没那么难上手，我来一步步给你拆解怎么实现你的需求～

首先，先确认你的Item类需要加上getter和setter方法，不然没法设置和获取属性（你给的代码里只有私有字段），补全后的类大概是这样：

public class Item {
    private String itemId;
    private String itemName;

    // Getter & Setter
    public String getItemId() {
        return itemId;
    }

    public void setItemId(String itemId) {
        this.itemId = itemId;
    }

    public String getItemName() {
        return itemName;
    }

    public void setItemName(String itemName) {
        this.itemName = itemName;
    }
}

接下来是核心的RxJava2实现代码，我会给你完整示例，再逐个解释关键部分：

// 你的初始Item列表
List<Item> itemsList = ...;

Observable.fromIterable(itemsList)
    // 第一步：为每个Item生成并设置唯一ID
    .map(item -> {
        String uniqueId = getUniqueId();
        item.setItemId(uniqueId);
        return item;
    })
    // 第二步：执行耗时操作，用fromCallable包装确保在后台线程执行
    .flatMap(item -> Observable.fromCallable(() -> {
        doSomeLongOperation(item);
        return item; // 可根据需求返回处理后的Item或其他结果
    }))
    // 指定所有耗时逻辑在IO线程执行，避免阻塞主线程
    .subscribeOn(Schedulers.io())
    // 如果是Android平台，需要在主线程处理结果的话加这句
    // .observeOn(AndroidSchedulers.mainThread())
    // 订阅处理结果、异常和完成回调
    .subscribe(
        processedItem -> {
            // 每个Item处理完成后的回调，比如打印日志或更新状态
            System.out.printf("处理完成：名称=%s，ID=%s%n", processedItem.getItemName(), processedItem.getItemId());
        },
        throwable -> {
            // 捕获处理过程中出现的异常
            throwable.printStackTrace();
        },
        () -> {
            // 所有Item都处理完毕后的回调
            System.out.println("全部Item处理完成！");
        }
    );

关键部分解释： #

1. Observable.fromIterable(itemsList)：把你的List转换成Observable，它会逐个发射列表中的每个Item对象，相当于RxJava版的"遍历"。
2. map(...)：用来同步转换每个Item对象。这里我们调用getUniqueId()获取唯一ID并设置到Item上——如果getUniqueId()本身也是耗时操作，记得把这部分也放到fromCallable里，用flatMap替代map，避免阻塞线程。
3. flatMap(...) + Observable.fromCallable(...)：因为doSomeLongOperation是耗时操作，我们用fromCallable包装这个任务，flatMap会把每个任务转换成独立的Observable，确保耗时逻辑在后台线程执行，不会卡住主线程。
4. subscribeOn(Schedulers.io())：指定整个Observable链的上游操作（包括生成ID、执行耗时任务）都在IO线程运行，这是RxJava处理耗时任务的标准做法。
5. subscribe(...)：订阅Observable，分别处理每个处理完成的Item、异常情况，以及所有任务完成后的收尾逻辑。

额外注意点： #

• 如果getUniqueId()也是耗时操作，修改成这样：

.flatMap(item -> Observable.fromCallable(() -> {
    String uniqueId = getUniqueId();
    item.setItemId(uniqueId);
    return item;
}))

这样设置ID的操作也会在IO线程执行。

• 如果你在Android平台开发，记得添加observeOn(AndroidSchedulers.mainThread())，这样订阅的回调（比如更新UI）会切换回主线程。
• 异常处理：如果getUniqueId()或doSomeLongOperation可能抛出异常，都会被subscribe的第二个参数（异常回调）捕获，你可以在这里做重试、提示用户等处理。

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