使用Spring批处理读取文件并写入Map

出身背景

我对Spring batch相当陌生,有以下要求:

1. 读取一个最少有百万条记录的文件(CSV、管道分隔等)
2. 将文件中的每一行加载到Map中,键作为第一列,值作为域对象/POJO。

我理解Spring批处理有一种称为面向块的处理,其中配置一个读取器、处理器和写入器来处理由提交间隔控制的特定数量的记录。这可以通过使用阅读器的任务执行器或通过分区添加另一层多线程来进一步扩展。

问题

如上文第2点所述,我想将文件加载到Map中。为了便于讨论,假设我实现了下面的ItemWriter,它将块聚合到Map中。

public class MapItemWriter implements ItemWriter<SomePOJO> {

    private Map<String, SomePOJO> somePojoMap; 

    public MapItemWriter() {
        System.out.println("Writer created ");
        somePojoMap= new ConcurrentHashMap<String, SomePOJO>();
    }

    public void write(List<? extends SomePOJO> item) throws Exception {
        if (item != null && item.size() > 0) {
            for (SomePOJO data : item) {
                String uniqueId = data.Id();
                somePojoMap.put(uniqueId, data);
             }
        }
    }

    public Map<String, SomePojo> getSomePojoMap() {
        return somePojoMap;
    }
}

由于我可以访问我的ItemWriter bean,我可以稍后调用getSomePojoMap来获取文件中记录的聚合Map;然而,在ItemWriter中持有这样的Map并不是最好的方式。另一个问题是,使用ConcurrentHashMap可能会降低性能,但我看不到任何其他方法可以以线程安全的方式将文件聚合到Map中。

有没有更好的方法将我的文件聚合成Map,而不是在我的编写器中保存Map并使用ConcurrentHashMap?