问题标签 [chronicle-queue]

我目前将我的对象放入编年史队列如下

考虑到“对象”类正在扩展 AbstractMarshallable 并且有一些整数、长整数和字符串，是否有更有效的方法将其传递给队列？我目前从队列中读取它的方式是调用Marshallable.fromString(text);. 我正在寻找一个没有太多代码但仍然很快的简单用例。

我有一个关于 Chronicle 队列如何避免垃圾收集的问题：

我了解 Chronicle 队列使用内存映射文件，以便它可以将对象保存到主内存或 dist 而不是 JVM。但是，当处理器从主内存中反序列化对象时，它仍然需要创建一个新实例。那么 Chronicle 队列究竟在哪里避免垃圾收集呢？

请参阅来自 Chronicle github 示例的以下案例。在执行写入/读取操作时，仍然需要使用 MyObject me = new MyObject() 创建一个新实例，“me”将被垃圾回收。

当在 Chronicle Queue 上使用 ExcerptAppender（仅附加日志）时，是否可以保证在断电的情况下仅截断文件末尾，即所有中间记录都不会损坏？如果是这样，这依赖于什么实现/文件系统/操作系统行为？

我对 linux/x64 感兴趣。由于这是通过 mmap - 我的理解是未定义从页面缓存中刷新页面的顺序，并且磁盘可以重新排序写入。是否应该只保证 SSD 或特定文件系统？

在某些容器盒中，编年史队列不起作用。我看到此异常：2018-11-17 16:30:57.825 [failsafe-sender] WARN nocqisSingleChronicleQueueExcerpts$StoreTailer - 无法附加 EOF，跳过 java.util.concurrent.TimeoutException：标头：80000000，位置：104666 在 net.openhft.chronicle.wire.AbstractWire.writeEndOfWire(AbstractWire.java:459) 在 net.openhft.chronicle.queue.impl.single.SingleChronicleQueueStore.writeEOF(SingleChronicleQueueStore.java:349) 在

我想了解为什么只在某些虚拟机中。

注意：我们使用的是 NFS 文件系统

试图了解 NFS 中的行为

我正在使用 Chronicle Queue (CQ) 设置市场数据回测，从二进制文件读取数据然后写入单个 CQ，同时从该 CQ 读取数据并转储统计数据。我正在做一个 POC 来替换我们现有的实时市场数据馈送处理程序工作队列。在 Linux/SSD 设置上进行基本的读/写测试时，我看到读取落后于写入 - 事实上延迟正在累积。Appender 和 Tailer 都在同一主机上作为单独的进程运行。

想知道，如果我使用的代码有任何问题？

以下是代码片段 -

作家 - 在构造函数中 -

在数据回调中 -

其中 myDataPacket 是包装 byte[] 和其他字段的 Java 对象。

Tailer - 在构造函数中 -

在读取方法中 -

非常感谢任何帮助。

谢谢，帕万

为什么没有定义每周滚动循环？有什么理由不应该使用它们吗？

我刚刚开始使用编年史队列 - 但是我对使用哪个 API 来读取/写入队列有点困惑。特别是 Chronicle-queue-5与Chronicle-3.5。*

我已经浏览了这个基本上使用 Chronicle-queue API 的链接，但是还有其他类似的使用 Chronicle。

下面这2个有什么区别？

对比

ChronicleQueue 和 Chronicle的 Javadoc 文档看起来非常相似

如this question的答案中所述，我想使用编年史队列使用高级API存储消息。但我也想要我的消息的某种密钥，如此处所述

1.) 首先，这是使用高级 API 进行读/写的正确/有效方式吗？- 下面的代码示例

2.) 如何区分不同类别的消息？例如“获取特定键的所有消息，下面代码示例中的键是 ric”。也许在同一个队列中使用不同的主题？但我该怎么做呢？

这是我要写入队列的测试代码：

这是一个要阅读的内容：

我的界面：

实现填充：

磁盘空间完成后，我得到了 InternalError。添加磁盘空间并不能解决问题。

是否有可能恢复并继续坚持？
可能出错我可以尝试重新创建/关闭吗？

的创建queue queue = SingleChronicleQueueBuilder.binary(basePath) .build();

在单线程上写入“TradeReactorEventPersister-1”

在下一个例外之后：

添加磁盘空间后我无法坚持。每次尝试持久化事件时，我都遇到了最后一个异常：

像这样的类应该在哪里添加 try-with-resources 以便正确关闭资源？我认为应该如图所示重用附加程序，对吗？