Apache ActiveMQ - 测试应用程序

启动 ActiveMQ 服务器

下面让我们启动 ActiveMQ 服务器。转到文件夹 F:/ → Apache → apache-activemq-5.16.4/bin 并键入以下命令。

示例

F:\Apache\apache-activemq-5.16.4\bin>activemq start

输出

您将看到类似的输出，并且 ActiveMQ 将开始运行。

...
INFO | Apache ActiveMQ 5.16.4 (localhost, ID:DESKTOP-86KD9FC-52669-1645860020983-0:1) started
INFO | For help or more information please see: https://activemq.apache.org
INFO | ActiveMQ WebConsole available at http://127.0.0.1:8161/
INFO | ActiveMQ Jolokia REST API available at http://127.0.0.1:8161/api/jolokia/

启动制造程序

在 eclipse 中，右键单击 Producer.java 源，然后选择“Run As（作为）”>“Java Application（Java 应用程序）”。制造程序将开始运行，并且您将看到如下输出 −

SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
Enter message:

启动消费程序

在 eclipse 中，右键单击 Consumer.java 源，然后选择“Run As（作为）”>“Java Application（Java 应用程序）”。消费程序将开始运行，并且您将看到如下输出 −

SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.

发送消息

在制造程序控制台窗口中，键入 Hi 并按 enter 键发送消息。

SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
Enter message:
Hi

接收消息

在消费程序控制台窗口中验证消息是否已接收。

SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
Received = Hi

将退出信息作为消息发送，以终止制造程序和消费程序控制台窗口会话。

验证

现在在浏览器中打开 http://127.0.0.1:8161/admin/。它将询问凭据。使用“admin/admin”作为用户名/密码，它将加载您可以在其中检查队列以查看状态的 ActiveMQ 管理控制台。它显示已入列并传送了 2 条消息。