变是永恒不变的真理。
由于公司的产品是由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--
本文出自 “通信，我的最爱” 博客，请务必保留此出处http://dgd2010.blog.51cto.com/1539422/1680244