reactor 相关问题

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

如何停止pymodbus异步ModbusTcpServer？

我想停止pymodbus异步ModbusTcpServer，然后启动新服务器。因此，我尝试使用以下简化的代码段，但出现错误：从pymodbus.server.async import ...

python python-3.x twisted reactor pymodbus

回答 3 投票 2

与反应堆抛出异常的正确方法

我是新来的工程反应堆和反应式编程一般。我目前正在在一张类似下面的代码：Mono.just（用户ID）.MAP（回购:: findById）.MAP（用户> {如果（...

java reactive-programming project-reactor reactor

回答 1 投票 9

如何把信息使用反应通量/单声道到上游每当它们比用于状态间隔轮询准备好了吗？

试图推动到上游时，他们是使用弹簧的反应磁通间隔消息冲洗后可用/就绪和紧密连接，而不是轮询消息。 @GetMapping（值=“/ ......

java rx-java reactive-programming spring-webflux reactor

回答 2 投票 0

Spring WebFlux带有非流应用程序/ json的Flux行为

我正在使用Spring Webflux进行评估，但我们必须支持希望使用application / json而不是application / stream + json的客户端。我不清楚在...

java spring spring-webflux reactor

回答 1 投票 3

Spring Reactor List >序列到单声道 >

目标是对List进行排序 >到单声道 >。 flatMap的主体是使用Kotlin代码片段中的Mono.block（）来实现的。还有更好的方法......

spring reactor

回答 1 投票 0

Reactor REST Mono返回ScanAvailable：true

我一直在研究使用Reactor的Java微服务，以便更容易地进行异步调用。在我的端点上，我有以下代码：@HystrixCommand @ApiOperation（value =“Resolve Dispute”...

java spring reactor

回答 2 投票 0

反应链中next（）的奇怪行为

首先，这是我的代码：public static void main（String [] args）{List l1 = Arrays.asList（“737”，“747”）;助焊剂 f1 = Flux.fromIterable（l1）;名单

java reactor

回答 1 投票 0

Reactor分页Web服务调用

我在spring项目中使用reactor，我必须调用一个paginated api。 api返回如下内容：{“last”：false，“totalPages”：2，“totalElements”：4178，“sort”：{“...

java spring spring-webflux reactor

回答 2 投票 0

如何在reactor中获取先前传递的变量？

我正在制作一个discord bot作为一个建立在项目反应堆之上的个人项目？我需要调用一个函数，该函数需要获取一个在链中进一步传递的变量。从代码......

java project-reactor reactor

回答 1 投票 0

ReactorNotRestartable错误，如何在for循环中使用scrapy CrawlerProcess

我想用一个子类用不同的url运行我的蜘蛛并通过循环保存信息。这是我的方法：类Run_Spider_From_SubClass：def __init __（self，url_list，* args，** kwargs）：super（）....

python loops scrapy reactor

回答 1 投票 0

如何在Spring WebFlux中的一个Mono中基于另一个请求执行连续的Web请求？

我想通过Spring WebFlux和给定的REST-API执行以下操作：检索文件名列表（GET /文件）删除每个检索到的文件（每个DELETE / files / local / {文件名}）问题是.. 。

java reactive-programming spring-webflux reactor

回答 2 投票 0

如何在反应堆中进行“选择案例”式操作

我正在制作一个需要读取参数列表的discord机器人，并且在给出第一个参数的情况下，让它确定要运行的分支。有点像这样的东西。 Mono.just（stringList）....

project-reactor reactor

回答 1 投票 0

在Reactor中并行调度`groupBy`组

我正在学习Reactor，我想知道如何实现某种行为。假设我有一串传入的消息。每条消息都与某个实体相关联，并包含一些数据。 ...

java event-driven reactor project-reactor

回答 2 投票 3

Spring 5 webflux如何在Webclient上设置超时

我正在尝试在我的WebClient上设置超时，这是当前代码：SslContext sslContext = SslContextBuilder.forClient（）。trustManager（InsecureTrustManagerFactory.INSTANCE）.build（）; ...

spring reactor spring-webflux reactor-netty

回答 5 投票 9

返回插入记录的处理程序

如果我在spring中使用反应式存储库（使用kotlin）并且我想返回插入的记录。我该怎么做？我需要一个运算符，它将订阅flatMap返回的内容，然后将其传递给...

spring kotlin reactor

回答 1 投票 0

以反应方式创建DTO的正确方法是什么？

我使用Spring Boot并且我有一些Reactive API（Controller调用一个基于Mongo Reactive Repositories调用存储库的服务）因为我不希望用户直接看到我的模型对象，我......

spring-boot dto reactive reactor reactor-netty

回答 1 投票 0

同步弹簧webflux调用保持操作顺序

我有一个简单的用例，不知道该怎么做，因为我是新的春天webflux。我正在使用spring boot webflux启动器。我需要调用2个端点。让我们说Endpoint1和Endpoint2。每当......

spring-boot spring-webflux project-reactor reactor

回答 3 投票 0

我需要在没有存储库的情况下使服务无效[关闭]

我的任务是通过使用Flux / Mono使UserService成为被动的。我理解通量和单声道是如何工作的，但只使用存储库而不是arraylists。 UserServiceImpl：@ Slf4j @Service @ ...

java spring-boot reactive-programming project-reactor reactor

回答 1 投票 1

在Java NIO Reactor Pattern中的不同线程中调度事件处理程序

我正在使用Reactor Pattern用java NIO编写一个简单的Server应用程序。据我了解，Reactor类负责收集事件（例如：OP_ACCEPT，OP_READ，OP_WRITE）。 ...

java selector nio reactor

回答 1 投票 0

Spring Reactor：Optional的对应类是什么？

所以我有一个Flux 我想将每个Foo映射到Baz。问题是，getBaz（Foo foo）可能抛出IOException。所以我想要拥有Mono getBazRx（Foo foo）方法将......

java spring reactive-programming project-reactor reactor

回答 2 投票 0

reactor 相关问题

最新问题