弹簧集成反应器

Question

阿特姆很高兴看到一个新版本的si。在春季集成流程中是否可以使用反应堆或rxjava？像这样

例如:使用collection=>reactive拆分器->无功变压器->无功出站输入xml

Answer 1

首先，感谢您的反馈和对我们工作的关注。我们正试图跟随现实世界的趋势，继续前进，永远及时;-)

关于反应器或类似的反应流溶液。

我确信这将是一个好主意，做你的“划痕”流。即使看起来像反应性流，我们以这种方式组合它们也无关紧要。

首先，Spring是一个“托管”流，它需要Spring，所以如果您想将它与反应堆结合起来，您应该可以从提供Stream的代码中访问Spring。另一方面，为了从Spring访问反应堆Stream，我们应该最终使它成为Spring。

即将发布的SpringIntegration4.1引入了Promise Gateway。因此，如果您的Controller或Service是Spring，并且代码是通过反应器Stream编写的，那么您就可以使用网关接口访问-集成流的结果将作为一个Event填充到下一个Stream。

当您需要Spring的push操作而不是pull时，您也可以做类似的事情。

假设您有反应堆Deffered bean：

@Bean
public Deffered<Integer, Stream<Integer>> reactorStream() {
    Deferred<Integer, Stream<Integer>> stream = Streams.<Integer>defer(new Environment());
    stream.compose().collect(5).timeout(1000);
    return stream;
}

之后，我们可以继续从channel-adapter中使用它。

<outbound-channel-adapter channel="reactorStreamChannel" ref="reactorStream" method="accept"/>

无论如何，我不建议总是从一个“世界”跳到“另一个世界”，因为我们可能会从这两个世界中失去最好的。或者说反应堆流是一种主流，全是弹簧集成。

我很高兴听到我们反应堆团队的一些其他想法:-)。