Apache中ActiveMQ消息传递的示例分析(activemq,apache,开发技术)

1.下载ActiveMQ

下载activeMQ：http://activemq.apache.org/

我这里用的是5.9.0版本

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，并导入apache-activemq-5.9.0\lib目录下需要用到的jar文件，项目结构如下图所示：

3.1.Sender.java

packageper.activemq.test;importjavax.jms.Connection;importjavax.jms.ConnectionFactory;importjavax.jms.DeliveryMode;importjavax.jms.Destination;importjavax.jms.MessageProducer;importjavax.jms.Session;importjavax.jms.TextMessage;importorg.apache.activemq.ActiveMQConnection;importorg.apache.activemq.ActiveMQConnectionFactory;publicclassSender{ privatestaticfinalintSEND_NUMBER=5; publicstaticvoidmain(String[]args){ //ConnectionFactory：连接工厂，JMS用它创建连接 ConnectionFactoryconnectionFactory; //Connection：JMS客户端到JMSProvider的连接 Connectionconnection=null; //Session：一个发送或接收消息的线程 Sessionsession; //Destination：消息的目的地;消息发送给谁. Destinationdestination; //MessageProducer：消息发送者 MessageProducerproducer; //构造ConnectionFactory实例对象，此处采用ActiveMq的实现jar connectionFactory=newActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,ActiveMQConnection.DEFAULT_PASSWORD,"tcp://127.0.0.1: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(Exceptione){ //TODO:handleexception }finally{try{if(null!=connection)connection.close();}catch(Throwableignore){}} } privatestaticvoidsendMessage(Sessionsession,MessageProducerproducer)throwsException{ for(inti=0;i<SEND_NUMBER;i++){ TextMessagemessage=session.createTextMessage("ActiveMQ发送的消息："+i); //发送消息到目的地方 System.out.println("发送消息,ActiveMQ发送的消息:"+i); producer.send(message); } }}

3.2.Receiver.java

packageper.activemq.test;importjavax.jms.Connection;importjavax.jms.ConnectionFactory;importjavax.jms.Destination;importjavax.jms.MessageConsumer;importjavax.jms.Session;importjavax.jms.TextMessage;importorg.apache.activemq.ActiveMQConnection;importorg.apache.activemq.ActiveMQConnectionFactory;publicclassReceiver{ publicstaticvoidmain(String[]args){ //ConnectionFactory：连接工厂，JMS用它创建连接ConnectionFactoryconnectionFactory;//Connection：JMS客户端到JMSProvider的连接Connectionconnection=null;//Session：一个发送或接收消息的线程Sessionsession;//Destination：消息的目的地;消息发送给谁.Destinationdestination;//消费者，消息接收者MessageConsumerconsumer;connectionFactory=newActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,ActiveMQConnection.DEFAULT_PASSWORD,"tcp://127.0.0.1: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){//设置接收者接收消息的时间，为了便于测试，这里谁定为100sTextMessagemessage=(TextMessage)consumer.receive(100000);if(null!=message){System.out.println("收到消息"+message.getText());}else{break;}} }catch(Exceptione){ //TODO:handleexception }finally{try{if(null!=connection)connection.close();}catch(Throwableignore){}} }}

4.注意事项

1. 最后接收者跟发送者在不同的机器上测试

2. 项目所引用的jar最后在ActiveMQ下的lib中找，这样不会出现版本冲突。

5.测试过程

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

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

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

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

5.查看队列

很明显有消息了