- RabbitMQ 教程
- RabbitMQ - 主页
- RabbitMQ - 概述
- RabbitMQ - 环境设置
- RabbitMQ - 功能
- RabbitMQ - 安装
- 基于队列的示例
- RabbitMQ - 生产者应用程序
- RabbitMQ - 消费者应用程序
- RabbitMQ - 测试应用程序
- 基于主题的示例
- RabbitMQ - 发布者应用程序
- RabbitMQ - 订阅者应用程序
- RabbitMQ - 测试应用程序
- RabbitMQ 有用资源
- RabbitMQ - 快速指南
- RabbitMQ - 有用的资源
- RabbitMQ - 讨论
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 管理控制台,您可以在其中检查队列和交换器以检查已传递消息和绑定的状态。