使用spring批量远程分区将工作移交给spring集成工作流

Question

我想写一个批处理，从一个表读取数据，对数据进行分区，并将其交给一个spring集成工作流。

批处理和集成工作流都是独立的maven项目，集成项目是批处理项目中的依赖项。

我的批处理有一个非常小的作业上下文（xml）。只有一个分区器和一个任务。在这个任务中，我将数据（为了测试目的而硬编码）放入一个spring集成网关。之后，我将消息传递到outbound-channel-adapter中，它只是将消息打印到控制台。

我的批处理作业上下文如下所示：

<job id="myJob" incrementer="idIncrementer"
        xmlns="http://www.springframework.org/schema/batch">
        
        <step id="startTasklet" next="giveToWorkflow">
            <partition step="worker" partitioner="myPartitioner">
                <handler task-executor="taskExecutor" grid-size="1"></handler>
            </partition>
        </step>
        
        <step id="giveToWorkflow">
            <tasklet ref="startTaskletBean">
                <transaction-attributes isolation="DEFAULT"
                    propagation="REQUIRED" timeout="1800" />
            </tasklet>
        </step>

    </job>
    
    <step xmlns="http://www.springframework.org/schema/batch" id="worker">
        <tasklet ref="startTaskletBean">
            <transaction-attributes isolation="DEFAULT"
                propagation="REQUIRED" timeout="1800" />
        </tasklet>
    </step>

    <bean id="startTaskletBean"
        class="com.my.project.WorkerTasklet">
        <property name="gateway" ref="mainGateway" />
    </bean>
    
    <bean id="myPartitioner"
        class="com.my.project.Partitioner">
    </bean>

我的集成上下文看起来像Follwing：

    <int:channel  id="request"/>
    <int:channel  id="reply"/>
    
    <int:gateway id="mainGateway" service-interface="com.my.project.workflow.Einstiegspunkt" default-request-channel="request" />
    
    <int:outbound-channel-adapter id="outboundAdapter" ref="consumerService" method="ausgeben" channel="request"/>
    
    <bean id="consumerService" class="com.my.project.workflow.Ausgabe"/>
    
</beans>

据我理解，spring集成项目是spring批项目中的一个正常库。我被告知要使用远程分区，以便集成工作流的多个实例可以（并发）在它们自己的JVM中运行。我认为在我当前的设置中，只有一个普通的分区器，而没有远程分区器，这是不可能的。

我发现了这个我不太懂的项目：回购

这是来自stackoverflow问题：SO问题

在本例中，注释用于配置。我认为经理和工人都是（分开的）spring批次的想法对吗？

spring boot不是我的选择。

Answer 1

您现在所拥有的是一个JVM中的一个应用程序上下文--仅仅是一个应用程序！

您可能需要了解更多什么是远程分区，以及如何为spring集成通道适配器配置它：

https://docs.spring.io/spring-batch/docs/4.3.x/reference/html/scalability.html#可伸缩性https://docs.spring.io/spring-batch/docs/4.3.x/reference/html/spring-batch-integration.html#springbatchintegration