spring-integration - Spring Integration DSL 通道支持

Question

在 spring integration dsl 的当前版本 1.0.2 中，我可以看到一些基本通道不存在，例如 ReST/HTTP、TCP/UDP、JDBC、MQTT 等。

只是想知道这个协议/通道是在路线图中还是被故意排除在外。

PS：我可能对发布的问题听起来很愚蠢，但只是想知道原因。

Answer 1

从一方面你应该明白，解决所有这些问题已经足够大了。例如， HTTP 模块在我们的雷达上1.1发布。

另一方面，Spring Integration Java DSL 只是现有 Spring Java & Annotation 配置的一个版本，因此任何@Bean定义在那里也是有效的。

使用这些所需的协议，您可以继续配置它们的组件，@Bean并从.handle()或.from()EIP 方法中引用它们。

例如：

@Bean
public MessageSource<Object> jdbcMessageSource() {
    return new JdbcPollingChannelAdapter(this.dataSource, "SELECT * FROM foo");
}

@Bean
public IntegrationFlow myFlow() {
   return IntegrationFlows.from(jdbcMessageSource())
                        .split(...)
                        .transform(...)
                        .handle(new MqttPahoMessageHandler("tcp://localhost:1883", "si-test-out"))
                        .get();
}