Linux下Apache ActiveMQ5.9的安装配置与测试-阿里云开发者社区

变是永恒不变的真理。

由于公司的产品是由java做的，因此消息队列当然也要用java的，因此选择activemq是不错的选择。自从事运维以来安装软件、配置环境等可谓驾轻就熟，而面对java项目时还是心里有点忐忑，activemq应该如何测试，如何写activemq的测试例程，对于一个不经常操作java的人来说都是一个小小的挑战。今天上午测试人员发过来一个压缩包，用来在Windows下测试activemq是否工作正常，感觉非常不好用。因为这个程序里面写成了两个窗体程序，每一个程序都要填写必要的参数才能执行，而且必须一收一发非常麻烦。到了中午，研发说测试环境中的activemq不好用了，发现是网络波动和延迟的原因，因此下午花了一些时间研究了一下activemq的测试例程，现总结如下。

一、安装配置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:5672、stomp://$HOSTNAME:61613、mqtt://$HOSTNAME:1883、ws://$HOSTNAME:61616，一般常用的就是tcptcp://$HOSTNAME:61616。

再通过ps –ef | grep activemq | grep –v grep和netstat –anop | grep 61616检测一下端口和相应的进程activemq的安装配置就算结束了。

二、通过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就可以运行，更为方便，结果（如果成功）如下：