如何在Spring批处理集成中使用文件锁？

Question

在我的spring-batch-integration应用程序中，文件轮询调用eachfile的batchjob，该应用程序可以在多个服务器（节点）上运行，但它们都应该读取一个公共目录。代码如下

public class MyFileLocker extends AbstractFileLockerFilter{

private final ConcurrentMap<File, FileLock> lockCache = new ConcurrentHashMap<File, FileLock>();
private final ConcurrentMap<File, FileChannel> ChannelCache = new ConcurrentHashMap<File, FileChannel>();

@Override
public boolean lock(File fileToLock) {
    FileChannel channel;
    FileLock lock;
    try {
        channel = new RandomAccessFile(fileToLock, "rw").getChannel();
        lock = channel.tryLock();

        if (lock == null || !lock.isValid()) {  
            System.out.println(" Problem in acquiring lock!!" + fileToLock);
            return false;
        }
        lockCache.put(fileToLock, lock);
        ChannelCache.put(fileToLock, channel);

    } catch (FileNotFoundException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }

    return true;
}

@Override
public boolean isLockable(File file) {

    return file.canWrite();
}

@Override
public void unlock(File fileToUnlock) {
    FileLock lock = lockCache.get(fileToUnlock);
    try {
    if(lock!=null){
        lock.release();
        ChannelCache.get(fileToUnlock).close();
    }
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }

}

}

现在，当我调用Spring批处理并尝试使用flatfileitemreader读取该文件时，它给了我

Answer 1

是的，您确实只能通过bytebuffer访问锁定的文件内容：

FileChannel fileChannel = channelCache.get(lockedFile);
ByteBuffer byteBuffer = ByteBuffer.allocate((int) fileChannel.size());
fileChannel.read(byteBuffer);
System.out.println("Read File " + lockedFile.getName() + " with content: " + new String(byteBuffer.array()));

哦！是啊。你真的指着我的回购：-）。

因此，对于Locker，您别无选择，除非在FlatFileItemReader之前以这种方式复制/粘贴文件Byte[]，或者只是将一些自定义的BufferedReader插入到同一个FlatFileItemReader，后者将锁定的文件转换为适当的BufferedReader:

new BufferedReader(new CharArrayReader(byteBuffer.asCharBuffer().array()));