project-reactor 相关问题

Reactor是一个基础库，用于构建JVM上的反应式快速数据应用程序。它提供了Java，Groovy和其他JVM语言的抽象，使构建事件和数据驱动的应用程序更容易。它也非常快。

想象您有这样的代码：public List addUserToGroups（String username，String label）{Mono userMono = webClient.getUser（username）;用户user = userMono.block（）; ... ] >>

java reactive-programming project-reactor reactor

回答 1 投票 0

Reactor-加载分页API的所有页面

我想知道Reactor和分页的HTTP API。我有一个私人有趣的getPage（pageNumber：Int）：Mono 。该资源具有“ numberOfPages”字段，我想获取...

kotlin project-reactor reactor

回答 1 投票 1

具有消息代理（例如Kafka）的事件驱动微服务与响应式编程（RxJava，Project Reactor）以及改进的协议（RSocket）

我们都同意，通过HTTP调用通信微服务的通常的请求-响应方式会导致它们之间的耦合。这使我们采用了事件驱动的方法，其中服务发布了...

apache-kafka microservices project-reactor event-driven rsocket

回答 1 投票 1

由操作员检查助焊剂流

我尝试检查现有的流，但到目前为止找不到特殊的运算符。 Flux.just（1、2、3）//仅检查每个元素.map（e-> {System.out.println（e）; return ...

java project-reactor

回答 1 投票 1

如何等待列表中的所有Monos结束（是否成功无关紧要）

我有这样的代码：List monoList = foo（）; //等待所有的Monos完成后，尝试{ 此作品： try { Flux.fromIterable(monoList) .flatMap(Function.identity()) .then() .onErrorContinue((throwable, o) -> { //just ignore it we've already caught all errors }) .block(); } catch (Exception e) { log.warn("Polling finished with exceptions", e); }

java concurrency spring-webflux project-reactor spring-reactive

回答 1 投票 0

Reactor-溢出策略IGNORE与ERROR

这两个下面的溢出策略有什么意义？例外是不同的。但是在两种情况下，如果订户无法跟上，则会通过错误呼叫通知他们。在这种情况下，我们应该...

project-reactor

回答 1 投票 0

Spring Reactor多个订阅

我正在尝试将我的单声道拆分为其他分离的单声道，该单声道将在不同线程上处理相同的数据输入数据。公共Mono process（）{Mono ...

rx-java2 spring-webflux project-reactor

回答 1 投票 0

基于Spring WebFlux / Reactive Mongo的应用程序打开到mongo db的多个连接

我有一个简单的Web应用程序，带有spring boot 2.x.x，用于响应式api的Spring WebFlux和Reactive Mongo存储库。在应用程序中，我有一个@Tailablequery与与...的get API关联的...

mongodb spring-boot spring-webflux project-reactor

回答 1 投票 0

Reactor-发布行为

我对Flux中的发布行为感到非常困惑。为什么第二个订户不打印任何东西，而第一个订户呢？这是一个热门发布者，并且每秒发出一次值。两者都应该...

project-reactor

回答 1 投票 1

使用Flux缓冲kafka消息

我有kafka输入和输出主题。我要做的是我在主题A中编写内容，并希望在主题B中接收消息但具有缓冲功能。我的代码如下所示：@Bean public Function ] >>>> buffer()，而不是window()是您只需要将结果作为集合而不是Flux返回的运算符。如果您还想从结果集合中过滤重复项，则可以通过传递HashSet供应商作为第二个参数来使用Set而不是List来存储值： flux -> flux.buffer(10, HashSet::new)

apache-kafka project-reactor spring-cloud-stream

回答 1 投票 0

在CommandLineRunner中使用Spring WebClient

我正在尝试使用反应式Spring WebClient在我的应用程序中执行HTTP请求。但是我的应用程序基本上是作为CommandLineRunner实现的简单工作：@Component public class ...

java spring project-reactor

回答 1 投票 0

为什么反应堆Mono 被识别为空的Mono？

这里是一段代码@Test public void test_mono_void_mono_empty（）{Mono.just（“ DATA”）.flatMap（s-> Mono.just（s.concat（“-”）.concat（s））.. 。

java project-reactor reactor

回答 1 投票 0

如何对无限通量进行排序？

我有一个由专用处理器生成的无限Flux实例，这意味着每个元素都是通过sink.next发出的（如果重要的话，元素来自反应式Kafka Receiver）。问题是...

java reactive-programming spring-webflux project-reactor

回答 1 投票 0

WebClient ExchangeFilterFunction无法添加标头java.lang.UnsupportedOperationException ReadOnlyHttpHeaders

我正在尝试将简单的ExchangeFilterFunction添加到WebClient请求。但是，我看到以下异常：org.springframework.http ....

spring-boot spring-webflux project-reactor

回答 1 投票 0

我如何有条件地在Project Reactor Netty HTTP Server中设置状态代码？

我怀疑我在这里确实遗漏了一些明显的东西，但是我无法弄清楚如何用Reactor-netty中的HttpServer实现一个非常简单的用例。本质上，我想实现以下功能：...

netty project-reactor reactor-netty

回答 1 投票 1

Netifi代理与在Kubernetes集群上使用直接RSocket应用程序通信相比有什么改进？

假设我有一个Kubernetes集群，在其中部署使用RSocket进行通信的Spring Boot应用程序。为了互相调用，他们将使用Kubernetes服务名称，因此我们将成为...

spring-boot project-reactor rsocket netifi

回答 1 投票 3

如何在项目反应堆中合并来自两个反应流的数据？

我最近开始使用Project Reactor，但无法弄清楚如何使用嵌套流。我想用内部Mono的一些数据更新外部Mono的数据。 @GetMapping（“ / search”）public ...

java spring-boot reactive-programming project-reactor

回答 1 投票 1

反应式编程是否比非反应式编程消耗更多的资源？

我们目前正面临Spring webFlux的性能问题。为了确定反应式编程的好处，我们实现了Spring Boot服务，该服务从...

java spring-boot project-reactor reactor spring-io

回答 2 投票 5

如何在循环中合并Mono的值？

我有一个实体列表List 像公共类Entity1 {private int id; ....}我需要遍历该列表，应用我的函数并获取Mono 基于...

java rx-java project-reactor java.util.concurrent reactive-streams

回答 1 投票 0

Reactor Kotlin通用类型返回

没有人知道为什么泛型变成了Nothing！不能与Reactor onErrorReturn链接？ fun test（）：Mono {return Mono.just（“”）} //编译错误...

generics kotlin project-reactor

回答 1 投票 0

project-reactor 相关问题

最新问题