ActiveMQ入门实例

1.下载ActiveMQ

去官方网站下载：http://activemq.apache.org/

2.运行ActiveMQ

解压缩apache-activemq-5.5.1-bin.zip，然后双击apache-activemq-5.5.1\bin\activemq.bat运行ActiveMQ程序。

启动ActiveMQ以后，登陆：http://localhost:8161/admin/，创建一个Queue，命名为FirstQueue。

3.创建Eclipse项目并运行

创建project：ActiveMQ-5.5，并导入apache-activemq-5.5.1\lib目录下需要用到的jar文件，项目结构如下图所示：

3.1.Sender.java

package com.xuwei.activemq;import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.DeliveryMode;import javax.jms.Destination;import javax.jms.MessageProducer;import javax.jms.Session;import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnection;import org.apache.activemq.ActiveMQConnectionFactory;public class Sender { private static final int SEND_NUMBER = 5; public static void main(String[] args) { // ConnectionFactory ：连接工厂，JMS 用它创建连接 ConnectionFactory connectionFactory; // Connection ：JMS 客户端到JMS Provider 的连接 Connection connection = null; // Session： 一个发送或接收消息的线程 Session session; // Destination ：消息的目的地;消息发送给谁. Destination destination; // MessageProducer：消息发送者 MessageProducer producer; // TextMessage message; // 构造ConnectionFactory实例对象，此处采用ActiveMq的实现jar connectionFactory = new ActiveMQConnectionFactory( ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616"); try { // 构造从工厂得到连接对象 connection = connectionFactory.createConnection(); // 启动 connection.start(); // 获取操作连接 session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE); // 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置 destination = session.createQueue("FirstQueue"); // 得到消息生成者【发送者】 producer = session.createProducer(destination); // 设置不持久化，此处学习，实际根据项目决定 producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); // 构造消息，此处写死，项目就是参数，或者方法获取 sendMessage(session, producer); session.commit(); } catch (Exception e) { e.printStackTrace(); } finally { try { if (null != connection) connection.close(); } catch (Throwable ignore) { } } } public static void sendMessage(Session session, MessageProducer producer) throws Exception { for (int i = 1; i <= SEND_NUMBER; i++) { TextMessage message = session .createTextMessage("ActiveMq 发送的消息" + i); // 发送消息到目的地方 System.out.println("发送消息：" + "ActiveMq 发送的消息" + i); producer.send(message); } }}

3.2.Receiver.java

package com.xuwei.activemq;import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.Destination;import javax.jms.MessageConsumer;import javax.jms.Session;import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnection;import org.apache.activemq.ActiveMQConnectionFactory;public class Receiver { public static void main(String[] args) { // ConnectionFactory ：连接工厂，JMS 用它创建连接 ConnectionFactory connectionFactory; // Connection ：JMS 客户端到JMS Provider 的连接 Connection connection = null; // Session： 一个发送或接收消息的线程 Session session; // Destination ：消息的目的地;消息发送给谁. Destination destination; // 消费者，消息接收者 MessageConsumer consumer; connectionFactory = new ActiveMQConnectionFactory( ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616"); try { // 构造从工厂得到连接对象 connection = connectionFactory.createConnection(); // 启动 connection.start(); // 获取操作连接 session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE); // 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置 destination = session.createQueue("FirstQueue"); consumer = session.createConsumer(destination); while (true) { //设置接收者接收消息的时间，为了便于测试，这里谁定为100s TextMessage message = (TextMessage) consumer.receive(100000); if (null != message) { System.out.println("收到消息" + message.getText()); } else { break; } } } catch (Exception e) { e.printStackTrace(); } finally { try { if (null != connection) connection.close(); } catch (Throwable ignore) { } } }}

4.注意事项

最后接收者跟发送者在不同的机器上测试项目所引用的jar最后在ActiveMQ下的lib中找，这样不会出现版本冲突。

5.测试过程

因为是在单机上测试，所以需要开启两个eclipse，每一个eclipse都有自身的workspace。我们在eclipse1中运行Receiver，在eclipse2中运行Sender。

刚开始eclipse1中运行Receiver以后console介面没有任何信息，在eclipse2中运行Sender以后，eclipse2中的console显示如下信息：

发送消息：ActiveMq 发送的消息1 发送消息：ActiveMq 发送的消息2 发送消息：ActiveMq 发送的消息3 发送消息：ActiveMq 发送的消息4 发送消息：ActiveMq 发送的消息5

而回到eclipse1中发现console界面出现如下信息：

收到消息ActiveMq 发送的消息1 收到消息ActiveMq 发送的消息2 收到消息ActiveMq 发送的消息3 收到消息ActiveMq 发送的消息4 收到消息ActiveMq 发送的消息5

 PS:2012-2-27

今天发现测试并不需要开启两个eclipse，在一个eclipse下页可以启动多个程序，并且有多个console，在上面的Receiver.java中，设置一个较大的时间，比如receive(500000)，如下代码所示：

TextMessage message = (TextMessage) consumer.receive(500000);

这个时候运行Receiver.java的话，会使得这个Receiver.java一直运行500秒，在eclipse中可以发现：

点击那个红色方块可以手动停止运行程序。

运行玩receiver以后我们在运行sender，在运行完sender以后，我们要切换到receiver的console，如下图所示：

作者： xwdreamer 出处： http://www.cnblogs.com/xwdreamer 欢迎任何形式的转载，但请务必注明出处。 分享到： 分类:  JMS 好文要顶  关注我  收藏该文    xwdreamer 关注 - 17 粉丝 - 1284 +加关注 25 0 « 上一篇： NoClassDefFoundError: org/slf4j/LoggerFactory和NoClassDefFoundError: org/apache/log4j/LogManager解决方法 » 下一篇： editplus格式化xml文档 posted @  2012-02-21 09:10  xwdreamer 阅读( 202756) 评论( 27)  编辑  收藏 评论列表    回复引用 #1楼   2013-03-29 09:39  残雪☆羽翼    学习了 谢谢 支持(0) 反对(0)    回复引用 #2楼   2013-07-25 09:22  神奇辉    路过，后台说使用这个东西，看看，撸主写这东西，对于不熟悉java的前端，有点压力。 支持(0) 反对(0)    回复引用 #3楼   2013-08-02 14:12  RamboHoo    简单明了，经典的东西不是写的很多，而是把问题简单化，配上例子代码，一下子就懂了，收藏了。谢谢 支持(6) 反对(0)    回复引用 #4楼   2013-08-06 09:28  mashiguang    关于activemq的问题，向您请教， http://www.oschina.net/question/139128_120198 支持(0) 反对(0)    回复引用 #5楼   2013-10-30 14:23  ralphhuang    可以模拟一发一收的流程 支持(0) 反对(0)    回复引用 #6楼   2013-11-26 17:49  雷雷netname    不明觉厉 支持(0) 反对(0)    回复引用 #7楼   2013-12-05 11:04  love_rain_boy    =================爱心提醒：================ 最新版本的activemq中已经把activemq-core-5.9.0.jar换成activemq-clent5.9.0.jar,希望能帮到后来的兄弟们。 支持(7) 反对(0)    回复引用 #8楼   2013-12-13 10:51  BurningFish    嗨，为什么我登陆 http://localhost:8161/admin/ 需要用户名密码呢 支持(2) 反对(0)    回复引用 #9楼   2014-03-26 14:53  静湖孤子    启动ActiveMQ以后，登陆： http://localhost:8161/admin/，创建一个Queue，命名为FirstQueue。 这一步, 不需要. 运行Sender.java后, FirstQueue会在ActiveMQ中, 自动创建. 支持(4) 反对(0)    回复引用 #10楼   2014-04-08 13:46  ding2wife    登陆 http://localhost:8161/admin/ 用户名和密码都是admin 支持(3) 反对(0)    回复引用 #11楼   2014-05-28 14:13  attackCityMaster    不错，就是希望有后续的深入内容。我的网站3gos.com 支持(0) 反对(0)    回复引用 #12楼   2014-06-28 16:32  kevin123de    博主，可以上传项目源码，作为附件下载吗？ 支持(0) 反对(0)    回复引用 #13楼   2014-08-11 11:37  野猪大改造    好东西，学习了！！ 100s足够了。。 支持(1) 反对(0)    回复引用 #14楼   2014-10-17 16:58  zhglhy    多谢分享 支持(0) 反对(0)    回复引用 #15楼   2014-12-13 08:42  lvlv岁月流逝    mark 支持(0) 反对(0)    回复引用 #16楼   2015-04-07 22:07  小包包    楼主总结的很好，收藏了 支持(0) 反对(0)    回复引用 #17楼   2015-06-21 09:24  ManKane    喜欢楼主的分享！！！ 支持(0) 反对(0)    回复引用 #18楼   2015-08-29 14:36  大有空明天    楼主你分享的太好了，按着你的走 一个错误都没发生，我去官网下载的最新的包，用的代码依然能用，一看到你八年前就注册了，我就莫名的亢奋，我却刚注册的 支持(3) 反对(0)    回复引用 #19楼   2015-08-29 14:36  大有空明天    说错了 6年^_^ 支持(0) 反对(0)    回复引用 #20楼   2015-08-31 11:47  stubbornMe    感谢，学习了！ 支持(0) 反对(0)    回复引用 #21楼   2015-11-03 16:35  herextinct    Log4jJMSAppenderExample类怎么写啊？ 支持(0) 反对(0)    回复引用 #22楼   2015-12-30 15:16  xiaotian1021    学习了，非常感谢！ 支持(0) 反对(0)    回复引用 #23楼   2016-03-03 11:09  Poko    非常好，简单明了，非常感谢！！！ 支持(0) 反对(0)    回复引用 #24楼   2016-03-14 11:52  奶瓶居士    看到一半就想说不用开启两个Eclipse，可以开启两个console。不过看到后面楼主自己写出来了。 支持(0) 反对(0)    回复引用 #25楼   2016-04-05 14:18  肖哥哥    TextMessage message = (TextMessage) consumer.receive(0);  这样程序就会一直运行着 不用设置100秒什么的 支持(0) 反对(0)    回复引用 #26楼   2016-04-13 13:39  为了我的梦，加油！    辛苦苦了，谢谢分享！！！ 支持(0) 反对(0)    回复引用 #27楼   2016-12-21 15:01  adarzhang    楼主很棒，作为一个新手你已经把我带入门了，加油！！