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

第二篇博文深入淺出JMS(二)–ActiveMQ簡(jiǎn)單介紹以及安裝，我們介紹了消息中間件ActiveMQ，安裝，啟動(dòng)，以及優(yōu)缺點(diǎn)。

這篇博文，我們使用ActiveMQ為大家實(shí)現(xiàn)一種點(diǎn)對(duì)點(diǎn)的消息模型。如果你對(duì)點(diǎn)對(duì)點(diǎn)模型的認(rèn)識(shí)較淺，可以看一下第一篇博文的介紹。

JMS其實(shí)并沒(méi)有想象的那么高大上，看完這篇博文之后，你就知道什么叫簡(jiǎn)單，下面直接進(jìn)入主題。

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

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

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

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

• 建立項(xiàng)目?
  我們只需要建立一個(gè)java項(xiàng)目就可以了，導(dǎo)入jar包，項(xiàng)目截圖：?
  

點(diǎn)對(duì)點(diǎn)的消息模型，只需要一個(gè)消息生成者和消息消費(fèi)者，下面我們編寫(xiě)代碼。

• 編寫(xiě)生產(chǎn)者

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; /*** 消息的生產(chǎn)者（發(fā)送者） * @author liang**/ public class JMSProducer {//默認(rèn)連接用戶(hù)名private static final String USERNAME = ActiveMQConnection.DEFAULT_USER;//默認(rèn)連接密碼private static final String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD;//默認(rèn)連接地址private static final String BROKEURL = ActiveMQConnection.DEFAULT_BROKER_URL;//發(fā)送的消息數(shù)量private static final int SENDNUM = 10;public static void main(String[] args) {//連接工廠(chǎng)ConnectionFactory connectionFactory;//連接Connection connection = null;//會(huì)話(huà) 接受或者發(fā)送消息的線(xiàn)程Session session;//消息的目的地Destination destination;//消息生產(chǎn)者MessageProducer messageProducer;//實(shí)例化連接工廠(chǎng)connectionFactory = new ActiveMQConnectionFactory(JMSProducer.USERNAME, JMSProducer.PASSWORD, JMSProducer.BROKEURL);try {//通過(guò)連接工廠(chǎng)獲取連接connection = connectionFactory.createConnection();//啟動(dòng)連接connection.start();//創(chuàng)建sessionsession = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);//創(chuàng)建一個(gè)名稱(chēng)為HelloWorld的消息隊(duì)列destination = session.createQueue("HelloWorld");//創(chuàng)建消息生產(chǎn)者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 消息生產(chǎn)者* @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);//通過(guò)消息生產(chǎn)者發(fā)出消息 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

• 編寫(xiě)消費(fèi)者

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; /*** 消息的消費(fèi)者（接受者）* @author liang**/ public class JMSConsumer {private static final String USERNAME = ActiveMQConnection.DEFAULT_USER;//默認(rèn)連接用戶(hù)名private static final String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD;//默認(rèn)連接密碼private static final String BROKEURL = ActiveMQConnection.DEFAULT_BROKER_URL;//默認(rèn)連接地址public static void main(String[] args) {ConnectionFactory connectionFactory;//連接工廠(chǎng)Connection connection = null;//連接Session session;//會(huì)話(huà) 接受或者發(fā)送消息的線(xiàn)程Destination destination;//消息的目的地MessageConsumer messageConsumer;//消息的消費(fèi)者//實(shí)例化連接工廠(chǎng)connectionFactory = new ActiveMQConnectionFactory(JMSConsumer.USERNAME, JMSConsumer.PASSWORD, JMSConsumer.BROKEURL);try {//通過(guò)連接工廠(chǎng)獲取連接connection = connectionFactory.createConnection();//啟動(dòng)連接connection.start();//創(chuàng)建sessionsession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//創(chuàng)建一個(gè)連接HelloWorld的消息隊(duì)列destination = session.createQueue("HelloWorld");//創(chuàng)建消息消費(fèi)者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

運(yùn)行

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

運(yùn)行發(fā)送者，eclipse控制臺(tái)輸出，如下圖：?
?
此時(shí)，我們先看一下ActiveMQ服務(wù)器，Queues內(nèi)容如下：?
?
我們可以看到創(chuàng)建了一個(gè)名稱(chēng)為HelloWorld的消息隊(duì)列，隊(duì)列中有10條消息未被消費(fèi)，我們也可以通過(guò)Browse查看是哪些消息，如下圖：?
?
如果這些隊(duì)列中的消息，被刪除，消費(fèi)者則無(wú)法消費(fèi)。

我們繼續(xù)運(yùn)行一下消費(fèi)者，eclipse控制臺(tái)打印消息，如下：?
?
此時(shí)，我們先看一下ActiveMQ服務(wù)器，Queues內(nèi)容如下：?
?
我們可以看到HelloWorld的消息隊(duì)列發(fā)生變化，多一個(gè)消息者，隊(duì)列中的10條消息被消費(fèi)了，點(diǎn)擊Browse查看，已經(jīng)為空了。?
點(diǎn)擊Active Consumers，我們可以看到這個(gè)消費(fèi)者的詳細(xì)信息：?

我們的實(shí)例到此就結(jié)束了，大家可以自己多點(diǎn)ActiveMQ服務(wù)器的內(nèi)容，進(jìn)一步熟悉ActiveMQ。

總結(jié)

這篇博文我們實(shí)現(xiàn)了點(diǎn)對(duì)點(diǎn)的消息模型以及發(fā)送的一個(gè)同步消息，是不是非常的簡(jiǎn)單？

下面博文，我們將實(shí)現(xiàn)一個(gè)ActiveMQ和Spring整合的實(shí)例。

總結(jié)

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

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。