问题标签 [chronicle]

我正在尝试第一次尝试反应器。所以我克隆并构建（如在https://github.com/reactor/reactor中）。

我使用的是 windows XP 和 jdk 8。但是，当我运行 ./gradlew 测试时，出现以下错误：

似乎我在这篇文章中遇到了类似的错误。在这篇文章中，如果不使用该功能，建议@Ignore 测试。但我不确定将来是否会使用这些功能。

任何人都知道如何成功构建和测试而不必@Ignore？

我正在使用 VanillaChronicle 将一些消息写入磁盘。

如果从多个线程调用 appendMessage(String message) 方法，如上所示，是线程安全的吗？

我在某处读到 VanillaChronicle 的 append(String message) 是线程安全的。但是，我认为 startExcerpt() + append() + finish() 的复合动作不是线程安全的，这是否正确？

谢谢。

有一个非常简单的 poc，比如这个：

给我一个IndexOutOfBoundsException在writeObject方法上的VanillaAppender。

但是，几乎没有区别，文档中也没有什么特别的不同

谁能建议它应该如何使用？

更新：

我重新安排了代码，使其与 peters 相同（实际上是复制了它），但我仍然得到这个异常：

导入的版本是3.2.1

我只是在尝试 ChronicleMap 并立即遇到了一个问题，即“UnsupportedClassVersionError: Unsupported major.minor version 52.0”。

我正在使用 Java 7... 我是否应该将此错误解释为 Chronicle Map 是在 Java 8 下编译的？我是否需要下载源代码并在 Java 7 下编译来解决这个问题（这甚至可以工作）？

我正在尝试编年史地图 2.0.0.a，并设置了一个玩具示例地图。我想设置一个乒乓示例，我在一个 JVM 中设置一个值并从另一个 JVM 中读取。我在下面的代码中得到了一个调用 map.get 的 NPE。这很奇怪，因为地图不为空（在命令行上打印出“{}”）......有人见过这个吗？

更多信息......如果我在 while 循环之前添加一行到map.put(7, true)，然后map.get(7)抛出一个不同的异常：

引起：java.lang.IllegalStateException：net.openhft.lang.io.serialization.BytesMarshallableSerializer.readSerializable(BytesMarshallableSerializer.java:119) 处的未知类型 ¬ net.openhft.lang.io.AbstractBytes.readInstance(AbstractBytes.java: 1907) ... 16 更多

我想玩一下 ChronicleMap，有点困惑我应该在生产中使用哪个版本。

1.*看起来像“已发布”，2.*看起来像处于 alpha 阶段。我会使用发布版本，但据我了解，当前文档指的是 alpha 版本的功能。即我没有看到OffHeapUpdatableChronicleMapBuilder。1.0.2由于它是“官方”文档，我认为它2.*也可以用于生产。它可以？

PS 环境 - 用于开发的 Java 8、64 位 Windows，生产中的 linux。

我们正在为akka-persistence实现存储插件， 这意味着 2 个提供者，用于：

1. 队列类日志插件 API
2. 类似地图的快照存储插件 API

由于只有Chronicle Map支持多节点对称复制，因此我们将Chronicle Queue排除在外。

问题：在地图顶部创建快速队列的最佳方法是什么？谢谢你。

当我尝试使用 Chronicle Map 时，我遇到了一些我无法解决的错误。在我最近的调试尝试中，我将流读入内存以检查字节是什么，但它使整个 JVM 崩溃。

我正在使用 Kryo 来写入我的数据，并使用BytesMarshaller<T>如下所示的每种类型将其读回：

写和读：

我试过关闭流但遇到完全相同的问题。

当我开始迭代一个键集时会发生这个问题 - 不确定这是否相关。

这是我的堆栈跟踪：

我查看了Chronicle Java文档，没有看到任何更新和删除 Chronicle 队列中现有条目的方法。Chronicle 队列是否仅支持 WRITE/APPEND 和 READ 操作？

提前谢谢你。

我正在开发一个临时实时流处理框架，该框架在内部使用java-chronicle库在构建块之间交换数据。

编年史使用磁盘空间来存储附加到队列的项目，并随着每条新消息而增加空间。

由于我只使用一次消息 - 重播行为由处理元素之外的 kafka 支持 - 处理的元素可能会被删除，从而清理磁盘空间。有没有办法通过删除条目来释放编年史文件占用的空间？

另一种方法是在固定数量的消息后打开新的编年史，并跟踪已经使用的编年史，然后将其从磁盘中删除。...但这似乎不是一个非常顺利的解决方案;-)

所以，我的问题是，是否有一种方法可以从编年史中删除已处理/尾部条目？