关于如何将遗留Java代码转换为Reactive with Project-React库的问题

Question

我打算用projectreactor库编写一个process（）方法

process（）方法将字节数组作为参数，并执行以下步骤。假设每个步骤的所有其他方法都已编写并准备好使用。

1. 将字节数组反序列化为消息对象
2. 从消息对象提取用户ID、用户状态和用户地址
3. 从数据库中按用户ID检索记录
4. 如果从消息对象提取的这两个值不为Null，则使用userStatus和userAddress更新记录
5. 将记录保存到数据库中

@Component
public class UserService {

    @Autowired
    private Repository repo;

    //this is the method I want to fix
    public Mono<User> process(byte[] byteArray) {
        Message msg = deserialize(byteArray).block();  --> Question #1
        String userId = extractUserId(msg);
        String userStatus = extractUserStatus(msg);
        String userAddress = extractUserAddress(msg);
        return repo.find(userId)
                .switchIfEmpty(Mono.defer(() -> {
                    log.error("Error Message");
                    return Mono.empty();
                }))
                .map(user -> {
                    if(userStatus != null) {
                        user.setStatus(userStatus);
                    }

                    if(userAddress != null) {
                        user.setAddress(userAddress);
                    }
                })
                .flatmap(repo::save);
    }

    private Mono<Message> deserialize(byte[] byteArray) {
        //assume this method is written and is ready to be invoked;
    }

    private String extractUserId(Message msg) {
        //assume this method is written and is ready to be invoked;
    }

    private String extractUserStatus(Message msg) {
        //assume this method is written and is ready to be invoked;
    }

    private String extractUserAddress(Message msg) {
        //assume this method is written and is ready to be invoked;
    }

}

public class Repository {
    public Mono<User> find (String id) {
        //assume this method is written and is ready to be invoked;
    }

    public Mono<User> save(User user) {
        //assume this method is written and is ready to be invoked;
    }
}

问题1：我不应该阻止它，但我必须从中提取ID以从数据库中检索记录，并在以后使用它提取userStatus和address。

问题2：extractUserId、extractUserStatus和extractUserAddress方法是否应该返回Mono？

Answer 1

问题1：我不应该阻止它，但是。。。

这并不是说你不应该这么做，但你不能阻止它（除非你采取一些策略，比如为链中没有其他选择的特定部分旋转线程池，这是混乱的，通常表明你还没有准备好移动到一个完全反应的堆栈）在一个完全反应的链中，任何块都会杀死死链，捆绑住宝贵的事件循环线程并削弱性能。

相反，您应该将其保留为Mono

return deserialize(byteArray)
    .flatMap(
        msg -> {
          String userId = extractUserId(msg);
          String userStatus = extractUserStatus(msg);
          String userAddress = extractUserAddress(msg);

          return repo.find(userId)
              .switchIfEmpty(
                  Mono.defer(
                      () -> {
                        log.error("Error Message");
                        return Mono.empty();
                      }))
              .map(
                  user -> {
                    if (userStatus != null) {
                      user.setStatus(userStatus);
                    }

                    if (userAddress != null) {
                      user.setAddress(userAddress);
                    }
                  })
              .flatmap(repo::save);
        });

提取用户ID、提取用户状态和提取用户地址方法是否应该返回Mono？

这取决于那些方法需要做什么。如果他们不返回单核细胞增多症，他们会阻止吗？如果是，那么他们应该返回Mono（而不是阻塞。）如果他们不需要阻塞，那么他们就没有理由返回mono（事实上他们不应该，因为这可能会导致开发人员对这些方法做出错误的假设）。）

请注意，您的反序列化（）方法也是如此。如果它采用字节数组，则可能不需要执行任何阻塞操作（反序列化阻塞的通常原因是因为它从inputstream或类似文件读取，而不是因为实际的反序列化本身。）