可以在 Spring 与 Project Reactor 的集成中使用 DirectChannel 而不阻塞吗？

Question

documentation of Spring Integration specifies that 上下文中的FluxMessageChannel：

为了实现整个集成流程的完全反应性行为， 这样的通道必须放置在流中的所有端点之间。

这让我想到在使用 Reactive Streams 时是否也可以使用DirectChannel，或者它会导致事件循环出现任何问题？

Answer 1

这取决于订阅DirectChannel 的MessageHandler 的阻塞程度。其目的是直接在已向此DirectChannel 发送消息的线程上调用MessageHandler。所以，如果你做.map(e -> directChannel.send(e))，你需要确保MessageHandler没有被阻塞。