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

￡神魔★判官ぃ 2022-06-15 22:17 203阅读 0赞

本文我们来介绍一下TemporaryQueue和TemporaryQueue的使用,

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

TemporaryQueue和TemporaryTopic，从字面上就可以看出它们是“临时”的目的地。可以通过Session来创建，例如：
     TemporaryQueue replyQueue = session.createTemporaryQueue();
    
     虽然它们是由Session来创建的，但是它们的生命周期确实整个Connection。如果在一个Connection上创建了两个Session，
     则一个Session创建的TemporaryQueue或TemporaryTopic也可以被另一个Session访问。那如果这两个Session是由不同的Connection创建，
     则一个Session创建的TemporaryQueue不可以被另一个Session访问。
     另外，它们的主要作用就是用来指定回复目的地， 即作为JMSReplyTo。
     在下面的例子中，先创建一个Connection，然后创建两个Session，其中一个Session创建了一个TemporaryQueue，
     另一个Session在这个TemporaryQueue上读取消息。

# 一个简单的实例 #

ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost");
    Connection connection = factory.createConnection();
    connection.start();
    
    Queue queue = new ActiveMQQueue("testQueue2");
    final Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    //使用session创建一个TemporaryQueue。
    TemporaryQueue replyQueue = session.createTemporaryQueue();
    
    //接收消息，并回复到指定的Queue中（即replyQueue）
    MessageConsumer comsumer = session.createConsumer(queue);
    comsumer.setMessageListener(new MessageListener() {
        public void onMessage(Message m) {
            try {
                System.out.println("Get Message: " + ((TextMessage) m).getText());
                MessageProducer producer = session.createProducer(m.getJMSReplyTo());
                producer.send(session.createTextMessage("ReplyMessage"));
            } catch (JMSException e) {
            }
        }
    });
    
    //使用同一个Connection创建另一个Session，来读取replyQueue上的消息。
    Session session2 = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
    MessageConsumer replyComsumer = session2.createConsumer(replyQueue);
    replyComsumer.setMessageListener(new MessageListener() {
        public void onMessage(Message m) {
            try {
                System.out.println("Get reply: " + ((TextMessage) m).getText());
            } catch (JMSException e) {
            }
        }
    });
    
    MessageProducer producer = session.createProducer(queue);
    TextMessage message = session.createTextMessage("SimpleMessage");
    message.setJMSReplyTo(replyQueue);
    producer.send(message);

> 我们来看一下运行结果

![这里写图片描述][9.gif]

> 现在我们的连接都是用的虚拟连接,但是实际应用中肯定不是这么做的,实际开发中我们需要下载apache-activemq-5.14.5-bin.tar.gz 手动运行

apache-activemq-5.14.5//bin/activemq.jar start

然后

ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory();
    factory.setPassword("admin");
    factory.setUserName("admin");
    factory.setBrokerURL("tcp://localhost:61616");
    Connection connection = factory.createConnection();
    connection.start();

> 这里的密码是默认密码,需要启动activeMq,activeMq也有自己的UI管理页面,启动之后

http://127.0.0.1:8161/admin/,即可看到页面,,默认密码:admin/admin

![这里写图片描述][10.gif]

到此为止关于activeMq对于JMS的实现,基本介绍完毕,后续章节介绍rabbitMq对于JMS的实现.以及rabbitMq集群

[9.gif]: http://7xr5s7.com1.z0.glb.clouddn.com/9.gif
[10.gif]: http://7xr5s7.com1.z0.glb.clouddn.com/10.gif