0

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

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

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

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

4

1 回答 1

2

Chronicle Queue 的一个关键特性是它尽可能避免涉及操作系统。即使是一个系统调用,通常也需要 10 倍于在进程之间传递一条简单消息的时间。

在您的情况下,您可以添加一个后台线程来监视队列并触发 Selector 唤醒。

我建议使用 Chronicle Queue v4.4.3(或最新版本)

http://search.maven.org/#search%7Cga%7C1%7Cchronicle%20queue

特别是我建议你阅读我关于微服务的帖子。

http://vanilla-java.github.io/tag/Microservices/

于 2016-06-09T06:33:56.637 回答