0
点赞
收藏
分享

微信扫一扫

【ActiveMQ入门-5】ActiveMQ学习-Queue与Topic的比较

QueueTopic的比较


1、JMS Queue执行load balancer语义:

一条消息仅能被一个consumer收到。

如果在message发送的时候没有可用的consumer,那么它将被保存一直到能处理该message的consumer可用。

如果一个consumer收到一条message后却不响应它,那么这条消息将被转到另一个consumer那儿。

一个Queue可以有很多consumer,并且在多个可用的consumer中负载均衡。

如何理解:如果一个consumer收到一条message后却不响应它,那么这条消息将被转到另一个consumer那儿。

见附件中的程序:

【ActiveMQ入门-5】ActiveMQ学习-Queue与Topic的比较_topic【ActiveMQ入门-5】ActiveMQ学习-Queue与Topic的比较_topic_02【ActiveMQ入门-5】ActiveMQ学习-Queue与Topic的比较_java_03

在Receiver.java中, 创建了消费者并实现了同步接收:

while (true) {
// 设置接收者接收消息的时间,为了便于测试,这里谁定为100s
TextMessage message = (TextMessage) consumer.receive(18000);
// Object message = (Object) consumer.receive(28000);
if (null != message) {
System.out.println("订阅者1:收到消息-->" + message.getText());
} else {
System.out.println("订阅者1:运行结束...\n");
break;
}
}

在Receiver2.java中,创建了消费者但是注释掉了接收部分的程序:

//while (true) {
// // 设置接收者接收消息的时间,为了便于测试,这里谁定为100s
// TextMessage message = (TextMessage) consumer.receive(18000);
// if (null != message) {
// System.out.println("订阅者2:收到消息-->" + message.getText());
// } else {
// System.out.println("订阅者2:消费者运行结束...\n");
// break;
// }
// }

先分别将Receiver和Receiver2运行起来,然后再运行Sender,将得到如下运行结果:

【ActiveMQ入门-5】ActiveMQ学习-Queue与Topic的比较_消息处理_04


【ActiveMQ入门-5】ActiveMQ学习-Queue与Topic的比较_java_05

【ActiveMQ入门-5】ActiveMQ学习-Queue与Topic的比较_topic_06


特别注意:订阅者2在订阅者1之后停止运行,如何在订阅者1前停止运行,结果还不一样。

【ActiveMQ入门-5】ActiveMQ学习-Queue与Topic的比较_topic_07


此时再次开启receive1,将看到:

【ActiveMQ入门-5】ActiveMQ学习-Queue与Topic的比较_topic_08



如果订阅者2在订阅者1之前停止运行,将会出现如下运行结果:

【ActiveMQ入门-5】ActiveMQ学习-Queue与Topic的比较_消息处理_09



2、Topic实现publish和subscribe语义:

一条消息被publish时,它将发到所有感兴趣的订阅者,所以零到多个subscriber将接收到消息的一个拷贝。但是在消息代理接收到消息时,只有激活订阅的subscriber能够获得消息的一个拷贝。

3、分别对应两种消息模式:

Point-to-Point (点对点),Publisher/Subscriber Model (发布/订阅者)

其中在Publicher/Subscriber 模式下又有Nondurable subscription(非持久订阅)和durable subscription (持久化订阅)2种消息处理方式。

举报

相关推荐

0 条评论