时间戳

首页 > 解决方案 > 如何让服务层在从数据库中获取任何内容时返回 Mono::error

java - 如何让服务层在从数据库中获取任何内容时返回 Mono::error

问题描述

我正在使用此代码块从 Couchbase 检索一些数据，但是当它无法获取任何内容时，它不会调用该onErrorResume块。onErrorResume有没有办法在找不到与密钥匹配的文档时调用此代码？

return referenceService.getReferenceTable(referenceKey)
    .flatMap(referenceTable -> {
        logger.info("reference table: {}", referenceTable.toString());
        Market market = getMarket(aggregate.getDate(), aggregate.getMarket(), referenceTable);
        aggregate.setMarket(market);
        return Mono.just(aggregate);
    })
    .onErrorResume(e -> {
        logger.info("Error getting reference table");
        return Mono.error(e);
    });

正在使用的服务层如下所示：

@Service("referenceService")
public class CouchbaseReferenceService implements ReferenceService {

    @Autowired
    private ReferenceRepository referenceRepository;

    @Override
    public Mono<ReferenceTable> getReferenceTable(String key) {
        return referenceRepository.getReferenceTable(key);
    }

}

标签： javaspring-bootreactive-programmingcouchbaseproject-reactor

解决方案

referenceRepository.getReferenceTable(key)当没有找到给定的Monoa 时返回一个空。ReferenceTablekey

从存储库的角度来看，这不是错误情况。要将空Mono值视为错误条件，您可以.switchIfEmpty(Mono.error(...))在流中使用。

这是您.switchIfEmpty应用的示例：

return referenceService.getReferenceTable(referenceKey)
    .switchIfEmpty(Mono.error(() -> new RuntimeException("No reference table found with key " + referenceKey)))
    .map(referenceTable -> {
        logger.info("reference table: {}", referenceTable.toString());
        Market market = getMarket(aggregate.getDate(), aggregate.getMarket(), referenceTable);
        aggregate.setMarket(market);
        return aggregate;
    })
    .doOnError(e -> logger.info("Error getting reference table", e));

另外，我对您的示例进行了另外两项更改：

  1. 由于您的.flatMap实现是同步的一对一映射，因此您可以使用.map，就像我在上面所做的那样。
  2. 由于您的.onErrorResume实现返回了与观察到的相同的异常，因此您可以.doOnError像我在上面所做的那样使用，允许原始异常继续传播。

推荐阅读