从零开始···AMQ主题模式实现

上一章实现了点对点的消息模式，接下来试着实现一下主题模式。
两者代码大致相同，但却让我纠结了好久才成功。
首先要理解一下主题模式的概念：
同样是发布者和消费者，这里发布者将消息发布到一个主题下，这时，订阅了这个主题的消费者就能接收到发布的消息。
简单来说，就像是订阅杂志，从你订阅杂志开始，你就能收到接下来出的杂志，但你肯定收不到之前已经发布的杂志。
这是与队列不同的地方，队列类似把消息放到一个地方，等着消费者过来取，取走了就没了，只有一份；主题是把消息复制发送给所有订阅了的消费者，只发送一次，所以后订阅的收不到这个消息。
以上是我的理解，有错误的地方请指正，谢谢。
接下来就是代码：
发布者的代码基本相同，唯一改变的地方是建立地址：

这里用的是createTopic方法，因为使用的是主题模式。
然后需要一个监听器，相当于帮助消费者订阅主题的：

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;public class MyMessageListener implements MessageListener {@Overridepublic void onMessage(Message message) {try {System.out.println("topic message" + ((TextMessage) message).getText());} catch (JMSException e) {e.printStackTrace();}}
}

然后就是消费者的代码，同样修改不是很大：

这里修改了两个地方，一个是创建地址改为创建主题。另一个是将接收消息的操作交给监听器执行。
代码写好以后，先运行消费者类，然后运行发布者类。
在控制台可以看到输出：

我这里用了三个线程进行测试，可以看到三个消费者都分别拿到了消息数据。

从零开始···AMQ主题模式实现相关推荐

AMQ初级使用（队列模式+主题模式）
队列模式 1.生产者代码: package com.zzf.jms.queue;import org.apache.activemq.ActiveMQConnectionFactory;import ...
java 配置jmstemplate_SpringBoot集成JmsTemplate(队列模式和主题模式)及xml和JavaConfig配置详解...
1.导入jar包: org.springframework.boot spring-boot-starter-activemq org.apache.activemq activemq-pool 2. ...
R语言使用ggplot2包使用geom_boxplot函数绘制基础分组箱图（主题模式配置、色彩设置）实战
R语言使用ggplot2包使用geom_boxplot函数绘制基础分组箱图(主题模式配置.色彩设置)实战目录 R语言使用ggplot2包使用geom_boxplot函数绘制基础分组箱图(分组箱体框颜 ...
RabbitMQ六种队列模式-主题模式
前言 RabbitMQ六种队列模式-简单队列 RabbitMQ六种队列模式-工作队列 RabbitMQ六种队列模式-发布订阅 RabbitMQ六种队列模式-路由模式 RabbitMQ六种队列模式-主题 ...
【转】RabbitMQ六种队列模式-5.主题模式
前言 RabbitMQ六种队列模式-简单队列 RabbitMQ六种队列模式-工作队列 RabbitMQ六种队列模式-发布订阅 RabbitMQ六种队列模式-路由模式 RabbitMQ六种队列模式-主题 ...
RabbitMQ主题模式（Topic）
主题模式(Topic) 主体模式其实就是在路由模式的基础上,支持了对key的通配符匹配(星号以及井号),以满足更加复杂的消息分发场景. "#" : 匹配一个或者多个 "* ...
代码主题darcula_darcula主题模式是()模式。_学小易找答案
[多选题]android studio安装并配置完成后,在命令行窗口输入()命令验证配置成功. [填空题]darcula主题模式是()模式. [单选题]当前unity官网最新版本是() [多选题]如何 ...
rabbitmq入门（四）Topics主题模式
文章目录 Topics主题模式代码实现测试总结下一章 Topics主题模式交换机类型为 topics - 将路由和某个模式匹配,# 匹配一个或者多个,* 匹配一个.例如交换机绑定的routi ...
五、交换机与发布/订阅模式、路由模式、主题模式
RabbitMQ目录文章目录交换机与发布/订阅模式.路由模式.主题模式 1.Exchanges(交换机) 1.1. Exchanges 概念 1.2. Exchanges 的类型 1.3. 无 ...

从零开始···AMQ主题模式实现

从零开始···AMQ主题模式实现相关推荐

最新文章

热门文章