问题标签 [spring-mono]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
237 浏览

spring - 如何生成一个随机字符串并使用 Mono 将其推出以每隔 X 秒或通过 Spring Reactive 随机延迟显示在浏览器中?

我希望浏览器在API使用Spring Reactive Mono.

以下是我的示例程序,它每秒生成随机字符串并在浏览器上显示,但页面不加载任何新数据,它看起来像静态数据加载。

pom.xml

0 投票
1 回答
89 浏览

spring - Spring Reactor - 使用 Pageable 端点

这是我第一次使用 Spring Reactor,我面临以下挑战:

我有一项服务,它允许使用由页码和页面大小指定的许多记录:

GetContactsForGroupResponse 在其他字段中包含分页元数据:

现在我需要编写另一种方法来读取所有页面

并将结果合并到一个集合中:

到目前为止,我已经写过:

我逐页阅读结果,直到读到最后一页。我想知道从 SpringReactor 的角度来看,正确的实现方式是什么

任何意见,将不胜感激,

谢谢

0 投票
1 回答
28518 浏览

java - Java 中的 Mono 类:什么是,何时使用?

我有以下代码:

我理解这段代码,除了 Mono 类做了什么以及它的功能是什么。我做了很多搜索,但没有直截了当:什么是 Mono 类以及何时使用它

0 投票
1 回答
116 浏览

java - 如何解决,调用 Mono然后结果将用于另一个 Mono,然后将返回 Mono?

嗨,我刚开始学习反应式编程

我在这里有这段代码,我的流程应该是我将调用 tokenRepository 来获取令牌,然后使用 token.getAccessToken() 作为 cardRepository.findAllCards() 上的参数

想知道这是否可能?

0 投票
1 回答
1310 浏览

functional-programming - Spring Webflux 单声道总是以成功的响应来响应

我有一个端点,它接受 id 参数并发送删除产品 api 来删除。productService.delete 也返回 Mono。问题是当 productService.delete 方法返回单声道错误时,端点总是以 http 200 响应。我可以看到有关此单声道错误的错误日志,但我的处理程序方法响应 http 200。

我有一个 AbstractErrorWebExceptionHandler 来处理我的 api 中的异常。但是由于 Mono 的原因,错误处理程序无法处理此问题。当下游发生异常时,Spring webflux 应该知道这个错误并且不会响应 http 200。

顺便说一句,在源代码中,它表示将在给定发布者完成时提交响应。但是错误完成怎么样?我认为 Spring webflux 不会检查它是否是错误信号。只需检查单声道是否完成。

先感谢您。

0 投票
2 回答
1183 浏览

java - Mono.then 和 Mono.flatMap/map 的区别

假设我想调用 webservice1,如果第一个成功则调用 webservice2。

我可以执行以下操作(只是指示性伪代码):-

或者

将 mono.just() 用于单个元素时,两者有什么区别?

0 投票
1 回答
377 浏览

java - Java Spring WebClient如何从正文响应中获取属性并设置为给定的类?

我正在尝试使用返回如下正文响应的给定 API:

所以我创建了以下类:

我可以使用以下代码发出请求并获得预期的响应正文:

但是当我尝试检索对 EHTLToken.class 的响应并获取它的属性时,该类被实例化,但它的所有属性都是空的。这是我正在尝试的:

我的第二次测试失败:

我误解了 bodyToMono() 的概念吗?请问如何从响应正文中获取属性并使用 WebClient 设置为给定的类?

问候。

0 投票
1 回答
400 浏览

spring - Spring 5 Reactive Mono - 将 Mono 值传递给对象的属性并调用另一个 Mono

我是整个 Spring 反应式 webflux 的新手。我的问题很简单。在我的 addActions() 中,我试图通过调用 getCurrentVal() 来获得 Mono。这工作正常。但我需要获取它的值并更新一个属性(submission.stateVal)。然后通过调用 customService.addActions() 返回 Mono。这可以在不使用 block() 的情况下完成吗?

0 投票
1 回答
86 浏览

spring - 在 AOP 中从 Mono 中抛出新的 RuntimeException()

我有一个反应式 springboot 应用程序,其中一个方面

这里发生了什么,来自某些服务的 updateApplicationStatus() 在某个时候抛出了一个业务异常(这很好),在这方面我打印了异常消息,这也很好。但是,当我尝试抛出业务异常(其基础为 RuntimeException)时......我可以在控制台中看到这个异常,但是......它没有到达客户端。我怀疑它被扔到了另一个线程上。有什么线索吗?

0 投票
1 回答
123 浏览

java - 如何停止主线程以完成所有 Mono 调用?

我正在对 DB 进行多次单声道调用。并且需要所有 Mono 响应的结果来计算在声明的 Mono 逻辑之后编写的最终结果。

但是我的主要逻辑是在单声道结果​​存储到PollObject之前执行。所以我在PollObject中得到了 null 。所以我想停止我的主线程,直到 Mono 结果存储到PollObject中。