点对点 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);