ActiveMQ入門例項

2022-09-06 06:18:07 字數 2535 閱讀 7624

解壓縮apache-activemq-5.5.1-bin.zip,然後雙擊apache-activemq-5.5.1\bin\activemq.bat執行activemq程式。

啟動activemq以後,登陸:http://localhost:8161/admin/,建立乙個queue,命名為firstqueue。

建立project:activemq-5.5,並匯入apache-activemq-5.5.1\lib目錄下需要用到的jar檔案,專案結構如下圖所示:

}最後接收者跟傳送者在不同的機器上測試

專案所引用的jar最後在activemq下的lib中找,這樣不會出現版本衝突。

因為是在單機上測試,所以需要開啟兩個eclipse,每乙個eclipse都有自身的workspace。我們在eclipse1中執行receiver,在eclipse2中執行sender。

剛開始eclipse1中執行receiver以後console介面沒有任何資訊,在eclipse2中執行sender以後,eclipse2中的console顯示如下資訊:

傳送訊息:activemq 傳送的訊息1

傳送訊息:activemq 傳送的訊息2

傳送訊息:activemq 傳送的訊息3

傳送訊息:activemq 傳送的訊息4

傳送訊息:activemq 傳送的訊息5

而回到eclipse1中發現console介面出現如下資訊:

收到訊息activemq 傳送的訊息1

收到訊息activemq 傳送的訊息2

收到訊息activemq 傳送的訊息3

收到訊息activemq 傳送的訊息4

收到訊息activemq 傳送的訊息5

今天發現測試並不需要開啟兩個eclipse,在乙個eclipse下頁可以啟動多個程式,並且有多個console,在上面的receiver.j**a中,設定乙個較大的時間,比如receive(500000),如下**所示:

textmessage message = (textmessage) consumer.receive(500000);
這個時候執行receiver.j**a的話,會使得這個receiver.j**a一直執行500秒,在eclipse中可以發現:

點選那個紅色方塊可以手動停止執行程式。

執行玩receiver以後我們在執行sender,在執行完sender以後,我們要切換到receiver的console,如下圖所示:

ActiveMQ入門 ActiveMQ環境搭建

解壓縮就能用,執行bin資料夾下面的可執行檔案 cd users szz downloads apache activemq 5.15.9 bin macosx macosx activemq startstarting activemq broker.可以開啟它的管理介面http localhos...

ActiveMQ入門學習總結

一,activemq是什麼?activemq是jms j a message servie 規範的一種訊息中介軟體的落地實現。二,activemq能幹什麼?主要作用就三個 業務解耦,訊息非同步,消峰。在考虐業務解耦的時候盡量使用訊息中介軟體,業務場景使用到訊息的時候盡量做到非同步 三,activem...

ActiveMQ詳細入門使用教程

mq是訊息中介軟體,是一種在分布式系統中應用程式藉以傳遞訊息的媒介,常用的有activemq,rabbitmq,kafka。activemq是apache下的開源專案,完全支援jms1.1和j2ee1.4規範的jms provider實現。特點 1 支援多種語言編寫客戶端 2 對spring的支援,...