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

开发者社区> 开发与运维> 正文

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

简介:
原创作品,允许转载,转载时请务必以超链接形式标明文章 原始出处 、作者信息和本声明。否则将追究法律责任。http://dgd2010.blog.51cto.com/1539422/1680244

变是永恒不变的真理。


由于公司的产品是由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(); 
        
 
}

如果出现发送消息和收到消息则表示成功,运行结果如下:

image

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就可以运行,更为方便,结果(如果成功)如下:

image

参考:

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

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

分享:
开发与运维
使用钉钉扫一扫加入圈子
+ 订阅

集结各类场景实战经验,助你开发运维畅行无忧

其他文章