ActiveMQ 快速上手：安装配置与基础通信实践（一）

一、引言

在当今分布式系统和微服务架构盛行的时代，消息通信作为实现系统间解耦、异步处理和可靠传输的关键技术，显得尤为重要。ActiveMQ 作为一款广泛应用的开源消息中间件，凭借其对 JMS 规范的全面支持、丰富的特性以及出色的性能，在消息通信领域占据着举足轻重的地位 。它不仅能够帮助开发者轻松实现应用程序之间的高效通信，还能在高并发、大规模的场景下稳定运行，为构建可靠的分布式系统提供坚实的基础。本文将带领大家快速上手 ActiveMQ，从安装配置到基础通信实践，一步步揭开它的神秘面纱，让你在实际项目中能够熟练运用这一强大的工具。

二、ActiveMQ 初相识

ActiveMQ 是 Apache 软件基金会所研发的开放源代码消息中间件，作为一个纯 Java 程序，只要操作系统支持 Java 虚拟机，ActiveMQ 便可执行。它在分布式系统中扮演着至关重要的角色，是企业级应用中实现消息通信的首选工具之一。

（一）特性亮点

1. 多语言客户端支持：ActiveMQ 支持多种语言编写客户端，如 Java、C、C++、C#、Ruby、Perl、Python、PHP 等。这使得不同技术栈的项目都能够轻松接入 ActiveMQ，实现系统间的消息通信 。例如，一个以 Python 为主开发的数据处理系统，可以通过 ActiveMQ 与 Java 编写的后端服务进行高效的数据交互。

1. 丰富的协议支持：它支持 OpenWire、Stomp、REST、WS Notification、XMPP、AMQP 等多种应用协议。这种多协议支持特性，让 ActiveMQ 可以适应不同的应用场景和通信需求。比如，在物联网场景中，ActiveMQ 可以通过 MQTT 协议与大量的物联网设备进行通信，实现设备状态监控和数据收集。

1. JMS 规范全面支持：ActiveMQ 完全支持 JMS1.1 和 J2EE 1.4 规范，包括持久化、XA 消息、事务等特性。这保证了在 Java 企业级开发中，ActiveMQ 能够与其他遵循 JMS 规范的组件无缝集成，提供可靠的消息服务。例如，在一个分布式事务处理系统中，ActiveMQ 可以利用 XA 消息和事务特性，确保消息在多个参与者之间的可靠传递和一致性。

1. Spring 集成友好：ActiveMQ 对 Spring 框架有着良好的支持，可以很容易地内嵌到使用 Spring 的系统里面去，并且支持 Spring2.0 的特性。借助 Spring 的配置机制，开发者可以方便地对 ActiveMQ 进行配置和管理，降低开发成本。比如，在一个基于 Spring Boot 的微服务项目中，只需要简单的配置，就可以集成 ActiveMQ 实现服务间的消息通信。

（二）分布式系统中的关键作用

1. 解耦系统组件：在分布式系统中，各个组件之间通常存在复杂的依赖关系。使用 ActiveMQ 作为消息中间件，可以将这些组件之间的直接调用转换为通过消息进行通信。例如，一个电商系统中的订单服务和库存服务，订单服务在生成订单后，不是直接调用库存服务的接口来扣减库存，而是向 ActiveMQ 发送一条包含订单信息的消息，库存服务从 ActiveMQ 接收消息并进行库存处理。这样，订单服务和库存服务就实现了解耦，它们的开发、部署和升级都可以独立进行，互不影响。

1. 异步处理提升性能：对于一些耗时较长的操作，如文件处理、数据分析等，可以将相关任务封装成消息发送到 ActiveMQ。系统在发送消息后可以立即返回，而不需要等待任务完成，从而提高系统的响应速度。例如，在一个日志处理系统中，应用程序将日志信息以消息的形式发送到 ActiveMQ，然后继续执行其他任务，而日志处理模块则从 ActiveMQ 中获取日志消息进行异步处理，这样可以避免因日志处理导致应用程序性能下降。

1. 可靠的消息传输：ActiveMQ 提供了消息持久化机制，即使在系统故障或服务器重启的情况下，也能保证消息不会丢失。它还支持消息的确认机制，确保消息被正确接收和处理。例如，在一个金融交易系统中，每一笔交易信息都作为消息发送到 ActiveMQ，通过消息的持久化和确认机制，保证交易信息的可靠传输和处理，避免因系统故障导致交易数据丢失或不一致。

三、安装 ActiveMQ

3.1 下载

ActiveMQ 的官方下载地址为：http://activemq.apache.org/components/classic/download/ 。在该页面，你可以看到不同版本的 ActiveMQ 可供下载。根据你的操作系统，选择相应的安装包：

• Windows 版：如果你使用的是 Windows 系统，下载以.zip结尾的文件，例如apache-activemq-5.16.3-bin.zip 。这种格式的文件便于在 Windows 系统上解压和使用。

• Linux 版：对于 Linux 系统，下载以.tar.gz结尾的压缩包，如apache-activemq-5.16.3-bin.tar.gz 。这种格式是 Linux 系统中常见的压缩格式，方便在 Linux 环境下进行解压和安装操作。

3.2 安装步骤

• Windows 系统

1. 1. 解压文件：将下载的.zip文件解压到你希望安装 ActiveMQ 的目录，例如D:\apache-activemq-5.16.3 。解压后，你可以看到 ActiveMQ 的目录结构，其中bin目录包含了启动和停止 ActiveMQ 的脚本，conf目录存放着配置文件，lib目录包含了 ActiveMQ 运行所需的各种库文件。

1. 1. 配置环境变量（可选）：如果希望在任意目录下都能方便地执行 ActiveMQ 的命令，可以配置环境变量。在系统环境变量中，找到Path变量，添加 ActiveMQ 的bin目录路径，如D:\apache-activemq-5.16.3\bin 。这样，在命令提示符中就可以直接使用activemq命令，而无需切换到bin目录。

1. 1. 启动 ActiveMQ：进入 ActiveMQ 的bin目录，找到activemq.bat文件，双击运行它，或者在命令提示符中切换到该目录后执行activemq start命令。启动成功后，你会看到命令行输出一些启动信息，并且可以在浏览器中访问http://localhost:8161/admin ，如果能看到 ActiveMQ 的管理界面，说明安装和启动成功。默认的用户名和密码都是admin 。

• Linux 系统

1. 1. 上传和解压：将下载的.tar.gz文件上传到 Linux 服务器的指定目录，比如/usr/local 。使用以下命令解压文件：

tar -zxvf apache-activemq-5.16.3-bin.tar.gz

解压后，会在当前目录下生成一个apache-activemq-5.16.3的目录。

2. 配置环境变量（可选）：与 Windows 系统类似，如果希望在任意目录下执行 ActiveMQ 命令，可以配置环境变量。编辑.bashrc或.profile文件，在文件末尾添加以下内容：

export ACTIVEMQ_HOME=/usr/local/apache-activemq-5.16.3

export PATH=$ACTIVEMQ_HOME/bin:$PATH

然后执行source ~/.bashrc（如果修改的是.bashrc文件）或source ~/.profile（如果修改的是.profile文件）使配置生效。

3. 启动 ActiveMQ：进入 ActiveMQ 的bin目录，执行以下命令启动 ActiveMQ：

./activemq start

如果需要将启动日志输出到指定文件，可以使用以下命令：

./activemq start > /opt/activemq/logs/activemq.log

这里/opt/activemq/logs/activemq.log是自定义的日志文件路径。启动成功后，可以通过命令ps -ef|grep activemq|grep -v grep查看 ActiveMQ 进程是否正在运行，也可以使用netstat -anp|grep 61616查看 ActiveMQ 默认端口（61616）是否在监听。在浏览器中访问http://服务器IP:8161/admin ，输入默认用户名和密码（admin/admin），即可进入 ActiveMQ 的管理界面。

3.3 安装常见问题及解决

• 端口冲突：ActiveMQ 默认使用 61616 作为 JMS 服务端口，8161 作为管理控制台端口。如果这些端口被其他程序占用，ActiveMQ 将无法启动。解决方法是修改 ActiveMQ 的配置文件，更改端口号。在conf目录下的activemq.xml文件中，找到以下配置项：

<transportConnectors>

<transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>

</transportConnectors>

将61616修改为其他未被占用的端口号。对于管理控制台端口，在conf/jetty.xml文件中，找到以下配置项：

<bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start">

<property name="host" value="0.0.0.0"/>

<property name="port" value="8161"/>

</bean>

将8161修改为其他可用端口。

• 权限不足：在 Linux 系统中，如果以普通用户身份启动 ActiveMQ，可能会因为权限不足而无法创建某些文件或目录，导致启动失败。解决方法是使用root用户启动，或者给 ActiveMQ 的安装目录及相关文件赋予足够的权限。例如，使用以下命令给apache-activemq-5.16.3目录赋予 777 权限：

chmod -R 777 /usr/local/apache-activemq-5.16.3

• Java 环境问题：ActiveMQ 是基于 Java 开发的，需要正确安装和配置 Java 环境。如果在启动 ActiveMQ 时提示找不到 Java 命令或 Java 环境配置错误，需要检查 Java 环境变量是否正确设置。在 Linux 系统中，可以通过echo $JAVA_HOME命令查看JAVA_HOME环境变量是否设置正确；在 Windows 系统中，可以在系统环境变量中查看JAVA_HOME的设置。如果未设置或设置错误，需要重新配置 Java 环境变量，并确保java -version命令能够正确输出 Java 版本信息。

四、配置 ActiveMQ

4.1 基本配置文件解读

在 ActiveMQ 的安装目录下，conf 目录存放着至关重要的配置文件，这些文件决定了 ActiveMQ 的运行行为和特性。其中，activemq.xml 是核心配置文件，它定义了 ActiveMQ 的基本设置，如代理（broker）的名称、消息存储方式、传输连接器等。在activemq.xml中，<broker>标签是整个配置的核心，其中的brokerName属性用于指定代理的名称，这个名称在网络环境中应当是唯一的，例如：

<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}">

dataDirectory属性指定了消息持久化的数据存储目录，${activemq.data}是一个占位符，它会在 ActiveMQ 启动时被解析为实际的目录路径。

<transportConnectors>标签用于配置传输连接器，定义了 ActiveMQ 监听的网络地址和端口，以及支持的协议。常见的配置如下：

<transportConnectors>

<transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

<transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

<transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

<transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

<transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

</transportConnectors>

这里配置了多种协议的传输连接器，name属性为连接器命名，uri属性指定了监听的地址和端口，以及一些连接参数。例如，openwire协议默认监听在0.0.0.0:61616，表示可以接受来自任何 IP 地址的连接，maximumConnections限制了最大连接数为 1000，wireFormat.maxFrameSize设置了最大帧大小为 100MB。

jetty.xml则主要用于配置 ActiveMQ 的 Web 控制台，包括 Web 服务器的端口、上下文路径以及安全认证等设置。其中，<bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start">定义了 Web 控制台的端口，默认值为 8161：

<bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start">

<property name="host" value="0.0.0.0"/>

<property name="port" value="8161"/>

</bean>

<bean id="securityConstraint" class="org.eclipse.jetty.util.security.Constraint">用于配置安全约束，如是否需要认证、允许的角色等。将authenticate属性设置为true，表示需要认证才能访问 Web 控制台：

<bean id="securityConstraint" class="org.eclipse.jetty.util.security.Constraint">

<property name="name" value="BASIC"/>

<property name="roles" value="user,admin"/>

<property name="authenticate" value="true"/>

</bean>

4.2 修改默认配置

为了增强 ActiveMQ 的安全性和适用性，我们通常需要修改一些默认配置。首先是端口的修改。由于 ActiveMQ 的默认端口（JMS 服务端口 61616 和 Web 控制台端口 8161）可能会与其他应用程序冲突，或者出于安全考虑，需要将其修改为其他未被占用的端口。在activemq.xml文件中，修改transportConnectors标签下的uri属性，例如将 JMS 服务端口修改为 61626：

<transportConnectors>

<transportConnector name="openwire" uri="tcp://0.0.0.0:61626?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

</transportConnectors>

在jetty.xml文件中，修改jettyPort的port属性，将 Web 控制台端口修改为 8162：

<bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start">

<property name="host" value="0.0.0.0"/>

<property name="port" value="8162"/>

</bean>

默认的用户名和密码（admin/admin）安全性较低，容易受到攻击，因此需要修改。在conf目录下的jetty-realm.properties文件中，存储着 Web 控制台的用户信息。该文件的格式为username: password [,rolename ...]，例如：

admin: newPassword, admin

user: userPassword, user

将admin用户的密码修改为newPassword，并可以根据需要添加或修改其他用户及其密码和角色。同时，为了进一步增强安全性，建议设置复杂度较高的密码，包含大小写字母、数字和特殊字符的组合，避免使用简单的字典词汇或连续重复的字符。

4.3 配置示例

假设我们有一个实际的项目场景，需要将 ActiveMQ 部署在生产环境中，并且对性能和安全性有较高的要求。我们可以参考以下配置示例来调整 ActiveMQ 的配置。

在activemq.xml中，我们增加消息持久化的配置，使用 KahaDB 存储消息，以确保消息在系统故障时不会丢失：

<persistenceAdapter>

<kahaDB directory="${activemq.data}/kahadb"/>

</persistenceAdapter>

为了优化内存使用，我们设置系统内存使用的上限为 JVM 堆内存的 80%：

<systemUsage>

<systemUsage>

<memoryUsage>

<memoryUsage percentOfJvmHeap="80"/>

</memoryUsage>

<storeUsage>

<storeUsage limit="100 gb"/>

</storeUsage>

<tempUsage>

<tempUsage limit="50 gb"/>

</tempUsage>

</systemUsage>

</systemUsage>

在安全方面，我们启用 JAAS 认证插件，对客户端连接进行身份验证：

<plugins>

<jaasAuthenticationPlugin configuration="activemq"/>

<authorizationPlugin>

<map>

<authorizationMap>

<authorizationEntries>

<authorizationEntry topic=">" read="admins" write="admins" admin="admins"/>

<authorizationEntry queue=">" read="admins" write="admins" admin="admins"/>

<authorizationEntry topic="ActiveMQ.Advisory.>" read="admins" write="admins" admin="admins"/>

<authorizationEntry queue="ActiveMQ.Advisory.>" read="admins" write="admins" admin="admins"/>

</authorizationEntries>

</authorizationMap>

</map>

</authorizationPlugin>

</plugins>

同时，在conf目录下创建login.config文件，配置 JAAS 认证的相关参数：

activemq {

org.apache.activemq.jaas.PropertiesLoginModule required

debug=true

org.apache.activemq.jaas.properties.user="users.properties"

org.apache.activemq.jaas.properties.group="groups.properties";

};

并在users.properties和groups.properties文件中分别配置用户和用户组信息，以实现更细粒度的权限控制。通过这样的配置示例，我们可以根据实际需求，灵活地调整 ActiveMQ 的各项配置，使其更好地适应不同的生产环境和业务需求。