【问题标题】:Hazelcast topic message expiryHazelcast 主题消息过期
【发布时间】:2016-03-14 07:36:51
【问题描述】:

谁能分享一些关于 Hazelcast ITopic 中消息过期策略的说明?我找不到任何相关文档。

基本上,我正在设计一个利用 Hazelcast 发布-订阅的点对点文件共享子系统。我想确保我的消息块(基本上是文件块)在消息被使用后过期。我确实有一个握手机制,可以在接收完成时得到通知,但是,无法以某种方式“清除”主题。

谢谢

【问题讨论】:

    标签: java publish-subscribe hazelcast


    【解决方案1】:

    “清除话题”是什么意思?消息被消费后,不会再出现在同一个节点上。

    Hazelcast 本身没有内置主题的到期时间,因为系统是一种即发即弃的实现。即使在 ReliableTopic 上,您也必须构建一个包含时间戳的信封。无论如何,我想我不确定您的用例中“到期”的真正含义。

    【讨论】:

    • 所以我的问题应该是,在消息被消费之后,它是否仍然存在于任何分布式数据结构中?我想如果ITTopic内部使用一些IMap来订阅,那么会有消息过期的概念吗?但是,从您的回答看来,它似乎不使用 IMap。
    • 没有 ITTopic 是一劳永逸的。它不会重新传递,也不会存储,它只是发送 :) 因此,在发送消息时每个订阅且可访问的订阅者最多会检索一次。虽然 IReliableTopic 基于 RingBuffer,但它是不同的。对于环形缓冲区,每个客户端/成员都知道自己的最后读取位置,并且不会重新读取相同的元素,无论如何其他消费者都能够读取它。除了使用分布式队列之外,没有一次性交付系统。
    猜你喜欢
    • 1970-01-01
    • 2018-07-22
    • 1970-01-01
    • 2015-03-22
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多