点对点 Queue,不可重复消费

生产者发送一条消息到queue,一个queue可以有很多消费者,但是一个消息只能被一个消费者接受,当没有消费者可用时,这个消息会被保存直到有 一个可用的消费者,所以Queue实现了一个可靠的负载均衡。

生产者往queue发送消息

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

消费者queue消费消息

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

results matching ""

    No results matching ""