chronicle-queue

1熱度

1回答

當'padToCacheAlign'== true時，Chronicle-Queue消息長度更改問題

以下代碼在第20次迭代的第二個assert語句上失敗 - 注意我只是重新創建了導致問題的代碼;計數不相關，而是寫入的字節數是。 SingleChronicleQueue writer = SingleChronicleQueueBuilder.binary("/tmp/broken").build(); ExcerptAppender excerptAppender = writer.

1熱度

1回答

O/S沖洗記錄文件到磁盤導致非常高的延遲？

我們在低延遲應用程序（在Linux Centos機器上）使用Vanilla Chronicle隊列，版本3.6.0。我們的客戶報告說，有一天，我們的客戶報告在應用程序中缺乏響應2.5秒（我們已經運行了很多個月，但沒有發生這種情況）。我們在延遲時間檢查了文件的頂部，並看到當時進程正在運行flush命令。（截屏來自頂上如下公佈。）大家都在猜測，該O/S刷新紀事內存頁到磁盤，這阻礙了我們的處理線程持

0熱度

1回答

如何通過ServiceWrapper分配StoreFileListener實現？

從Chronicle-Queue v4.5.27開始，似乎ServiceWrapperBuilder需要增強以包含StoreFileListener分配？如果有不同的構造，再次，通過ServiceWrapper隊列創建，它是什麼？

2熱度

1回答

Maven Central的Chronicle隊列

我發現maven central的chronicle-queue版本已經很老了：4.5.27，而4.6.23是github上最新發布的版本。這是否意味着4.5.27是一種「prod-ready」，而所有4.5.27+都是實驗性的？或者您使用其他存儲庫進行分發？

2熱度

1回答

紀事地圖回調

嗨，我是編年史產品的新用戶，直到現在文檔/用法看起來相當順利。雖然我有一個問題，當Map數據在同一主機上的JVM之間共享時，消費者JVM等待數據時會收到任何類型的回調或信號，或者我們需要實現自定義回調機制。想法？

2熱度

1回答

Chronicle V4 - 同時寫在同一個Chronicle隊列安全

我打算使用編年史4（SingleChronicleQueue）的IPC。我使用編年史前3（IndexedQueue），它不是線程安全的，我用來創建多個隊列每個線程，但我被告訴某人通過使用SingleChronicleQueue我可以使用1隊列JVM中的所有線程。但是，如果2個不同的進程試圖在同一個編年史隊列中併發寫入，它會很好嗎？這是建議做或爲不同的過程，我需要創建不同的隊列。

1熱度

1回答

更新摘錄在紀事隊列

我們將事件存儲在Chronicle隊列V4中，並有一個Tailer來處理它們。其中一些事件過期（不是基於時間的，但是被後來的事件所取代），因此可以在處理過程中跳過。有沒有辦法更新現有的摘錄，即設置一個布爾標誌「過期」爲真，所以我們可以跳過過期的事件？還是有另一種解決方案來實現Chronicle隊列？例如，系統生成事件A1，B1和C1。現在事件B2到達，使B1過時。我們現在可以在沒有昂貴處理的情

2熱度

2回答

Chronicle每日滾動文件

我正在嘗試將Chronicle Queue實現到我們的系統中，並且每天都有一個關於文件滾動的問題，但是在特定的時間根據當地時區的流程。我讀了幾篇關於如何指定滾動週期的文章，但根據文檔說明，紀元時間按UTC的午夜時間工作。我需要做些什麼來配置滾動週期讓我們說每天在運行過程的當地時區下午5點？有什麼建議麼？ public class TestRollCycle { public class

2熱度

1回答

Linux基於JNA的關聯無法使用，因爲它無法加載

我有一個在java上實現的偵聽器項目，它使用來自kafka的數據並將其推入到Vanilla Chronicle隊列中。我正在使用jna，jna-platform版本4.4.0和編年史隊列版本3.6.4的java庫。當我在Windows上運行項目時，它成功地消耗並將數據推入隊列。但是，當我在位於Azure VM上的「Ubuntu 16.04.3 LTS」上運行它時，將數據推入隊列時失敗。另外，當我在

2熱度

1回答

將數據從一個Chronicle複製到另一個

對於恢復的概念，我需要將數據從一個記錄隊列複製到另一個。將一個隊列中的整個Bytes對象直接複製到另一個隊列中是否安全？類似 documentContext（）。電線（）。字節（）。讀（byte_buffer），然後包裹此byte_buffer成byte_store和寫入作爲 documentContext（）。電線（）.bytes（）。寫（byte_Store）。我這樣做的原因是避免任