问题标签 [spring-reactive]

问问题

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.

130 问题
Newest
Active
Bountied
318
Unanswered
0 投票
1 回答
470 浏览

spring-boot - 无法使用 AbstractReactiveElasticsearchConfiguration 将数据写入 ElasticSearch

我正在尝试将数据写入我的本地 Elasticsearch Docker 容器（7.4.2），为简单起见，我使用了 Spring 提供的 AbstractReactiveElasticsearchConfiguration 也覆盖了 entityMapper 函数。我构建了我的存储库，扩展了 ReactiveElasticsearchRepository 然后最后我使用我的自动装配存储库来 saveAll() 我包含数据的元素集合。但是 Elasticsearch 不会写入任何数据。我还有一个 REST 控制器，它开始我的整个过程，基本上什么都不返回，DeferredResult>

来自我的 ApiDelegateImpl 的 REST 方法

我的 Elasticsearch 配置

我的仓库

我的 DTO

我的适配器实现

最后是我的 IT 测试

0 投票
1 回答
1207 浏览

java - 反应堆：通量 .subscribe() vs. .toStream()

I have a function: Flux queryPerson() which queries database to generate the objects and return them in Flux. When I use .subscribe(), the app just run thru the code and exit. It doesn't wait f

I have a function: Flux queryPerson() which queries database to generate the objects and return them in Flux. When I use .subscribe(), the app just run thru the code and exit. It doesn't wait for the results to come back for the query. But when I use .toStream() to block the stream, I can see the printouts. What am I doing wrong?

Test if group means are statistically significantly different in R

*(I asked this question earlier, but it got migrated to stackexchange and was labeled 'unclear' and I couldn't edit it, so I'm going to try to clean up the question and make it more clear).

I have the following data frame and need to determine if there are statistically significant differences among the means of Test Groups, and repeat this for each Task Grouping. :

For example, for Task A, I need to see if there are significant differences in the means of the Test Groups (Green, Yellow, Orange).

I've tried the following code, but something is wrong since the p.value is the same for each Test Group combination among different Task Groupings (i.e. every p-value is 0.6190578):

I'm also not 100% sure if a pairwise.t.test is the correct statistical test to use. To rephrase, I need to see if the Test_Group means are statistically different from one another. And then I need to repeat this analysis for each Task Grouping.

0 投票
4 回答
4545 浏览

mongodb - 无法在 Spring Boot 应用程序中连接到 MongoDB

我刚刚使用具有mongoDB-reactive依赖关系的 Spring Tool Suite 创建了一个非常基本的 Spring Boot 项目并运行该应用程序，但是，我不断收到以下异常

2019-11-27 00:31:19.699 INFO 11988 --- [localhost:27017] org.mongodb.driver.cluster：连接到服务器 localhost:27017 时监控线程出现异常

com.mongodb.MongoSocketOpenException：在 com.mongodb.connection.netty.NettyStream$OpenChannelFutureListener.operationComplete(NettyStream.java:410) ~[mongodb-driver-core-3.11.2.jar:na] 处打开套接字的异常

我正在使用 Spring Boot (2.2.1.RELEASE)

在里面applications.properties我添加了以下行

我错过了什么？

0 投票
1 回答
910 浏览

java - Spring Boot OAuth 资源服务器代理配置

我目前正在努力将代理与 Spring-Webflux 结合使用。在其他服务中，我总是遵循这种方法，效果很好（代理配置是从标准环境变量中检索的）：

但现在我正在尝试使用 Spring Oauth-Resource-Server 包设置 OAuth-Ressource-Server。这个包使用 Spring-Webflux for HTTP(S)。该服务现在尝试从给定的 uri（需要代理）中获取 jwk-set，但由于连接被拒绝错误而失败。有没有人得到 Spring-Webflux/OAuth-Ressource 和代理工作的组合？

0 投票
1 回答
180 浏览

spring - 如何在spring响应中解压缩gzip压缩的内容？

在将我的 spring 服务器从 servlet 迁移到响应式时，我必须将代码中的所有过滤器更改为 WebFilter。其中一个过滤器是解压缩 gzip 压缩的内容，但我无法对新的 WebFilter 做同样的事情。

使用 servlet，我用 GzipInputStream 包装了输入流。使用弹簧反应的最佳实践是什么？

0 投票
0 回答
904 浏览

csv - 使用 Spring 响应式 webflux 生成 CSV

我有一个应该生成带有流的 CSV 报告的端点。我实现了这样的端点：

现在我通过流获得响应，但我没有标题，并且数据与字段名称一起显示。我尝试使用StatefulBeanToCsvopencsv，但为此我需要一个作家。当我使用 servlet 时，我可以使用 the 初始化编写器，response.getOutputStream()但使用 webflux 我无法使其工作。

我没有找到任何文档。有什么帮助吗？

0 投票
0 回答
377 浏览

spring - Spring Data Reactive Mongo 模板：MongoDB 游标

使用响应式 mongo 模板迭代大型结果的推荐方法是什么？

我找不到阻塞 MongoTemplate::stream() 操作的反应替代方案，它使用 MongoDB 游标（并且工作得很好）。

当我使用 Reactive 模板做最明显的事情时，我的应用程序工作了一段时间，然后毫无例外地卡住了（下面的 Kotlin 代码段）：

我不明白 - 如果它试图获取内存中的所有结果，它应该立即因 OOM 失败，但不会在一段时间后卡住，对吗？

我究竟做错了什么？

0 投票
1 回答
182 浏览

java - 当 List 中的所有 Monos 完成时如何等待（成功与否无关紧要）

我有这样的代码：

当所有 MONO 都成功完成时，它工作得很好，但如果至少一个 Mono 完成错误，它就不起作用。方法block抛出异常并中断所有其他单声道。因此，当所有单声道成功完成或发生第一个错误时，此代码将等待。

当所有 Monos 完成时如何等待monoList（成功与否无关紧要）

0 投票
1 回答
403 浏览

postgresql - Spring Boot 2.2 中的 r2dbc-postgresql 0.8.0.RC1 无法正常工作

在我将 spring webflux （spring boot 2.2.0.m3 到 2.2.2.RELEASE ）和 r2dbc （spring-data-r2dbc 1.0.0.M2 到 1.0.0.RELEASE ）和 r2dbc-postgresql （1.0 .0.M7 到 0.8.0.M8) 项目我不断收到此错误

我的 pom.xml 在这里

我失败的业务逻辑就像上面

你能帮我找出为什么我会收到这个错误吗？

0 投票
1 回答
615 浏览

java - 使用 spring r2dbc 时找不到 javax.persistence 注释

我正在尝试通过H2using使用反应式存储库Spring Boot。

我添加了依赖项

我的域看起来像这样

当依赖是

一切正常。但是由于我添加了r2dbc依赖项，因此无法找到javax.persistence注释的任何依赖项。当我使用starter-jpa反应式存储库时，它在启动时失败（常规Reactive Repositories are not supported by JPA）。

如何解决问题？javax.persistence手动添加依赖？

问题是什么？


12345678910