|
对于最新的稳定版本，请使用 Spring Integration 6.4.3！ |
使用消息流
IntegrationFlowBuilder提供顶级 API 以生成连接到消息流的集成组件。
当您的集成可以通过单个流完成时（通常是这种情况），这很方便。
交互IntegrationFlow实例可以通过MessageChannel实例。
默认情况下，MessageFlow在 Spring 集成的说法中表现为“链”。
也就是说，端点由DirectChannel实例。
消息流实际上并不是作为一个链构建的，这提供了更大的灵活性。
例如，您可以向流中的任何组件发送消息，前提是您知道其inputChannel名称（即，如果您明确定义了它）。
您还可以在流中引用外部定义的通道，以允许使用通道适配器（以启用远程传输协议、文件 I/O 等），而不是直接通道。
因此，DSL 不支持 Spring 集成chain元素，因为它在这种情况下不会增加太多价值。
由于 Spring 集成 Java DSL 生成与任何其他配置选项相同的 bean 定义模型，并且基于现有的 Spring 框架@Configuration基础结构，它可以与 XML 定义一起使用，并与 Spring Integration 消息传递注释配置连接。
您还可以定义 directIntegrationFlow实例。
以下示例显示了如何执行此作：
@Bean
public IntegrationFlow lambdaFlow() {
return f -> f.filter("World"::equals)
.transform("Hello "::concat)
.handle(System.out::println);
}此定义的结果是与隐式直接通道连接的同一组集成组件。
此处的唯一限制是此流从命名的直接渠道 -lambdaFlow.input.
此外，Lambda 流不能从MessageSource或MessageProducer.
从版本 5.1 开始，这种IntegrationFlow包装到代理中，以公开生命周期控制并提供对inputChannel内部关联的StandardIntegrationFlow.
从版本 5.0.6 开始，为IntegrationFlow包括 Flow Bean，后跟一个点 （.） 作为前缀。
例如，ConsumerEndpointFactoryBean对于.transform("Hello "::concat)在前面的示例中，将生成 Bean 名称lambdaFlow.o.s.i.config.ConsumerEndpointFactoryBean#0.
（该o.s.i是org.springframework.integration以适应页面。
这Transformer该端点的实现 Bean 名称为lambdaFlow.transformer#0（从版本 5.1 开始），其中MethodInvokingTransformerclass 时，会使用其组件类型。
相同的模式适用于所有NamedComponents。
这些生成的 Bean 名称前面加上流 ID，用于解析日志或在某些分析工具中将组件分组在一起，以及避免在运行时同时注册集成流时出现争用情况。
有关更多信息，请参阅 动态和运行时集成流 。