Log Spring webflux类型-Mono和Flux

Question

我是Spring5的新手。

1）如何记录Mono和flux类型的方法参数而不阻塞它们？

编辑1：我有这个命令式代码，我正在尝试转换成一个反应代码。由于在论证中引入了Mono，目前存在编译问题。

    public Mono<UserContactsBO> getUserContacts(Mono<LoginBO> loginBOMono)
    {

     LOGGER.info("Get contact info for login: {}, and client: {}", loginId, clientId);

    if (StringUtils.isAllEmpty(loginId, clientId)) {
      LOGGER.error(ErrorCodes.LOGIN_ID_CLIENT_ID_NULL.getDescription());
      throw new ServiceValidationException(
          ErrorCodes.LOGIN_ID_CLIENT_ID_NULL.getErrorCode(),
          ErrorCodes.LOGIN_ID_CLIENT_ID_NULL.getDescription());
    }

    if (!loginId.equals(clientId)) {

      if (authorizationFeignClient.validateManagerClientAccess(new LoginDTO(loginId, clientId))) {
        loginId = clientId;
      } else {
        LOGGER.error(ErrorCodes.LOGIN_ID_VALIDATION_ERROR.getDescription());

        throw new AuthorizationException(
            ErrorCodes.LOGIN_ID_VALIDATION_ERROR.getErrorCode(),
            ErrorCodes.LOGIN_ID_VALIDATION_ERROR.getDescription());
      }
    }

    UserContactDetailEntity userContactDetail = userContactRepository.findByLoginId(loginId);
    LOGGER.debug("contact info returned from DB{}", userContactDetail);
    //mapstruct to map entity to BO
    return contactMapper.userEntityToUserContactBo(userContactDetail);
  }

Answer 1

你可以这样试试。如果您想添加日志，您可以使用.map并在那里添加日志。如果没有传递筛选器，它将返回空，您可以使用swichifempty获得它

loginBOMono.filter(loginBO -> !StringUtils.isAllEmpty(loginId, clientId))
          .filter(loginBOMono1 -> loginBOMono.loginId.equals(clientId))
          .filter(loginBOMono1 -> authorizationFeignClient.validateManagerClientAccess(new LoginDTO(loginId, clientId)))
          .map(loginBOMono1 -> {
              loginBOMono1.loginId = clientId;
              return loginBOMono1;
          })
          .flatMap(o -> {
             return userContactRepository.findByLoginId(o.loginId);
          })