如何获取在主tomcat和从tomcat中运行的spring批处理作业的分区列表

Question

我已经通过以Spring Batch Talk作为参考来处理一个Spring Batch Admin示例。该示例以我想要的方式完美运行。使用兔子服务器，我已经在主服务器和从服务器之间建立了通信。但是我怎么能知道哪个分区在主服务器中运行，哪个在从服务器中运行。有没有机会从Spring Batch AdminUI查看它。

Answer 1

在ColumnRangePartitioner中进行分区时，我又向ExecutionContext添加了一个值partitionId。

value.putLong("minValue", start);
value.putLong("maxValue", end);
value.putLong("partitionId", number);

我在TARGET中添加了一个名为分区信息的新列，它存储了详细信息，例如在哪个分区中扫描了哪个端口。在读取端口时，我显式添加了值。

<bean id="targetItemReader" class="org.springframework.batch.item.database.JdbcPagingItemReader" scope="step">
        <property name="dataSource" ref="dataSource" />
        <property name="queryProvider">
            <bean
                class="org.springframework.batch.item.database.support.SqlPagingQueryProviderFactoryBean">
                <property name="dataSource" ref="dataSource" />
                <property name="selectClause" value="ID, IP, PORT, CONNECTED, BANNER, :partitionId as PARTITIONINFO" />
                <property name="fromClause" value="FROM TARGET" />
                <property name="whereClause" value="ID >= :minId AND ID &lt;= :maxId AND CONNECTED IS NULL"/>
                <property name="sortKey" value="ID" />
            </bean>
        </property>
        <property name="pageSize" value="10" />
        <property name="parameterValues">
            <map>
                <entry key="minId" value="#{stepExecutionContext[minValue]}"/>
                <entry key="maxId" value="#{stepExecutionContext[maxValue]}"/>
                <entry key="partitionId" value="#{stepExecutionContext[partitionId]}" />
            </map>
        </property>
        <property name="rowMapper">
            <bean class="com.michaelminella.springbatch.domain.TargetRowMapper"/>
        </property>
</bean>

后来，我在最后运行了更新查询，并将详细信息保存在表中。

<bean id="targetWriter" class="org.springframework.batch.item.database.JdbcBatchItemWriter">
        <property name="assertUpdates" value="true" />
        <property name="itemSqlParameterSourceProvider">
            <bean class="org.springframework.batch.item.database.BeanPropertyItemSqlParameterSourceProvider" />
        </property>
        <property name="sql" value="UPDATE TARGET SET CONNECTED = :connected, BANNER = :banner, PARTITIONINFO = :partitionId WHERE ID = :id" />
        <property name="dataSource" ref="dataSource" />
</bean>

我已将新变量添加到存储分区ID信息的Target bean。

private int partitionId;

public int getPartitionId() {
    return partitionId;
}

public void setPartitionId(int partitionId) {
    this.partitionId = partitionId;
}

DB在business-schema-mysql.sql中的更改

DROP TABLE IF EXISTS TARGET;

CREATE TABLE TARGET  (
    ID BIGINT  NOT NULL PRIMARY KEY ,
    IP VARCHAR(15) NOT NULL,
    PORT INT NOT NULL,
    CONNECTED BOOLEAN NULL,
    BANNER VARCHAR(255),
    PARTITIONINFO INT
) ENGINE=InnoDB;