reactor 相关问题

反应器设计模式是用于处理通过一个或多个输入同时传递给服务处理器的服务请求的事件处理模式。服务处理程序解复用传入的请求，并将它们同步分派给关联的请求处理程序。

我们有一个使用 Reactor Kafka 和 KafkaReceiver 进行消费的 Spring Boot 项目，我们希望收集和发出底层消费者指标。看起来我们可以利用 KafkaRecei...

spring-boot apache-kafka kafka-consumer-api metrics reactor

回答 1 投票 0

考虑以下代码片段： @预定(...) 公共无效cleanUpDbs（）{ fooRepository.deleteAll() .retryWhen(重试.backoff(3, Duration.ofSeconds(2))) .doOnError(日志::错误) ...

java mockito reactor

回答 1 投票 0

Spring Webflux：Webclient：获取错误主体

我正在使用 spring webflux 的网络客户端，如下所示： WebClient.create() 。邮政（） .uri(网址) .syncBody(主体) .accept(MediaType.APPLICATION_JSON) ...

java spring spring-webflux reactor

回答 15 投票 0

Project Reactor 中的默认调度程序是什么？

Project Reactor 中是否有“默认”调度程序？哪一个？我所说的“默认”是指当链没有调用 subscribeOn() 或publishOn() 时使用的默认值。

spring-webflux project-reactor reactor

回答 2 投票 0

WebClient 在 Stream 中的每个元素调用上打开和关闭连接

尝试了解 spring webclient 如何处理对等点之间的连接。使用以下代码时：我与流中的元素有尽可能多的密切联系。我正期待着...

java spring-webflux reactor reactor-netty

回答 1 投票 0

是否使用Active对象？

据我了解，活动对象设计模式是将（私有/专用）线程生命周期与对象绑定在一起，并使其在独立数据上工作。从我读过的一些文档来看，

c++ design-patterns boost-asio reactor active-objects

回答 2 投票 0

Webflux - 多次读取单声道（请求）

首先，我很困惑使用反应式处理程序方法参数是否有任何好处。其次，当我需要多次读取这些参数时，我在使用这种技术时遇到了一些问题...

spring-webflux reactor

回答 3 投票 0

如何结合Mono和Flux来创建一个对象？

我想创建一个对象，该对象由一个Mono和一个Flux组成。假设有 2 个服务 getPersonalInfo 和 getFriendsInfo。 Person 需要这两种服务来创建对象。拉链...

java spring-webflux project-reactor reactor reactive-streams

回答 2 投票 0

如何在Java中对Reactor Flux中的元素进行缓冲和分组

给定无限通量的对象，其中每个对象都有一个 ID，我如何使用 Flux 创建按 ID 属性分组的更新缓冲列表（保留最后发出的值）？谢谢例子哦...

java project-reactor reactor

回答 3 投票 0

Reactor多次使用doOnNext

我试图从这里改变一些反应器样本，我对我得到的行为有点困惑。所以首先我这样编码： EmitterProcessor 流 = EmitterProcess...

reactor

回答 2 投票 0

使 Mono 的缓存值失效的最佳方法是什么？

我会尝试尽可能简单地解释我的用例。在我的应用程序中调用外部 Web 服务之前，我使用 Spring Webflux WebC 从令牌提供者请求 oauth 访问令牌...

spring spring-webflux netty reactor

回答 1 投票 0

Spring Reactor Merge 与 Concat

我正在使用 Spring Reactor，我看不出 concat 和 merge 运算符之间有任何区别这是我的例子 @测试公共无效合并（）{ 通量通量1 = 通量.j...

java spring flux reactor

回答 4 投票 0

如何迭代Flux中的对象并对其进行操作？

我正在使用项目反应器，我想执行以下操作： @覆盖公共无效运行（ApplicationArguments args）{ Flux.from(KafkaReceiver.create(receiverOptions) ...

spring-webflux project-reactor reactor reactive-streams

回答 1 投票 0

Mono.defer() 的真实情况是什么？

我知道 Mono.defer() 的作用，但我应该什么时候使用它？我知道其中一个用例是推迟返回 Mono 的函数中的一些阻塞副作用，但这通常是一种不好的做法（

java reactive-programming reactor reactive-streams

回答 3 投票 0

Jenkins/Maven 构建因“无法在反应器中找到所选项目”错误而垂死

我在 Cloudbees 构建服务上使用 Jenkins 并创建了一个多模块 Maven 项目。最近，我们从父 pom 中删除了一个项目，但是，当我们使用以下命令在 Jenkins 中运行构建时......

maven jenkins cloudbees multi-module reactor

回答 1 投票 0

使用 dev.miku 的 R2BC for MYSQL 中的事务

我试图实现简单的事务机制只是为了检查它在使用 dev.miku for Mysql 的反应世界中如何工作但出现以下错误接收类 dev.miku.r2dbc.mysql.MySqlConnect...

spring-boot transactions spring-webflux reactor r2dbc

回答 1 投票 0

什么是工作线程，它们在反应器模式中的作用是什么？

我试图理解 Reactor 模式（并发），但在许多示例中，他们都在谈论“工作线程”。什么是工作线程？它们与“普通”线程有何不同？和

java multithreading design-patterns reactor

回答 2 投票 0

如何过滤空通量

例如，我有以下代码，它创建了一个包含3个数字1,2,3的Mono列表。我想过滤掉数字1。结果将是一个2个数字2,3的列表。我应该在...

project-reactor reactive reactor

回答 1 投票 0

如何用kotlin coroutine在spring flux上实现多租户？

对不起，我的英语不好。我是一个新的春天和kotlin。我试图解决的问题是在kotlin coroutine中获取租户值。我做了一个简单的例子 https:/github.comcardid-zzspring-...

spring kotlin spring-webflux kotlin-coroutines reactor

回答 1 投票 0

Webflux: 重复次数用尽后的OnErrorResume没有被触发。

我试图使用onErrorResume执行重复耗尽后的代码，但onErrorResume没有被触发。以下是代码示例 Mono.just(request) .filter(this::...)

reactive-programming spring-webflux project-reactor reactor reactive-streams

回答 1 投票 0

reactor 相关问题

最新问题