java - Hazelcast 中的优先级阻塞队列

Question

我正在评估 Hazelcast IMDG，希望用它来减少一些数据库瓶颈。我们的应用程序运行在多个节点上，并行处理来自中间数据库的数据。

我们使用信号量表来分配工作，我们正在考虑将其替换为 Hazelcast 阻塞队列。

然而，有些要处理的消息比其他消息具有更高的优先级，这让我开始产生怀疑，因为 Hazelcast 似乎没有与 java.util.concurrent.PriorityBlockingQueue 等效的东西。

我的第一个问题是是否有办法通过 Hazelcast 实现这一目标。我的第二个问题是是否有其他易于配置并嵌入到现有应用程序中的 IMDG 数据网格可以实现这一点。

预先感谢您的投入。

Answer 1

我知道有点晚了，但 Hazelcast 终于为分布式 PriorityQueue 提供了开箱即用的支持。请参阅:https://github.com/hazelcast/hazelcast/pull/17201

它是常规队列的扩展，您只需在队列配置中添加一个比较器即可( https://github.com/hazelcast/hazelcast/pull/17201/files#diff-adec01c0eef8a0df650ac3c02789b91a2eafc8c2ffbb6e77c563dc88f5a5e9a2R559 ):

<priority-comparator-class-name>your.comparator.Class</priority-comparator-class-name>

一旦 Hazelcast IMDG 4.1 发布并添加文档，我将更新这篇文章。