Spring Reactor：如何在发布者发出值时抛出异常？
我正在学习Reactor的反应编程，我想实现注册场景，其中一个用户可以有许多帐户分配到相同的配置文件。但是，分配给配置文件的用户名和分配给帐户的电话必须是唯一的。
public Mono<PersonalAccountResponse> createPersonalAccount(PersonalAccountRequest request) {
return Mono
.just(request.isAlreadyUser())
.flatMap(isAlreadyUser -> {
if(isAlreadyUser){
return profileDao
.findByUsername(request.getUsername()) //
.switchIfEmpty(Mono.error(() -> new IllegalArgumentException("...")));
}else{
return profileDao
.findByUsername(request.getUsername())
.switchIfEmpty(Mono.from(profileDao.save(profileData)))
.switchIfNotEmpty(Mono.error(() -> new IllegalArgumentException("...")));
}
})
.map(profileData -> personalAccountMapper.toData(request))
.flatMap(accountData -> personalAccountDao
.retrieveByMobile(request.getMobileNumber())
.switchIfEmpty(Mono.from(personalAccountDao.save(accountData)))
.switchIfNotEmpty(Mono.error(() -> new IllegalArgumentException("..."))))
.map(data -> personalAccountMapper.toResponse(data, request.getUsername()));
}
共有1个答案
若要在发布服务器发出值时传播异常，可以使用对发出的值进行操作的几个运算符之一。
一些例子：
fluxOrMono.flatMap(next -> Mono.error(new IllegalArgumentException()))
fluxOrMono.map(next -> { throw new IllegalArgumentException(); })
fluxOrMono.doOnNext(next -> { throw new IllegalArgumentException(); })
fluxOrMono.handle((next, sink) -> sink.error(new IllegalArgumentException()))
-
我正在制作一个小应用程序，我可以使用spring-boot保存用户详细信息。我创建了实体及其相应的存储库。当我发出帖子请求以添加用户的用户对象的id时，该id在保存到数据时为空base.Thisid在MySQL中自动生成（自动增量）。从POST请求中，我得到3个字段，即用户名、电子邮件、密码。用户类包含字段id、用户名、电子邮件、密码。我添加了注释 作为 id 字段。构造函数是 我的用户服务类 我
-
问题内容： 如何在Python中引发异常，以便以后可以通过except块将其捕获？ 问题答案： 在你的消息中要具体，例如： 不要引发通用异常 避免提出泛型。要捕获它，你必须捕获将其子类化的所有其他更具体的异常。 问题1：隐藏错误 例如： 问题2：无法抓住 而且更具体的捕获不会捕获一般异常： 最佳做法：raise声明 而是使用在语义上适合你的的最特定的构造函数。 这也方便地允许将任意数量的参数传递给
-
在你可以捕获异常之前，一些代码必须抛出一个异常。任何代码都可能会抛出异常：您的代码，来自其他人编写的包（例如Java平台附带的包）或Java运行时环境的代码。无论是什么引发的异常，它总是通过 throw 语句抛出。 您可能已经注意到，Java平台提供了许多异常类。所有类都是Throwable类的后代，并且都允许程序区分在程序执行期间可能发生的各种类型的异常。 您还可以创建自己的异常类来表示在您编写
-
我知道JVM有一个异常表，它映射在给定字节码索引中可以抛出的可能异常。我还读到athrow字节码抛出了堆栈顶部存在的引用类型的exception。我的问题更多地涉及像irem这样的指令如何“抛出”异常。 JVM是否会在每次指令执行后检查堆栈的顶部，以检查是否存在异常？如果你能洞察到这件事的话，你会很感激的。
-
我将一个使用Spring AMQP的项目迁移到一个使用Spring Cloud Stream和RabbitMQ的项目。 谢了！
-
我在其中一个POJO中使用javax.validation.constraints.NotNull，如下所示： 然后，即使我为两个字段都使用 null 值制作 Abc 的对象，它也不会引发任何异常。知道为什么吗？ 例如。 不会抛出任何异常。