轉載：http://blog.csdn.net/jiuqiyuliang/article/details/48608237

JMS其實并沒有想象的那么高大上，看完這篇博文之后，你就知道什么叫簡單，下面直接進入主題。

開發(fā)環(huán)境

我們使用的是ActiveMQ 5.11.1 Release的Windows版，官網最新版是ActiveMQ 5.12.0 Release，大家可以自行下載，下載地址。

需要注意的是，開發(fā)時候，要將apache-activemq-5.11.1-bin.zip解壓縮后里面的activemq-all-5.11.1.jar包加入到classpath下面，這個包包含了所有jms接口api的實現。

搭建開發(fā)環(huán)境

• 建立項目
  我們只需要建立一個java項目就可以了，導入jar包，項目截圖：
  

點對點的消息模型，只需要一個消息生成者和消息消費者，下面我們編寫代碼。

• 編寫生產者

package com.tgb.activemq;import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.Destination; import javax.jms.JMSException; import javax.jms.MessageProducer; import javax.jms.Session; import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnection; import org.apache.activemq.ActiveMQConnectionFactory; /*** 消息的生產者（發(fā)送者） * @author liang**/ public class JMSProducer {//默認連接用戶名private static final String USERNAME = ActiveMQConnection.DEFAULT_USER;//默認連接密碼private static final String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD;//默認連接地址private static final String BROKEURL = ActiveMQConnection.DEFAULT_BROKER_URL;//發(fā)送的消息數量private static final int SENDNUM = 10;public static void main(String[] args) {//連接工廠ConnectionFactory connectionFactory;//連接Connection connection = null;//會話 接受或者發(fā)送消息的線程Session session;//消息的目的地Destination destination;//消息生產者MessageProducer messageProducer;//實例化連接工廠connectionFactory = new ActiveMQConnectionFactory(JMSProducer.USERNAME, JMSProducer.PASSWORD, JMSProducer.BROKEURL);try {//通過連接工廠獲取連接connection = connectionFactory.createConnection();//啟動連接connection.start();//創(chuàng)建sessionsession = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);//創(chuàng)建一個名稱為HelloWorld的消息隊列destination = session.createQueue("HelloWorld");//創(chuàng)建消息生產者messageProducer = session.createProducer(destination);//發(fā)送消息sendMessage(session, messageProducer);session.commit();} catch (Exception e) {e.printStackTrace();}finally{if(connection != null){try {connection.close();} catch (JMSException e) {e.printStackTrace();}}}}/*** 發(fā)送消息* @param session* @param messageProducer 消息生產者* @throws Exception*/public static void sendMessage(Session session,MessageProducer messageProducer) throws Exception{for (int i = 0; i < JMSProducer.SENDNUM; i++) {//創(chuàng)建一條文本消息 TextMessage message = session.createTextMessage("ActiveMQ 發(fā)送消息" +i);System.out.println("發(fā)送消息：Activemq 發(fā)送消息" + i);//通過消息生產者發(fā)出消息 messageProducer.send(message);}} }

• 編寫消費者

package com.tgb.activemq;import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.Destination; import javax.jms.JMSException; import javax.jms.MessageConsumer; import javax.jms.Session; import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnection; import org.apache.activemq.ActiveMQConnectionFactory; /*** 消息的消費者（接受者）* @author liang**/ public class JMSConsumer {private static final String USERNAME = ActiveMQConnection.DEFAULT_USER;//默認連接用戶名private static final String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD;//默認連接密碼private static final String BROKEURL = ActiveMQConnection.DEFAULT_BROKER_URL;//默認連接地址public static void main(String[] args) {ConnectionFactory connectionFactory;//連接工廠Connection connection = null;//連接Session session;//會話 接受或者發(fā)送消息的線程Destination destination;//消息的目的地MessageConsumer messageConsumer;//消息的消費者//實例化連接工廠connectionFactory = new ActiveMQConnectionFactory(JMSConsumer.USERNAME, JMSConsumer.PASSWORD, JMSConsumer.BROKEURL);try {//通過連接工廠獲取連接connection = connectionFactory.createConnection();//啟動連接connection.start();//創(chuàng)建sessionsession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//創(chuàng)建一個連接HelloWorld的消息隊列destination = session.createQueue("HelloWorld");//創(chuàng)建消息消費者messageConsumer = session.createConsumer(destination);while (true) {TextMessage textMessage = (TextMessage) messageConsumer.receive(100000);if(textMessage != null){System.out.println("收到的消息:" + textMessage.getText());}else {break;}}} catch (JMSException e) {e.printStackTrace();}} }

運行

首先，啟動ActiveMQ，如何啟動ActiveMQ如何啟動，請看第二篇博文。在瀏覽器中輸入：http://localhost:8161/admin/，然后開始執(zhí)行：

運行發(fā)送者，eclipse控制臺輸出，如下圖：

此時，我們先看一下ActiveMQ服務器，Queues內容如下：

我們可以看到創(chuàng)建了一個名稱為HelloWorld的消息隊列，隊列中有10條消息未被消費，我們也可以通過Browse查看是哪些消息，如下圖：

如果這些隊列中的消息，被刪除，消費者則無法消費。

我們繼續(xù)運行一下消費者，eclipse控制臺打印消息，如下：

此時，我們先看一下ActiveMQ服務器，Queues內容如下：

我們可以看到HelloWorld的消息隊列發(fā)生變化，多一個消息者，隊列中的10條消息被消費了，點擊Browse查看，已經為空了。
點擊Active Consumers，我們可以看到這個消費者的詳細信息：

我們的實例到此就結束了，大家可以自己多點ActiveMQ服務器的內容，進一步熟悉ActiveMQ。

總結

這篇博文我們實現了點對點的消息模型以及發(fā)送的一個同步消息，是不是非常的簡單？

總結

以上是生活随笔為你收集整理的activemq的使用(四)的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。