[Hazelcast系列九] 主题(Topic)
Hazelcast支持常用的publish/subscribe消息模型。发布和订阅都是集群级操作,一个member订阅主题,其实是订阅了集群内所有member发布到主题的消息,即使member是在订阅之后加入集群。
发布/订阅主题
发布消息:
fun main() = runBlocking {
val hz: HazelcastInstance = Hazelcast.newHazelcastInstance()
val topic = hz.getTopic<String>("topic")
topic.publish("hello")
}
相关文章