ActiveMQ安裝配置和使用簡例

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

安裝和使用方法

(1)首先到ActiveMQ官方網站下載最新發布的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運行環境。啟動成功后如圖所示：

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

netstat -an|find "61616"

查看到端口61616的狀態如圖：

表明ActiveMQ消息服務器端啟動已經成功，已經在端口61616收發消息。

(3)下面就可以使用ActiveMQ在自己的Java程序中編寫代碼收發消息。以兩個java應用程序為例，一個單獨的Sender.java作為消息的發送方，另外一個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服務器端綁定的端口。privatestaticfinalintPORT=61616;//發送10條消息。private static final int COUNT = 10; public static void main(String[] args) {// ConnectionFactory ：連接工廠，JMS 創建連接ConnectionFactory connectionFactory;// Connection ：JMS 客戶端到JMS Provider 的連接Connection connection = null;// Session： 一個發送或接收消息的線程Session session;// Destination ：消息的目的地Destination destination;// MessageProducer：消息生產者。MessageProducer producer;// 構造ConnectionFactory實例對象，此處采用ActiveMq的實現jarconnectionFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,ActiveMQConnection.DEFAULT_PASSWORD, "tcp://127.0.0.1:"+PORT);try {// 構造從工廠得到連接對象connection = connectionFactory.createConnection();// 啟動connection.start();// 獲取操作連接session = connection.createSession(Boolean.TRUE.booleanValue(), Session.AUTO_ACKNOWLEDGE);// 獲取session注意參數值 zhangphil 是一個服務器的queue，須在在ActiveMq的console配置destination = session.createQueue(MESSAGE_QUEUE);// 得到消息生成者，發送者producer = session.createProducer(destination);// 設置不持久化producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);// 發送消息。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默認的系統配置網頁是: http://localhost:8161/admin/

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

總結

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

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