project-reactor 相关问题

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

在 Spring WebFlux 中排队请求

在我的 API 中，我有一个调用外部 API 的服务。此外部 API 按请求收取费用。因此我想对外部 API 的请求进行排队。这就是今天的样子： @Compon...

java spring spring-webflux reactive-programming project-reactor

回答 2 投票 0

无法在reactor kafka中使用schemaRegistry

我正在使用reactor kafka设置kafka消费者。 Producer 与 kafka 模式注册表集成 @Value("${spring.kafka.schemaRegistryUrls}") 私有字符串

java apache-kafka project-reactor confluent-schema-registry reactor-kafka

回答 1 投票 0

并行执行缓冲通量上的映射

我有一个变化，所有的值同时出现。我想对这些值的块并行执行一项时间密集型任务。为什么这段代码在同一个线程上执行每个映射......

java spring-webflux project-reactor

回答 1 投票 0

使用 Flux / Executor 服务并发执行一组操作

我有一个场景来处理客户号码列表并更新数据库中的详细信息公共无效updateCustomerDetailsInDB（ListnumberList） for(字符串数字:数字列表){ if(!isExistBy(

spring-boot asynchronous spring-webflux project-reactor threadpoolexecutor

回答 1 投票 0

tcp 连接的消息分块

我目前正在开发一个TCP服务器/客户端应用程序，并且我已经成功建立了服务器和客户端之间的通信。虽然对于小消息来说沟通效果很好，但我

java tcp project-reactor bytebuffer

回答 0 投票 0

项目reactor spring webflux开关

我想知道在 spring webflux 中进行某种切换的最佳实践是什么。我的意思是，假设我需要理解传入参数（例如请求参数），以经典的方式我会写...

spring-webflux project-reactor

回答 0 投票 0

JAVA PROJECT REACTOR CORE 中 TCP 连接的消息分块

我目前正在开发一个TCP服务器/客户端应用程序，并且我已经成功建立了服务器和客户端之间的通信。虽然对于小消息来说沟通效果很好，但我

java tcp blockchain project-reactor bytebuffer

回答 0 投票 0

Flux.doOnEach 和 Flux.doOnNext 与 Flux.publishOn 的不同行为

我试图理解使用 doOnEach 运算符和空 Flux 进行发布的后果。我有一个简单的测试：私有静态无效incrementOnNext（AtomicInteger值，Signal符号...

spring-webflux project-reactor

回答 0 投票 0

使用元组重构 java spring boot 代码

我有一个代码，我想重构它以删除元组，但我不确定如何在其他方法中重用 validateInfractionId 和 validateInfractionVersion 方法中的列表...

java spring-boot spring-webflux project-reactor

回答 0 投票 0

如何使用 R2DBC 继续调试此问题？

我正在使用 Spring 数据生成一个 ReactiveCrudRepository，我正在调用 saveAll。我有一个执行多个 API 请求的集成测试，最后一个更新 3 个实体，使用 saveAl ...

debugging spring-webflux project-reactor spring-data-r2dbc

回答 0 投票 0

具有非阻塞嵌入式资源的 REST API

我正在研究 REST API，对于收集端点，希望 _embedded 数组异步填充。不幸的是，我似乎无法在拥有

rest project-reactor micronaut hateoas

回答 1 投票 0

Mono.just() 在我的用例中当发出的元素挂起时仍然阻塞

我有两个测试使用 sleep() 模拟需要时间处理的 api 调用，并测试 Mono.just() 是否使其成为非阻塞。在我的第一个测试中，我直接发出了一个字符串，但让它阻塞了......

java project-reactor nonblocking reactive-streams

回答 1 投票 0

使用 reactor kafka 消费时丢失的事件

我正在使用 Reactive kafka 来消费事件。问题：我向队列中推送了 7 个事件，但消费者只消费了其中的 5 个。（仅在部署在服务器上时发生，在本地工作正常

reactive-programming spring-kafka project-reactor reactive reactor-kafka

回答 0 投票 0

Spring Cloud Gateway：重写超大请求体

我正在使用 Spring Cloud Gateway 4 来实现代理。它应该做的一件事是，当接受一个大的视频文件时，在将它发送到请求的目的地之前，给它加水印。作为...

java spring-webflux project-reactor spring-cloud-gateway

回答 0 投票 0

处理返回 Flux 的 Spring Integration MessageHandler

我的消息处理程序返回一个通量，理想情况下，我希望 spring 集成来处理阻塞/订阅通量，以便我下面的第二个处理程序获得已解析的对象。但是当以下...

spring-boot spring-integration spring-webflux project-reactor spring-integration-dsl

回答 1 投票 0

响应式平面图发送不使用“并发”参数缩放的 http 请求

我想要达到的目标：将尽可能多的 http 请求并行地从一个积极的 Flux 发送到一个非常可靠的第三方服务背景：第三方服务很靠谱。。。

java spring-webflux project-reactor spring-webclient flatmap

回答 1 投票 0

Reactor Kafka 优雅关闭和暂停消费者

Spring Application使用Reactor Kafka消费消息。问题 1：是否有标准约定在应用程序关闭期间暂停消息消费并完成处理动态消息？

kafka-consumer-api spring-kafka project-reactor spring-webclient graceful-shutdown

回答 1 投票 0

如何在Spring Cloud Gateway中对外部API进行身份验证，然后再将请求转发给它的命运？

Spring Cloud Gateway 似乎是在将请求转发到后端之前执行某种验证（特别是身份验证检查）的有效工具，但我找不到太多重点教程...

java spring-webflux project-reactor spring-cloud-gateway spring-webclient

回答 0 投票 0

线程 reactor-http-nio 长时间计算某些东西并消耗 CPU 和内存

我们有一个服务，我们通过 websocket 连接并从中接收消息。我们更新了 Spring Boot 3.0.6、reactor: 1.1.6、reactor-core 3.5.5 服务的依赖项。连接后...

project-reactor reactor-netty

回答 0 投票 0

Reactor-netty：Theads reactor-http-nio 长时间计算一些东西并消耗 cpu 和内存

我们有一个服务，我们通过 websocket 连接并从中接收消息。我们更新了 spring boot 3.0.6、reactor: 1.1.6、reactor-core 3.5.5 服务的依赖项。还有一个公关...

project-reactor reactor-netty

回答 0 投票 0

project-reactor 相关问题

最新问题