但行好事
莫论前程❤

Java消息中间件学习笔记(5) — ActiveMQ的使用【主题模式】

经过上一篇的 消息中间件学习笔记四 – ActiveMQ的使用【队列模式】的学习,我们学到了队列模式的使用,可以知道队列模式是平均消费的。这一节将学习ActiveMQ的主题模式,那么主题模式有什么特点呢?

开始使用

img

从新创建一个包,并且将上一节中的类复制到 topic 包中

并且将两个类进行修改:

生产者:
package mobi.liupeng.jms.topic;

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

public class AppProducer {

    private static final String url = "tcp://127.0.0.1:61616";
    private static final String topicName = "topic-test";

    public static void main(String[] args) throws JMSException {

        //1. 创建ConnectionFactory
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);

        //2. 创建Connection
        Connection connection = connectionFactory.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("test"+i);
            //8. 发布消息
            producer.send(textMessage);
            System.out.println("发送消息"+textMessage.getText());

        }

        //9. 关闭连接
         connection.close();


    }
}
消费者:
package mobi.liupeng.jms.topic;

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

public class AppConsumer {

    private static final String url = "tcp://127.0.0.1:61616";
    private static final String topicName = "topic-test";

    public static void main(String[] args) throws JMSException {

        //1. 创建ConnectionFactory
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);

        //2. 创建Connection
        Connection connection = connectionFactory.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 message) {
                  TextMessage textMessage = (TextMessage) message;
                 try {
                     System.out.println("接收消息  = [" + textMessage.getText()  + "]");
                 } catch (JMSException e) {

                 }
             }
         });

        //9. 关闭连接
        //connection.close();


    }
}
测试:
  • 首先,我们启动生产者,发布100条消息,然后再启动消费者,但是这样消费者根本就不能消费到消息,因为这就是主题模式的特点: 只有提前订阅生产者的消费者才能成功消费消息而队列模式消费者不需要提前订阅生产者也可以消费消息
  • 如果我们首先启动一个消费者,然后再启动生产者发布100条消息,结果消费者成功消费了ActiveMQ服务器中的消息。
  • 如果我们首先启动两个消费者,然后启动生产者发布100条消息,结果两个消费者都可以消费服务器中的每一条消息。这就是主题模式的特点: 每个订阅者都可以消费主题模式中的每一条消息。队列模式中,只能平均消费消息,被别的消费者消费的消息不能重复被其他的消费者消费
赞(0) 打赏
未经允许不得转载:刘鹏博客 » Java消息中间件学习笔记(5) — ActiveMQ的使用【主题模式】
分享到: 更多 (0)

评论 抢沙发

评论前必须登录!

 

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信扫一扫打赏