Linux下Apache ActiveMQ5.9的安裝配置與測試

變是永恆不變的真理。

因爲公司的產品是由java作的，所以消息隊列固然也要用java的，所以選擇activemq是不錯的選擇。自從事運維以來安裝軟件、配置環境等可謂得心應手，而面對java項目時仍是內心有點忐忑，activemq應該如何測試，如何寫activemq的測試例程，對於一個不常常操做java的人來講都是一個小小的挑戰。今天上午測試人員發過來一個壓縮包，用來在Windows下測試activemq是否工做正常，感受很是很差用。由於這個程序裏面寫成了兩個窗體程序，每個程序都要填寫必要的參數才能執行，並且必須一收一發很是麻煩。到了中午，研發說測試環境中的activemq很差用了，發現是網絡波動和延遲的緣由，所以下午花了一些時間研究了一下activemq的測試例程，現總結以下。

1、安裝配置activemq

#安裝java，如 openjdk-7-jdk或 openjdk-7-jre

apt-get install openjdk-7-jdk

#建議至少有1GB剩餘內存，由於默認ACTIVEMQ_OPTS_MEMORY="-Xms1G -Xmx1G"

cd /tmp/
wget http://archive.apache.org/dist/activemq/apache-activemq/5.9.0/apache-activemq-5.9.0-bin.tar.gz
tar zxf apache-activemq-5.9.0-bin.tar.gz
cd apache-activemq-5.9.0/
vim bin/activemq

# 以debug模式啓動activemq

./bin/activemq console

# 以正常模式啓動activemq

./bin/activemq start

若是提示如下信息，則跟/etc/default/activemq文件配置有關，能夠去掉此文件，或者修改bin/activemq啓動腳本中的第32行「ACTIVEMQ_CONFIGS="/etc/default/activemq $HOME/.activemqrc"」，去掉default，改爲「ACTIVEMQ_CONFIGS="$HOME/.activemqrc"」，或者也能夠用./activemq setup [ /etc/default/activemq | /$USER/.activemqrc ]命令來建立一個activemq配置文件。

INFO: Loading '/etc/default/activemq'

INFO: Using java '/usr/bin/java'

INFO: Starting in foreground, this is just for debugging purposes (stop process by pressing CTRL+C)

./bin/activemq: 422: ./bin/activemq: /usr/bin/java -Xms1G -Xmx1G -Djava.util.logging.config.file=logging.properties -Dhawtio.realm=activemq -Dhawtio.role=admins -Dhawtio.rolePrincipalClasses=org.apache.activemq.jaas.GroupPrincipal -Djava.security.auth.login.config=/tmp/apache-activemq-5.9.0/conf/login.config  -Dcom.sun.management.jmxremote  -Djava.awt.headless=true -Djava.io.tmpdir="/tmp/apache-activemq-5.9.0/tmp"                -Dactivemq.classpath="/tmp/apache-activemq-5.9.0/conf;"               -Dactivemq.home="/tmp/apache-activemq-5.9.0"               -Dactivemq.base="/tmp/apache-activemq-5.9.0"               -Dactivemq.conf="/tmp/apache-activemq-5.9.0/conf"               -Dactivemq.data="/tmp/apache-activemq-5.9.0/data"                              -jar "/tmp/apache-activemq-5.9.0/bin/activemq.jar" start : not found

若是正常啓動後，activemq的工做端口是61616（tcp），監控端口是8161（http），此外activemq的工做端口還有：amqp://$HOSTNAME:567二、stomp://$HOSTNAME:6161三、mqtt://$HOSTNAME:188三、ws://$HOSTNAME:61616，通常經常使用的就是tcptcp://$HOSTNAME:61616。

再經過ps –ef | grep activemq | grep –v grep和netstat –anop | grep 61616檢測一下端口和相應的進程activemq的安裝配置就算結束了。

2、經過java程序測試activemq

先是從網上找了一下相應的文章，畢竟這東西用的人比較多，別人確定有寫好了的，果不其然發現了一篇相似文章《JMS消息服務AcitveMQ的配置和測試小例子》，雖然是針對Windows平臺的，但java程序卻能夠由於jvm的存在在Linux平臺上也能使用，裏面寫到了兩個java程序，仍是以爲麻煩，所以編譯運行java源代碼有時很是的棘手，儘管知道是classpath的問題，但若是沒有操練過仍是難如下手的。下午的測試主要是在這上面花了很多時間。

如何編譯運行java源代碼？

若是源代碼說明中須要導入jar包或者將jar包加入到classpath下面，那能夠這樣作。

編譯java源代碼：javac -cp .:activemq-all-5.9.0.jar:/usr/lib/jvm/java-7-openjdk-amd64/jre App.java  
運行java類程序：java -cp .:activemq-all-5.9.0.jar:/usr/lib/jvm/java-7-openjdk-amd64/jre App

-cp等於-classpath，後面必定要加上java jre自帶的lib的位置，Ubuntu下是/usr/lib/jvm/java-7-openjdk-amd64/jre，其餘系統也相似，若是jar包在當前目錄，則將當前目錄「.」和jar包文件絕對路徑加入到classpath中，後面再帶上class名字命令的.java文件名就能夠了。

若是.java中有「package com.jms;」這樣的行，那還須要作額外操做（此處嘲諷一下開發人員，賤人就是矯情，測試例程都給別人挖坑），在.java文件的目錄下一次建立com/jms目錄，再將.java文件放到jms目錄下面，變成如下操做（以「package com.jms;」爲例）：

mkdir -p com/jms   
mv App.java com/jms    
javac -cp .:activemq-all-5.9.0.jar:/usr/lib/jvm/java-7-openjdk-amd64/jre com/jms/App.java    
java -cp .:activemq-all-5.9.0.jar:/usr/lib/jvm/java-7-openjdk-amd64/jre com.jms.App

我的猜想java中目錄分隔符看成」.」用，估計也是之因此具備移植性的緣由之一吧。

前面提到「裏面寫到了兩個java程序，仍是以爲麻煩」，是由於《JMS消息服務AcitveMQ的配置和測試小例子》原文給出的例程中有兩個.java文件，須要建兩個目錄分別存放這兩個.java文件，不然當一個.java文件編譯經過後下面就會產生一些依賴性的.class文件，取決於編譯的.java文件中的import的包的內容，所以一旦兩個.java文件須要用到相同的依賴.class文件時就會引起編譯衝突，提示「bad class file……Please remove or make sure it appears in the correct subdirectory of the classpath.」。所以我把這兩個.java文件寫成了一個，現粘貼以下（請將其保存成JmsTestActivemq.java）：

//package com.jms;
// Refer: 
// Refer: 
import org.apache.activemq.ActiveMQConnection; 
import org.apache.activemq.ActiveMQConnectionFactory; 

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.ExceptionListener;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;

public class JmsTestActivemq { 
        public static void main(String[] args) throws JMSException { 
                ConnectionFactory connectionFactory = new ActiveMQConnectionFactory( 
                                ActiveMQConnection.DEFAULT_USER, 
                                ActiveMQConnection.DEFAULT_PASSWORD, 
                                "tcp://58.67.199.171:61616"); 
                Connection connection = connectionFactory.createConnection(); 
                connection.start(); 
                Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE); 
                Destination destination = session.createQueue("jmstestqueue"); 
                MessageProducer producer = session.createProducer(destination); 
                producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); 
                TextMessage message = session.createTextMessage("Hello world!"); 
                System.out.println("發送消息：Hello world！"); 
                producer.send(message); 
                // session.commit();
                session.close(); 
                connection.close();

                ConnectionFactory connectionFactory2 = new ActiveMQConnectionFactory( 
                        ActiveMQConnection.DEFAULT_USER, 
                        ActiveMQConnection.DEFAULT_PASSWORD, 
                        "tcp://58.67.199.171:61616"); 
                Connection connection2 = connectionFactory2.createConnection(); 
                connection2.start(); 
                Session session2 = connection2.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE); 
                Destination destination2 = session2.createQueue("jmstestqueue"); 
                MessageConsumer consumer = session2.createConsumer(destination2); 
                while (true) { 
                        TextMessage message2 = (TextMessage) consumer.receive(1000); 
                        if (null != message2) 
                                System.out.println("收到消息：" + message2.getText()); 
                        else 
                                break; 
                } 
                consumer.close();
                session2.close(); 
                connection2.close(); 
        } 

}

若是出現發送消息和收到消息則表示成功，運行結果以下：

《JMS消息服務AcitveMQ的配置和測試小例子》原文中提到了「activemq官方也有個HelloWorld例子，http://activemq.apache.org/hello-world.html」，這個例子是activemq4的例子，activemq5的例子在http://activemq.apache.org/version-5-hello-world.html，這個官方的例子通過javac -cp .:activemq-all-5.9.0.jar:/usr/lib/jvm/java-7-openjdk-amd64/jre App.java後直接執行java -cp .:activemq-all-5.9.0.jar:/usr/lib/jvm/java-7-openjdk-amd64/jre App就能夠運行，更爲方便，結果（若是成功）以下：

參考：

JMS消息服務AcitveMQ的配置和測試小例子 http://flyer2010.iteye.com/blog/662047

Apache ActiveMQ ? -- Version 4 Hello World： http://activemq.apache.org/hello-world.html

Apache ActiveMQ ? -- Version 5 Hello World： http://activemq.apache.org/version-5-hello-world.html

--end--