ActiveMQ安裝配置和使用簡例

ActiveMQ是一套JMS(Java Message Service)開源消息服務(wù)實現(xiàn)的組件。以Windows操作系統(tǒng)為例，本文簡述了ActiveMQ的安裝配置和使用簡例。消息服務(wù)是互聯(lián)網(wǎng)應(yīng)用的最基本功能，只要是互聯(lián)網(wǎng)應(yīng)用，就少不了消息通信。而ActiveMQ是一個相對比較成熟穩(wěn)定的JMS消息服務(wù)組件，安裝簡單，使用簡單，可以快速上手。很容易就實現(xiàn)當下很多應(yīng)用的消息推送、用戶反饋等消息服務(wù)功能。

安裝和使用方法

(1)首先到ActiveMQ官方網(wǎng)站下載最新發(fā)布的ActiveMQ版本：http://activemq.apache.org/download.html

以ActiveMQ 5.12.0為例，apache-activemq-5.12.0-bin.zip的下載鏈接地址：http://www.apache.org/dyn/closer.cgi?path=/activemq/5.12.0/apache-activemq-5.12.0-bin.zip

(2)下載后，將這個壓縮包解壓，找到解壓目錄下的 …apache-activemq-5.12.0-binapache-activemq-5.12.0binwin64activemq.bat 文件，(32位計算機則選擇win32目錄下的activemq.bat)運行之。

其中 …apache-activemq-5.12.0-binapache-activemq-5.12.0activemq-all-5.12.0.jar將在后面的Java程序中作為引用的庫包導入使用。

注意！運行activemq.bat前提需要java運行環(huán)境。啟動成功后如圖所示：

ActiveMQ默認綁定本地端口61616，如果一切順利，啟動ActiveMQ成功后，可以執(zhí)行命令：

netstat -an|find "61616"

查看到端口61616的狀態(tài)如圖：

表明ActiveMQ消息服務(wù)器端啟動已經(jīng)成功，已經(jīng)在端口61616收發(fā)消息。

(3)下面就可以使用ActiveMQ在自己的Java程序中編寫代碼收發(fā)消息。以兩個java應(yīng)用程序為例，一個單獨的Sender.java作為消息的發(fā)送方，另外一個Receiver.java作為消息的接收方。

Sender.javaimport javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.DeliveryMode;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; public class Sender { //標明一個消息隊列。privatestaticfinalStringMESSAGE_QUEUE="zhangphil";//默認的ActiveMQ服務(wù)器端綁定的端口。privatestaticfinalintPORT=61616;//發(fā)送10條消息。private static final int COUNT = 10; public static void main(String[] args) {// ConnectionFactory ：連接工廠，JMS 創(chuàng)建連接ConnectionFactory connectionFactory;// Connection ：JMS 客戶端到JMS Provider 的連接Connection connection = null;// Session： 一個發(fā)送或接收消息的線程Session session;// Destination ：消息的目的地Destination destination;// MessageProducer：消息生產(chǎn)者。MessageProducer producer;// 構(gòu)造ConnectionFactory實例對象，此處采用ActiveMq的實現(xiàn)jarconnectionFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,ActiveMQConnection.DEFAULT_PASSWORD, "tcp://127.0.0.1:"+PORT);try {// 構(gòu)造從工廠得到連接對象connection = connectionFactory.createConnection();// 啟動connection.start();// 獲取操作連接session = connection.createSession(Boolean.TRUE.booleanValue(), Session.AUTO_ACKNOWLEDGE);// 獲取session注意參數(shù)值 zhangphil 是一個服務(wù)器的queue，須在在ActiveMq的console配置destination = session.createQueue(MESSAGE_QUEUE);// 得到消息生成者，發(fā)送者producer = session.createProducer(destination);// 設(shè)置不持久化producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);// 發(fā)送消息。sendMessage(session, producer);session.commit();} catch (Exception e) {e.printStackTrace();} finally {try {if (null != connection)connection.close();} catch (Throwable ignore) {}}} public static void sendMessage(Session session, MessageProducer producer){for (int i = 0; i

編譯上述兩個java文件，需要導入ActiveMQ的jar庫包。將(2)中的…apache-activemq-5.12.0-binapache-activemq-5.12.0activemq-all-5.12.0.jar作為庫包導入進來。

ActiveMQ的基本配置

ActiveMQ默認的系統(tǒng)配置網(wǎng)頁是: http://localhost:8161/admin/

用戶名和密碼默認均是： admin

總結(jié)

以上是生活随笔為你收集整理的activemq中怎么知道推送消息是否成功_ActiveMQ安装试用示列的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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