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

左手的ㄟ右手 2022-06-17 14:24 229阅读 0赞

上一篇中我们介绍了,一对多的,生产消费队列模型,本篇我们来介绍发布/订阅模型,同样我们需要一个生产者
    两个消费者不同之处在于:上篇之中,我们的生产者的同一个消息,只能被消费一次,本篇之中,一个消息,多个消费者能收到所有的消息.

# 广播/订阅 #

场景如下图

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

## 实现思路 ##

1.先利用activeMq,创建一个虚拟的注册中心(实际上要运行activeMq,和redis类似,先运行再连接,再操作)
    2.创建一个topic
    3.两个监听者,监听这个topic
    4.监听者监听消息并处理

## 一个简单的实例 ##

ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost");
    Connection connection = factory.createConnection();
    connection.start();
    
    //创建一个Topic
    Topic topic= new ActiveMQTopic("testTopic");
    Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    
    //注册收听者1
    MessageConsumer comsumer1 = session.createConsumer(topic);
    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(topic);
    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(topic);
    for(int i=0; i<10; i++){
        producer.send(session.createTextMessage("Message:" + i));
    }

我们来看运行结果;下一篇,我们介绍队列的持久化

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

[SouthEast]: /images/20220617/cbc7e5b560974bf6a665a8c04ec051f2.png
[SouthEast 1]: /images/20220617/03236280c152474ca27e637f92c43b1c.png