DSL 基础知识 (DSL Basics) _ Spring Integration6.2.10-SNAPSHOT中文文档(官方文档中文翻译)|Spring 教程 —

此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 Spring Integration 6.3.4！spring-doc.cn

该包包含前面提到的 API 和许多实现，这些实现也是构建器，并提供 Fluent API 来配置具体端点。该基础设施为基于消息的应用程序（例如通道、终端节点、轮询程序和通道拦截器）提供通用的企业集成模式（EIP）。org.springframework.integration.dslIntegrationFlowBuilderIntegrationComponentSpecIntegrationFlowBuilderspring-doc.cn

重要: 这是一个实现，因此不能从 bean 定义中调用其方法。对于 Bean 定义，实现必须保持原样，框架将管理其生命周期。目标类型（值）的 Bean 方法参数注入必须用于 Bean 定义，而不是 Bean 方法引用。IntegrationComponentSpecFactoryBeangetObject()IntegrationComponentSpecIntegrationComponentSpecFactoryBeanIntegrationFlowspring-doc.cn

端点在 DSL 中表示为动词，以提高可读性。以下列表包括常见的 DSL 方法名称和关联的 EIP Endpoint：spring-doc.cn

转换→Transformerspring-doc.cn
筛选→Filterspring-doc.cn
手柄 →ServiceActivatorspring-doc.cn
拆分→Splitterspring-doc.cn
聚合→Aggregatorspring-doc.cn
路线 →Routerspring-doc.cn
桥接→Bridgespring-doc.cn

从概念上讲，集成流程是通过将这些端点组合成一个或多个消息流来构建的。请注意，EIP 并未正式定义术语“消息流”，但将其视为使用众所周知的消息传递模式的工作单元会很有用。 DSL 提供了一个组件来定义通道和它们之间的端点的组合，但现在只扮演配置角色，在应用程序上下文中填充真实的 bean，并且在运行时不使用。但是，bean for 可以自动连接为 to control 和 for 整个 flow，它被委托给与此关联的所有 Spring Integration 组件。以下示例使用 Fluent API 通过使用 EIP-methods 来定义 bean：IntegrationFlowIntegrationFlowIntegrationFlowLifecyclestart()stop()IntegrationFlowIntegrationFlowIntegrationFlowIntegrationFlowBuilderspring-doc.cn

@Bean
public IntegrationFlow integerFlow() {
    return IntegrationFlow.from("input")
            .<String, Integer>transform(Integer::parseInt)
            .get();
}

该方法接受 lambda 作为终端节点参数，以对消息负载进行操作。此方法的真正参数是实例。因此，这里可以使用任何提供的转换器（，，和其他）。transformGenericTransformer<S, T>ObjectToJsonTransformerFileToStringTransformerspring-doc.cn

在后台，可识别它的和终端节点，分别使用和。考虑另一个例子：IntegrationFlowBuilderMessageHandlerMessageTransformingHandlerConsumerEndpointFactoryBeanspring-doc.cn

@Bean
public IntegrationFlow myFlow() {
    return IntegrationFlow.from("input")
                .filter("World"::equals)
                .transform("Hello "::concat)
                .handle(System.out::println)
                .get();
}

前面的示例组成了一系列 . 流程是 “'单向'”。也就是说，它不提供回复消息，而只将有效负载打印到 STDOUT。终端节点使用直接通道自动连接在一起。Filter → Transformer → Service Activatorspring-doc.cn

Lambda 和参数Message<?>

在 EIP 方法中使用 lambda 表达式时，“input” 参数通常是消息负载。如果要访问整个消息，请使用将 a 作为第一个参数的重载方法之一。例如，this 将不起作用：Class<?>spring-doc.cn

.<Message<?>, Foo>transform(m -> newFooFromMessage(m))

这在运行时将失败，因为 lambda 不保留参数类型，并且框架将尝试将有效负载转换为 .ClassCastExceptionMessage<?>spring-doc.cn

相反，请使用：spring-doc.cn

.(Message.class, m -> newFooFromMessage(m))

Lambda 和参数Message<?>

.<Message<?>, Foo>transform(m -> newFooFromMessage(m))

这在运行时将失败，因为 lambda 不保留参数类型，并且框架将尝试将有效负载转换为 .ClassCastExceptionMessage<?>spring-doc.cn

相反，请使用：spring-doc.cn

.(Message.class, m -> newFooFromMessage(m))

Bean 定义覆盖

Java DSL 可以为流定义中内联定义的对象注册 bean，也可以重用现有的注入的 bean。如果为内联对象和现有 bean 定义定义了相同的 bean 名称，则会抛出 a，指示此类配置是错误的。但是，在处理 bean 时，无法从集成流处理器中检测现有的 bean 定义，因为每次我们从调用 bean 时，都会得到一个新实例。这样，提供的实例就可以按原样使用，而无需任何 bean 注册，也不需要对现有 bean 定义进行任何可能的检查。但是，如果此对象具有显式，并且此名称的 bean 定义在范围内，则为此对象调用。BeanDefinitionOverrideExceptionprototypeprototypeBeanFactoryIntegrationFlowprototypeBeanFactory.initializeBean()idprototypespring-doc.cn

Bean 定义覆盖