腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
以
正确
的
方式
处理
和
返回
Mono
错误
-
Java
Reactor
代码
java
、
spring-webflux
我写了以下
代码
来删除记录: public
Mono
<String> userData(User body) { return
Mono
.just("Remove Successful");} RemoveUserDetails方法类似于: public
Mono
<User> removeUserDetails() + " doesn't ex
浏览 395
提问于2021-05-11
得票数 1
1
回答
为什么在Spring反应函数中没有捕获异常?
spring-boot
、
exception
、
project-reactor
我试图捕捉在运行反应性函数时抛出
的
异常(此函数
返回
一个
Mono
)。我使用
的
代码
灵感来自以下URL中
的
信息:我有一个具有以下功能
的
测试应用程序: return
Mono
.er
浏览 4
提问于2022-06-28
得票数 0
1
回答
Mono
.subscribe()将异常抛回客户端
java
、
spring-boot
、
spring-webflux
、
subscribe
我有下一段
代码
,所以当我
返回
一个
Mono
.error时,应该在订阅
错误
部分中
处理
它,以便向客户端抛出一个异常,但这是不可能
的
。你知道我做错了什么吗?) at
reactor
.core.publisher.
Mono
.subscribeWith(
Mo
浏览 1
提问于2021-03-30
得票数 1
回答已采纳
1
回答
如何在反应堆网中
处理
io.netty.channel.ConnectTimeoutException
java
、
project-reactor
、
reactor-netty
我试图使用反应堆Netty TcpClient
的
反应
方式
与主机交互,这可能是无法触及
的
。producer [
reactor
.core.publisher.MonoCreate] :“入站”
和
“出站”有一个专门
的
方法来
处理
它们<e
浏览 0
提问于2019-09-04
得票数 3
回答已采纳
1
回答
Micronaut不
返回
Flux
返回
类型
的
默认HTTP
错误
表示
java
、
project-reactor
、
micronaut
、
micronaut-rest
我有简单
的
微控制器与两个类似的GET方法,
返回
不同
的
反应类型。)) }} 现在,如果我调用端点/b,我将得到HTTP400,它具有由提供
的
默认
错误
表示,这是理想
的
和
完美的。at
reactor
.core.publisher.FluxJust.subscribe(FluxJust.
java
:68)
浏览 8
提问于2022-01-11
得票数 1
2
回答
如果从switchIfEmpty
返回
服务器响应,Spring webflux“只允许一个连接接收订阅者”
spring
、
spring-boot
、
spring-webflux
、
project-reactor
下面是我
的
处理
程序:
Mono
<UserBO> userBOMono不是空
的
,那么它
的
返回
冲突是我想要的如果如果是空
的
,那么创建新
的
,但它抛出下面的
错误
:
java
.lang.IllegalStateException: Only o
浏览 55
提问于2018-09-06
得票数 1
回答已采纳
1
回答
反应堆
Java
单元测试模拟依赖项
返回
值
的
顺序
java
、
junit
、
mockito
、
mono
、
project-reactor
我是反应性
Java
的
初学者。当设置一个模拟依赖项
以
返回
两个不同
的
值时,我试图理解为什么简单
的
单元测试失败。此依赖项在正在测试
的
主类中被调用两次。我使用flatmap
和
then是有原因
的
,因为我希望在第二个
Mono
之前完成第一个
Mono
。这方面的一个例子可能是将数据写入数据库,然后从同一链中
的
数据库读取数据。下面是正在测试
的
主要类: package my.servi
浏览 2
提问于2022-05-05
得票数 0
1
回答
Project
Reactor
是
java
CompletableFuture
的
包装器吗?
java
、
asynchronous
、
reactive-programming
、
project-reactor
、
completable-future
我想知道
Reactor
类型(
Mono
和
Flux)甚至Rxjava类型是否是
Java
可完成未来
的
包装器,还是它们使用自己
的
实现。 对这件事
的
任何帮助都将不胜感激。
浏览 0
提问于2019-08-13
得票数 1
2
回答
WebFlux在后台执行请求?
java
、
spring
、
spring-webflux
我
的
方法应该在执行confirm方法后
返回
结果或
错误
消息,然后执行一些后台工作。我写了类似于上面的东西,但是我不确定在then中调用
的
方法。我错了吗?public
Mono
<Void> someMethod(...){ return someReactiveApiClient.confirm().onErrorMap(...).then(
浏览 2
提问于2020-07-29
得票数 3
回答已采纳
1
回答
flatMap输出上
的
电抗器调用阻塞导致ClassCastException
spring-data
、
project-reactor
我使用
的
是Spring Boot 2.0.0.M7
和
Project
Reactor
。我
的
问题与编写单元测试时遇到
的
一些奇怪行为有关。在尝试将flatMap
的
输出提供给存储库时,我也遇到了这个问题。into Foo domain Entity })由于flatMap
的
返回
值,这个闭包应该发出一个
Mono
<Foo>。(FluxFlatMap.
java</e
浏览 28
提问于2017-12-27
得票数 0
回答已采纳
3
回答
LoadbalanceRSocketClient与Spring
的
RSocketRequester
的
正确
使用
spring-messaging
、
rsocket
、
rsocket-java
我试图理解LoadbalanceRSocketClient在SpringBoot应用程序(RSocketRequester)上下文中
的
正确
配置
和
使用模式。(MonoCallable.
java
:61) ~[
reactor
-core-3.4.0.jar:3.4.0] at
reactor
.core.publisher.
Mono
.subscribe(
Mono
.
java
) ~[
reactor
-core-3.4.0.j
浏览 11
提问于2020-12-11
得票数 3
回答已采纳
1
回答
工程反应堆
的
flatMap
和
switchIfEmpty操作人员
的
使用问题
reactive-programming
、
project-reactor
我对依赖flatMap()
和
switchIfEmpty()
的
反应链有一个问题。出于某种原因,其中一个
Mono
不发射任何东西.这是调用其他
处理
程序
的
公共
处理
程序方法:public
Mono
<ServerResponse> createUser下面是我遇到
的
错误
:
java
.util.N
浏览 0
提问于2019-09-07
得票数 1
回答已采纳
1
回答
如何
处理
OAuth webclient异常
java
、
spring
、
exception
、
oauth
、
authorization
:82) at
reactor
.core.publisher.
Mono
.lambda$onErrorResume$31(
Mono
.
java
:3362) at
reactor
.core.publisher.FluxOnErrorResume$ResumeS
浏览 3
提问于2020-11-30
得票数 0
1
回答
如何在webclient中使用检索
处理
500个
错误
代码
java
、
spring
、
spring-webflux
、
spring-webclient
我读过很多关于这个问题
的
文档
和
其他堆叠溢出
的
问题,但是我似乎无法让我
的
代码
正常工作。但是我注意到,如果我得到一个500个
错误
代码
,WebClient会抛出一个异常。我想要做
的
是捕获异常并优雅地
处理
它,并
返回
一个字符串,如“
错误
调用第一个端点等等”。or
浏览 5
提问于2020-08-29
得票数 3
1
回答
Spring webclient池在某个时候耗尽。
spring-boot
、
spring-webflux
、
spring-webclient
下面是我尝试使用web客户端发送帖子
的
不同
方式
,但是每次连接池在某个时候都会耗尽。我得到了以下
错误
。请帮助哪些连接没有被释放。(Utils.getNewObjectNode());}public
Mono
<JsonNode> sendPostR(String url,()); .log(); 下面是我使用<em
浏览 38
提问于2022-09-22
得票数 0
1
回答
如何在反应式环境中
处理
文件访问
java
、
reactive-programming
、
project-reactor
我正在将一些阻塞
代码
重构为reactive (使用
Reactor
)。我认为
java
.nio.file.Files类中
的
大多数方法都是阻塞
的
。如果我替换如下所示
的
方法是否
正确
: public boolean exists() {} 通过以下
方式
: public
Mono
<Boolean> exists() { return
Mono
.f
浏览 27
提问于2020-07-15
得票数 0
回答已采纳
1
回答
尽管使用了
Mono
.fromCallable(),但为什么会出现“阻塞,线程反应器-http-nio-4不支持”
的
错误
?
kotlin
、
azure-blob-storage
、
spring-webflux
、
project-reactor
我同意反应式
代码
不应该阻塞,但是... 在下面的方法findTenantStorageFactory()中,我需要在tenantId上阻塞,以便该方法可以
返回
租户
的
特定工厂。我发现来自Project
Reactor
的
指令需要将该方法包装在
Mono
.fromCallable()中并使用boundedElastic()调度器。但是,当我在调试器中运行这段
代码
时,我收到一个可怕
的
错误
:“/blockFirst()/blo
浏览 525
提问于2020-07-09
得票数 1
1
回答
如何用Spring 2
和
WebFlux测试@控制器
spring-boot
、
spring-webflux
我目前正在普通控制器中尝试测试一个简单
的
post方法,它
返回
一个
Mono
来重定向到另一个页面,或者在本例中是主页。我尝试过各种不同
的
aproache,模拟组件,但是我似乎总是在测试中
返回
一个null
Mono
,所有这些都是通过表单提交正常工作
的
。("redirect:/"));}public
Mono
<Void> addTimeKeepingE
浏览 2
提问于2018-10-21
得票数 1
回答已采纳
1
回答
如何以
reactor
方式
编写快捷循环
project-reactor
我有一个像下面这样
的
非
reactor
风格
的
代码
,如果任何一个checker
返回
false,那么就迭代一系列
的
checker
和
快捷
方式
,
返回
"BAD“: public static String oldWayreturn "BAD"; }} boolean check(Strin
浏览 11
提问于2019-04-19
得票数 0
回答已采纳
1
回答
将Future转换为
Mono
java
、
future
、
project-reactor
、
completable-future
我有
返回
convert
java
.util.concurrent.Future
的
遗留
代码
,现在我应该将这个方法调用包装在一个
返回
reactor
publishers或Flux
的
层中。我相信转换成其中任何一个
的
方法都应该是相似的,那么转换成
Mono
的
正确
方法是什么呢? 例如,假设我从API获得了Future,并且我需要
Mono
浏览 77
提问于2020-05-07
得票数 2
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
响应式编程——Reactor
Spring Boot 中的响应式编程和 WebFlux 入门
Spring5-Webflux响应式编程的必由之路
Spring Boot 2.0-WebFlux framework
Kotlin Coroutine 是如何与 Spring WebFlux 整合的
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券