chronicle

    2热度

    1回答

    我想知道纪事图中的原子性语义。如果我有一个跨2个节点(服务器)共享的历史记录映射,并且我尝试在两个节点上同时将相同的密钥插入此映射,那么事务性语义是什么? 第一次成功,第二次失败? 我很好奇,如果Chronicle Map保证Apache Zookeeper具有相同的事务语义? 在我的用例中,我想依赖的事实是,如果node1将密钥K1放入地图中,则该节点2将能够检查K1的存在,如果不存在,它会明确

    3热度

    1回答

    我在玩ChronicleSet,它由ChronicleMap支持。我已经完成了一些初步测试,对我们的需求非常好。内存使用效率比其他解决方案高得多,访问时间稍慢,但仍然非常快。 但是,我测试的一件事是设置最大数量的条目,并且它似乎没有按预期工作。 我用下面的代码: ChronicleSetBuilder<Long> postalSetBuilder = ChronicleSetBuil

    0热度

    1回答

    在OpenHFT的Chronicle Queue的版本3中,在ExcerptAppender(nextSynchronous(boolean))上有一个API调用,要求在下一个摘录完成时强制将队列内容写入磁盘(fsync'd)。我在版本4中看不到类似的调用。是否可以在版本4中实现相同的效果?

    2热度

    1回答

    嗨,我是编年史产品的新用户,直到现在文档/用法看起来相当顺利。 虽然我有一个问题,当Map数据在同一主机上的JVM之间共享时,消费者JVM等待数据时会收到任何类型的回调或信号,或者我们需要实现自定义回调机制。 想法?

    2热度

    1回答

    我打算使用编年史4(SingleChronicleQueue)的IPC。我使用编年史前3(IndexedQueue),它不是线程安全的,我用来创建多个队列每个线程,但我被告诉某人通过使用SingleChronicleQueue我可以使用1队列JVM中的所有线程。 但是,如果2个不同的进程试图在同一个编年史队列中并发写入,它会很好吗? 这是建议做或为不同的过程,我需要创建不同的队列。

    1热度

    1回答

    我一直在试验编年史队列4.5.27。我们在Windows 7x64 VM(Java x64)上运行一些测试,有时候Chronicle Queue似乎永远不会释放它创建的第一个文件。 我们配置了MINUTELY滚动循环。 1-3线程可以写入,另一端有单个消费者处理。我注册了一个StoreFileListener来监听onReleased事件,并从那里修改文件(在Windows上,由于mmap文件已知

    0热度

    1回答

    我评估纪事队列在我们的软件使用,我必须做一些错误的。 我有一个appender,它可以非常快速地写入650k条目。之后,它会停下来,此时内存已经达到最大允许值,并最终击中OutOfMemory。 这里是我的代码: final class LogEntryOutput implements WriteBytesMarshallable { private final int maxMes

    2热度

    2回答

    我正在尝试将Chronicle Queue实现到我们的系统中,并且每天都有一个关于文件滚动的问题,但是在特定的时间根据当地时区的流程。我读了几篇关于如何指定滚动周期的文章,但根据文档说明,纪元时间按UTC的午夜时间工作。我需要做些什么来配置滚动周期让我们说每天在运行过程的当地时区下午5点?有什么建议么? public class TestRollCycle { public class

    2热度

    1回答

    在此先感谢您的支持。 有没有什么办法可以在Chronicle-Map中创建Java NavigableMap?

    2热度

    1回答

    对于恢复的概念,我需要将数据从一个记录队列复制到另一个。 将一个队列中的整个Bytes对象直接复制到另一个队列中是否安全? 类似 documentContext()。电线()。字节()。读(byte_buffer) ,然后包裹此byte_buffer成byte_store和写入作为 documentContext()。电线( ).bytes()。写(byte_Store)。 我这样做的原因是避免任