代码之家 › 专栏 › 技术社区 › Viraj

反应式编程如何实现相关结果

project-reactor spring-webflux reactive-programming spring

Viraj · 技术社区 · 6 年前

我正在尝试使用spring boot使用反应模式REST服务。我已经设置了代码,它正在将项目保存到Cassandara数据库中。现在我有以下要求以反应式方式书写:

如果在数据库中找不到项,请保存该项。如果项目存在,则引发异常。

我一直在试图弄清楚如何以反应式的方式进行这种逻辑。由于我是这个领域的初学者,很难理解这个概念。以下是我的方法:

@Override
public Mono<String> createItem(ItemCreateParam itemCreateParam) {
    //This check if item exits in database.
    Mono<Boolean> byName = reactiveItemRepository.existsById(itemCreateParam.getName());

    //This save the item and return the id (i.e name)
    return Mono.just(itemCreateParam)
            .flatMap(item -> convert(item))
            .log()
            .flatMap(t -> reactiveTemplateRepository.save(t))
            .map(t-> t.getName());
}

如何以被动的方式将这两者结合起来?

1 回复 | 直到 6 年前

MuratOzkan 6 年前

只需检查 existsWithId() .我将这样实施:

@Override
public Mono<String> createItem(ItemCreateParam itemCreateParam) {
    return reactiveItemRepository.existsById(itemCreateParam.getName())
           .doOnNext(exists -> {
                if (exists) {
                     throw new AppException(ErrorCode.ITEM_EXISTS);
                }
           })
          .flatMap(exists -> convert(item))
          .flatMap(converted -> reactiveTemplateRepository.save(converted))
          .map(saved -> saved.getName());
}

请注意 AppException 类型可以是任何其他类型,但它应该扩展 RuntimeException .

推荐文章

ropes-nopes · 如何在反应式Spring集成中处理反应式类型?

3 年前

Bibek Shakya Dev. Joel · Mono<T>和Flux<T>作为函数中的参数

6 年前

Flavouski · 反应性异常处理

6 年前

Viraj · 反应式编程如何实现相关结果

6 年前

Aleksey Kozel · Mono如何订阅

6 年前

KJQ · 如何将2个Spring Mongo反应式保存操作链接在一起?

7 年前

KJQ · 是否可以在底层同时运行Spring WebFlux和MVC(CXF、Shiro等)服务?

7 年前

billdoor · Reactor/WebFlux实现一个反应式http新闻自动收录器

7 年前

Stav Alfi · 了解缓冲区操作的工作原理

7 年前

Ruslan · 无法构造“reactor”的实例。果心出版商Mono ` Spring Cloud OpenFeign和Spring boot 2

7 年前