1.安装jdk

在CentOS操作系统中，可以下载rpm包直接安装。

[root@m161p114 ~]# lsb_release -a
LSB Version:    :core-4.1-amd64:core-4.1-noarch:cxx-4.1-amd64:cxx-4.1-noarch:desktop-4.1-amd64:desktop-4.1-noarch:languages-4.1-amd64:languages-4.1-noarch:printing-4.1-amd64:printing-4.1-noarch
Distributor ID: CentOS
Description:    CentOS Linux release 7.9.2009 (Core)
Release:    7.9.2009
Codename:   Core
[root@m161p114 ~]# 

现在下载jdk的rpm包。
jdk-8u311-linux-x64.rpm

直接安装即可：

[root@m161p114 software]# rpm -ivh jdk-8u311-linux-x64.rpm 
warning: jdk-8u311-linux-x64.rpm: Header V3 RSA/SHA256 Signature, key ID ec551f03: NOKEY
Preparing...                          ################################# [100%]
Updating / installing...
   1:jdk1.8-2000:1.8.0_311-fcs        ################################# [100%]
Unpacking JAR files...
    tools.jar...
    plugin.jar...
    javaws.jar...
    deploy.jar...
    rt.jar...
    jsse.jar...
    charsets.jar...
    localedata.jar...
[root@m161p114 software]# 

如果需要使用到多个版本的jdk,那么不建议通过rpm的方式来安装，最好安装tar.gz版本，然后在环境变量中配置。

2.active 安装及启动

activeMQ的安装非常简单，在安装好jdk之后，只需要将activeMQ的压缩包上传解压即可。
从apache下载最新的activeMQ。
apache-activemq-5.16.3-bin.tar.gz
activeMQ有两个分支，我们在此选择了传统的分支。

[root@m161p114 opt]# tar -zxvf /opt/software/apache-activemq-5.16.3-bin.tar.gz 
apache-activemq-5.16.3/
apache-activemq-5.16.3/lib/
apache-activemq-5.16.3/docs/
apache-activemq-5.16.3/examples/
apache-activemq-5.16.3/examples/openwire/
apache-activemq-5.16.3/examples/openwire/csharp/
apache-activemq-5.16.3/examples/openwire/csharp/ActiveMQExamples/
apache-activemq-5.16.3/examples/openwire/csharp/ActiveMQExamples/Listener/
apache-activemq-5.16.3/examples/openwire/csharp/ActiveMQExamples/Publisher/
apache-activemq-5.16.3/examples/openwire/advanced-scenarios/

... ...

解压之后就可以通过如下方式启动：

[root@m161p114 apache-activemq-5.16.3]# bin/activemq start
INFO: Loading '/opt/apache-activemq-5.16.3//bin/env'
INFO: Using java '/bin/java'
INFO: Starting - inspect logfiles specified in logging.properties and log4j.properties to get details
INFO: pidfile created : '/opt/apache-activemq-5.16.3//data/activemq.pid' (pid '14540')
[root@m161p114 apache-activemq-5.16.3]# bin/activemq status
INFO: Loading '/opt/apache-activemq-5.16.3//bin/env'
INFO: Using java '/bin/java'
ActiveMQ is running (pid '14540')
[root@m161p114 apache-activemq-5.16.3]# 

这样activeMQ启动成功。

activeMQ的管理后台在jetty中进行配置，默认端口为8161。不过需要注意的是，activeMQ的管理后台监听为127.0.0.1。需要配置为0.0.0.0.
该配置为于jetty.xml中。这个host需要改为0.0.0.0。

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

之后重启activeMQ：

[root@m161p114 apache-activemq-5.16.3]# bin/activemq restart
INFO: Loading '/opt/apache-activemq-5.16.3//bin/env'
INFO: Using java '/bin/java'
INFO: Loading '/opt/apache-activemq-5.16.3//bin/env'
INFO: Using java '/bin/java'
INFO: Waiting at least 30 seconds for regular process termination of pid '14540' : 
Java Runtime: Oracle Corporation 1.8.0_311 /usr/java/jdk1.8.0_311-amd64/jre
  Heap sizes: current=62976k  free=61992k  max=932352k
    JVM args: -Xms64M -Xmx1G -Djava.util.logging.config.file=logging.properties -Djava.security.auth.login.config=/opt/apache-activemq-5.16.3//conf/login.config -Dactivemq.classpath=/opt/apache-activemq-5.16.3//conf:/opt/apache-activemq-5.16.3//../lib/: -Dactivemq.home=/opt/apache-activemq-5.16.3/ -Dactivemq.base=/opt/apache-activemq-5.16.3/ -Dactivemq.conf=/opt/apache-activemq-5.16.3//conf -Dactivemq.data=/opt/apache-activemq-5.16.3//data
Extensions classpath:
  [/opt/apache-activemq-5.16.3/lib,/opt/apache-activemq-5.16.3/lib/camel,/opt/apache-activemq-5.16.3/lib/optional,/opt/apache-activemq-5.16.3/lib/web,/opt/apache-activemq-5.16.3/lib/extra]
ACTIVEMQ_HOME: /opt/apache-activemq-5.16.3

通过http://192.168.161.114:8161/ 就能访问activeMQ的管理界面。

管理界面需要用户和密码，位于 jetty-realm.properties文件中：

# Defines users that can access the web (console, demo, etc.)
# username: password [,rolename ...]
admin: admin, admin
user: user, user

可以通过admin和user用户登陆访问。

3.java客户端

现在可以通过java代码进行连接测试。
需要导入的包有：

 <!-- activeMQ -->
        <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-all</artifactId>
            <version>5.16.3</version>
        </dependency>

这样就导入了activeMQ的依赖的包，现在通过如下代码可以对activeMQ进行操作。

package com.dhb.activemq.demo;

import lombok.extern.slf4j.Slf4j;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQTopic;

import javax.jms.Destination;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import java.util.concurrent.atomic.AtomicInteger;


@Slf4j
public class ActiveMQTest {

    public static void main(String[] args) {
        Destination destination = new ActiveMQTopic("test.topic");
        testDestination(destination);
    }
    
    public static void testDestination(Destination destination) {
        try {
            ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://192.168.161.114:61616");
            ActiveMQConnection conn = (ActiveMQConnection) factory.createConnection();
            conn.start();
            Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);

            // 创建消费者
            MessageConsumer consumer = session.createConsumer( destination );
            final AtomicInteger count = new AtomicInteger(0);
            MessageListener listener = new MessageListener() {
                @Override
                public void onMessage(Message message) {
                    try {
                        // 打印所有的消息内容
                        // Thread.sleep();
                        log.info(count.incrementAndGet() + " => receive from " + destination.toString() + ": " + message);
                        // message.acknowledge(); // 前面所有未被确认的消息全部都确认。

                    } catch (Exception e) {
                        e.printStackTrace(); // 不要吞任何这里的异常，
                    }
                }
            };
            // 绑定消息监听器
            consumer.setMessageListener(listener);
            
            // 创建生产者，生产100个消息
            MessageProducer producer = session.createProducer(destination);
            int index = 0;
            while (index++ < 100) {
                TextMessage message = session.createTextMessage(index + " message.");
                producer.send(message);
            }

            Thread.sleep(20000);
            session.close();
            conn.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

执行上述代码，可以完成对activeMQ的相关操作。