我正在尝试使用MassTransit.ExtensionsDependencyInjectionIntegration和PrefetchCount进行实验。我注意到，对于多个消息，有时会使用相同的消费者。 有没有办法强制masstransit为每条消息创建消费者？我的服务逻辑需要为每条消息创建新的di作用域，据
浏览 5提问于2019-01-26得票数 1
回答已采纳
如果我向一个长期运行的使用者发送一些消息(每个消息需要大约5秒的工作时间)，那么看起来就像一个线程响应了我的请求，并同时发送了消息，等待前面的消息被消耗。更新与的示例不同，我使用RabbitMq并使用反射创建使用者，这样我就可以使用配置文件来管理ESB。仍然在RabbitMq管理控制台上查看预取计数0。1时，更
浏览 5提问于2017-04-26得票数 0
回答已采纳
我使用MassTransit和Autofac，需要一种方法来查询租户Id的入站消息，该Id将用于动态构造连接字符串。因此，合乎逻辑的步骤如下：
消息使用者由容器解析，容器使用每个消息作用域组
浏览 6提问于2019-12-10得票数 0
回答已采纳
1回答
我首先阅读了本机RabbitMQ客户机的文档，然后介绍了使用单个使用者和预取计数>1来控制并行性的设计。直接使用RabbitMQ客户机，这似乎是很自然的。handleDelivery方法的DefaultConsumer可以生成一个新的Runnable来完成工作，并在工作结束时确认消息。预取计数有效地控制了
浏览 8提问于2016-05-03得票数 1
回答已采纳
我正在尝试创建过滤器来填充使用者中的correlationId，并在发送的消息中添加这个correlationId。await next.Send(context);} <Pac
浏览 5提问于2022-11-02得票数 0
我已经创建了一个Masstransit发布过滤器，它根据访问者提供的信息创建一个消息头。 我希望在处理过程中在访问器中设置一些值，这些值将由发布筛选器拾取。我对过滤器的理解是，它们是有作用域的，因此，任何发布的消息都将创建一个新的DI作用域。这意味着我在发布消息</e
浏览 22提问于2021-10-27得票数 0
回答已采纳
我想知道在rabbitmq中预取计数和无ack的区别是什么？如果我将预取计数设置为10，是否会创建10个消费者线程？或者--以上哪一项更有效
浏览 9提问于2016-09-26得票数 3
回答已采纳
我正在尝试为我的应用程序设置MassTransit和RabbitMQ。1)每当抛出一个FactAddedEvent (来自另一个服务)时，应用程序就会将消息传递给消费者: FactAddedFirstHandler和FactAddedSecondHandler这是正确<
浏览 2提问于2020-02-06得票数 1
回答已采纳
我的activemq中有一个配置，不将消息转发到.DLQ队列。policyEntry> </policyMap>但仍在将消息存储在当我试图查看存储在.DLQ中的消息时，我可以看到一些附加属性显示了以下原因
dlqDeliveryFailureCause java.lang.Throwable
浏览 3提问于2022-07-25得票数 0
1回答
我们有一个队列，它接收传入的数据并通过铲子将数据推入另一台机器中的另一个队列中。我们还意识到铲子是在默认的预取计数为1000的情况下设置的。我们无法修改铲子设置一个较高的预
浏览 1提问于2018-05-14得票数 0
回答已采纳
是否可以使用auto=false禁用预取？我只想避免每次确认消息时从队列中读取消息(预取)。我只想在调用“when _ message”时才阅读一条消息。设置prefetch_count=0似乎不起作用，它被视为“无特定限制”。据我所知，'prefetch_count‘是缓存在客户端的消息的数量(将本地读入缓冲区)。例如，有一个用例：
(让我们假设有一个队列连接到并且它有
浏览 2提问于2017-09-07得票数 3
回答已采纳
在我的应用程序中，我们使用骆驼路径从RabbitMQ队列中读取消息。配置如下所示：生产者可以在几分钟内发送50k条消息，每条消息需要1秒或更多时间处理。我能看到的是，所有的消息都被很快地消耗掉了，但是处理这些消息需要花费很多时间。需要处理许多小时，但这是否意味着50k消息存储在内存中？如果是这样的话，
浏览 2提问于2019-10-17得票数 2
回答已采纳
1回答
DMLC消息的消耗和确认
、、、、
我正在使用DMLC，并发的使用者计数为1，预取限制为> 1。我收到一条消息，并在侦听器执行之前确认它。因此，当侦听器执行时，broker有更多的消息，并按照预取设置将其发送给使用者。由于侦听器仍在执行，消费和确认将如何对后续消息工作？
会不会为所有新消息调用接收()，并确认它们并等待侦听
浏览 4提问于2015-02-12得票数 0
回答已采纳
在我的发布类中，构造函数接受IPublishEndpoint，它在发布消息时使用：...endpoint的类型是：massTransit.Context.ConsumeContextScope<ExternalServiceBus.Messages.IDeviceChanged>
这是消息被接收到的上下文，而不是应该
浏览 2提问于2021-11-23得票数 0
回答已采纳
如何在nodejs中设置amqplib的预取计数为1？
期望的结果是使用者只从队列中获取一条消息，处理它，并在完成后获取新的消息。我有一个设置，其中一些消息需要很长时间来处理，而其他消息需要很短的时间。因此，我不仅仅想在所有消费者上平等地分享消息。
浏览 3提问于2017-12-13得票数 1
回答已采纳
2回答
到目前为止，我的RabbitMQ消费者客户端使用的预取值为1。我希望增加该值以获得性能。如果我将值设置为2，RabbitMQ服务器是否会一次向每个消费者发送2条消息，以便我需要解析这两条消息并将第二条消息存储在列表中，直到第一条消息得到处理和确认？或者API会在幕后处理这件事？我使用的是Java AMQP客户端库：
ConnectionFactory factor
浏览 2提问于2013-04-09得票数 3
回答已采纳
它在RabbitMQ文档中声明如下
“经验法则是，在线程之间共享通道实例是必须避免的。应用程序应该更喜欢使用每个线程的通道，而不是在多个线程之间共享相同的通道。”目前，我们正在查看预取计数，建议如果您有少量的使用者和autoack=false，那么我们应该同时使用许多消息。但是，我们发现，如果使用者使用单个执行线程发送手动确认，则预取不会产生效
浏览 0提问于2019-02-08得票数 3
回答已采纳
我正在阅读，这是非常好的信息，但我对RabbitMQ如何管理线程感到有点困惑。在并发考虑部分中，它声明每个IConnection都由单个后台线程备份。然后，它继续说：
我被这事弄糊涂了。这是否意味着每次调用HandleBasicDeliver时都会<em
浏览 4提问于2016-08-25得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
