RabbitMQ - 测试应用程序主题


启动发布者应用程序

在 Eclipse 中,右键单击 Publisher.java 源,然后选择 Run As → Java Application。发布者应用程序将开始运行,您将看到如下输出 -

Enter message:

启动订阅者应用程序

在 Eclipse 中,右键单击 Subscriber.java 源,然后选择 Run As → Java Application。订阅者应用程序将开始运行,您将看到如下输出 -

Waiting for messages. To exit press CTRL+C

启动另一个订阅者应用程序

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

Waiting for messages. To exit press CTRL+C

发信息

在发布者控制台窗口中,键入 Hi 并按 Enter 按钮发送消息。

Enter message:
Hi

接收消息

在订阅者控制台窗口中验证是否在每个窗口中都收到了消息。

Received = Hi

将 Quit 作为消息发送以终止所有发布者和订阅者控制台窗口会话。

确认

现在在浏览器中打开http://rabbitmq:15672/ 。它会要求提供凭据。使用 guest/guest 作为用户名/密码,它将加载 RabbitMQ 管理控制台,您可以在其中检查队列和交换器以检查已传递消息和绑定的状态。