[Hazelcast系列九] 主题(Topic)

2022-04-18 00:00:00 集群 订阅 消息 主题 顺序

Hazelcast支持常用的publish/subscribe消息模型。发布和订阅都是集群级操作,一个member订阅主题,其实是订阅了集群内所有member发布到主题的消息,即使member是在订阅之后加入集群。

发布/订阅主题

发布消息:

fun main() = runBlocking {
    val hz: HazelcastInstance = Hazelcast.newHazelcastInstance()
    val topic = hz.getTopic<String>("topic")
    topic.publish("hello")
}

相关文章