EasyNetQ 消费行为和模块化整体

问题描述 投票:0回答:1

我是 EasyNetQ 的新手。考虑将这个库采用到我的项目中。

我有一个关于消费消息的问题。维基百科指出:

“当从通过 EasyNetQ 订阅的队列接收消息时,它们被放置在内存队列中。单个线程处于循环中,从队列中获取消息并调用其 Action 委托。由于一次处理一个委托在单线程上,您应该避免长时间运行的同步 IO 操作。尽快从委托返回控制权。”

这是否意味着每条收到的消息只能在一个应用程序中依次处理,还是通过订阅(订阅 ID/交换/其他)进行处理?

我为什么要问这个?我的应用程序是一个模块化的整体。

我寻找每个模块完全独立地消费和处理消息的行为(不等待其他模块)。这可能吗?

一个长时间处理的处理程序会导致当时没有其他处理程序可以执行?

rabbitmq producer-consumer easynetq
1个回答
0
投票

我已经有一段时间没有参与该项目了,但我认为这已经过时了,如果您使用异步消费方法,它将使用标准任务调度程序来并行处理消息。

© www.soinside.com 2019 - 2024. All rights reserved.