上一节:

  ActiveMQ - 测试 Pub/Sub Topic

  • 启动 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: http://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 中，右键单击 Publisher.java 源，然后选择 Run As → Java Application。Publisher 应用程序将开始运行，您将看到如下输出 - 
    
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 中，右键单击 Subscriber.java 源，然后选择 Run As → Java Application。订阅者应用程序将开始运行，您将看到如下输出 - 
    
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.

  • 启动另一个订户应用程序

    在 Eclipse 中，再次右键单击 Subscriber.java 源，然后选择 Run As → Java Application。另一个订阅者应用程序将开始运行，您将看到如下输出 - 
    
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.

  • 发信息

    在 Publisher 控制台窗口中，键入 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.
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
    将 Quit 作为消息发送以终止所有发布者和订阅者控制台窗口会话。

  • 确认

    现已开放http://127.0.0.1:8161/admin/在您的浏览器中。它将要求凭据。使用 admin/admin 作为用户名/密码，它将加载 ActiveMQ 管理控制台，您可以在其中检查主题以检查状态。它将显示排队和发送的多条消息。
    主题
上一节: