问题标签 [chronicle-queue]

编年史队列 doco 指定可以在不同的盒子上拥有编年史接收器，并且事件通过网络从单个编年史队列分发给它。( http://chronicle.software/products/chronicle-queue/ )

我的问题是是否可以做相反的事情？

从这些编年史接收器中，我们希望生成新事件，然后将其发送到单个新队列。（不更新现有事件 - 因为这些新事件仅在收到适当的事件组合时生成 - 否则复制模型听起来合适？）是否可以将本地队列全部复制到一个盒子中的单个盒子队列？

嗨，我正在使用以下队列版本，

我的 Chronicle 阅读器在某个时刻卡住了（索引 74204158352345 ）并且 readDocument 在每次调用后返回 false，但我的 Chronicle 编写器继续将消息写入同一个队列。阅读器代码如下，

我在 while 循环中调用 readDocument。日志中没有编年史错误。但是我的代码在来自编年史队列的最后一条消息上刹车，因为该消息不完整。我只得到了最后一条消息的一些字节，并且在 readDocument 返回 false 之后。但是有消息不断写入队列。

我的作家代码，

4.5.27 & 1.7.32我尝试在本地机器上将队列升级到最新的（

在新版本中，readDocument 方法被挂起。可能挂在递归上。可能是什么问题，请帮忙。

我在多个 Linux 主机上运行的应用程序之一中使用 Chronicle Queue 4.5.15。该应用程序的每个实例都有自己的编年史队列，通常存储数百万个字符串。

最近我注意到每个实例上的队列文件都消失了。一旦尾部循环增加，我的应用程序确实具有删除编年史文件的代码，但是我已经登录到那里说明何时发生这种情况并且没有在日志中看到这种情况发生。

我的问题是 - Chronicle 库是否会出于任何原因删除队列文件？我认为该库从未删除文件，但我只想确认这一点，以便我可以从调查文件丢失的原因中消除它。

嗨，我是 Chronicle Queue 的新手，我有一些疑问，

1. 我想用每小时滚动的存储文件创建一个 ChronicleQueue 我该如何创建一个。我按如下方式创建作家，

   /li>

2. 另外我想在消费者完成阅读后删除文件，我可以按以下方式创建一个作家吗？

   /li>

我想知道在这种情况下我是否以正确的方式做事。

3. 我们是否需要将循环编号也存储在阅读器中，以便在重新启动后阅读。目前我只存储索引。

使用版本 4.5.27 我正在使用此代码将 Throwable 写入队列，然后将其读回。

写作工作正常，当我转储队列时我可以看到异常。

但是阅读会抛出这个异常：

我已经尝试过其他对象（Marshallables）并且效果很好。

非常感谢您的帮助

我一直在对 Chronicle 队列进行一些性能测试，但我没有得到 Chronicle 声称的微秒延迟。我有一个作家和读者设置。写入器将当前时间写入队列，读取器从队列中读取并获取当前时间并进行差异获取延迟。我对一百万条消息执行此操作，然后取平均值。

我的作家的代码：

我的读者

我得到了几十甚至几百毫秒的延迟。有什么可以帮助我的吗？我认为我做的事情显然是错误的。

我正在评估 Chronicle Queue 在我们软件中的使用情况，我一定是做错了什么。
我有一个附加程序，可以非常快地写入大约 650k 条目。之后，它停止运行，此时内存已飙升至允许的最大值，并最终达到 OutOfMemory。

这是我的代码：

这是在带有 64 位 JVM 的 Windows 7 x64 中运行的，使用：-Xmx1024m
任何想法我可能做错了什么？

编辑：我有其他信息。我在内存峰值之后拍摄了对象分配的快照。很多对象数组等。 以及当我收到 OOM 错误时的堆栈跟踪。

我有以下代码可以从 Chronicle 队列中读取（它是用 Kotlin 编写的，但这并不重要）：

如何修改注释代码以从队列中读取前 10 条记录并继续？

理由：在队列用于显示日志的情况下很有用。您想查看一些以前的日志记录语句并在它们出现时查看新的日志记录语句。

我正在使用以下代码将 byte[] 写入编年史队列，

如何从队列中读回相同的 byte[]。我发现了这样的东西，

但在这种情况下，我需要长度。我是否需要单独编写长度并读取相同的长度以创建字节 []。？

或者有没有办法让框架本身处理长度，这样我们就可以读起来像，

我找不到太多关于此的文档。

从 github 得到这个样本，

这是否推荐用于生产。？

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