Springバッチ統合でファイルロックを使用するには？

Question

私の春バッチ統合アプリケーションでは、ファイルポーリングは各ファイルの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(); 
    } 

} 

}今

、私は私の春のバッチを起動し、私はそれが私に

org.springframework.batch.item.fileを与えるflatfileitemreader使用してそのファイルを読み込むしようとすると、 .NonTransientFlatFileException

私はbeacuseファイルがロックされていると信じています。私はいくつかのグーグルをして、NIOLockerが現在のスレッドでも読むことができないようにファイルをロックすることを発見しました。私はlinkを見つけました。ロックされたファイルの読み方を示していますが、バッファを使用しています。 私のファイルを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())); 

ああ！うん。あなたは本当に私のレポを指摘しました:-)。

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

：コピー/ FlatfileItemReader前にファイル byte[]そのように貼り付けたり、単に適切な BufferedReaderにロックされたファイルを変換し、同じ FlatfileItemReader、にいくつかのカスタム BufferedReaderFactoryを注入しない限り、

ので、lockerであなたは選択肢を持っていません

Answer 2

あなたが共有したlinkに基づいて、次のようなことができるようです。

//This is from your link (except the size variable) 
FileChannel fileChannel = channelCache.get(lockedFile); 
int size = (int) fileChannel.size(); 
ByteBuffer byteBuffer = ByteBuffer.allocate(size); 
fileChannel.read(byteBuffer); 

//Additional code that you could try 
byte[] bArray = new byte[size]; 

//Write data to the byte array 
byteBuffer.get(bArray); 

FlatFileItemReader flatFileItemReader = new FlatFileItemReader(); 
flatFileItemReader.setResource(new ByteArrayResource(bArray)); 

//Next you can try reading from your flatFileItemReader as usual 
... 

問題が解決しない場合は教えてください。

Answer 3

解決方法：ロックされたファイルの内容を含む一時ファイルを作成して処理しています。処理が完了すると、そのファイルをアーカイブし、ロックされた両方の一時ファイルを削除します。ここで重要なのは、ロックされたファイルの内容で新しいファイルを作成することです。次のように以下のコードは次のとおりです。ここで

File tmpFile = new File(inputFile.getAbsolutePath() + ".lck");  
FileChannel fileChannel = MyFileLocker.getChannelCache().get(new File(inputFile.getAbsolutePath())); 
InputStream inputStream = Channels.newInputStream(fileChannel); 
ByteStreams.copy(inputStream, Files.newOutputStreamSupplier(tmpFile)); 

 

で、inputFile私のロックされたファイルとtmpファイルがロックされたファイルの内容を新しいファイルです。私も実際にprodシナリオで

public void unlockAndDelete(File fileToUnlockandDelete) { 
    FileLock lock = lockCache.get(fileToUnlockandDelete); 
    String fileName = fileToUnlockandDelete.getName(); 
    try { 
    if(lock!=null){ 
     lock.release(); 
     channelCache.get(fileToUnlockandDelete).close(); 
     //remove from cache 
     lockCache.remove(fileToUnlockandDelete); 
     channelCache.remove(fileToUnlockandDelete); 
     boolean isFiledeleted = fileToUnlockandDelete.delete(); 
     if(isFiledeleted){ 
      System.out.println("File deleted successfully" + fileName); 
     }else{ 
      System.out.println("File is not deleted."+fileName); 
     } 
    } 
    } catch (IOException e) { 
     // TODO Auto-generated catch block 
     e.printStackTrace(); 
    } 

}