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

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

从版本 5.0 开始，由于实现，引入了一个新的功能，使整个下游流具有事务性。 当在元素中使用 regular 时（例如，通过 配置 ），启动的事务仅应用于内部，而不会传播到下游流。TransactionHandleMessageAdviceHandleMessageAdviceTransactionInterceptor<request-handler-advice-chain><tx:advice>AbstractReplyProducingMessageHandler.handleRequestMessage()spring-doc.cn

为了简化 XML 配置，除了 之外，还向 all and and 相关组件添加了一个元素。 以下示例显示了使用情况：<request-handler-advice-chain><transactional><outbound-gateway><service-activator><transactional>spring-doc.cn

<int-jdbc:outbound-gateway query="select * from things where id=:headers[id]">
        <int-jdbc:transactional/>
</int-jdbc:outbound-gateway>

<bean id="transactionManager" class="org.mockito.Mockito" factory-method="mock">
    <constructor-arg value="org.springframework.transaction.TransactionManager"/>
</bean>

如果您熟悉 JPA 集成组件，那么这样的配置并不新鲜，但现在我们可以从流中的任何点启动事务 — 而不仅仅是从消息驱动的通道适配器（如 JMS）开始。<poller>spring-doc.cn

可以使用 ，可以使用 Java 配置，并且可以在 messaging annotations 属性中使用结果 Bean 名称，如下例所示：TransactionInterceptorBuilderadviceChainspring-doc.cn

@Bean
public ConcurrentMetadataStore store() {
    return new SimpleMetadataStore(hazelcastInstance()
                       .getMap("idempotentReceiverMetadataStore"));
}

@Bean
public IdempotentReceiverInterceptor idempotentReceiverInterceptor() {
    return new IdempotentReceiverInterceptor(
            new MetadataStoreSelector(
                    message -> message.getPayload().toString(),
                    message -> message.getPayload().toString().toUpperCase(), store()));
}

@Bean
public TransactionInterceptor transactionInterceptor() {
    return new TransactionInterceptorBuilder(true)
                .transactionManager(this.transactionManager)
                .isolation(Isolation.READ_COMMITTED)
                .propagation(Propagation.REQUIRES_NEW)
                .build();
}

@Bean
@org.springframework.integration.annotation.Transformer(inputChannel = "input",
         outputChannel = "output",
         adviceChain = { "idempotentReceiverInterceptor",
                 "transactionInterceptor" })
public Transformer transformer() {
    return message -> message;
}

请注意构造函数上的参数。 它会导致创建 ，而不是常规的 。trueTransactionInterceptorBuilderTransactionHandleMessageAdviceTransactionInterceptorspring-doc.cn

Java DSL 支持端点配置上的直通选项，如下例所示：Advice.transactional()spring-doc.cn

@Bean
public IntegrationFlow updatingGatewayFlow() {
    return f -> f
        .handle(Jpa.updatingGateway(this.entityManagerFactory),
                e -> e.transactional(true))
        .channel(c -> c.queue("persistResults"));
}