当我需要库函数的上下文和单响应时，如何重构嵌套的平面映射？

Question

我有一个反应性的Web应用程序（Spring WebFlux）通过Azure Storage中的POST API存储用户配置文件图像。我需要为用户创建一个存储桶，如果它不存在的话。

服务层方法如下所示：（它包含嵌套的平面地图--这在反应性应用程序中被认为是一种不好的做法，而且是一种代码气味。）我想重构，这样就没有嵌套的平面地图。有什么办法可以做到这一点吗？

public Mono<BlockBlobItem> processAndUpload(FilePart filePart) {

    return Mono.subscriberContext().flatMap(context -> {
      String userId = context.get(USER_ID_CONTEXT);
      BlobContainerAsyncClient blobContainerClient = blobServiceAsyncClient.getBlobContainerAsyncClient(userId);

      return blobContainerClient.exists()
          .doOnEach(logOnNext(doesContainerExist -> {
            if (doesContainerExist) {
              LOGGER.info(STORAGE_CONTAINER_EXISTS_MSG);
            } else {
              LOGGER.info(STORAGE_CONTAINER_DOES_NOT_EXIST_MSG);
            }
          }))
          .doOnEach(logOnError(err -> LOGGER.error(CONTAINER_CHECK_FAILURE_MSG, err.getMessage(), err)))
          .flatMap(doesContainerExist -> {
            if (doesContainerExist) {
              return uploadFile(filePart, blobContainerClient, userId);
            } else {
              return blobContainerClient.createWithResponse(null, null)
                  .doOnEach(logOnComplete(response -> LOGGER.info(CONTAINER_CREATION_SUCCESS_MSG)))
                  .doOnEach(logOnError(err -> LOGGER.error(CONTAINER_CREATION_FAILURE_MSG, err.getMessage(), err)))
                  .then(uploadFile(filePart, blobContainerClient, userId));
            }
          });
    });
  }

Answer 1

恐怕嵌套的FlatMap是唯一的方法，只要您需要这两个上下文。

如果您谈到重构，我会将lambda表达式（或者至少是它们的右侧）移出方法，以实现可读性。另外，只要不需要初始的上下文，请考虑首先使用map来获取userid。

public Mono<BlockBlobItem> processAndUpload(FilePart filePart) {

    return Mono.subscriberContext()
        .map(context -> context.get(USER_ID_CONTEXT))
        .flatMap(userId -> {
                var client = blobServiceAsyncClient.getBlobContainerAsyncClient(userId);
                return client.exists()
                    .doOnEach(logOnNext(doesContainerExistLambda))
                    .doOnEach(logOnError(errLambda))
                    .flatMap(doesExist -> existenceHandler(filePart, client, userId));
                }
        );
}

名为doescontainerexistlambda、errlambda、existencehandler的方法和lambda表达式是根据需要和考虑进行更改的主题。代码段的重点是要强调可以转移到其他地方的内容。