分区感知hazelcast队列

Question

我们是否可以在 Hazelcast 分布式队列上执行分区感知操作？

例如，我将在一个队列中有多个消费者节点，并且希望每次都由同一个节点处理“相似”类型的消息。类似的类型是指消息的一些业务密钥。

目前，我们拥有一个分布式流数据处理生态系统，通过在 IMap 上使用来自本地入口侦听器的消息。一个特定的对象模型属性被设置为键，所以我们知道模型分布在分区中。因此，处理逻辑可以在本地执行，而无需使用分布式锁（或根据设计合同根本不使用任何锁）。我希望使用分布式阻塞队列来实现类似的行为。

这可行吗？使用 Hazelcast 3.3.3

Answer 1

您知道队列（当前）不是分区数据结构吗？因此，集群中有一个成员负责存储该队列中的所有数据（另一个成员负责备份）。

您可以控制队列的存储位置，例如如果您有 2 个队列并希望它们存储在同一个分区中，请使用

foo@somekey bar@somekey

在这种情况下，两个队列都存储在“somekey”分区中。