chronicle

    1熱度

    1回答

    當要寫入的消息數很多時,在一段時間後變爲IllegalStateException。下面是代碼: chronicle = ChronicleQueueBuilder.indexed(basePrefix).build(); 循環開始 { appender = chronicle.createAppender(); appender.startExcerpt();

    1熱度

    1回答

    當我從一個編年史隊列中讀取消息時,我得到一個異常「java.lang.IllegalStateException:元數據未準備好c0000000」。是可以修復這個隊列文件?

    1熱度

    2回答

    我創建了一個每日滾動的隊列。第二天,我無法閱讀最新的附加信息。我發現在讀取上一個週期中的所有消息後,尾部索引不會自動移動到最新週期。順便說一句,java進程在晚上關閉,並在第二天重新啓動。 我使用Chronicle隊列V4.52。 謝謝。

    0熱度

    1回答

    我們正在嘗試Chronicle HFT作爲低延遲消息黑白組件概念的證明。我們正在使用編年史-1.7.2.jar 我們有一個讀者和作家,作家不斷寫作摘錄到編年史和讀者不斷閱讀它在一個繁忙的while循環。 我們無法在epoll上掛接閱讀器,並在歷史記錄文件中存在可用數據時使其可選。通常我們選擇DatagramChannel數據可用性。 請注意如何讓讀寫器選擇並在有記錄數據時註冊回調。

    2熱度

    1回答

    我期待着使用紀事地圖作爲數據存儲/數據緩存和打算與在同一機器上運行的其他JVM進程共享,以減少其他每個JVM進程的內存佔用否則每個JVM進程都會加載相同的數據。每當從數據存儲添加或刪除條目時,是否可以在每個JVM進程上獲取通知?它真的會減少內存佔用?因爲,無論如何,每個JVM進程都將創建一些域對象。 我看着API和文檔,但它不是太清楚,我如何實現我的使用情況。 MapMethods和remoteO

    0熱度

    2回答

    這用於處理編年史隊列v3。它不會在v4中創建隊列。我究竟做錯了什麼?謝謝。 Chronicle chronicleSignal = ChronicleQueueBuilder.vanilla(「somePath」)。build(); ExcerptAppender appender = chronicleSignal.createAppender();

    0熱度

    1回答

    import net.openhft.chronicle.map.ChronicleMap; import java.io.File; import java.io.Serializable; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; public class App { pu

    1熱度

    1回答

    堆內存的工作方式讓我感到困惑。我有一臺服務器,內存爲32GB,一個大小爲1TB的鍵值映射數據集。我正在尋找一個簡單而快速的嵌入式Java數據庫,該數據庫允許我根據這個1TB數據集將鍵映射到一個值,而這個數據集大部分都必須從磁盤讀取。這個數據集中的每個條目很小(< 500字節),所以我認爲使用文件系統將是無效的。 我想使用Chronicle Map來做到這一點。我讀過關於堆內存使用情況可能會超出內存

    1熱度

    1回答

    1)在最chronicle queue v4顯示test patterns某種形式的DocumentContext.isPresent()busy state checking,當ExcerptTailer位於隊列的末尾和代碼正在等待爲新條目從ExcerptAppender到達。 2)是否有一個內置的編年史隊列機制異步appender -> tailer通知,使得在收到通知的事件,給tailer保

    1熱度

    1回答

    我每天滾動編寫utf8字符串到編年史隊列。默認隊列文件大小爲81920 KB。在我寫了幾十條消息(每個1 KB)之後,該文件快速變爲超過1 GB。我如何控制文件大小?