Spring Integration如何将JPA更新出站网关事务范围限定为仅包裹更新操作

问题原因 #

你直接在请求处理通知链中使用未配置事务属性的<tx:advice>时，默认的方法匹配规则没有覆盖JPA出站网关的核心处理方法handleRequestMessage，导致JPA更新操作执行时没有活跃事务，所以抛出TransactionRequiredException异常。

解决方案 #

不需要在回复通道加executor打断事务边界，按如下配置即可实现事务仅包裹JPA更新操作、执行完成后立即提交、下游流不受该事务影响的效果：

1. 首先声明独立的事务通知Bean，明确配置事务规则：

<tx:advice id="jpaExclusiveTxAdvice" transaction-manager="transactionManager">
  <tx:attributes>
    <!-- 匹配JPA网关核心处理方法，开启独立读写事务 -->
    <tx:method name="handleRequestMessage" propagation="REQUIRES_NEW" read-only="false"/>
    <!-- 其他方法默认不强制开启事务 -->
    <tx:method name="*" propagation="SUPPORTS" read-only="true"/>
  </tx:attributes>
</tx:advice>

2. 调整JPA更新出站网关配置，移除原有的<int-jpa:transactional>子元素，在请求处理通知链中引用上面的事务通知：

<int-jpa:updating-outbound-gateway
  request-channel="requestChannel"
  reply-channel="replyChannel"
  named-query="myUpdatingJpqlQuery"
  entity-manager-factory="entityManagerFactory">
  <int-jpa:parameter name="param1" expression="payload" />
  <int-jpa:parameter name="param2"
    expression="T(java.time.Instant).now()" />
  <int-jpa:request-handler-advice-chain>
    <ref bean="jpaExclusiveTxAdvice"/>
  </int-jpa:request-handler-advice-chain>
</int-jpa:updating-outbound-gateway>

原理解释 #

• 原配置中的<int-jpa:transactional>是端点级别的事务通知，会包裹整个消息消费全流程：接收消息→调用JPA处理器执行更新→发送回复到下游通道，因此事务会一直延续到下游流执行完成才提交。
• 请求处理通知链中的通知仅包裹JPA处理器的核心更新逻辑，更新操作执行完成、事务提交之后，才会开始向下游通道发送回复，下游流的事务完全独立，不会和JPA更新的事务产生关联。
• 配置中使用propagation="REQUIRES_NEW"是为了强制开启独立事务，即使后续上游流修改逻辑增加了事务，也不会影响JPA更新操作的事务独立性，更符合你的需求。

内容的提问来源于stack exchange，提问作者Mauro Molinari