测量单个项目（读取器、处理器和写入器）的性能 - Spring Batch

Question

我的问题与this SO Question 非常相似，即我希望测量单个项目的性能 - 阅读器、处理器和编写器。

正如对链接问题的回答所建议的那样，我添加了一个ItemReadListener<T>，但这让我在使用JdbcPagingItemReader 时有时间阅读每个阅读项目，并希望花时间阅读每一页而不是单个项目。

处理器也是如此（也就是说，它会给我时间处理每个项目），而我希望处理器花费时间来准备整个块。

ChunkListener 看起来也不合适，因为这将再次测量读取器、处理器和写入器的组合时间。

我怎样才能达到这个要求？

Answer 1

这是一个非线程安全的简单示例，该示例说明了在处理单个项目时计算处理器执行时间并记录总执行时间的可能解决方案。

public class PersonItemProcessor implements ItemProcessor<Person, Person> {

    private static final Logger log = LoggerFactory.getLogger(PersonItemProcessor.class);
    private static int count;
    private long processTime;

    @Override
    public Person process(final Person person) throws Exception {
        count++;
        long start = System.currentTimeMillis();    
        final String firstName = person.getFirstName().toUpperCase();
        final String lastName = person.getLastName().toUpperCase();

        final Person transformedPerson = new Person(firstName, lastName);

        // bear in mind that this will pollute the logging when processing millions of records
        log.info("Converting (" + person + ") into (" + transformedPerson + ")");
        log.info("Processing 1 item took " + (System.currentTimeMillis() - start) / 1e3 + " sec");

        processTime += System.currentTimeMillis() - start;    

        // use some interval value, here I used 5.
        // last few items won't be counted e.g. 18 items you will see this message 3 times.
        if (count == 5) {
            log.info(String.format("Processed %d items in %s sec", count, processTime / 1e3));
            count = 0;
        }
        return transformedPerson;       
    }

    public long getProcessTime(){
        return processTime;
    }
}

其余的代码你可以找到here。把处理器调到上面就可以看到效果了。

同样的逻辑可以应用于读写器。