Hazelcast - 忽略本地消息

Question

对于特定用例，我需要发布到 ITopic 并使用 Hazelcast 客户端（而不是实例）使用来自同一 ITopic 的消息。但是，我不希望在本地处理在主题上生成的消息，即同一组件不应生成和使用自己的消息。

对于 JMS，可以忽略本地消息。但是，我没有为 Hazelcast ITopic 找到这样的选项。

作为一种解决方法，我尝试比较 Message.getMember().getUUID 和 HazelcastInstance.localEndpoint().getUUID()，看看它们是否相同。它们不一样（不知何故，我没想到它们与客户端-服务器设置相同）。

现在的问题是，Hazelcast API 中是否有任何机制可以用来忽略本地消息？或者我是否必须基于组件/客户端维护消息标签并过滤消息。

任何帮助将不胜感激。

Answer 1

Topic 背后的理念是分布式的，任何消费者都可以订阅事件。因此，没有地方性这样的东西。

恐怕您需要在消息中添加额外的元数据来标识您的节点并根据它设置过滤器。