Centos下安装ActiveMQ消息间件

记录一下在centos7.x下面安装activeMQ消息中间件

在安装ActiveMQ之前必须保证服务器安装了java环境

安装java环境的地址:安装java环境

找到activeMQ的官网下载安装包

https://activemq.apache.org/components/classic/download/

java版本是java8

从官网下载后(apache-activemq-5.16.5-bin.tar.gz)上传到centos的目录下(根据自己习惯选定目录或者按照要求选定目录)

/usr/local/

1.  
   [root@myw~]# cd /usr/local
2.  
   [root@myw local]# ls
3.  
   apache-activemq-5.16.5-bin.tar.gz
4.  
   [root@myw local]#

解压

[root@myw local]# tar -xvzf apache-activemq-5.16.5-bin.tar.gz

修改文件夹名字

1.  
   [root@myw local]# mv apache-activemq-5.16.5 activemq
2.  
   [root@myw local]# ls
3.  
   activemq apache-activemq-5.16.5-bin.tar.gz
4.  
   [root@myw local]#

1.  
   [root@myw local]# cd activemq
2.  
   [root@myw activemq]# ls
3.  
   activemq-all-5.16.5.jar bin conf data docs examples lib LICENSE NOTICE README.txt webapps webapps-demo
4.  
   [root@myw activemq]# cd bin
5.  
   [root@myw bin]# ls
6.  
   activemq activemq-diag activemq.jar env linux-x86-32 linux-x86-64 macosx wrapper.jar
7.  
   [root@myw bin]# ./activemq start
8.  
   INFO: Loading '/usr/local/activemq//bin/env'
9.  
   INFO: Using java '/usr/local/jdk18/bin/java'
10.  
    INFO: Starting - inspect logfiles specified in logging.properties and log4j.properties to get details
11.  
    INFO: pidfile created : '/usr/local/activemq//data/activemq.pid' (pid '29548')
12.  
    [root@myw bin]# netstat -lnp|grep java
13.  
    tcp6 0 0 :::1883 :::* LISTEN 29548/java
14.  
    tcp6 0 0 127.0.0.1:8161 :::* LISTEN 29548/java
15.  
    tcp6 0 0 :::36453 :::* LISTEN 29548/java
16.  
    tcp6 0 0 :::5672 :::* LISTEN 29548/java
17.  
    tcp6 0 0 :::61613 :::* LISTEN 29548/java
18.  
    tcp6 0 0 :::61614 :::* LISTEN 29548/java
19.  
    tcp6 0 0 :::61616 :::* LISTEN 29548/java
20.  
    [root@myw bin]#

在云服务器上启动之后，安全组规则和防火墙也放开8161端口之后，还需要更改一个配置才能实现浏览器访问界面(127.0.0.1改成0.0.0.0)

配置文件

conf/jetty.xml

原配置信息

1.  
   <bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start">
2.  
   <!-- the default port number for the web console -->
3.  
   <property name="host" value="127.0.0.1"/>
4.  
   <property name="port" value="8161"/>
5.  
   </bean>

修改后的配置信息

1.  
   <bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start">
2.  
   <!-- the default port number for the web console -->
3.  
   <property name="host" value="0.0.0.0"/>
4.  
   <property name="port" value="8161"/>
5.  
   </bean>

重启后浏览器访问具体的IP 端口

1.  
   http://XXX.XXX.XXX.XXX:8161
2.  
    
3.  
   http://XXX.XXX.XXX.XXX:8161/index.html

登录账号和密码都是admin

点击Manage ActiveMQ broker便可以进入

记录一下常用指令

1.  
   启动服务
2.  
   ./activemq start
3.  
   查看状态
4.  
   ./activemq status
5.  
   停止服务
6.  
   ./activemq stop
7.  
   重启服务
8.  
   ./activemq restart

1.  
   [root@myw ~]# cd /usr/local/activemq/bin
2.  
   [root@myw bin]# ./activemq start
3.  
   INFO: Loading '/usr/local/activemq//bin/env'
4.  
   INFO: Using java '/usr/local/jdk18/bin/java'
5.  
   INFO: Process with pid '29873' is already running
6.  
   [root@myw bin]# ./activemq status
7.  
   INFO: Loading '/usr/local/activemq//bin/env'
8.  
   INFO: Using java '/usr/local/jdk18/bin/java'
9.  
   ActiveMQ is running (pid '29873')
10.  
    [root@myw bin]# ./activemq restart
11.  
    INFO: Loading '/usr/local/activemq//bin/env'
12.  
    INFO: Using java '/usr/local/jdk18/bin/java'
13.  
    INFO: Loading '/usr/local/activemq//bin/env'
14.  
    INFO: Using java '/usr/local/jdk18/bin/java'
15.  
    INFO: Waiting at least 30 seconds for regular process termination of pid '29873' :
16.  
    Java Runtime: Oracle Corporation 1.8.0_144 /usr/local/jdk18/jre
17.  
    Heap sizes: current=62976k free=61992k max=932352k
18.  
    JVM args: -Xms64M -Xmx1G -Djava.util.logging.config.file=logging.properties -Djava.security.auth.login.config=/usr/local/activemq//conf/login.config -Dactivemq.classpath=/usr/local/activemq//conf:/usr/local/activemq//../lib/: -Dactivemq.home=/usr/local/activemq/ -Dactivemq.base=/usr/local/activemq/ -Dactivemq.conf=/usr/local/activemq//conf -Dactivemq.data=/usr/local/activemq//data
19.  
    Extensions classpath:
20.  
    [/usr/local/activemq/lib,/usr/local/activemq/lib/camel,/usr/local/activemq/lib/optional,/usr/local/activemq/lib/web,/usr/local/activemq/lib/extra]
21.  
    ACTIVEMQ_HOME: /usr/local/activemq
22.  
    ACTIVEMQ_BASE: /usr/local/activemq
23.  
    ACTIVEMQ_CONF: /usr/local/activemq/conf
24.  
    ACTIVEMQ_DATA: /usr/local/activemq/data
25.  
    Connecting to pid: 29873
26.  
    Stopping broker: localhost
27.  
    .. FINISHED
28.  
     
29.  
    INFO: Loading '/usr/local/activemq//bin/env'
30.  
    INFO: Using java '/usr/local/jdk18/bin/java'
31.  
    INFO: Starting - inspect logfiles specified in logging.properties and log4j.properties to get details
32.  
    INFO: pidfile created : '/usr/local/activemq//data/activemq.pid' (pid '30248')
33.  
    INFO: Loading '/usr/local/activemq//bin/env'
34.  
    INFO: Using java '/usr/local/jdk18/bin/java'
35.  
    ActiveMQ is running (pid '30248')
36.  
    [root@myw bin]#

配置开机启动，我这里使用的方式是创建服务

在/usr/local/activemq/bin/目录下有一个env文件

原来文件内容有一个JAVA_HOME

1.  
   # location of the pidfile
2.  
   # ACTIVEMQ_PIDFILE="$ACTIVEMQ_DATA/activemq.pid"
3.  
    
4.  
   # Location of the java installation
5.  
   # Specify the location of your java installation using JAVA_HOME, or specify the
6.  
   # path to the "java" binary using JAVACMD
7.  
   # (set JAVACMD to "auto" for automatic detection)
8.  
   #JAVA_HOME=""
9.  
   JAVACMD="auto"

配置成java环境的地址(/usr/local/jdk18)，我的环境是这样的

1.  
   # Location of the java installation
2.  
   # Specify the location of your java installation using JAVA_HOME, or specify the
3.  
   # path to the "java" binary using JAVACMD
4.  
   # (set JAVACMD to "auto" for automatic detection)
5.  
   JAVA_HOME="/usr/local/jdk18"
6.  
   JAVACMD="auto"

然后创建服务文件(activemq.service)

1.  
   [Unit]
2.  
   Description=nginx-black web server
3.  
   After=network.target remote-fs.target nss-lookup.target
4.  
    
5.  
   [Service]
6.  
   Type=forking
7.  
   ExecStart=/usr/local/activemq/bin/activemq start
8.  
   ExecReload=/usr/local/activemq/bin/activemq restart
9.  
   ExecStop=/usr/local/activemq/bin/activemq stop
10.  
    [Install]
11.  
    WantedBy=multi-user.target

准备好的文件activemq.service 放入/etc/systemd/system/里面后刷新加载

/usr/lib/systemd/system/

使用

1.  
   [root@myw bin]# systemctl daemon-reload
2.  
   [root@myw bin]# systemctl start activemq.service
3.  
   [root@myw bin]# netstat -lnp|grep java
4.  
   tcp6 0 0 :::1883 :::* LISTEN 31018/java
5.  
   tcp6 0 0 :::8161 :::* LISTEN 31018/java
6.  
   tcp6 0 0 :::33732 :::* LISTEN 31018/java
7.  
   tcp6 0 0 :::5672 :::* LISTEN 31018/java
8.  
   tcp6 0 0 :::61613 :::* LISTEN 31018/java
9.  
   tcp6 0 0 :::61614 :::* LISTEN 31018/java
10.  
    tcp6 0 0 :::61616 :::* LISTEN 31018/java
11.  
    [root@myw bin]# systemctl stop activemq.service
12.  
    [root@myw bin]# netstat -lnp|grep java
13.  
    [root@myw bin]# systemctl restart activemq.service
14.  
    [root@myw bin]# netstat -lnp|grep java
15.  
    tcp6 0 0 :::1883 :::* LISTEN 31297/java
16.  
    tcp6 0 0 :::5672 :::* LISTEN 31297/java
17.  
    tcp6 0 0 :::61613 :::* LISTEN 31297/java
18.  
    tcp6 0 0 :::61614 :::* LISTEN 31297/java
19.  
    tcp6 0 0 :::40975 :::* LISTEN 31297/java
20.  
    tcp6 0 0 :::61616 :::* LISTEN 31297/java
21.  
    [root@myw bin]# systemctl enable activemq.service
22.  
    Created symlink from /etc/systemd/system/multi-user.target.wants/activemq.service to /usr/lib/systemd/system/activemq.service.
23.  
    [root@myw bin]#

1.  
    
2.  
   // 重新加载
3.  
   systemctl daemon-reload
4.  
    
5.  
   // 启动
6.  
   systemctl start activemq.service
7.  
    
8.  
   // 重启
9.  
   systemctl restart activemq.service
10.  
     
11.  
    // 停止
12.  
    systemctl stop activemq.service
13.  
     
14.  
    // 查看启动状态
15.  
    systemctl status activemq.service
16.  
     
17.  
     
18.  
    // 加入开机启动
19.  
    systemctl enable activemq.service
20.  
     
21.  
    // 取消开机启动
22.  
    systemctl disable activemq.service