クロニクルロールファイル毎日

Question

私はシステムにクロニクルキューを実装しようとしていますが、ファイルのローリングに関する問題がありましたが、プロセスのローカルタイムゾーンごとに特定の時刻に質問がありました。私は、ロールサイクルを指定する方法に関するいくつかの記事を読むが、ドキュメントごとにエポックタイムはUTCの真夜中に働く。ロールサイクルを設定するために何をする必要がありますか？毎日午後5時に、プロセスのローカルタイムゾーンを実行していますか？助言がありますか？

public class TestRollCycle { 

    public class TestClass implements TestEvent { 
     private int counter = 1; 

     @Override 
     public void setOrGetEvent(String event) { 
      System.out.println("Counter Read Value: " + counter); 
      counter++; 
     } 
    } 

    public interface TestEvent { 
     void setOrGetEvent(String event); 
    } 

    @Test 
    public void testRollProducer() { 
     int insertCount = 1; 
     String pathOfFile = "rollPath"; 
     // Epoch is 5:15PM EDT 
     SingleChronicleQueue producerQueue = SingleChronicleQueueBuilder.binary(pathOfFile).epoch(32940000).build(); 
     ExcerptAppender myAppender = producerQueue.acquireAppender(); 
     TestEvent eventWriter = myAppender.methodWriter(TestEvent.class); 

     while (true) { 
      String testString = "Insert String"; 
      eventWriter.setOrGetEvent(testString); 

      try { 
       Thread.sleep(1000); 
      } catch (InterruptedException e) { 
       e.printStackTrace(); 
      } 
      System.out.println("Counter Write Value: " + insertCount); 
      insertCount++; 
     } 
    } 

    @Test 
    public void testRollConsumer() throws InterruptedException { 
     String pathOfFile = "rollPath"; 
     // Epoch is 5:15PM EDT 
     SingleChronicleQueue producerQueue = SingleChronicleQueueBuilder.binary(pathOfFile).epoch(32940000).build(); 
     TestClass myClass = new TestClass(); 
     ExcerptTailer trailer = producerQueue.createTailer(); 
     MethodReader methodReader = trailer.methodReader(myClass); 

     while (true) { 
      if (!methodReader.readOne()) { 
       Thread.sleep(1000); 
      } else { 
       //System.out.println(trailer.index()); 
      } 
     } 
    } 
} 

Answer 1

これはChronicle Queue Enterpriseに追加された機能です。あなたがそれを支払うつもりなら、sales@chronicle.softwareに連絡することをお勧めします。

Answer 2

あなたのテストには問題があると思います。キュービルダーに供給される32940000のエポックは、真夜中から9時15分、午前9時15分（UTCまたは午前5時15分）です。ロールアップ時間が午後5時15分になると、12時間後にもう1時間かかるはずです。

私はあなたのユースケースの現在の動作を文書化し、期待どおりに合格するテストを追加しました。正しいエポックオフセットを供給していることを再度確認できます。ロールイベントをキャプチャ/ログするには、StoreFileListenerを実装してください。

ロールはロールバック境界の後のキューにイベントが書き込まれるまで実際には発生しません。したがって、書き込まれていないアイドルキューは、入力イベントがなければロールバックしません。

テストはgithubの上にある：応答のための

https://github.com/OpenHFT/Chronicle-Queue/blob/master/src/test/java/net/openhft/chronicle/queue/impl/single/QueueEpochTest.java