springバッチのファイルの代わりにストリームからの読み込みitemReader

Question

webサービス呼び出しとしてCSVファイルが取得されています。今私は一時ディレクトリにsetResourceとしてReaderに提供するために保存しています。

最初にファイルを保存する代わりに、stream（byte []）をそのまま使用する方法はありますか？

Answer 1

ItemReaderの方法setResourceは、org.springframework.core.io.Resourceをパラメータとする。このクラスにはすぐに使用できる実装がいくつかありますが、その中でorg.springframework.core.io.InputStreamResourceがあります。このクラスのコンストラクタは、java.io.ByteArrayInputStreamで実装できるjava.io.InputStreamを受け取ります。

技術的には、はい、ItemReaderのbyte[]パラメータを消費することができます。

1）独自のFlatFileItemReaderを作成します（CSVがフラットファイルであるため）、それはStepExecutionListener

public class CustomFlatFileItemReader<T> extends FlatFileItemReader<T> implements StepExecutionListener { 
} 

2を実装します：実際には、ここではいくつかのアイデアであることを行う方法について今

、 ）をオーバーライド）内のあなたのWebサービス呼び出しを行い、beforeStepメソッドをオーバーライドし、変数

private byte[] stream; 

@Override 
public void beforeStep(StepExecution stepExecution) { 

    // your webservice logic 
    stream = yourWebservice.results(); 

} 

3に結果を保存しますメソッドを使用して、streamを実際のリソースとして渡します。

@Override 
public void setResource(Resource resource) { 

    // Convert byte array to input stream 
    InputStream is = new ByteArrayInputStream(stream); 

    // Create springbatch input stream resource 
    InputStreamResource res = new InputStreamResource(is); 

    // Set resource 
    super.setResource(res); 
} 

あなたがItemReader以内にあなたのWebサービスを呼び出すためにしたくない場合にも、あなたは、単にJobExecutionContextのバイト配列を格納し、stepExecution.getJobExecution().getExecutionContext().get("key");