问题标签 [chronicle-queue]

我正在编写一个适配器以在 Apache Aries 远程服务管理中使用编年史队列。当我只使用一个线程时它工作正常。使用多个线程时，我会遇到如下异常。

知道我做错了什么吗？

作为参考，这是我的代码： https ://github.com/cschneider/rsa-chronicle-provider/blob/master/src/test/java/org/apache/aries/rsa/provider/chronicle/ChronicleProviderTest.java

如果您增加执行程序中的线程数，您可以看到异常。

我们正在尝试将 Chronicle HFT 作为低延迟消息传递 b/w 组件的概念证明。我们正在使用chronicle-1.7.2.jar

我们有一个读者和作家，作家一直在为编年史写摘录，而读者则在忙碌的 while 循环中继续阅读。

当编年史文件中有可用数据时，我们无法在 epoll 上挂钩 reader 并使其可选择。通常我们在 DatagramChannel 数据可用性上进行选择。

请阐明如何使阅读器可选择并在编年史上写入数据时注册回调。

我真的对chronicle的连接界面感到困惑。我找不到任何关于它的测试代码或源代码。

我想捕捉断开和连接事件。

我的设置看起来像（香草编年史 3.6.2。）；

两个相同的过程，相互连接。

资源：：

裁缝::

当要写入的消息数量很高时，会IllegalStateException在一段时间后获取。这是代码：

循环开始

循环结束

java Chronicle 3.6.2 是 java 1.7 的版本。

我创建了一个每天滚动的队列。第二天，我无法阅读最新的附加消息。我发现tailer index在读取了上一个周期的所有消息后并没有自动移动到最新的周期。顺便说一下，java进程在晚上关闭并在第二天重新启动。

我使用编年史队列 V4.52。

谢谢。

我每天滚动将 utf8 字符串写入编年史队列。默认队列文件大小为 81920 KB。在我写了几十条消息（每条 1 KB）后，文件很快就超过了 1 GB。如何控制文件大小？

从编年史队列中读取消息不会自动将当前索引移动到下一个周期。我收到以下日志消息： 697917 [SCHEDULER#4] INFO net.openhft.chronicle.queue.impl.single.SingleChronicleQueueExcerpts - 滚动 2 次以查找下一个循环文件​​。如果您的附加程序有一段时间没有写入任何内容，则可能会发生这种情况，从而使循环文件有间隙。

这是什么意思？

我的队列文件是：20160824.cq4 20160826.cq4 20160829.cq4 20160830.cq4。20160825.cq4 文件不存在，因为没有数据添加到队列中。

我可以控制编年史队列消耗的最大内存吗？我在带有 Xmx1200m 参数的 32 位 java 进程上遇到以下异常：

如果我将 Xmx 减小到 768m，异常就会消失。

当我从编年史队列中读取消息时，出现异常“java.lang.IllegalStateException：元数据未准备好 c0000000”。是否可以修复此队列文件？

我想阅读写入 SingleChronicleQueue 实例的最后一条消息。

虽然“chronicle.createTailer().direction(TailerDirection.BACKWARD).toEnd()”在我们与最后一条写入消息处于同一周期时有效，但只要我们处于未来周期之一（与最后一次写入相比）消息），tailer.readDocument(...) 总是返回“false”。

我已经基于 SingleChronicleQueueTest.testForwardFollowedBackBackwardTailer测试实现了一个重现问题的测试：

在对“testForwardFollowedBackwardTailer”方法进行这些更改后，测试在“readBackward”方法中的 assertTrue(documentContext.isPresent()) 行失败。

有没有办法可靠地从 SingleChronicleQueue 实例中读取最后一条消息，无论最后一条消息过去多远？（没有从一开始就通读整个编年史实例）