使用 EventBus.RabbitMQ.Standard 无法在 rabbitmq 上看到消息
Cannot see message on rabbitmq using EventBus.RabbitMQ.Standard
我开始在 .net Core 上使用 rabbitmq 学习微服务。我试图了解如何实现发布和订阅事件的简单方法,我发现了一个带有示例的 nuget:
Github EventBus.RabbitMQ.Standard
我执行 Publisher 示例 并使用 URL 以使用此配置发布一个简单事件:
"RabbitMq": {
"BrokerName": "test_broker",
"AutofacScopeName": "test_autofac",
"QueueName": "temp_queue",
"RetryCount": "5",
"VirtualHost": "/",
"Username": "guest",
"Password": "guest",
"Host": "localhost",
"DispatchConsumersAsync": true
}
现在可以工作,创建队列并且不会生成异常,但是我在队列中看不到消息:
如今,根据我对 rabbitmq 的了解,我不知道 可能是 我的 rabbit 配置 上的错误还是nuget 库。
对可能发生的事情有什么想法吗?
如果没有消费者,基本上您不会在队列中看到消息。
- 为发布者和订阅者设置appsettings.json
- 运行 发布者和订阅者
- 发布消息并在订阅者中查看消息
- 停止订阅者应用程序
- 发布新消息并在 RabbitMQ 管理中查看消息
您是否尝试查看他们 website 上的教程?
它非常清楚地解释了如何发布和订阅 messages
、交换、队列和路由键如何工作等...
我在我的实现中发现了错误。
我没有打开订阅者的 Startup class(在 Configure 方法中):
app.SubscribeToEvents();
因为博客中不存在该部分-github 示例文档 ;/ .
我开始在 .net Core 上使用 rabbitmq 学习微服务。我试图了解如何实现发布和订阅事件的简单方法,我发现了一个带有示例的 nuget: Github EventBus.RabbitMQ.Standard
我执行 Publisher 示例 并使用 URL 以使用此配置发布一个简单事件:
"RabbitMq": {
"BrokerName": "test_broker",
"AutofacScopeName": "test_autofac",
"QueueName": "temp_queue",
"RetryCount": "5",
"VirtualHost": "/",
"Username": "guest",
"Password": "guest",
"Host": "localhost",
"DispatchConsumersAsync": true
}
现在可以工作,创建队列并且不会生成异常,但是我在队列中看不到消息:
如今,根据我对 rabbitmq 的了解,我不知道 可能是 我的 rabbit 配置 上的错误还是nuget 库。
对可能发生的事情有什么想法吗?
如果没有消费者,基本上您不会在队列中看到消息。
- 为发布者和订阅者设置appsettings.json
- 运行 发布者和订阅者
- 发布消息并在订阅者中查看消息
- 停止订阅者应用程序
- 发布新消息并在 RabbitMQ 管理中查看消息
您是否尝试查看他们 website 上的教程?
它非常清楚地解释了如何发布和订阅 messages
、交换、队列和路由键如何工作等...
我在我的实现中发现了错误。 我没有打开订阅者的 Startup class(在 Configure 方法中):
app.SubscribeToEvents();
因为博客中不存在该部分-github 示例文档 ;/ .