我们正在尝试将 Chronicle HFT 作为低延迟消息传递 b/w 组件的概念证明。我们正在使用chronicle-1.7.2.jar
我们有一个读者和作家,作家一直在为编年史写摘录,而读者则在忙碌的 while 循环中继续阅读。
当编年史文件中有可用数据时,我们无法在 epoll 上挂钩 reader 并使其可选择。通常我们在 DatagramChannel 数据可用性上进行选择。
请阐明如何使阅读器可选择并在编年史上写入数据时注册回调。
我们正在尝试将 Chronicle HFT 作为低延迟消息传递 b/w 组件的概念证明。我们正在使用chronicle-1.7.2.jar
我们有一个读者和作家,作家一直在为编年史写摘录,而读者则在忙碌的 while 循环中继续阅读。
当编年史文件中有可用数据时,我们无法在 epoll 上挂钩 reader 并使其可选择。通常我们在 DatagramChannel 数据可用性上进行选择。
请阐明如何使阅读器可选择并在编年史上写入数据时注册回调。
Chronicle Queue 的一个关键特性是它尽可能避免涉及操作系统。即使是一个系统调用,通常也需要 10 倍于在进程之间传递一条简单消息的时间。
在您的情况下,您可以添加一个后台线程来监视队列并触发 Selector 唤醒。
我建议使用 Chronicle Queue v4.4.3(或最新版本)
http://search.maven.org/#search%7Cga%7C1%7Cchronicle%20queue
特别是我建议你阅读我关于微服务的帖子。