问题标签 [spring-reactive]

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

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

pom.xml

如果发生错误，我希望以下方法引发自定义异常：

我还设置了一个单元测试，期望抛出 CustomException。不幸的是，测试失败了，异常被包裹在一个 Mono 对象中。这里还有测试代码供参考：

我正在使用MockWebServer来模拟测试中的错误。

那么，如果调用，我应该如何实现 doOnError 或 onError 部分，以使我的方法真正抛出异常？

我正在使用oauth2with springboot reactive( webclient webflux) 我想获取给定属性文件的访问令牌：

我尝试过没有成功的springboot文档文档：
1）https://docs.spring.io/spring-security/site/docs/5.0.7.RELEASE/reference/html/oauth2login-advanced.html
2）https： //www.baeldung.com/spring-webclient-oauth2

我们如何将 Flux< Employe> 转换为 Mono< Customers> 对象？

通量<雇员> empFlux = getService(); // 它将返回 Employe 列表 Employe { private String id; 私人字符串信息；}

// 需要将 empFlux 数据转换为 Mono<Customers>

公共类 CusData {

}

公共类客户{

} 公共类雇员 {

}

WebSession当 a具有响应式 netty 服务器的HttpSessionBindingListener valueBound(HttpSessionBindingEvent event)or 等​​价物时，什么是或如何得到通知。valueUnbound(HttpSessionBindingEvent event)

挖掘文档或网络搜索时，似乎找不到任何内容。

将显示代码，但不存在。

我想创建一个经过身份验证的用户列表，以便另一台服务器可以检查活动用户列表。我想根据上述事件来维护这个列表，这样我就可以通过其他事情来触发这些事件，比如撤销令牌或其他什么。

我有一项将图片上传到服务器的服务。我在这个服务上使用了 Java Spring Reactive，我用 dateformat 重命名了文件，并且需要返回这个新名称。这就是我在服务中所做的：

此代码将 Mono 返回给我的控制器。在此控制器中，我需要将 Mono 中的字符串返回给客户端，因为此字符串包含前端所需的新上传文件名。这是我的控制器：

我的问题是，如何从 Mono 中获取 createImage 函数返回的字符串，以便将其发送给客户端？

谢谢你的帮助。

我对这个线程中的提议进行了一些测试： flux within executorservice

我已经稍微简化了这个例子，以便更容易理解。因此，这是示例：

但是，现在如果执行它，它总是在主线程结束前等待 10 秒。我期待什么？我希望执行程序服务最多等待 10 秒，直到继续并调用关机。通常它应该在几毫秒内完成，并在打印 1、2、3 后立即返回。javadoc 在这里说：

阻塞直到所有任务在关闭请求后完成执行，或者发生超时，或者当前线程被中断，以先发生者为准。

我不明白。这里有什么问题？

另一个立即运行并结束的示例（但在我看来是错误的）是这个：

但是，在这里我希望主线程不会等到通量完成（分别是执行程序服务）。但确实如此。据我了解，根据 javadoc 描述，这两个示例的行为完全颠倒了。javadoc 说：

此方法不等待主动执行的任务终止。使用 awaitTermination 来做到这一点。

有任何想法吗？

问候贝尔纳多

I would like to get Flux<String> to await all mono-s from list.

How could I achieve it ?

P.S.

I've found similar question but I need vice versa operation https://stackoverflow.com/a/44040346/2674303

让我们考虑以下代码：

我需要等待所有单声道完成。

我怎样才能实现它？

我有以下代码：

webClient 实例化：

我的目标是允许并行执行队列中的所有 http 请求，并在所有请求完成后等待。但是尽管队列不是空的，但实际的 http 调用并没有发生。你能解释一下为什么以及如何解决它吗？

更新

感谢@caco3 的建议。我更正了这样的代码：

我看到以下日志：

所以当前代码不会等待所有请求终止。但我真的需要它