此版本仍在开发中，尚不被认为是稳定的。对于最新的稳定版本，请使用 Spring Integration 6.5.1！spring-doc.cadn.net.cn

消息传递元注释

从 V4.0 开始，所有消息传递注释都可以配置为元注释，并且所有用户定义的消息传递注释都可以定义相同的属性来覆盖其默认值。此外，元注释可以分层配置，如以下示例所示：spring-doc.cadn.net.cn

@Target({ElementType.METHOD, ElementType.ANNOTATION_TYPE})
@Retention(RetentionPolicy.RUNTIME)
@ServiceActivator(inputChannel = "annInput", outputChannel = "annOutput")
public @interface MyServiceActivator {

    String[] adviceChain = { "annAdvice" };
}

@Target({ElementType.METHOD, ElementType.ANNOTATION_TYPE})
@Retention(RetentionPolicy.RUNTIME)
@MyServiceActivator
public @interface MyServiceActivator1 {

    String inputChannel();

    String outputChannel();
}
...

@MyServiceActivator1(inputChannel = "inputChannel", outputChannel = "outputChannel")
public Object service(Object payload) {
   ...
}

分层配置元注释允许用户为各种属性设置默认值，并允许将框架 Java 依赖项隔离到用户注释，从而避免在用户类中使用它们。如果框架找到具有具有框架元注释的用户注释的方法，则将其视为直接使用框架注释注释该方法。spring-doc.cadn.net.cn

注释`@Bean`方法

从 4.0 版开始，您可以在@Bean方法定义@Configuration类，以基于 bean（而不是方法）生成消息端点。当以下情况时，它很有用@Bean定义是“开箱即用”MessageHandler实例（AggregatingMessageHandler,DefaultMessageSplitter等），Transformer实例（JsonToObjectTransformer,ClaimCheckOutTransformer等），以及MessageSource实例（FileReadingMessageSource,RedisStoreMessageSource等）。以下示例演示如何将消息传递注释与@Bean附注：spring-doc.cadn.net.cn

@Configuration
@EnableIntegration
public class MyFlowConfiguration {

    @Bean
    @InboundChannelAdapter(value = "inputChannel", poller = @Poller(fixedDelay = "1000"))
    public MessageSource<String> consoleSource() {
        return CharacterStreamReadingMessageSource.stdin();
    }

    @Bean
    @Transformer(inputChannel = "inputChannel", outputChannel = "httpChannel")
    public ObjectToMapTransformer toMapTransformer() {
        return new ObjectToMapTransformer();
    }

    @Bean
    @ServiceActivator(inputChannel = "httpChannel")
    public HttpRequestExecutingMessageHandler httpHandler() {
    HttpRequestExecutingMessageHandler handler = new HttpRequestExecutingMessageHandler("https://foo/service");
        handler.setExpectedResponseType(String.class);
        handler.setOutputChannelName("outputChannel");
        return handler;
    }

    @Bean
    @ServiceActivator(inputChannel = "outputChannel")
    public LoggingHandler loggingHandler() {
        return new LoggingHandler("info");
    }

}

5.0 版引入了对@Bean注释为@InboundChannelAdapter返回java.util.function.Supplier，它可以生成 POJO 或Message. 以下示例演示如何使用该组合：spring-doc.cadn.net.cn

@Configuration
@EnableIntegration
public class MyFlowConfiguration {

    @Bean
    @InboundChannelAdapter(value = "inputChannel", poller = @Poller(fixedDelay = "1000"))
    public Supplier<String> pojoSupplier() {
        return () -> "foo";
    }

    @Bean
    @InboundChannelAdapter(value = "inputChannel", poller = @Poller(fixedDelay = "1000"))
    public Supplier<Message<String>> messageSupplier() {
        return () -> new GenericMessage<>("foo");
    }
}

元注释规则适用于@Bean方法（@MyServiceActivator前面描述的注释可以应用于@Bean定义）。spring-doc.cadn.net.cn

当您在消费者上使用这些注释时@Bean定义，如果 Bean 定义返回适当的MessageHandler（取决于注释类型），您必须设置属性（例如outputChannel,requiresReply,order等），在MessageHandler @Bean定义本身。仅使用以下注释属性：adviceChain,autoStartup,inputChannel,phase和poller. 所有其他属性都用于处理程序。

Bean 名称是使用以下算法生成的：

这MessageHandler (MessageSource) @Bean从方法名称中获取自己的标准名称或name属性@Bean. 这就像@Bean方法。spring-doc.cadn.net.cn
这AbstractEndpointbean name 使用以下模式生成：[@Bean name].[decapitalizedAnnotationClassShortName]. 例如，SourcePollingChannelAdapterendpoint 的consoleSource()前面显示的定义的 bean 名称为consoleSource.inboundChannelAdapter. 与 POJO 方法不同，Bean 方法名称不包含在端点 Bean 名称中。另请参阅端点 Bean 名称。spring-doc.cadn.net.cn
如果@Bean不能直接在目标端点中使用（不是MessageSource,AbstractReplyProducingMessageHandler或AbstractMessageRouter），分别AbstractStandardMessageHandlerFactoryBean已注册以委托此@Bean. 此包装器的 bean 名称是使用以下模式生成的：[@Bean name].[decapitalizedAnnotationClassShortName].[handler (or source)].spring-doc.cadn.net.cn

在@Bean定义，则inputChannel必须引用声明的 bean。如果应用程序上下文中尚不存在通道，则会自动声明通道。

使用 Java 配置，您可以使用任何@Conditional（例如，@Profile）定义@Bean方法级别出于某种条件原因跳过 bean 注册。以下示例显示了如何执行此作：spring-doc.cadn.net.cn

@Bean
@ServiceActivator(inputChannel = "skippedChannel")
@Profile("thing")
public MessageHandler skipped() {
    return System.out::println;
}

与现有的 Spring 容器逻辑一起，消息传递端点 bean（基于@ServiceActivator注释），也未注册。spring-doc.cadn.net.cn

创建带有注释的桥梁

从 4.0 版开始，Java 配置提供了@BridgeFrom和@BridgeTo @Bean要标记的方法注释MessageChannel豆子在@Configuration类。这些确实是为了完整性而存在的，提供了一种方便的机制来声明BridgeHandler及其消息端点配置：spring-doc.cadn.net.cn

@Bean
public PollableChannel bridgeFromInput() {
    return new QueueChannel();
}

@Bean
@BridgeFrom(value = "bridgeFromInput", poller = @Poller(fixedDelay = "1000"))
public MessageChannel bridgeFromOutput() {
    return new DirectChannel();
}
@Bean
public QueueChannel bridgeToOutput() {
    return new QueueChannel();
}

@Bean
@BridgeTo("bridgeToOutput")
public MessageChannel bridgeToInput() {
    return new DirectChannel();
}

您也可以将这些注释用作元注释。spring-doc.cadn.net.cn

为带注释的端点提供建议

请参阅使用注释通知端点。spring-doc.cadn.net.cn

消息传递元注释

注释@Bean方法

创建带有注释的桥梁

为带注释的端点提供建议

注释`@Bean`方法