问题标签 [reactor-netty]

编辑：已解决。使用 spring-boot 2.1.0 运行网关，升级到 2.1.3 并解决了问题。

移植遗留 grails 应用程序以在 spring 云网关代理后面运行。事情似乎在 HTTP 上运行良好，但是当我们启用 SSL 并使用 HTTPS 时，我们会看到间歇性错误。

• 在端口上运行的网关8443
• myApp在端口上运行9006

网关配置摘录：

启动网关和应用程序，并尝试导航到https://localhost:8443/myApp导致浏览器挂起，从未收到响应。网关日志显示：

它只是在之后停止Writing object MonoJust。这仅在第一次尝试通过网关访问应用程序时发生。按下刷新，请求完成：

关于为什么它卡在第一个请求的响应上，但后续请求有效的任何想法？

也就是说，任何具有重定向的 POST 请求都会卡在重定向的同一位置：

日志

重定向到

再一次，日志记录就停在那里，调用者永远不会收到响应。

我使用骆驼反应流，我想APPLICATION_JSON_UTF8_VALUE为响应添加内容类型。我试图将它添加到地图功能中。这是我的代码。

此代码仅返回没有标题“内容类型”的文本我想我不明白它是如何工作的，所以如果有人可以给我发送一个带有教程的链接（因为我找不到），或者有人可以帮助我理解，那就太好了它。谢谢你的帮助

what to do? ReadFlushMessage () will wait for this. message to get new content.

Not quitting the websocket connection immediately

我们必须在 application.properties 中设置什么日志级别才能在控制台中从 reactor-netty看到完整的 HTTP 请求和响应以及标头和正文作为十六进制转储？

仅显示响应 http 标头。

我正在尝试使用从 websocket 读取数据，ReactorNettyWebSocketClient但我无法连接到它的 api。问题是我收到的所有数据都在 lambda 样式 websockethandler 的内部可用（#1），但我想在 client.execute(..) 上的 .subscribe 之后将它们提供给订阅者（#2）

对此有点迷茫和陌生，所以，请指导我。

我使用 SpringBoot 并且我有一些反应式 API（控制器调用一个服务，该服务调用基于 MongoReactiveRepositories 的存储库）

因为我不希望用户直接看到我的模型对象，所以我想要 DTO。

一个 DTO 可以基于多个模型的信息。

例如：给定两个模型项目

我想创建一个 DTO 项目

在我的对象模型和 DTO 之间响应式映射数据的正确方法是什么？

我想通过 udp 客户端一次发送大量 udp 消息，但演示只发送一条消息。我该如何实现呢？

使用演示代码，我只能发送有限数量的消息。我想使用一段时间（真）来发送消息，我该如何实现呢？

public static void main(String[] args) { Connection connection = UdpClient.create() .host("localhost") .port(8080) .handle((udpInbound, udpOutbound) -> { return udpOutbound.sendString(Mono.just ("end")).sendString(Mono.just("end1")).sendString(Mono.just("end2")); }) .connectNow(Duration.ofSeconds(30)); 连接.onDispose() .block(); }

我正在尝试升级 spring boot，看起来 reactor-netty 已经删除了 reactor.ipc 包及其所有类。我正在尝试找到一个文档/指针，它可以帮助我了解 reactor.ipc 包的新等效项。

我查看了：https ://github.com/reactor/reactor-netty/releases 0.8.0 版本的新增部分（实际上删除了这些类/包），但没有可用的链接。

如果有文档或注释可以帮助从 0.7.x 过渡到 0.8.x 版本，我将不胜感激。

我已经实现了一项服务，它使 ReST 调用其他服务来实现其部分功能。我WebClient为此使用了反应式，例如：

现在...我在 中处理 HTTP 状态someResponseHandler::handleResponse，但我真正想知道的是，还有哪些其他类型的异常/错误可以从exchange()- 即

• 如果我根本无法连接到下游服务，我会得到什么异常/错误？
• 如果连接尝试超时，我会得到哪些异常/错误？
• 如果我可以连接但在我得到响应之前请求超时，我会得到什么异常/错误？

显然，这些都不是 HTTP 状态代码 - 但我找不到任何文档来告诉我可以查找的内容。我只是没有找对地方吗？我查看了响应式 WebClient 的文档，并查看了 Reactor Netty 参考指南，但没有运气。

作为背景，这很重要，因为我们进行基于 HATEOAS 的服务发现——对于其中一些异常，我想触发重新发现，对于其中一些，我不这样做。

I am using springboot webclient to call rest api from remote server. First request works fine. If I made subsequent request after sometime, the server throws 500 server error. The error I got is " onError(java.io.IOException: An existing connection was forcibly closed by the remote host)".

I want to test the behavior with disabling connection pool since I believe it uses the previous connection. Can you help me how to disable the connection pool when creating webclient?