Linux下Apache ActiveMQ5.9的安装配置与测试

变是永恒不变的真理。

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

一、安装配置activemq

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

1
apt-get install openjdk-7-jdk

#建议至少有1GB剩余内存，因为默认ACTIVEMQ_OPTS_MEMORY="-Xms1G -Xmx1G"

1
2
3
4
5
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

1
./bin/activemq console

# 以正常模式启动activemq

1
./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;”为例）：

1
2
3
4
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）：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
//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--

本文转自 urey_pp 51CTO博客，原文链接：http://blog.51cto.com/dgd2010/1680244，如需转载请自行联系原作者