问题标签 [chronicle-queue]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
1092 浏览

java - 如何在 Reactor 中使用 PersistentQueue?

我正在尝试将Reactor配置为使用基于Chronicle的持久性,但我无法在文档中找到有关此内容的信息。我看到两种方法:

  1. 创建我自己的调度员支持PersistentQueue
  2. 与此类队列一起使用EventBatcher来包装我的Reactor实例

哪个选项更好?或者也许还有另一个我忽略的解决方案?

0 投票
3 回答
359 浏览

chronicle - 我可以将不同类型的消息写入编年史队列吗?

我想将不同类型的消息写入编年史队列,并根据消费者的类型处理消费者中的消息。

我怎样才能做到这一点?

0 投票
1 回答
112 浏览

java - 如何从特定日期开始重播 VanillaChronicle 中的数据?

由于 VanillaChronicle 将数据存储在按日期命名的不同目录中,我可以从特定日期开始重播数据吗?示例代码表示赞赏。谢谢!

0 投票
1 回答
183 浏览

maven - 构建 OpenHFT / Chronicle Queue 的问题

我一直在尝试构建最新版本的编年史队列(3.4.4),但一直遇到依赖解析失败。oss sonatype 存储库中缺少一些依赖项 SNAPSHOT 版本等。是否有一个可以用来构建整个产品套件的“全部”jar?任何记录构建过程的教程?

0 投票
1 回答
267 浏览

java - 热身纪事

我在延迟敏感的应用程序中使用 Indexed Chronicle 队列(版本 3.4.3)。为了消除延迟峰值,我在编年史前面有一个阻塞队列,生产者在其中丢弃消息。然后后台线程轮询队列并将数据写入 Chronicle。

我想知道有没有什么技巧可以热身编年史?我通过使一组消息入队/出队来预热阻塞队列。我是否应该将这些信息写入编年史并清理它以使其热身?

谢谢

0 投票
1 回答
466 浏览

ipc - 如何将编年史队列用于非持久 IPC?

我不需要本地 IPC 的任何持久性。我可以以某种方式使用具有固定大小或固定大小文件的内存的编年史队列作为缓冲区,以便不必存储已处理的消息吗?或者你能告诉我这种情况吗?

0 投票
1 回答
210 浏览

chronicle - 编年史问题?难道我做错了什么?

该程序使用 net.openhft:chronicle:3.5.3 说明了我在使用 Chronicle 时遇到的以下问题。

1 Vanilla Chronicle.size() 返回疯狂的值

2 ExcerptTailer.toStart 不适用于索引编年史

3 ExcerptTailer.index(-1) 不适用于香草编年史

0 投票
1 回答
87 浏览

chronicle - 如果消费者在 Chronicle 上失败会发生什么

嗨,看看 Chronicle v3,如果消费者读取队列的记录然后尝试对下游的记录做某事但失败了,会发生什么。

可以再次从队列中提取该记录吗?一切都需要重播吗?

考虑使用 Chronicle Queue 对一堆 json 文档进行排队并将它们批处理到 Elasticsearch :)

0 投票
1 回答
352 浏览

chronicle - 多个 Chronicle/ExcerptAppender 可以写入同一个队列吗?

将 Chronicle 与 vertx.io 一起使用...

我为每个垂直创建一个新的编年史。即:每个线程一个实例。

现在对于我所做的每个 web http POST 请求......每个帖子一次只由 1 个线程处理。

这似乎有效。但是可以吗?

0 投票
1 回答
234 浏览

java - Chronicle Queue 可以像 RMI 一样使用吗?

我希望我的两个 JVM 应用程序在同一台机器上相互通信。我考虑过使用 RMI,但后来我发现Chronicle Queue声称它非常快。我想知道是否可以使用 Chronicle 调用另一个 JVM 上的方法并等待返回值。有什么用例吗?