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

注释支持

除了用于配置消息端点的 XML 名称空间支持之外，您还可以使用注释。 首先，Spring Integration 提供了类级@MessageEndpoint作为构造型注释，这意味着它本身使用 Spring 的@Component注解，因此被 Spring 的组件扫描自动识别为 bean 定义。spring-doc.cadn.net.cn

更重要的是各种方法级 Comments。 它们指示带注释的方法能够处理消息。 以下示例演示了类级和方法级 Comments：spring-doc.cadn.net.cn

@MessageEndpoint
public class FooService {

    @ServiceActivator
    public void processMessage(Message message) {
        ...
    }
}

“处理”Message 的方法的确切含义取决于特定的 Comments。 Spring Integration 中可用的 Comments 包括：spring-doc.cadn.net.cn

如果您将 XML 配置与注解结合使用，则@MessageEndpoint注释不是必需的。 如果要从ref属性<service-activator/>元素中，您只能提供方法级注解。 在这种情况下，注解可以防止歧义，即使<service-activator/>元素。

在大多数情况下，带注解的处理程序方法不应要求Messagetype 作为其参数。 相反，method 参数类型可以与消息的有效负载类型匹配，如下例所示：spring-doc.cadn.net.cn

public class ThingService {

    @ServiceActivator
    public void bar(Thing thing) {
        ...
    }

}

当 method 参数应从MessageHeaders，另一个选项是使用 parameter-level@Header注解。 通常，使用 Spring 集成注释注释的方法可以接受Message本身、消息负载或标头值（使用@Header） 作为参数。 实际上，该方法可以接受组合，如下例所示：spring-doc.cadn.net.cn

public class ThingService {

    @ServiceActivator
    public void otherThing(String payload, @Header("x") int valueX, @Header("y") int valueY) {
        ...
    }

}

您还可以使用@Headers注解将所有消息标头作为Map，如下例所示：spring-doc.cadn.net.cn

public class ThingService {

    @ServiceActivator
    public void otherThing(String payload, @Headers Map<String, Object> headerMap) {
        ...
    }

}
注释的值也可以是 SPEL 表达式（例如，someHeader.toUpperCase()），当您希望在注入 header 值之前对其进行作时，这非常有用。 它还提供了一个可选的required属性，该属性指定属性值是否必须在标头中可用。 的requiredproperty 为true.

对于其中几个注释，当消息处理方法返回非 null 值时，终端节点会尝试发送回复。 这在两个配置选项（namespace 和 annotations）中是一致的，因为使用了这种端点的输出通道（如果可用），并且REPLY_CHANNELmessage header 值用作回退。spring-doc.cadn.net.cn

端点上的输出通道和回复通道消息头的组合支持管道方法，其中多个组件有一个输出通道，最终组件允许将回复消息转发到回复通道（如原始请求消息中指定）。 换句话说，最终组件取决于原始发送方提供的信息，并且可以动态支持任意数量的客户端。 这是返回地址模式的一个示例。

除了此处显示的示例之外，这些注解还支持inputChannel和outputChannel属性，如下例所示：spring-doc.cadn.net.cn

@Service
public class ThingService {

    @ServiceActivator(inputChannel="input", outputChannel="output")
    public void otherThing(String payload, @Headers Map<String, Object> headerMap) {
        ...
    }

}

这些 Comments 的处理将创建与相应的 XML 组件相同的 bean——AbstractEndpointinstances 和MessageHandler实例（或MessageSource实例）。 看注释@Bean方法. Bean 名称由以下模式生成：[componentName].[methodName].[decapitalizedAnnotationClassShortName]. 在前面的示例中，Bean 名称为thingService.otherThing.serviceActivator对于AbstractEndpoint和相同的名称，并附加一个.handler (.source） 后缀的MessageHandler (MessageSource） bean 的 Bean 中。 这样的名称可以使用@EndpointId注释以及这些消息注释。 这MessageHandler实例 （MessageSource实例）也有资格被消息历史记录跟踪。spring-doc.cadn.net.cn

从版本 4.0 开始，所有消息收发注释都提供SmartLifecycle选项 （autoStartup和phase） 以允许对应用程序上下文初始化进行终端节点生命周期控制。 它们默认为true和0分别。 要更改终端节点的状态（例如start()或stop()），您可以使用BeanFactory（或自动装配）并调用方法。 或者，您可以向 Control Bus 发送命令消息。 为此，您应该使用beanName前面在上一段中提到过。spring-doc.cadn.net.cn

在解析上述注释后自动创建的通道（当没有配置特定的通道 bean 时）和相应的消费者端点，在上下文初始化结束时被声明为 bean。 这些 bean 可以在其他服务中自动连接，但它们必须用@Lazyannotation 的 Comments，因为在正常的 autowire 处理过程中，定义通常还不可用。spring-doc.cadn.net.cn

@Autowired
@Lazy
@Qualifier("someChannel")
MessageChannel someChannel;
...

@Bean
Thing1 dependsOnSPCA(@Qualifier("someInboundAdapter") @Lazy SourcePollingChannelAdapter someInboundAdapter) {
    ...
}

从版本 6.0 开始，所有消息传递注释都是@Repeatable现在，可以在同一个 service method 上声明几个相同类型的 Token，其含义是创建与这些 Comments 重复的 Endpoints 一样多的 Endpoints：spring-doc.cadn.net.cn

@Transformer(inputChannel = "inputChannel1", outputChannel = "outputChannel1")
@Transformer(inputChannel = "inputChannel2", outputChannel = "outputChannel2")
public String transform(String input) {
    return input.toUpperCase();
}

使用@Poller注解

在 Spring Integration 4.0 之前，消息传递注释要求inputChannel是对SubscribableChannel. 为PollableChannel实例、<int:bridge/>元素来配置<int:poller/>并将复合端点设为PollingConsumer. 版本 4.0 引入了@Poller注解以允许配置poller属性，如下例所示：spring-doc.cadn.net.cn

public class AnnotationService {

    @Transformer(inputChannel = "input", outputChannel = "output",
        poller = @Poller(maxMessagesPerPoll = "${poller.maxMessagesPerPoll}", fixedDelay = "${poller.fixedDelay}"))
    public String handle(String payload) {
        ...
    }
}

这@Pollerannotation 仅提供简单的PollerMetadata选项。 您可以配置@Poller注解的属性 （maxMessagesPerPoll,fixedDelay,fixedRate和cron） 替换为属性占位符。 此外，从版本 5.1 开始，receiveTimeout选项PollingConsumers 的 如果需要提供更多轮询选项（例如，transaction,advice-chain,error-handler等），您应该配置PollerMetadata作为通用 Bean 使用，并使用其 Bean 名称作为@Poller的value属性。 在这种情况下，不允许使用其他属性（必须在PollerMetadatabean） 的 Bean 的 注意，如果inputChannel是一个PollableChannel没有@Poller，则默认的PollerMetadata（如果它存在于应用程序上下文中）。 要使用@Configurationannotation 中，请使用类似于以下示例的代码：spring-doc.cadn.net.cn

@Bean(name = PollerMetadata.DEFAULT_POLLER)
public PollerMetadata defaultPoller() {
    PollerMetadata pollerMetadata = new PollerMetadata();
    pollerMetadata.setTrigger(new PeriodicTrigger(10));
    return pollerMetadata;
}

下面的示例展示了如何使用默认 Poller：spring-doc.cadn.net.cn

public class AnnotationService {

    @Transformer(inputChannel = "aPollableChannel", outputChannel = "output")
    public String handle(String payload) {
        ...
    }
}

下面的示例展示了如何使用命名的 Poller：spring-doc.cadn.net.cn

@Bean
public PollerMetadata myPoller() {
    PollerMetadata pollerMetadata = new PollerMetadata();
    pollerMetadata.setTrigger(new PeriodicTrigger(1000));
    return pollerMetadata;
}

以下示例显示了使用默认 Poller 的终端节点：spring-doc.cadn.net.cn

public class AnnotationService {

    @Transformer(inputChannel = "aPollableChannel", outputChannel = "output"
                           poller = @Poller("myPoller"))
    public String handle(String payload) {
         ...
    }
}

从版本 4.3.3 开始，@Pollerannotation 具有errorChannel属性，以便更轻松地配置底层MessagePublishingErrorHandler. 此属性的作用与error-channel在<poller>XML 组件。 有关更多信息，请参阅终端节点命名空间支持。spring-doc.cadn.net.cn

这poller()属性与reactive()属性。 有关更多信息，请参阅下一节。spring-doc.cadn.net.cn

用@Reactive注解

这ReactiveStreamsConsumer自 5.0 版本以来一直存在，但仅当端点的输入通道为FluxMessageChannel（或任何org.reactivestreams.Publisher实现）。 从版本 5.3 开始，当目标消息处理程序是ReactiveMessageHandler独立于 input channel type。 这@Reactivesub-annotation （类似于上面提到的@Poller） 已针对从版本 5.5 开始的所有消息传递注释引入。 它接受一个可选的Function<? super Flux<Message<?>>, ? extends Publisher<Message<?>>>Bean 引用，并且独立于输入通道类型和消息处理程序，将目标端点转换为ReactiveStreamsConsumer实例。 该函数从Flux.transform()运算符应用一些自定义 （publishOn(),doOnNext(),log(),retry()等）在来自 input 通道的反应式流源上。spring-doc.cadn.net.cn

下面的示例演示了如何将发布线程从独立于最终订阅者和生产者的 input 通道更改为该DirectChannel:spring-doc.cadn.net.cn

@Bean
public Function<Flux<?>, Flux<?>> publishOnCustomizer() {
    return flux -> flux.publishOn(Schedulers.parallel());
}

@ServiceActivator(inputChannel = "directChannel", reactive = @Reactive("publishOnCustomizer"))
public void handleReactive(String payload) {
    ...
}

这reactive()属性与poller()属性。 看使用@Poller注解和 Reactive Streams Support 了解更多信息。spring-doc.cadn.net.cn

使用@InboundChannelAdapter注解

版本 4.0 引入了@InboundChannelAdapter方法级注解。 它生成一个SourcePollingChannelAdapter集成组件基于MethodInvokingMessageSource对于带注释的方法。 此注释类似于<int:inbound-channel-adapter>XML 组件，并且具有相同的限制：方法不能有参数，并且返回类型不能是void. 它有两个属性：value（必需的MessageChannelBean 名称）和poller（可选的@Poller注释，如前所述）。 如果您需要提供一些MessageHeaders，请使用Message<?>return 类型并使用MessageBuilder构建Message<?>. 使用MessageBuilder允许您配置MessageHeaders. 以下示例演示如何使用@InboundChannelAdapter注解：spring-doc.cadn.net.cn

@InboundChannelAdapter("counterChannel")
public Integer count() {
    return this.counter.incrementAndGet();
}

@InboundChannelAdapter(value = "fooChannel", poller = @Poller(fixed-rate = "5000"))
public String foo() {
    return "foo";
}

版本 4.3 引入了channel别名的valueannotation 属性，以提供更好的源代码可读性。 此外，目标MessageChannelbean 在SourcePollingChannelAdapter通过提供的名称（由outputChannelName选项）在第一个receive()调用，而不是在初始化阶段。 它允许 “late binding” 逻辑：目标MessageChannel从消费者的角度来看，bean 的创建和注册时间比@InboundChannelAdapterparsing 阶段。spring-doc.cadn.net.cn

第一个示例要求已在应用程序上下文中的其他位置声明默认 Poller。spring-doc.cadn.net.cn

使用@MessagingGateway注解spring-doc.cadn.net.cn

看@MessagingGateway注解.spring-doc.cadn.net.cn

使用@IntegrationComponentScan注解

标准的 Spring 框架@ComponentScanannotation 不扫描接口中的构造型@Component附注。 为了克服此限制并允许配置@MessagingGateway（参见@MessagingGateway注解），我们引入了@IntegrationComponentScan机制。 此注释必须与@Configuration注释并自定义以定义其扫描选项， 如basePackages和basePackageClasses. 在这种情况下，所有发现的带有@MessagingGateway被解析并注册为GatewayProxyFactoryBean实例。 所有其他基于 class 的组件都由标准@ComponentScan.spring-doc.cadn.net.cn