如何创建自定义组件并将其添加到Spring Java dsl中的flow中？

Question

我想创建一个客户组件 trace（） 并希望在流程中使用它。

类似于 CustomFlows.from（“”）.trace（）.get（）;

你能建议我怎么做吗？似乎集成流定义是封闭的，不可扩展。

Answer 1

这是一个有趣的技术...但是现在我不相信我们应该允许FlowBuilder进行这样的扩展......请随时就此事提出GitHub问题，我们将来会看到如何处理。

对于这样的扩展，您应该了解框架如何在后台工作。

让我们考虑最简单的组件 .bridge（）！它的目标是将消息从一个通道传输到另一个通道。因此，此组件是请求-答复类型，必须与其两侧的两个通道绑定：

.channel()
.bridge()
.channel()

当然，DSL可以在那些我们没有明确定义的地方创建DirectChannel。或者，如果我们以结束 - .get（） 完成流程，我们也可以依赖 replyChannel 标头。等等。

BridgeHandler 是一个开箱即用的组件，这就是我们为它提供显式 DSL 方法的原因。

但从另一边来看，它有非常简单的代码：

public class BridgeHandler extends AbstractReplyProducingMessageHandler {

    @Override
    public String getComponentType() {
        return "bridge";
    }

    @Override
    protected Object handleRequestMessage(Message<?> requestMessage) {
        return requestMessage;
    }

    @Override
    protected boolean shouldCopyRequestHeaders() {
        return false;
    }
}

如您所见，它是一个消息处理程序实现，因此我们可以直接像这样使用它：

.handle(new BridgeHandler())

从这里开始，我向您提出的问题是：如果您可以使用现有功能满足您的要求，那么给框架带来一些复杂性的原因是什么：实现MessageHandler，扩展AbstractPayloadTransformer。或者甚至只是忘记它们，并使用 POJO 方法调用执行所有操作，就像从 DSL 1.1 开始的这样：

@Override
protected IntegrationFlowDefinition<?> buildFlow() {
        return from(this, "messageSource", e -> e.poller(p -> p.trigger(this::nextExecutionTime)))
                .split(this)
                .transform(this)
                .aggregate(a -> a.processor(this, null), null)
                .enrichHeaders(Collections.singletonMap("foo", "FOO"))
                .filter(this)
                .handle(this)
                .channel(c -> c.queue("myFlowAdapterOutput"));
    }

请参阅我关于此事的文章。

所以，你应该找到很多论据来说服我以这种方式扩展框架：-）。