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

相关实践学习
RocketMQ一站式入门使用
从源码编译、部署broker、部署namesrv,使用java客户端首发消息等一站式入门RocketMQ。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
5天前
|
运维 监控 Ubuntu
怎样配置Linux分析工具:atop篇
在管理Linux系统时,了解系统级监控工具是至关重要的。其中,atop是一种功能强大的工具,它允许运维人员以实时的方式监控系统运行状态,包括进程活动、内存使用、磁盘I/O以及网络负载等。atop提供了一种简洁而全面的方式来追踪系统表现和资源消耗情况,使得性能分析变得简单而直观。
|
8天前
|
Ubuntu Linux Shell
Ubuntu/linux系统环境变量配置详解
理解和掌握如何配置环境变量对于使用和管理Ubuntu/Linux系统非常重要。
19 2
|
23天前
|
域名解析 网络协议 Linux
Linux系统下DNS配置指南
Linux系统下DNS配置指南
42 1
|
25天前
|
安全 Linux 测试技术
Kali Linux渗透测试教程:解锁黑客之门
Kali Linux渗透测试教程:解锁黑客之门
|
24天前
|
网络协议 Linux 网络安全
Linux配置SSH允许TCP转发
Linux配置SSH允许TCP转发
23 1
|
25天前
|
Linux 测试技术 开发工具
CentOS Linux 8使用阿里源(安装jdk11、git测试)
CentOS Linux 8使用阿里源(安装jdk11、git测试)
136 1
|
4天前
|
存储 运维 监控
怎样配置Linux分析工具:kdump篇
在运维的世界里,服务器的稳定运行是生命的灯塔,一旦遭遇异常重启,便是暴风雨来临的预兆。作为一名运维工程师,深知在这场与故障斗争的战役中,武器的锋利至关重要。今天,我要介绍的主角/工具——kdump,正是这样一款能在风雨来临之际,为我们捕获那一闪而过的真相的工具。
|
16天前
|
网络协议 Linux 开发工具
配置Linux固定IP地址,为什么要固定IP,因为他是通DHCP服务获取的,DHCP服务每次重启都会重新获取一次ip,VMware编辑中有一个虚拟网络编辑器
配置Linux固定IP地址,为什么要固定IP,因为他是通DHCP服务获取的,DHCP服务每次重启都会重新获取一次ip,VMware编辑中有一个虚拟网络编辑器
|
16天前
|
Ubuntu Linux
Linux软件安装-Linux系统靠yum命令安装软件,yum命令是一个RPM包软件管理器,用于自动化安装配置Linux软件,.rpm是Linux包下的软件,yum install下载 wget re
Linux软件安装-Linux系统靠yum命令安装软件,yum命令是一个RPM包软件管理器,用于自动化安装配置Linux软件,.rpm是Linux包下的软件,yum install下载 wget re
|
16天前
|
运维 监控 大数据
部署-Linux01,后端开发,运维开发,大数据开发,测试开发,后端软件,大数据系统,运维监控,测试程序,网页服务都要在Linux中进行部署
部署-Linux01,后端开发,运维开发,大数据开发,测试开发,后端软件,大数据系统,运维监控,测试程序,网页服务都要在Linux中进行部署