java在Spring集成中等待所有线程完成

Question

我有一个自我执行的jar程序，它严重依赖于Spring集成。我遇到的问题是，程序在其他SpringBean完全完成之前终止

下面是我正在使用的代码的简化版本，如果需要，我可以提供更多的代码/配置。入口点是main（）方法，它引导Spring并启动导入过程：

public static void main(String[] args) {
    ctx = new ClassPathXmlApplicationContext("flow.xml");
    DataImporter importer = (DataImporter)ctx.getBean("MyImporterBean");
    try {
        importer.startImport();
    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        ctx.close();
    }
}

DataImporter包含一个向Spring集成网关发送消息的简单循环。这为流提供了一种主动的“推送”方法，而不是常见的数据轮询方法。这就是我的问题所在：

public void startImport() throws Exception {
    for (Item item : items) {
        gatewayBean.publish(item);
        Thread.sleep(200); // Yield period
    }
}

为完整起见，流XML如下所示：

<gateway default-request-channel="inChannel" service-interface="GatewayBean" />

<splitter input-channel="inChannel" output-channel="splitChannel" />

<payload-type-router input-channel="splitChannel">
    <mapping type="Item" channel="itemChannel" />
    <mapping type="SomeOtherItem" channel="anotherChannel" />
</payload-type-router>

<outbound-channel-adapter channel="itemChannel" ref="DAOBean" method="persist" />

流启动并有效地处理项，但一旦startImport（）循环完成，主线程就会终止并立即中断所有Spring集成线程。这将导致一个竞争条件，当程序终止时，最后（n）个项目没有被完全处理

我有一个想法，就是维护我正在处理的项目的引用计数，但这被证明是相当复杂的，因为流经常将消息拆分/路由到多个服务激活器，这意味着很难确定每个项目是否已“完成”

我想我需要的是某种方法来检查是否没有Springbean仍在执行，或者标记发送到网关的所有项目在终止之前都已被完全处理

我的问题是，我该如何做这两件事，还是有更好的方法来解决我的问题，我还没有想到

Answer 1

这里没有使用请求-响应模式

出站通道适配器是一种“即发即忘”操作，如果要等待响应，应使用将等待响应的出站网关，并将响应连接到原始网关，然后在java sendAndReceive中，而不仅仅是发布

Answer 2

如果您可以获得一个Item来确定是否仍然需要它（processingFinished（）或在后端阶段执行的类似操作），那么您可以在一个中央机构中注册所有Item，该机构跟踪未完成的Item的数量，并有效地确定终止条件

如果这种方法可行，您甚至可以考虑将这些项打包到FutureTask-对象中，或者使用java.util.concurrent中的类似概念

编辑：第二个想法：

你有没有想过让频道更智能化？发送方在不再发送任何数据时关闭通道。在这个场景中，工作bean不必是deamon线程，但可以基于一个封闭的空输入通道来确定它们的终止标准