在 JPAOutboundGateway 中使用事务和请求处理程序建议链的正确方法

Question

我有一个 JPA Outbound-channel-adapter 交易和请求处理程序建议链。在建议链中，我尝试在异常发生时记录它。 它没有记录，但我知道它实际上是在消息被发送到故障转移 clickDbFailoverChannel 后发生的。它可能有什么问题？这是 Spring Integration 中的错误吗？

<int:channel id="clickDbWithFailoverChannelSite-1">
     <int:dispatcher load-balancer="none" task-executor="clickDbSiteRouterExecutor"/>
</int:channel>
<int:bridge input-channel="clickDbWithFailoverChannelSite-1"
     output-channel="jpaOutboundChannelSite-1" order="1" send-timeout="100" />
<int:bridge input-channel="clickDbWithFailoverChannelSite-1"
     output-channel="clickDbFailoverChannel" order="2" />
<int-jpa:outbound-channel-adapter id="jpaOutboundChannelSite-1"
     persist-mode="PERSIST" flush-size="100" entity-manager-factory="emfSite-1">
    <int-jpa:transactional transaction-manager="transactionManagerSite-1" />
    <int-jpa:request-handler-advice-chain>
        <bean class="org.springframework.integration.handler.advice.ExpressionEvaluatingRequestHandlerAdvice">
            <property name="failureChannel" ref="clickDbFailureLogger"/>
            <property name="onFailureExpression" value="#exception"/>
        </bean>
    </int-jpa:request-handler-advice-chain>
</int-jpa:outbound-channel-adapter>

Answer 1

好的。我可以猜到你的问题在哪里。回滚事务的真正异常是在内部逻辑之前引起的，<request-handler-advice-chain> 负责处理这些事情。这就是为什么您的 ExpressionEvaluatingRequestHandlerAdvice 没有收到失败消息的原因。

要解决您的回滚问题，您应该在<int-jpa:request-handler-advice-chain> 中将<int-jpa:transactional> 替换为<tx:advice>。

您应该在这里了解<int-jpa:transactional> 是整个MessageHandler.handleMessage，但<int-jpa:request-handler-advice-chain> 只是它的一部分 - AbstractReplyProducingMessageHandler.handleRequestMessage。

更新

TX Advice 应该是这样的：

 <tx:advice transaction-manager="transactionManagerSite-1"/>
        <tx:attributes>
            <tx:method name="*"/>
        </tx:attributes>
</tx:advice>