为何不建议在RxJava流水线中修改对象？

嘿，这个问题问得特别实在——不少刚上手RxJava的开发者都会在这个点上纠结，我来给你拆解清楚～

首先得明确：为什么绝大多数资料都强调不要在流水线步骤（比如map、flatMap）里修改原对象？核心原因有两个：

1. 线程安全与共享状态风险 #

RxJava的流水线很容易跨线程执行（比如用subscribeOn/observeOn切换线程），如果你的users集合里的对象是被外部代码或者其他Observable共享的，那在map里直接修改原对象就会导致竞态条件——比如线程A正在修改user的name，线程B同时读取这个user的age，就可能拿到不一致的状态，这种问题调试起来简直是噩梦。

2. 违背函数式编程的纯函数原则 #

RxJava的设计很大程度上借鉴了函数式编程，而函数式编程要求转换操作（比如map）是纯函数：输入确定时输出必须确定，且不能产生副作用（修改外部状态就是典型的副作用）。你在map里修改原对象，相当于偷偷改变了数据流之外的状态，后续的操作或者外部代码拿到的user已经不是原来的样子了，整个数据流的可预测性会大打折扣。

看你给出的示例代码 #

Observable.fromIterable(users)
    .map(user -> { 
        user.name = //do something with name;
        user.age = // do something with age;
        return user; 
    })
    .subscribe(user -> { });

这里的问题就在于：你直接修改了传入map的原user对象，属于典型的副作用操作，完全踩了前面说的两个坑。

正确的两种做法 #

做法一：创建新对象传递（推荐） #

最稳妥的方式是复制原对象的属性，修改需要调整的字段后返回新对象，让原对象保持不变。

如果你的User是普通POJO，可以这么写：

.map(user -> {
    User newUser = new User();
    newUser.setName(modifyUserName(user.getName()));
    newUser.setAge(modifyUserAge(user.getAge()));
    newUser.setId(user.getId()); // 保留其他不需要修改的属性
    return newUser;
})

如果用Lombok的@Data和@Builder，代码会更简洁：

.map(user -> user.toBuilder()
    .name(modifyUserName(user.getName()))
    .age(modifyUserAge(user.getAge()))
    .build())

这种方式下，原对象完全不受影响，数据流里传递的都是新实例，状态完全可控，也符合函数式编程的要求。

做法二：用doOnNext处理副作用 #

如果修改对象是不可避免的副作用（比如这个user是数据库实体，修改后需要立即持久化），那应该把修改操作放到doOnNext里——doOnNext的职责就是处理副作用，而map只负责数据转换，两者要分工明确：

Observable.fromIterable(users)
    .doOnNext(user -> {
        user.setName(modifyUserName(user.getName()));
        user.setAge(modifyUserAge(user.getAge()));
        // 这里还可以添加保存到数据库等副作用操作
    })
    .subscribe(user -> { });

不过要注意：即使这么做，也要确保这个user对象不会被其他线程或Observable共享，否则线程安全问题依然存在。如果必须共享，建议加锁或者使用线程安全的对象实现。

总结一下：尽量遵循“不修改原对象，传递新实例”的原则，这能让你的RxJava代码更清晰、更稳定，减少后期排查问题的成本。

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