深入淺出JMS(三)--ActiveMQ簡單的HelloWorld實例
阿新 • • 發佈:2017-05-20
通過 scons ack 無法 簡單 開發 zip解壓 技術 一個
開發環境
我們使用的是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(); //創建session session = 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); } } }
- 編寫消費者
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(); //創建session session = 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(); } } }
運行
- 首先,啟動ActiveMQ,如何啟動ActiveMQ如何啟動,請看第二篇博文。在瀏覽器中輸入:http://localhost:8161/admin/,然後開始執行:
-
運行發送者,eclipse控制臺輸出,如下圖:
此時,我們先看一下ActiveMQ服務器,Queues內容如下:
我們可以看到創建了一個名稱為HelloWorld的消息隊列,隊列中有10條消息未被消費,我們也可以通過Browse查看是哪些消息,如下圖:
如果這些隊列中的消息,被刪除,消費者則無法消費。 -
我們繼續運行一下消費者,eclipse控制臺打印消息,如下:
此時,我們先看一下ActiveMQ服務器,Queues內容如下:
我們可以看到HelloWorld的消息隊列發生變化,多一個消息者,隊列中的10條消息被消費了,點擊Browse查看,已經為空了。
點擊Active Consumers,我們可以看到這個消費者的詳細信息:
我們的實例到此就結束了,大家可以自己多點ActiveMQ服務器的內容,進一步熟悉ActiveMQ。
深入淺出JMS(三)--ActiveMQ簡單的HelloWorld實例