如何在spring集成中找到事务结束点？

Question

好的，我添加了我的Spring xml配置以对我的情况进行更多解释。

首先，我聚合了7个通道；其次，聚合器释放声明为发布通道的聚合通道。第三，每7个订阅频道选择室内数据库制作每条消息。第四，每个通道使用jdbc出站通道适配器将数据插入外部数据库。

下面我附上了每个与xml配置相关的。。谢谢

<int:bridge input-channel="request-write-to-openPMSQueueChannel"
        output-channel="writetoOpenPMSChannel">
        <int:poller fixed-rate="5000" max-messages-per-poll="-1">
            <int:transactional propagation="REQUIRED"
                transaction-manager="transactionExternalDatabaseManager" />
        </int:poller>
    </int:bridge>

<int:chain input-channel="writetoOpenPMSChannel"
    output-channel="writetoOpenPMS007Channel">
    <int:service-activator method="exectue007">
        <bean id=""
            class="com.sds.redca.core.module.analyzer.convert.ModelingConvertSVC">
        </bean>
    </int:service-activator>
    <int:splitter ref="fromListToRowSplitter" />
</int:chain>

<int:chain input-channel="writetoOpenPMSChannel"
        output-channel="writetoOpenPMS006Channel">
        <int:service-activator method="exectue006">
            <bean id=""
                class="com.sds.redca.core.module.analyzer.convert.ModelingConvertSVC">
            </bean>
        </int:service-activator>
        <int:splitter ref="fromListToRowSplitter" />
    </int:chain>

<int-jdbc:outbound-channel-adapter channel="writetoOpenPMS001Channel" 
query="INSERT INTO IF_RSRC
       (PJT_ID, DT_INPUT, RSRC_ID, RSRC_TYPE_ID, RSRC_DETAILTYPE_ID, RSRC_NM, CNFG_PJT_NM, RSRC_PATH_NM, LST_RGSTR_ID, LST_RGST_DTM, FINAL_RVSN_NO, YN_USE)
       VALUES
       (:payload[PJT_ID], :headers[timeStamp], :payload[RSRC_ID], :payload[RSRC_TYPE_ID], :payload[RSRC_DETAILTYPE_ID], :payload[RSRC_NM], :payload[CNFG_PJT_NM],
       :payload[RSRC_PATH_NM], :payload[LST_RGSTR_ID], :payload[LST_RGST_DTM], :payload[FINAL_RVSN_NO], :payload[YN_USE])"
data-source="outboundDataSource" />
<int-jdbc:outbound-channel-adapter channel="writetoOpenPMS002Channel" 
query="INSERT INTO IF_RSRC_RELATION
       (PJT_ID, DT_INPUT, MAIN_RSRC_ID, SUB_RSRC_ID, RELATION_TYPE_CODE_ID)
       VALUES
       (:payload[PJT_ID], :headers[timeStamp], :payload[MAIN_RSRC_ID], :payload[SUB_RSRC_ID], :payload[RELATION_TYPE_CODE_ID])"
data-source="outboundDataSource" />

但问题是，我必须在7个插入作业成功完成后立即触发一些事件。如何获得7个插入事务完成的点，以触发某些post事件？

Answer 1

抱歉，信息不够。我们需要查看上游配置。

如果您的所有插入都在同一个发送中，那么您可以在业务逻辑的一端再添加一个订户。

如果使用TX使用同一个线程完成所有操作，则在您不执行最终通知之前，TX不会完成。

从另一方面来说，如果所有这些项目都在不同的交易中，那么当每个项目向另一个表中添加一些信息以确认它已经完成了原始工作时，您需要类似于收据之类的东西。是的，它可以在同一个TX。

要确定所有所需的项目都完成了它们的工作，您需要以较短的间隔轮询，该新表具有特定的业务密钥来计数它们。

从另一端，您的所有任务都可以向公共<代码>

可能还有其他解决方案，但我们需要更多地了解您的用例。

更新

感谢您的配置。

我希望你的WritetoOpenPMSChannel是单线程发布订阅通道。

因此，您的所有WritetoOpenPMS*html" target="_blank">进程都绑定到该轮询器的TX，并将在该单个TX中一个接一个地完成。

因此，没有停止向该频道添加一个以上的订户作为最后一个订户。在发送结束时，也就是提交之前，它会收到相同的消息。如果这些表上没有任何延迟约束，那么在单个TX内，一切都将正常。

从另一侧<代码>