第一篇博文深入淺出JMS(一)–JMS基本概念，我們介紹了JMS的兩種消息模型：點對點和發布訂閱模型，以及消息被消費的兩個方式：同步和異步，JMS編程模型的對象，最后說了JMS的優點。

第二篇博文深入淺出JMS(二)–ActiveMQ簡單介紹以及安裝，我們介紹了消息中間件ActiveMQ，安裝，啟動，以及優缺點。

這篇博文，我們使用ActiveMQ為大家實現一種點對點的消息模型。如果你對點對點模型的認識較淺，可以看一下第一篇博文的介紹。

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

開發環境

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

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

搭建開發環境

• 建立項目?
  我們只需要建立一個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; /*** 消息的生產者（發送者） * @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;//發送的消息數量private static final int SENDNUM = 10;public static void main(String[] args) {//連接工廠ConnectionFactory connectionFactory;//連接Connection connection = null;//會話 接受或者發送消息的線程Session session;//消息的目的地Destination destination;//消息生產者MessageProducer messageProducer;//實例化連接工廠connectionFactory = new ActiveMQConnectionFactory(JMSProducer.USERNAME, JMSProducer.PASSWORD, JMSProducer.BROKEURL);try {//通過連接工廠獲取連接connection = connectionFactory.createConnection();//啟動連接connection.start();//創建sessionsession = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);//創建一個名稱為HelloWorld的消息隊列destination = session.createQueue("HelloWorld");//創建消息生產者messageProducer = session.createProducer(destination);//發送消息sendMessage(session, messageProducer);session.commit();} catch (Exception e) {e.printStackTrace();}finally{if(connection != null){try {connection.close();} catch (JMSException e) {e.printStackTrace();}}}}/*** 發送消息* @param session* @param messageProducer 消息生產者* @throws Exception*/public static void sendMessage(Session session,MessageProducer messageProducer) throws Exception{for (int i = 0; i < JMSProducer.SENDNUM; i++) {//創建一條文本消息 TextMessage message = session.createTextMessage("ActiveMQ 發送消息" +i);System.out.println("發送消息：Activemq 發送消息" + i);//通過消息生產者發出消息 messageProducer.send(message);}} }

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9
• 10
• 11
• 12
• 13
• 14
• 15
• 16
• 17
• 18
• 19
• 20
• 21
• 22
• 23
• 24
• 25
• 26
• 27
• 28
• 29
• 30
• 31
• 32
• 33
• 34
• 35
• 36
• 37
• 38
• 39
• 40
• 41
• 42
• 43
• 44
• 45
• 46
• 47
• 48
• 49
• 50
• 51
• 52
• 53
• 54
• 55
• 56
• 57
• 58
• 59
• 60
• 61
• 62
• 63
• 64
• 65
• 66
• 67
• 68
• 69
• 70
• 71
• 72
• 73
• 74
• 75
• 76
• 77
• 78
• 79
• 80
• 81
• 82
• 83
• 84
• 85
• 86
• 87
• 88
• 89
• 90

• 編寫消費者

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;//會話 接受或者發送消息的線程Destination destination;//消息的目的地MessageConsumer messageConsumer;//消息的消費者//實例化連接工廠connectionFactory = new ActiveMQConnectionFactory(JMSConsumer.USERNAME, JMSConsumer.PASSWORD, JMSConsumer.BROKEURL);try {//通過連接工廠獲取連接connection = connectionFactory.createConnection();//啟動連接connection.start();//創建sessionsession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//創建一個連接HelloWorld的消息隊列destination = session.createQueue("HelloWorld");//創建消息消費者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();}} }

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9
• 10
• 11
• 12
• 13
• 14
• 15
• 16
• 17
• 18
• 19
• 20
• 21
• 22
• 23
• 24
• 25
• 26
• 27
• 28
• 29
• 30
• 31
• 32
• 33
• 34
• 35
• 36
• 37
• 38
• 39
• 40
• 41
• 42
• 43
• 44
• 45
• 46
• 47
• 48
• 49
• 50
• 51
• 52
• 53
• 54
• 55
• 56
• 57
• 58
• 59
• 60
• 61
• 62
• 63
• 64
• 65

運行

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

運行發送者，eclipse控制臺輸出，如下圖：?
?
此時，我們先看一下ActiveMQ服務器，Queues內容如下：?
?
我們可以看到創建了一個名稱為HelloWorld的消息隊列，隊列中有10條消息未被消費，我們也可以通過Browse查看是哪些消息，如下圖：?
?
如果這些隊列中的消息，被刪除，消費者則無法消費。

我們繼續運行一下消費者，eclipse控制臺打印消息，如下：?
?
此時，我們先看一下ActiveMQ服務器，Queues內容如下：?
?
我們可以看到HelloWorld的消息隊列發生變化，多一個消息者，隊列中的10條消息被消費了，點擊Browse查看，已經為空了。?
點擊Active Consumers，我們可以看到這個消費者的詳細信息：?

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

總結

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

下面博文，我們將實現一個ActiveMQ和Spring整合的實例。

總結

以上是生活随笔為你收集整理的JMS学习(3):--ActiveMQ简单的HelloWorld实例的全部內容，希望文章能夠幫你解決所遇到的問題。

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