JAXBがファイルにマーシャリングされたことを確認する方法

Question

サーバー上に特定のディレクトリ（特定のディレクトリ）（たとえば5分）ごとにファイルを取得するプロセスがあります。 ピックアップされているファイルは、Webサービスによって生成されます。 JAXBマーシャリングはファイルをオブジェクトからxmlファイルに変換します。 問題は、ファイルが完了する前にピックアップされることが頻繁に発生することです。 解決方法は、一時ディレクトリにファイルを配置するか、一時的な特定の拡張子を付けて、ポーリングプロセスにこれらをスキップするよう通知させることです。 その後、ファイルを処理ディレクトリに移動することができます。または、拡張機能を変更して、ポーリングプロセスがそれらを取得できるようにすることができます。

この方法は次のようになります。

private void writeToFile(Object obj, String outputFileName) { 
    LOG.debug("Executing operation writeToFile using filename '{}' and object of type '{}'.", outputFileName, obj.getClass()); 

    try { 
     Marshaller jaxbMarshaller = JAXB_CONTEXT.createMarshaller(); 
     jaxbMarshaller.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, true); 
     jaxbMarshaller.marshal(obj, new File(outputFileName)); 
     LOG.debug("Wrote request to file '{}'.", outputFileName); 
    } catch (JAXBException e) { 
     LOG.error("Exception occurred while writing request to file:", e); 
    } 
    LOG.debug("Done executing operation writeToFile."); 
} 

私の質問は、ファイルがさらなる処理のためにリリースすることができるようにマーシャリングプロセスへが行われていることdtermineする暑いですか？ここで

Answer 1

人の内のルートノードのインスタンスをチェックして、これは、各ノードに対して呼び出されますようhttps://turreta.com/2017/03/07/jaxb-perform-pre-and-post-processing-with-unmarshaller-listener/]は、ソースに人マーシャルリスナーのコードの下に加える[このリンクからコードをダウンロードしてください（これを変更する必要がありますあなたのベースノードとして）は、始まりと終わりのノードがこれを毎回呼び出すので、2のカウントを使用しました。count == 2ならば、終点ノードのチェックでのみ呼び出さなければなりません。

package com.turreta.jaxb.unmarshaller.listener; 

    public class PersonMarshallListener extends javax.xml.bind.Marshaller.Listener { 

      int beforeCount = 1; 
      int afterCount = 1; 

      @Override 
      public void beforeMarshal(Object source) { 
       super.beforeMarshal(source); 
       if (source instanceof Person) { 

        if (beforeCount == 2) { 
         beforeCount = 1; 
         System.out.println("BEFORE MARSHAL"); 
        } else { 
         beforeCount++; 
        } 
       } 

      } 

      @Override 
      public void afterMarshal(Object source) { 
       super.afterMarshal(source); 

       if (source instanceof Person) { 

        if (afterCount == 2) { 

         afterCount = 1; 
         System.out.println("AFTER MARSHAL"); 
    //     System.out.println("This will be called once the marshall has been completed"); 
        } else { 
         afterCount++; 
        } 
       } 


      } 

    } 

DemoAppを次のコードに置き換えます。

package com.turreta.jaxb.unmarshaller.listener; 

import java.io.FileInputStream; 

import javax.xml.bind.JAXBContext; 
import javax.xml.bind.Marshaller; 
import javax.xml.bind.Unmarshaller; 
import javax.xml.stream.XMLInputFactory; 
import javax.xml.stream.XMLStreamReader; 

public class DemoApp { 
    public static void main(String[] args) throws Exception { 
     JAXBContext jc = JAXBContext.newInstance(Person.class); 

     XMLInputFactory xif = XMLInputFactory.newFactory(); 
     FileInputStream xml = new FileInputStream("src/main/resources/person.xml"); 
     XMLStreamReader xsr = xif.createXMLStreamReader(xml); 

     Unmarshaller unmarshaller = jc.createUnmarshaller(); 
     PersonUnmarshallListener pul = new PersonUnmarshallListener(); 
     unmarshaller.setListener(pul); 

     Person person = (Person) unmarshaller.unmarshal(xsr); 
     System.out.println(person); 

     Marshaller marshaller = jc.createMarshaller(); 
     marshaller.setListener(new PersonMarshallListener()); 
     marshaller.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, true); 
     marshaller.marshal(person, System.out); 


    } 
} 

Answer 2

は、私はそれを解決する方法いくつかのコード、（春インテグレーション）

は、あなたが十分な年齢ではないし、後でそれらを処理ファイルを格納するためのバッファを作成することです。

私はそれが完璧ではない（睡眠あり）と知っていますが、それは機能します。より良い解決策は、ファイル交換ではなく、REST-apiでデータを転送することです。

import com.google.common.collect.Lists; 
import org.slf4j.Logger; 
import org.slf4j.LoggerFactory; 
import org.springframework.integration.core.MessageSource; 
import org.springframework.messaging.Message; 

import java.io.File; 
import java.util.List; 

public class LastModifiedFileReadingMessageSource implements MessageSource<File> { 

    private final Logger log = LoggerFactory.getLogger(LastModifiedFileReadingMessageSource.class); 
    private final MessageSource fileReadingMessageSource; 
    private final List<Message<File>> buffer = Lists.newArrayList(); 
    private final long age = 60; 

    public LastModifiedFileReadingMessageSource(MessageSource fileReadingMessageSource) { 
     this.fileReadingMessageSource = fileReadingMessageSource; 
    } 

    public Message<File> receive() { 
     Message<File> message = fileReadingMessageSource.receive(); 
     while (message != null) { 
      if (isOldEnough(message)) { 
       return message; 
      } else { 
       buffer.add(message); 
       log.info("Buffering file which is not old enough: {}; Buffer size: ", message, buffer.size()); 
      } 
      message = fileReadingMessageSource.receive(); 
     } 
     while (!buffer.isEmpty()) { 
      message = buffer.stream().filter(this::isOldEnough).findFirst().orElse(null); 
      if (message != null) { 
       buffer.remove(message); 
       log.info("Use file from buffer: {}; Buffer size: ", message, buffer.size()); 
       return message; 
      } 
      sleep(); 
     } 
     return message; 
    } 

    private void sleep() { 
     try { 
      log.info("Go to sleep for a while... ({} seconds)", age); 
      Thread.sleep(this.age * 1000); 
     } catch (InterruptedException e) { 
      log.error("Thread.sleep was never a good idea ;(", e); 
     } 
    } 

    private boolean isOldEnough(Message<File> message) { 
     long now = System.currentTimeMillis()/1000; 
     return (message.getPayload().lastModified()/1000 + this.age <= now); 
    } 
}