对于最新的稳定版本，请使用 Spring Integration 6.4.0！spring-doc.cn

消息通道

除了 with EIP 方法之外，Java DSL 还提供了一个 Fluent API 来配置实例。为此，提供了 builder factory。以下示例演示如何使用它：IntegrationFlowBuilderMessageChannelMessageChannelsspring-doc.cn

@Bean
public PriorityChannelSpec priorityChannel() {
    return MessageChannels.priority(this.mongoDbChannelMessageStore, "priorityGroup")
                        .interceptor(wireTap());
}

同一个构建器工厂可以在 EIP 方法 from to wire endpoints 中使用，类似于在 XML 配置中连接 / 对。默认情况下，端点与 Bean 名称基于以下模式的实例连接：。此规则也适用于内联构建器工厂使用生成的未命名通道。但是，所有方法都有一个变体，该变体知道，您可以使用它来设置实例的 bean 名称。引用和可以用作 bean 方法调用。以下示例显示了使用 EIP 方法的可能方法：MessageChannelschannel()IntegrationFlowBuilderinput-channeloutput-channelDirectChannel[IntegrationFlow.beanName].channel#[channelNameIndex]MessageChannelsMessageChannelschannelIdMessageChannelMessageChannelbeanNamechannel()spring-doc.cn

@Bean
public QueueChannelSpec queueChannel() {
    return MessageChannels.queue();
}

@Bean
public PublishSubscribeChannelSpec<?> publishSubscribe() {
    return MessageChannels.publishSubscribe();
}

@Bean
public IntegrationFlow channelFlow() {
    return IntegrationFlow.from("input")
                .fixedSubscriberChannel()
                .channel("queueChannel")
                .channel(publishSubscribe())
                .channel(MessageChannels.executor("executorChannel", this.taskExecutor))
                .channel("output")
                .get();
}

from("input")表示 “'查找并使用 '输入' ID 的，或创建一个 ID'”。MessageChannelspring-doc.cn
fixedSubscriberChannel()生成的实例并使用名称 .FixedSubscriberChannelchannelFlow.channel#0spring-doc.cn
channel("queueChannel")工作方式相同，但使用现有的 Bean。queueChannelspring-doc.cn
channel(publishSubscribe())是 Bean 方法引用。spring-doc.cn
channel(MessageChannels.executor("executorChannel", this.taskExecutor))是公开并将其注册为的。IntegrationFlowBuilderIntegrationComponentSpecExecutorChannelexecutorChannelspring-doc.cn
channel("output")将 Bean 注册为其名称，只要不存在具有此名称的 Bean。DirectChanneloutputspring-doc.cn

注意：前面的定义是有效的，它的所有通道都应用于具有实例的终端节点。IntegrationFlowBridgeHandlerspring-doc.cn

请注意，通过工厂从不同的实例使用相同的内联通道定义。即使 DSL 解析器将不存在的对象注册为 bean，它也无法从不同的容器中确定相同的对象（）。以下示例是错误的：MessageChannelsIntegrationFlowMessageChannelIntegrationFlow

@Bean
public IntegrationFlow startFlow() {
    return IntegrationFlow.from("input")
                .transform(...)
                .channel(MessageChannels.queue("queueChannel"))
                .get();
}

@Bean
public IntegrationFlow endFlow() {
    return IntegrationFlow.from(MessageChannels.queue("queueChannel"))
                .handle(...)
                .get();
}

该错误示例的结果是以下异常：spring-doc.cn

Caused by: java.lang.IllegalStateException:
Could not register object [queueChannel] under bean name 'queueChannel':
     there is already object [queueChannel] bound
	    at o.s.b.f.s.DefaultSingletonBeanRegistry.registerSingleton(DefaultSingletonBeanRegistry.java:129)

要使其工作，您需要为该通道声明并从不同的实例中使用其 bean 方法。@BeanIntegrationFlowspring-doc.cn