主题模式
主题模式就是订阅模式，和队列模式不一样，不用争抢，就像听大喇叭，都能听得到。
实例
仍然用上一个maven项目。
生产者类
TestTopicProducter,和TestProducter差不多一样，只是创建主题又区别，
//5.创建一个目标 (主题类型) Destination destination=session.createTopic(topicName);
package edu.hpu.queue; import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.Destination; import javax.jms.JMSException; import javax.jms.MessageProducer; import javax.jms.Session; import javax.jms.TextMessage; import org.apache.activemq.ActiveMQConnectionFactory; import edu.hpu.util.ActiveMQUtil; public class TestTopicProducter { //服务地址，端口默认61616 private static final String url="tcp://127.0.0.1:61616"; //这次发送的消息名称 private static final String topicName="topic_style"; public static void main(String[] args) throws JMSException { //0. 先判断端口是否启动了 Active MQ 服务器 ActiveMQUtil.checkServer(); //1.创建ConnectiongFactory,绑定地址 ConnectionFactory factory=new ActiveMQConnectionFactory(url); //2.创建Connection Connection connection= factory.createConnection(); //3.启动连接 connection.start(); //4.创建会话 Session session=connection.createSession(false, Session.AUTO_ACKNOWLEDGE); //5.创建一个目标 (主题类型) Destination destination=session.createTopic(topicName); //6.创建一个生产者 MessageProducer producer=session.createProducer(destination); for (int i = 0; i < 100; i++) { //7.创建消息 TextMessage textMessage=session.createTextMessage("主题消息-"+i); //8.发送消息 producer.send(textMessage); System.out.println("发送："+textMessage.getText()); } //7. 关闭连接 connection.close(); } }
消费者类
TestTopicConsumer，和TestConsumer类似，也是创建目标的时候不一样，
//5.创建一个目标 （主题类型） Destination destination=session.createTopic(topicName);
package edu.hpu.queue; import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.Destination; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageConsumer; import javax.jms.MessageListener; import javax.jms.Session; import javax.jms.TextMessage; import org.apache.activemq.ActiveMQConnectionFactory; import cn.hutool.core.util.RandomUtil; import edu.hpu.util.ActiveMQUtil; public class TestTopicConsumer { //服务地址，端口默认61616 private static final String url="tcp://127.0.0.1:61616"; //这次消费的消息名称 private static final String topicName="topic_style"; //消费者有可能是多个，为了区分不同的消费者，为其创建随机名称 private static final String consumerName="consumer-" + RandomUtil.randomString(5); public static void main(String[] args) throws JMSException { //0. 先判断端口是否启动了 Active MQ 服务器 ActiveMQUtil.checkServer(); System.out.printf("%s 消费者启动了。 %n", consumerName); //1.创建ConnectiongFactory,绑定地址 ConnectionFactory factory=new ActiveMQConnectionFactory(url); //2.创建Connection Connection connection= factory.createConnection(); //3.启动连接 connection.start(); //4.创建会话 Session session=connection.createSession(false, Session.AUTO_ACKNOWLEDGE); //5.创建一个目标 （主题类型） Destination destination=session.createTopic(topicName); //6.创建一个消费者 MessageConsumer consumer=session.createConsumer(destination); //7.创建一个监听器 consumer.setMessageListener(new MessageListener() { public void onMessage(Message arg0) { // TODO Auto-generated method stub TextMessage textMessage=(TextMessage)arg0; try { System.out.println(consumerName +" 接收消息："+textMessage.getText()); } catch (JMSException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }); //8. 因为不知道什么时候有，所以没法主动关闭，就不关闭了，一直处于监听状态 //connection.close(); } }
启动
这里先启动消费者类两次，创建两个消费者，再启动生产者类一次，创建一个生产者，主题模式有个次序问题，在生产者之后创建的消费者收不到生产者发的消息，就像今天进村的听不到昨天的大喇叭。
访问： http://127.0.0.1:8161/admin/topics.jsp 就可以看到 刚才的消息处理情况。
看最下面那行：
topics_style 是在代码中定义的消息名称。
number Of Consumers 表示有2个消费者。
Messages Enqueued：表示收到了 100 个消息。
Messages Dequeued：表示消费了 200 个消息。
参考：
【1】、http://how2j.cn/k/message/message-activemq-topic/2027.html#nowhere
