在 Spring Integration 流程中保持事务

Question

入站网关：

<int-http:inbound-gateway   id="inbound.gateway"
                            request-channel="transactional.channel.input"
                            reply-channel="channel.output"
                            error-channel="channel.error"
                            request-payload-type="java.lang.String"
</int-http:inbound-gateway>

建议定义：

<tx:advice id="advice">
    <tx:attributes>
        <tx:method name="send" propagation="REQUIRES_NEW" rollback-for="MyClassException"/>
    </tx:attributes>
</tx:advice>

建议配置：

<aop:config>
    <aop:advisor advice-ref="advice" pointcut="bean(transactional.channel.input)"/>
</aop:config>

需要交易的链：

<int:chain input-channel="transactional.channel.input" output-channel="non.transactional.channel.input>
    <int:service-activator ref="v1.registerUser.service" method="registerUser"/>
    <int:service-activator ref="v1.saveObject.service" method="saveObject"/>
</int:chain>

需要先执行事务以获取在最后一个事务链步骤中生成的对象id的链：

<int:chain input-channel="non.transactional.channel.input" output-channel="channel.output">
    <int:service-activator  ref="v1.getObjectId.service" method="getObjectId"/>
    <int:object-to-json-transformer/>
</int:chain>

有了这个简化的上下文，当我访问 getObjectId 服务中的 id 时，事务还没有执行。

所以事务似乎是在入站网关输出级别提交的。

Answer 1

一个更神奇的技巧，无需编写任何 Java 代码：

<channel id="input"/>

<aop:config>
    <aop:advisor advice-ref="txAdvice" pointcut="bean(input)"/>
</aop:config>

<tx:advice id="txAdvice">
    <tx:attributes>
     <tx:method name="send"/>
    </tx:attributes>
</tx:advice>

有了这个，你所有的直接单线程消息流将被包装到发送到通道输入

的消息的TX

Answer 2

如果它是一个注入到您的代码中的 MessagingGateway，您可以简单地在网关处启动您的事务，并且由于所有通道都是直接的，因此整个流程将在同一个事务中运行。只需使用 @Transactional 注释您的网关方法，并将 <tx:annotation-driven/> 或 @EnableTransactionManagement 添加到您的上下文（和事务管理器）中。

或者，如果您想要交易中的其他内容，您可以更早地开始交易......

@Transactional
public void foo() {
    ...
    Object reply = myGateway.exchange(Object foo);
    ...
}

请务必从另一个 bean 调用 foo()，以便将包含 foo() 的类包装在事务代理中（通过 @EnableTransactionManagement 或 <tx:annotation-driven/>）。

如果是http入站网关等网关，在入站网关后添加@Transactional网关，开始事务。 （添加一个服务激活器，refs 和 <gateway/> 交换 Message<?> 并带有 @Transactional 注释）。