本文是Apache ActiveMQ快速入门,介绍ActiveMQ安装与基本使用。

ActiveMQ的分支

ActiveMQ分为了Classic和Artemis两个分支。

如果没有特殊说明,ActiveMQ就是指传统的分支Classic。

有关ActiveMQ Artemis详见https://waylau.com/apache-activemq-artemis-quickstart/

ActiveMQ安装

下载地址:https://activemq.apache.org/components/classic/download/

本例下载包为“ apache-activemq-5.17.3-bin.zip”,解压到任意的安装目录即可。

启动ActiveMQ

在ActiveMQ安装目录下(比如本例“D:\dev\java\apache-activemq-5.17.3”)执行以下命令来启动ActiveMQ:

bin\activemq start

访问ActiveMQ的控制台界面

可以通过http://localhost:8161/admin/来访问ActiveMQ的控制台界面。

  • 账号:admin
  • 密码:admin

关闭ActiveMQ

关闭ActiveMQ

bin\activemq stop

发送消息、接收消息

以下是发送消息的示例:

bin\activemq producer --message "My message" --messageCount 1

以下是接收消息的示例:

bin\activemq consumer

控制台输出如下:

D:\dev\java\apache-activemq-5.17.3>bin\activemq consumer
Java Runtime: Oracle Corporation 19.0.2 D:\dev\java\openjdk-19.0.2_windows-x64_bin\jdk-19.0.2
  Heap sizes: current=1048576k  free=1037822k  max=1048576k
    JVM args: -Dcom.sun.management.jmxremote -Xms1G -Xmx1G -Djava.util.logging.config.file=logging.properties -Djava.security.auth.login.config=D:\dev\java\apache-activemq-5.17.3\bin\..\conf\login.config -Dactivemq.classpath=D:\dev\java\apache-activemq-5.17.3\bin\..\conf;D:\dev\java\apache-activemq-5.17.3\bin\../conf;D:\dev\java\apache-activemq-5.17.3\bin\../conf; -Dactivemq.home=D:\dev\java\apache-activemq-5.17.3\bin\.. -Dactivemq.base=D:\dev\java\apache-activemq-5.17.3\bin\.. -Dactivemq.conf=D:\dev\java\apache-activemq-5.17.3\bin\..\conf -Dactivemq.data=D:\dev\java\apache-activemq-5.17.3\bin\..\data -Djolokia.conf=file:D:\\dev\\java\\apache-activemq-5.17.3\\bin\\..\\conf\\jolokia-access.xml -Djava.io.tmpdir=D:\dev\java\apache-activemq-5.17.3\bin\..\data\tmp
Extensions classpath:
  [D:\dev\java\apache-activemq-5.17.3\bin\..\lib,D:\dev\java\apache-activemq-5.17.3\bin\..\lib\camel,D:\dev\java\apache-activemq-5.17.3\bin\..\lib\optional,D:\dev\java\apache-activemq-5.17.3\bin\..\lib\web,D:\dev\java\apache-activemq-5.17.3\bin\..\lib\extra]
ACTIVEMQ_HOME: D:\dev\java\apache-activemq-5.17.3\bin\..
ACTIVEMQ_BASE: D:\dev\java\apache-activemq-5.17.3\bin\..
ACTIVEMQ_CONF: D:\dev\java\apache-activemq-5.17.3\bin\..\conf
ACTIVEMQ_DATA: D:\dev\java\apache-activemq-5.17.3\bin\..\data
 INFO | Connecting to URL: failover://tcp://localhost:61616 as user: null
 INFO | Consuming queue://TEST
 INFO | Sleeping between receives 0 ms
 INFO | Running 1 parallel threads
 INFO | Successfully connected to tcp://localhost:61616
 INFO | consumer-1 wait until 1000 messages are consumed
 INFO | consumer-1 Received My message

可以看到已经接收到消息“My message”。

当然,也可以在ActiveMQ的控制台界面来发送消息。

参考引用