发布/订阅:Topic,可以重复消费

发布者发送到topic的消息,只有订阅了topic的订阅者才会收到消息。topic实现了发布和订阅,当你发布一个消息,所有订阅这个topic的服务都能得到这个消息,所以从1到N个订阅者都能得到这个消息的拷贝。

生产者往topic发布消息

// Destination :消息的目的地;消息发送给谁.
Destination destination = session.createTopic("demo2");
// MessageProducer:消息发送者
MessageProducer producer = session.createProducer(destination);

消费者消费订阅的topic中的消息

// Destination :消息的目的地;消息送谁那获取.
Destination destination =  session.createTopic("demo2");
// 消费者,消息接收者
MessageConsumer consumer1 =  session.createConsumer(destination);

results matching ""

    No results matching ""