JMS&MQ,从入门到精通(八)
2017-04-28 18:01
197 查看
本文我们来介绍一下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);
我们来看一下运行结果
现在我们的连接都是用的虚拟连接,但是实际应用中肯定不是这么做的,实际开发中我们需要下载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
到此为止关于activeMq对于JMS的实现,基本介绍完毕,后续章节介绍rabbitMq对于JMS的实现.以及rabbitMq集群
相关文章推荐
- JMS&MQ,从入门到精通(四)
- JMS&MQ,从入门到精通(二)
- JMS&MQ,从入门到精通(五)
- JMS&MQ,从入门到精通(三)
- JMS&MQ,从入门到精通(一)
- JMS&MQ,从入门到精通(七)
- JMS&MQ,从入门到精通(六)
- JMS&MQ系列之简单示例
- G7从入门到精通 =>(新手实践成功 HBOOT-0.93.0001 )
- JMS&MQ系列之普通Java程序中加载配置
- JMS&MQ系统之Spring中嵌入ActiveMQ
- JMS&MQ系列之JMS的请求和回应
- JMS&MQ系列之简单JMS应用程序编写步骤
- MQ入门总结(二)JMS
- lucene&solr从入门到精通-----创建索引,写到索引库
- Spring.NET & NHibernate从入门到精通
- 分享一个两年前写的JMS&ActiveMQ入门的ppt
- JMS&MQ系列之消息存储方式
- JMS&MQ系列之JMS概述
- MQ入门总结(二)JMS