我正在学习调度程序是如何工作的。所以我尝试将数字设置为 100。使用 publishOn 它可以工作（它将数字设置为 100），但是使用 subscribeOn 它没有将数字设置为 100。我不明白为什么？

更新：添加一些代码后，我发现结果不一致。

时emiiter.next(dataBuffer)，我无法从 webflux 服务器获得响应。

什么时候emitter.complete()，我得到一个总的回应。我想实时获得流媒体，我该怎么做？

这是查询：

这就是错误

在这里，我尝试从数据库中调用并从不同的单声道和通量组合成新的单声道。

在这里，我为标题（如电影）和详细信息（如电影评论）两次调用 db 以将它们分开。在我检索两个不同的数据后，我想加入基于通量数据和单声道的新单声道数据。为了使它们成为一个数据，我使 DTO 将电影表和评论表放在一起，但它失败了。我假设 mono.zip 中的错误将数据放入一个新的单声道。

这是来自调试控制台的错误

谢谢

我在 reactor-kafka 中找不到任何 json 序列化程序，所以我使用org.springframework.kafka.support.serializer.JsonSerializer 我也尝试使用com.fasterxml.jackson.databind.annotation.JsonSerialize，但它没有用。任何机构都可以帮助我吗？我想使用一些标准的 JSON 序列化器，所以可以用其他语言编写的其他服务可以读取数据而不会出现严重问题。

我的配置类

我的发件人方法

我的数据类

我的 build.gradle 文件的一部分

我收到这样的错误

当使用WebClient的exchangeToMono()主体检索部分总是返回一个空的 Mono：

示例，返回非空 Mono的公开服务

WebClient 与.retrieve()

WebClient 与.exchangeToMono()

难道我做错了什么？

我目前正在使用spring boot webflux进行开发。我正在使用 websocket 客户端和 API 客户端，但在部署后几个小时会出现此错误。我无法弄清楚这个错误来自哪里。这个问题从何而来？

错误日志如下。

有时还会发现破碎的字符以及句子“文本为空”。如果这是一个编码问题，我应该如何设置它？

我需要用图像 jpeg 数据来响应

它可以工作，但控制台中出现错误：

同样的方法适用于spring-boot-starter-web.

不幸的是，我找不到如何使用 spring boot + kotlin + webflux 的文档