JMS&MQ,从入门到精通(二)

╰+攻爆jí腚メ 2022-06-17 13:46 240阅读 0赞

上一篇,我们介绍了jms&mq的一对一的消息传输与消息处理,本章节我们再实现,2个消费者共同监听一个Queue,然后循环给这
    个Queue中发送多个消息，我们依然采用ActiveMQ来实现这个案例

--------------------

# 1个队列多个监听者 #

场景如下图:

![这里写图片描述][SouthEast]

## 实现思路 ##

new 一个queue,启动2个监听者对这个queue进行监听,处理数据,启动一个循环10次for循环,向这个队列里面放消息,让先前
    两个create的监听者进行处理

--------------------

## 一个简单的实例 ##

//create一个连接
    ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost");
    Connection connection = factory.createConnection();
    connection.start();
    
    //创建一个Queue
    Queue queue = new ActiveMQQueue("testQueue");
    //创建一个Session
    final  Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    
    //注册消费者1
    MessageConsumer comsumer1 = session.createConsumer(queue);
    comsumer1.setMessageListener(new MessageListener(){
       public void onMessage(Message m) {
           try {
               System.out.println("Consumer1 get --> :" + ((TextMessage)m).getText());
           } catch (JMSException e) {
               e.printStackTrace();
           }
       }
    });
    
    //注册消费者2
    MessageConsumer comsumer2 = session.createConsumer(queue);
    comsumer2.setMessageListener(new MessageListener(){
       public void onMessage(Message m) {
           try {
               System.out.println("Consumer2 get --> : " + ((TextMessage)m).getText());
           } catch (JMSException e) {
               e.printStackTrace();
           }
       }
    
    });
    
    //创建一个生产者，然后发送多个消息。
    MessageProducer producer = session.createProducer(queue);
    for(int i=0; i<10; i++){
        producer.send(session.createTextMessage("Message-" + i));
    }
    
    //可以看出每个消息直被消费了一次，但是如果有多个消费者同时监听一个Queue的话，无法确定一个消息最终会被哪一个消费者消费。

我们来运行,看结果如何:

![这里写图片描述][SouthEast 1]

结果和我们预期一致,下一篇我们介绍"发布&订阅"模式

[SouthEast]: /images/20220617/20237525f46b42e8bcec9a57a86d6641.png
[SouthEast 1]: /images/20220617/8db8a68548a948df9dcf86ff42b6946f.png