java - 强制将对象放入 Hazelcast 本地 map

Question

我们正在开发一个分布式数据处理系统，Hazelcast 是我们正在使用的组件之一。

我们有一个流数据输入到集群，我们必须处理数据(更新/累积等)。有分布式请求映射，它具有本地条目监听器。我们处理一个新请求(在内存中更新/累积)并放入另一个分布式 map ，这是实际的数据网格。

因此我们可以并发处理每个请求而无需锁定。但是，将数据放入主数据网格可能会涉及网络行程。

有没有办法可以强制指定要选择哪个节点？基本上我想把它放在数据网格的本地 map 中。这应该可以通过避免网络行程来提高整体吞吐量。

通过使用分区感知键，我可以指定所有此类键都转到同一分区，但是，我希望实际“指定”该分区。这可能吗？

Answer 1

您可以为特定分区创建 key 。我们经常这样做是为了测试。

一旦为每个分区创建了这样的 key ，您就可以使用

map.put("yourkey@partitionkey", value)

查看 git 存储库并查找 HazelcastTestSupport.generateKeyOwnedBy(hz)。

重要提示:分区可能在某个时间点属于某个成员，但分区可以在系统中移动。例如。当成员加入/离开集群时，因此解决方案可能很脆弱。